udp的服務(wù)器設(shè)計(jì)說明書(編輯修改稿)
2025-06-09 22:38 本頁面
【文章內(nèi)容簡介】 fPending = TRUE。 } //如果完成 if(fPending) { //等待結(jié)束請(qǐng)求或退出事件hEvents[0] = 。 hEvents[1] = m_hEventExit。 dwRet = WaitForMultipleObjects(2, hEvents, FALSE, INFINITE)。 // //判斷是否是接收方發(fā)出的信號(hào) // if (dwRet != 0) { return FALSE。 } if (!WSAGetOverlappedResult(m_Socket, amp。over, amp。dwRecv, FALSE, amp。dwFlags)) return FALSE。 } // //接收結(jié)束 // m_translate = dwRecv。 return TRUE。 }}(3) 數(shù)據(jù)處理部分BOOL CUdpSock::DelWithResData(struct sockaddr FAR *lpFrom){ DWORD lenPag = sizeof(PackHead)。 DWORD start = 0。 DWORD onePagLeft = 0。 SockPags pags。 if(m_bFillHead) {//判斷緩沖區(qū)的長度 onePagLeft = lenPag。 if(() onePagLeft) { TRACE(There is no enough packege length! 1\n)。 return FALSE。 } ASSERT(onePagLeft = IOBUFFLEN)。 = new char[onePagLeft]。 if(( ,onePagLeft)) { = onePagLeft。 = 。 if(m_pResInterFace) { m_pResInterFaceExcute(amp。pags,lpFrom)。 m_bFillHead = FALSE。 DelWithResData(lpFrom)。 } } delete []。 }else { while(((char*)amp。m_PackHead,lenPag)) { if([0] != 39。T39。 amp。amp。 [1] != 39。P39。) { ()。 m_bFillHead = FALSE。 TRACE(There is packege2 is erro!\n)。 return FALSE。 } m_bFillHead = TRUE。 onePagLeft = lenPag。 if(() onePagLeft) { TRACE(There is no enough packege length! 2\n)。 return FALSE。 } ASSERT(onePagLeft = IOBUFFLEN)。 = new char[onePagLeft]。 if(( ,onePagLeft)) { = onePagLeft。 = 。 if(m_pResInterFace) { m_pResInterFaceExcute(amp。pags,lpFrom)。 m_bFillHead = FALSE。 } } delete []。 } } return TRUE。}void CUdpSock::OnRead(){ m_translate=0。 sockaddr_in addrfro。 memset(amp。addrfro,0,sizeof(sockaddr_in))。 =AF_INET。 //如果沒有接收請(qǐng)求就返回到讀信息函數(shù) if(!RecvRequest((LPBYTE), sizeof(m_byInBuffer),(sockaddr*)amp。addrfro)){ TRACE(CClientOverlappedSock::OnRead\n)。 return。}//如果m_translate不為0，則向m_SimpleIOBuffer緩沖區(qū)寫信息if(m_translate){ (,m_translate)。 try{ //處理收到的信息 DelWithResData((sockaddr*)amp。addrfro)。 }catch(..
環(huán)評(píng)公示相關(guān)推薦
鄂ICP備17016276號(hào)-1