File tree Expand file tree Collapse file tree
crates/wasi/src/p3/sockets/host/types Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -292,8 +292,10 @@ impl HostTcpSocketConcurrent for WasiSockets {
292292 Ok ( Err ( ErrorCode :: InvalidState ) )
293293 }
294294 }
295- } ) {
296- Ok ( Ok ( sock) ) => {
295+ } ) ? {
296+ Ok ( sock) => {
297+ // FIXME: handle possible cancellation of the outer `connect`
298+ // https://github.com/bytecodealliance/wasmtime/pull/11291#discussion_r2223917986
297299 let res = sock. connect ( remote_address) . await ;
298300 store. with ( |mut view| {
299301 let socket = get_socket_mut ( view. get ( ) . table , & socket) ?;
@@ -313,8 +315,7 @@ impl HostTcpSocketConcurrent for WasiSockets {
313315 }
314316 } )
315317 }
316- Ok ( Err ( err) ) => Ok ( Err ( err) ) ,
317- Err ( err) => Err ( err) ,
318+ Err ( err) => Ok ( Err ( err) ) ,
318319 }
319320 }
320321
@@ -617,9 +618,9 @@ impl HostTcpSocket for WasiSocketsCtxView<'_> {
617618 Ok ( sock. set_send_buffer_size ( value) )
618619 }
619620
620- fn drop ( & mut self , rep : Resource < TcpSocket > ) -> wasmtime:: Result < ( ) > {
621+ fn drop ( & mut self , sock : Resource < TcpSocket > ) -> wasmtime:: Result < ( ) > {
621622 self . table
622- . delete ( rep )
623+ . delete ( sock )
623624 . context ( "failed to delete socket resource from table" ) ?;
624625 Ok ( ( ) )
625626 }
Original file line number Diff line number Diff line change @@ -199,9 +199,9 @@ impl HostUdpSocket for WasiSocketsCtxView<'_> {
199199 Ok ( sock. set_send_buffer_size ( value) )
200200 }
201201
202- fn drop ( & mut self , rep : Resource < UdpSocket > ) -> wasmtime:: Result < ( ) > {
202+ fn drop ( & mut self , sock : Resource < UdpSocket > ) -> wasmtime:: Result < ( ) > {
203203 self . table
204- . delete ( rep )
204+ . delete ( sock )
205205 . context ( "failed to delete socket resource from table" ) ?;
206206 Ok ( ( ) )
207207 }
You can’t perform that action at this time.
0 commit comments