Changeset 7041 for trunk/src/wsock32/asyncthread.cpp

Timestamp:

Oct 13, 2001, 8:51:08 PM (24 years ago)

Author:

sandervl

Message:

several updates + fixes

File:

• trunk/src/wsock32/asyncthread.cpp (modified) (3 diffs)

trunk/src/wsock32/asyncthread.cpp

@@ -1 @@
-/* $Id: asyncthread.cpp,v 1.11 2001-07-07 14:29:40 achimha Exp $ */
+/* $Id: asyncthread.cpp,v 1.12 2001-10-13 18:51:07 sandervl Exp $ */
 
 /*
@@ -40 +40 @@
 ////    WSASetBlocking(FALSE, pThreadParm->hThread);
 
+  dprintf(("AsyncThread %x exit", pThreadParm->hAsyncTaskHandle));
   free((PVOID)pThreadParm);
 }
@@ -109 +110 @@
    memset(pThreadParm, 0, sizeof(*pThreadParm));
    asyncThreadMutex.leave();
+}
+//******************************************************************************
+//******************************************************************************
+void WSACancelAllAsyncRequests()
+{
+ PASYNCTHREADPARM pThreadInfo;
+ BOOL             found = FALSE;
+
+   dprintf(("WSACancelAllAsyncRequests"));
+   asyncThreadMutex.enter();
+   pThreadInfo = threadList;
+
+   while(pThreadInfo) {
+        dprintf(("WSACancelAllAsyncRequests %x", pThreadInfo->hAsyncTaskHandle));
+        pThreadInfo->fCancelled = TRUE;
+        pThreadInfo->u.asyncselect.asyncSem->post();
+        pThreadInfo = pThreadInfo->next;
+   }
+   asyncThreadMutex.leave();
+   //TODO: not the right way to wait for the async threads to die
+   DosSleep(250);
 }
 //******************************************************************************