diff options
| author | midipix <writeonce@midipix.org> | 2018-05-18 20:35:40 +0000 |
|---|---|---|
| committer | midipix <writeonce@midipix.org> | 2018-05-18 16:45:01 -0400 |
| commit | 543bf711a91ce96b52b62fc9c0a280a563be903c (patch) | |
| tree | 1849b15b14d9c2834e23bc216db04bb42f252c03 /src | |
| parent | 80236ad5d20fbed5fc375d79a7aabcef0137553c (diff) | |
| download | ntapi-543bf711a91ce96b52b62fc9c0a280a563be903c.tar.bz2 ntapi-543bf711a91ce96b52b62fc9c0a280a563be903c.tar.xz | |
socket interfaces: send and receive: defer wait for completion to caller.
Diffstat (limited to 'src')
| -rw-r--r-- | src/socket/ntapi_sc_recv.c | 12 | ||||
| -rw-r--r-- | src/socket/ntapi_sc_send.c | 12 |
2 files changed, 10 insertions, 14 deletions
diff --git a/src/socket/ntapi_sc_recv.c b/src/socket/ntapi_sc_recv.c index 19a4423..a45eb17 100644 --- a/src/socket/ntapi_sc_recv.c +++ b/src/socket/ntapi_sc_recv.c @@ -56,7 +56,7 @@ int32_t __cdecl __ntapi_sc_recv( afd_recv.afd_recv.afd_flags = (uint32_t)afdflags; afd_recv.afd_recv.tdi_flags = (uint32_t)tdiflags; - hssocket->iostatus = __ntapi->zw_device_io_control_file( + if ((hssocket->iostatus = __ntapi->zw_device_io_control_file( hssocket->hsocket, hssocket->hevent, 0, @@ -66,13 +66,11 @@ int32_t __cdecl __ntapi_sc_recv( &afd_recv, raddr ? sizeof(afd_recv) : sizeof(afd_recv.afd_recv), 0, - 0); + 0))) + return hssocket->iostatus; - if (hssocket->iostatus && (hssocket->ntflags & __NT_FILE_SYNC_IO)) - __ntapi->sc_wait(hssocket,iosb,&hssocket->timeout); - - if (!hssocket->iostatus && bytes_received) + if (bytes_received) *bytes_received = iosb->info; - return hssocket->iostatus; + return NT_STATUS_SUCCESS; } diff --git a/src/socket/ntapi_sc_send.c b/src/socket/ntapi_sc_send.c index bf2c0ea..f987cad 100644 --- a/src/socket/ntapi_sc_send.c +++ b/src/socket/ntapi_sc_send.c @@ -68,7 +68,7 @@ int32_t __cdecl __ntapi_sc_send( afd_send.afd_send.afd_flags = (uint32_t)afdflags; afd_send.afd_send.tdi_flags = (uint32_t)tdiflags; - hssocket->iostatus = __ntapi->zw_device_io_control_file( + if ((hssocket->iostatus = __ntapi->zw_device_io_control_file( hssocket->hsocket, hssocket->hevent, 0, @@ -78,13 +78,11 @@ int32_t __cdecl __ntapi_sc_send( &afd_send, addrlen ? sizeof(afd_send) : sizeof(afd_send.afd_send), 0, - 0); + 0))) + return hssocket->iostatus; - if (hssocket->iostatus && (hssocket->ntflags & __NT_FILE_SYNC_IO)) - __ntapi->sc_wait(hssocket,iosb,&hssocket->timeout); - - if (!hssocket->iostatus && bytes_sent) + if (bytes_sent) *bytes_sent = iosb->info; - return hssocket->iostatus; + return NT_STATUS_SUCCESS; } |