update: add process_event function for FFI

Author: joemphilips

bindings/src/peermanager.rs

@@ -31,20 +31,6 @@ fn construct_socket_desc (
     socket
 }
 
-fn read_event(
-    index: usize,
-    send_data_ptr: Ref<socket_descriptor_fn::SendData>,
-    disconnect_socket_ptr: Ref<socket_descriptor_fn::DisconnectSocket>,
-    data_ptr: Ref<FFIBytes>,
-    handle: FFIArcPeerManagerHandle
-) -> FFIResult {
-    let mut socket = construct_socket_desc(index, send_data_ptr, disconnect_socket_ptr);
-    let peer_man: &FFISimpleArcPeerManager = unsafe_block!("We know handle points to valid PeerManager" => handle.as_ref());
-    let data = unsafe_block!("We know it points to valid data" => data_ptr.as_ref());
-    peer_man.read_event(&mut socket, data.as_ref());
-    FFIResult::ok()
-}
-
 ffi! {
     fn create_peer_manager(
         seed_ptr: Ref<u8>,
@@ -171,6 +157,26 @@ ffi! {
         FFIResult::ok()
     }
 
+    fn read_event(
+        index: usize,
+        send_data_ptr: Ref<socket_descriptor_fn::SendData>,
+        disconnect_socket_ptr: Ref<socket_descriptor_fn::DisconnectSocket>,
+        data_ref: Ref<FFIBytes>,
+        handle: FFIArcPeerManagerHandle
+    ) -> FFIResult {
+        let mut socket = construct_socket_desc(index, send_data_ptr, disconnect_socket_ptr);
+        let peer_man: &FFISimpleArcPeerManager = unsafe_block!("We know handle points to valid PeerManager" => handle.as_ref());
+        let data = unsafe_block!("data lives as long as this function and it points to valid value" => data_ref.as_ref());
+        peer_man.read_event(&mut socket, data.as_ref())?;
+        FFIResult::ok()
+    }
+
+    fn process_events(handle: FFIArcPeerManagerHandle) -> FFIResult {
+        let peer_man: &FFISimpleArcPeerManager = unsafe_block!("We know handle points to valid PeerManager" => handle.as_ref());
+        peer_man.process_events();
+        FFIResult::ok()
+    }
+
     fn release_peer_manager(handle: FFIArcPeerManagerHandle) -> FFIResult {
         unsafe_block!("The upstream caller guarantees the handle will not be accessed after being freed" => FFIArcPeerManagerHandle::dealloc(handle, |mut handle| {
             FFIResult::ok()