dispose FfiHandle immediately (#531)

Author: theomonnom

livekit-rtc/livekit/rtc/_ffi_client.py

@@ -241,6 +241,5 @@ def request(self, req: proto_ffi.FfiRequest) -> proto_ffi.FfiResponse:
         resp_data = ctypes.string_at(resp_ptr, resp_len.value)
         resp = proto_ffi.FfiResponse()
         resp.ParseFromString(resp_data)
-
-        FfiHandle(handle)
+        FfiHandle(handle).dispose()
         return resp

livekit-rtc/livekit/rtc/audio_frame.py

@@ -90,7 +90,7 @@ def _from_owned_info(owned_info: proto_audio.OwnedAudioFrameBuffer) -> "AudioFra
         size = info.num_channels * info.samples_per_channel
         cdata = (ctypes.c_int16 * size).from_address(info.data_ptr)
         data = bytearray(cdata)
-        FfiHandle(owned_info.handle.id)
+        FfiHandle(owned_info.handle.id).dispose()
         return AudioFrame(data, info.sample_rate, info.num_channels, info.samples_per_channel)
 
     def _proto_info(self) -> proto_audio.AudioFrameBufferInfo:

livekit-rtc/livekit/rtc/room.py

@@ -811,7 +811,7 @@ def _on_room_event(self, event: proto_room.RoomEvent):
                 ).contents
 
                 data = bytes(native_data)
-                FfiHandle(owned_buffer_info.handle.id)
+                FfiHandle(owned_buffer_info.handle.id).dispose()
                 rparticipant = cast(
                     RemoteParticipant,
                     self._retrieve_remote_participant(packet.participant_identity),

livekit-rtc/livekit/rtc/video_frame.py

@@ -105,7 +105,7 @@ def _from_owned_info(owned_info: proto_video.OwnedVideoBuffer) -> "VideoFrame":
             type=info.type,
             data=data,
         )
-        FfiHandle(owned_info.handle.id)
+        FfiHandle(owned_info.handle.id).dispose()
         return frame
 
     def _proto_info(self) -> proto_video.VideoBufferInfo: