CalvinBackup/facefusion
1
0
Fork 0
mirror of https://github.com/facefusion/facefusion.git synced 2026-06-06 12:43:53 +02:00
Code Issues Packages Projects Releases Wiki Activity

add create_event method

Browse Source
This commit is contained in:
harisreedhar
2026-06-02 03:06:16 +05:30
parent beeb1d99e9
commit 314ee61826
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
facefusion/apis/stream_helper.py
+10 -6
View File
@@ -204,9 +204,7 @@ def receive_video_frames(rtc_peer_video : RtcPeerVideo, video_deque : deque[Vide
datachannel_library = datachannel_module.create_static_library()
video_decoder = create_video_decoder(video_codec)
receive_buffer = ctypes.create_string_buffer(512 * 1024)
available_event = threading.Event()
available_callback = ctypes.CFUNCTYPE(None, ctypes.c_int, ctypes.c_void_p)(partial(dispatch_event, available_event))
datachannel_library.rtcSetAvailableCallback(video_track, available_callback)
available_event = create_event(video_track, datachannel_library)
receive_status_code = -3
while receive_status_code == 0 or receive_status_code == -3:
@@ -241,9 +239,7 @@ def receive_audio_frames(rtc_peer_audio : RtcPeerAudio, audio_deque : deque[Audi
datachannel_library = datachannel_module.create_static_library()
audio_decoder = create_audio_decoder(audio_codec)
receive_buffer = ctypes.create_string_buffer(8 * 1024)
available_event = threading.Event()
available_callback = ctypes.CFUNCTYPE(None, ctypes.c_int, ctypes.c_void_p)(partial(dispatch_event, available_event))
datachannel_library.rtcSetAvailableCallback(audio_track, available_callback)
available_event = create_event(audio_track, datachannel_library)
receive_status_code = -3
while receive_status_code == 0 or receive_status_code == -3:
@@ -369,5 +365,13 @@ def destroy_stream(session_id : SessionId) -> bool:
return False
def create_event(track : int, datachannel_library : ctypes.CDLL) -> threading.Event:
available_event = threading.Event()
available_callback = ctypes.CFUNCTYPE(None, ctypes.c_int, ctypes.c_void_p)(partial(dispatch_event, available_event))
datachannel_library.rtcSetAvailableCallback(track, available_callback)
available_event.callback = available_callback # type: ignore[attr-defined]
return available_event
def dispatch_event(event : threading.Event, track : int, pointer : ctypes.c_void_p) -> None:
event.set()