@@ -31,8 +31,8 @@ lazy_static! {
31
31
32
32
fn construct_socket_desc (
33
33
index : usize ,
34
- send_data_ptr : Option < socket_descriptor_fn:: SendData > ,
35
- disconnect_socket_ptr : Option < socket_descriptor_fn:: DisconnectSocket > ,
34
+ send_data_ptr : Ref < socket_descriptor_fn:: SendData > ,
35
+ disconnect_socket_ptr : Ref < socket_descriptor_fn:: DisconnectSocket > ,
36
36
) -> FFISocketDescriptor {
37
37
let send_data_ref = unsafe_block ! ( "" => send_data_ptr. as_ref( ) ) ;
38
38
let disconnect_socket_ref = unsafe_block ! ( "" => disconnect_socket_ptr. as_ref( ) ) ;
@@ -48,11 +48,11 @@ ffi! {
48
48
cfg: Ref <UserConfig >,
49
49
50
50
chan_man: FFIArcChannelManagerHandle ,
51
- install_watch_tx_ptr: Option <chain_watch_interface_fn:: InstallWatchTxPtr >,
52
- install_watch_outpoint_ptr: Option <chain_watch_interface_fn:: InstallWatchOutpointPtr >,
53
- watch_all_txn_ptr: Option <chain_watch_interface_fn:: WatchAllTxnPtr >,
54
- get_chain_utxo_ptr: Option <chain_watch_interface_fn:: GetChainUtxoPtr >,
55
- log_ptr: Option <ffilogger_fn:: LogExtern >,
51
+ install_watch_tx_ptr: Ref <chain_watch_interface_fn:: InstallWatchTxPtr >,
52
+ install_watch_outpoint_ptr: Ref <chain_watch_interface_fn:: InstallWatchOutpointPtr >,
53
+ watch_all_txn_ptr: Ref <chain_watch_interface_fn:: WatchAllTxnPtr >,
54
+ get_chain_utxo_ptr: Ref <chain_watch_interface_fn:: GetChainUtxoPtr >,
55
+ log_ptr: Ref <ffilogger_fn:: LogExtern >,
56
56
57
57
our_node_secret_ptr: Ref <Bytes32 >,
58
58
our_node_id_ptr: Ref <Bytes33 >,
99
99
100
100
fn new_inbound_connection(
101
101
index: usize ,
102
- send_data_ptr: Option <socket_descriptor_fn:: SendData >,
103
- disconnect_socket_ptr: Option <socket_descriptor_fn:: DisconnectSocket >,
102
+ send_data_ptr: Ref <socket_descriptor_fn:: SendData >,
103
+ disconnect_socket_ptr: Ref <socket_descriptor_fn:: DisconnectSocket >,
104
104
handle: FFIArcPeerManagerHandle
105
105
) -> FFIResult {
106
106
let socket = construct_socket_desc( index, send_data_ptr, disconnect_socket_ptr) ;
@@ -111,8 +111,8 @@ ffi! {
111
111
112
112
fn new_outbound_connection(
113
113
index: usize ,
114
- send_data_ptr: Option <socket_descriptor_fn:: SendData >,
115
- disconnect_socket_ptr: Option <socket_descriptor_fn:: DisconnectSocket >,
114
+ send_data_ptr: Ref <socket_descriptor_fn:: SendData >,
115
+ disconnect_socket_ptr: Ref <socket_descriptor_fn:: DisconnectSocket >,
116
116
their_node_id: Ref <Bytes33 >,
117
117
handle: FFIArcPeerManagerHandle ,
118
118
initial_send: Out <[ u8 ; 50 ] >
@@ -136,8 +136,8 @@ ffi! {
136
136
137
137
fn write_buffer_space_avail(
138
138
index: usize ,
139
- send_data_ptr: Optionf <socket_descriptor_fn:: SendData >,
140
- disconnect_socket_ptr: Option <socket_descriptor_fn:: DisconnectSocket >,
139
+ send_data_ptr: Ref <socket_descriptor_fn:: SendData >,
140
+ disconnect_socket_ptr: Ref <socket_descriptor_fn:: DisconnectSocket >,
141
141
handle: FFIArcPeerManagerHandle
142
142
) -> FFIResult {
143
143
let mut socket = construct_socket_desc( index, send_data_ptr, disconnect_socket_ptr) ;
@@ -148,8 +148,8 @@ ffi! {
148
148
149
149
fn read_event(
150
150
index: usize ,
151
- send_data_ptr: Option <socket_descriptor_fn:: SendData >,
152
- disconnect_socket_ptr: Option <socket_descriptor_fn:: DisconnectSocket >,
151
+ send_data_ptr: Ref <socket_descriptor_fn:: SendData >,
152
+ disconnect_socket_ptr: Ref <socket_descriptor_fn:: DisconnectSocket >,
153
153
data_ref: Ref <FFIBytes >,
154
154
should_pause_read: Out <Bool >,
155
155
handle: FFIArcPeerManagerHandle
@@ -170,8 +170,8 @@ ffi! {
170
170
171
171
fn socket_disconnected(
172
172
index: usize ,
173
- send_data_ptr: Option <socket_descriptor_fn:: SendData >,
174
- disconnect_socket_ptr: Option <socket_descriptor_fn:: DisconnectSocket >,
173
+ send_data_ptr: Ref <socket_descriptor_fn:: SendData >,
174
+ disconnect_socket_ptr: Ref <socket_descriptor_fn:: DisconnectSocket >,
175
175
handle: FFIArcPeerManagerHandle ) -> FFIResult {
176
176
let mut socket = construct_socket_desc( index, send_data_ptr, disconnect_socket_ptr) ;
177
177
let peer_man: & FFISimpleArcPeerManager = unsafe_block!( "We know handle points to valid PeerManager" => handle. as_ref( ) ) ;
0 commit comments