Huw Davies : nsiproxy: Pass the listen request off to a separate thread.
Alexandre Julliard
julliard at winehq.org
Tue Oct 5 15:51:40 CDT 2021
Module: wine
Branch: master
Commit: be0765ac2633202a7d267aebf0a7b62ca7f21507
URL: https://source.winehq.org/git/wine.git/?a=commit;h=be0765ac2633202a7d267aebf0a7b62ca7f21507
Author: Huw Davies <huw at codeweavers.com>
Date: Tue Oct 5 07:37:49 2021 +0100
nsiproxy: Pass the listen request off to a separate thread.
Signed-off-by: Huw Davies <huw at codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard at winehq.org>
---
dlls/nsiproxy.sys/device.c | 36 ++++++++++++++++++++++++++++++++----
1 file changed, 32 insertions(+), 4 deletions(-)
diff --git a/dlls/nsiproxy.sys/device.c b/dlls/nsiproxy.sys/device.c
index cd0bc0e4db2..0cd168946cb 100644
--- a/dlls/nsiproxy.sys/device.c
+++ b/dlls/nsiproxy.sys/device.c
@@ -178,6 +178,16 @@ static NTSTATUS nsiproxy_get_parameter( IRP *irp )
return status;
}
+static inline HANDLE irp_get_icmp_handle( IRP *irp )
+{
+ return irp->Tail.Overlay.DriverContext[0];
+}
+
+static inline HANDLE irp_set_icmp_handle( IRP *irp, HANDLE handle )
+{
+ return InterlockedExchangePointer( irp->Tail.Overlay.DriverContext, handle );
+}
+
static void WINAPI icmp_echo_cancel( DEVICE_OBJECT *device, IRP *irp )
{
TRACE( "device %p, irp %p.\n", device, irp );
@@ -293,6 +303,26 @@ static int add_device( DRIVER_OBJECT *driver )
return 1;
}
+static DWORD WINAPI listen_thread_proc( void *arg )
+{
+ IRP *irp = arg;
+
+ TRACE( "\n" );
+
+ /* FIXME */
+
+ EnterCriticalSection( &nsiproxy_cs );
+
+ nsiproxy_call( icmp_close, irp_set_icmp_handle( irp, NULL ) );
+
+ irp->IoStatus.Status = STATUS_NOT_SUPPORTED;
+ IoCompleteRequest( irp, IO_NO_INCREMENT );
+
+ LeaveCriticalSection( &nsiproxy_cs );
+
+ return 0;
+}
+
static void handle_queued_send_echo( IRP *irp )
{
struct nsiproxy_icmp_echo *in = (struct nsiproxy_icmp_echo *)irp->AssociatedIrp.SystemBuffer;
@@ -323,10 +353,8 @@ static void handle_queued_send_echo( IRP *irp )
}
else
{
- /* FIXME */
- nsiproxy_call( icmp_close, params.handle );
- irp->IoStatus.Status = STATUS_NOT_SUPPORTED;
- IoCompleteRequest( irp, IO_NO_INCREMENT );
+ irp_set_icmp_handle( irp, params.handle );
+ RtlQueueWorkItem( listen_thread_proc, irp, WT_EXECUTELONGFUNCTION );
}
}
More information about the wine-cvs
mailing list