Changeset 10428 for trunk/src/wsock32
- Timestamp:
- Jan 30, 2004, 11:02:12 PM (22 years ago)
- Location:
- trunk/src/wsock32
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/src/wsock32/asyncapi.cpp
r7992 r10428 1 /* $Id: asyncapi.cpp,v 1.2 0 2002-02-23 16:39:09 sandervlExp $ */1 /* $Id: asyncapi.cpp,v 1.21 2004-01-30 22:02:11 bird Exp $ */ 2 2 3 3 /* … … 407 407 ULONG eventReply = WSAMAKESELECTREPLY(event, socket_error); 408 408 409 #ifdef DEBUG 409 #ifdef DEBUG_LOGGING 410 410 char *pszEvent = NULL; 411 411 … … 576 576 577 577 //Don't send FD_CONNECT is socket was already connected (accept returns connected socket) 578 if(!pThreadParm->fConnected && (lEventsPending & FD_CONNECT)) 578 if(!pThreadParm->fConnected && (lEventsPending & FD_CONNECT)) 579 579 { 580 580 if(state & SS_ISCONNECTED) { … … 636 636 } 637 637 else 638 if((lEventsPending & FD_CLOSE) && (state == 0 && bytesread == 0)) 638 if((lEventsPending & FD_CLOSE) && (state == 0 && bytesread == 0)) 639 639 { 640 640 state = ioctl(s, FIOBSTATUS, (char *)&tmp, sizeof(tmp)); 641 641 642 //Have to make sure this doesn't generates FD_CLOSE 643 //messages when the connection is just fine (recv 642 //Have to make sure this doesn't generates FD_CLOSE 643 //messages when the connection is just fine (recv 644 644 //executed in another thread when select returns) 645 645 if(state & (SS_CANTRCVMORE|SS_CANTSENDMORE|SS_ISDISCONNECTING|SS_ISDISCONNECTED)) { … … 694 694 strcat(tmpbuf, " FD_WRITE"); 695 695 if (lEventMask & FD_OOB) 696 strcat(tmpbuf, " FD_OOB"); 696 strcat(tmpbuf, " FD_OOB"); 697 697 if (lEventMask & FD_ACCEPT) 698 698 strcat(tmpbuf, " FD_ACCEPT"); … … 809 809 // return our internal event bit representation 810 810 lpEvent->lNetworkEvents = InterlockedExchange((LPLONG)&pThreadInfo->u.asyncselect.lLastEvent, 0); 811 } 811 } 812 812 else 813 813 { -
trunk/src/wsock32/asyncthread.cpp
r9627 r10428 1 /* $Id: asyncthread.cpp,v 1.1 6 2003-01-06 13:05:40 sandervlExp $ */1 /* $Id: asyncthread.cpp,v 1.17 2004-01-30 22:02:12 bird Exp $ */ 2 2 3 3 /* … … 33 33 { 34 34 PASYNCTHREADPARM pThreadParm = (PASYNCTHREADPARM)arg; 35 #ifdef DEBUG 35 #ifdef DEBUG_LOGGING 36 36 ULONG ulSocket = pThreadParm->u.asyncselect.s; 37 37 ULONG hTaskHandle = pThreadParm->hAsyncTaskHandle; … … 113 113 DebugInt3(); 114 114 } 115 } 115 } 116 116 memset(pThreadParm, 0, sizeof(*pThreadParm)); 117 117 asyncThreadMutex.leave(); … … 220 220 221 221 while(pThreadInfo) { 222 dprintf(( "SOCKET %08xh thread#%d events %xh pending %xh, select %d", 222 dprintf(( "SOCKET %08xh thread#%d events %xh pending %xh, select %d", 223 223 pThreadInfo->u.asyncselect.s, 224 224 pThreadInfo->hAsyncTaskHandle, … … 255 255 asyncThreadMutex.enter(); 256 256 pThreadInfo = FindAsyncEvent(s); 257 if(pThreadInfo) 257 if(pThreadInfo) 258 258 { 259 259 int size, state, tmp; … … 309 309 //****************************************************************************** 310 310 //****************************************************************************** 311 BOOL QueryAsyncEvent(SOCKET s, int *pMode, ULONG *pNofityHandle, ULONG *pNofityData, 311 BOOL QueryAsyncEvent(SOCKET s, int *pMode, ULONG *pNofityHandle, ULONG *pNofityData, 312 312 ULONG *plEvent) 313 313 {
Note:
See TracChangeset
for help on using the changeset viewer.