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

Timestamp:

Apr 28, 2001, 6:15:18 PM (24 years ago)

Author:

sandervl

Message:

YD: fixes for opera

File:

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

trunk/src/wsock32/asyncthread.cpp

@@ -1 @@
-/* $Id: asyncthread.cpp,v 1.6 2000-05-18 22:54:21 sandervl Exp $ */
+/* $Id: asyncthread.cpp,v 1.7 2001-04-28 16:15:18 sandervl Exp $ */
 
 /*
@@ -30 +30 @@
 //******************************************************************************
 //******************************************************************************
-static void APIENTRY AsyncThread(ULONG arg)
+static void _Optlink AsyncThread(void *arg)
 {
  PASYNCTHREADPARM pThreadParm = (PASYNCTHREADPARM)arg;
@@ -48 +48 @@
 ULONG QueueAsyncJob(ASYNCTHREADPROC asyncproc, PASYNCTHREADPARM pThreadParm, BOOL fSetBlocking)
 {
- APIRET rc;
- TID    tid;
+ TID tid;
 
    pThreadParm->asyncProc         = asyncproc;
@@ -62 +61 @@
    if(fSetBlocking) WSASetBlocking(TRUE);
 
-   rc = DosCreateThread(&tid, AsyncThread, (ULONG)pThreadParm, CREATE_READY, 16384);
-   if(rc)
-   {
-        dprintf(("QueueAsyncJob: DosCreateThread failed with error %x", rc));
+   tid = _beginthread(AsyncThread, NULL, 16384, (PVOID)pThreadParm);
+   if (tid == -1) {
+        dprintf(("QueueAsyncJob: _beginthread failed"));
         if(fSetBlocking) WSASetBlocking(FALSE);
         RemoveFromQueue(pThreadParm);
@@ -166 +164 @@
 #endif
    return SOCKET_ERROR;
+}
+//******************************************************************************
+//dump queue
+//******************************************************************************
+void DumpQueue(void)
+{
+ HANDLE hThread = GetCurrentThread();
+ PASYNCTHREADPARM pThreadInfo;
+
+   dprintf(("DumpQueue"));
+
+   asyncThreadMutex.enter();
+   pThreadInfo = threadList;
+
+   while(pThreadInfo) {
+        dprintf(( "SOCKET %08xh thread#%d events %xh pending %xh, select %d", 
+                pThreadInfo->u.asyncselect.s,
+                pThreadInfo->hAsyncTaskHandle,
+                pThreadInfo->u.asyncselect.lEvents,
+                pThreadInfo->u.asyncselect.lEventsPending,
+                pThreadInfo->fWaitSelect));
+        pThreadInfo = pThreadInfo->next;
+   }
+   asyncThreadMutex.leave();
+   dprintf(("DumpQueue done"));
 }
 //******************************************************************************