Changeset 10428 for trunk/src/wsock32
- Timestamp:
 - Jan 30, 2004, 11:02:12 PM (22 years ago)
 - Location:
 - trunk/src/wsock32
 - Files:
 - 
      
- 2 edited
 
- 
          
  asyncapi.cpp (modified) (6 diffs)
 - 
          
  asyncthread.cpp (modified) (6 diffs)
 
 
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.
  