網狐棋牌(三) 排程引擎初步分析
阿新 • • 發佈:2019-02-11
{
46 //效驗大小47 NTY_SocketReadEvent * pSocketReadEvent=(NTY_SocketReadEvent *)pBuffer;
48 ASSERT(wDataSize>=sizeof(NTY_SocketReadEvent));
49 ASSERT(wDataSize==(sizeof(NTY_SocketReadEvent)+pSocketReadEvent->wDataSize));
50 if (wDataSize<sizeof(NTY_SocketReadEvent)) return ;
51 if (wDataSize!=(sizeof(NTY_SocketReadEvent)+pSocketReadEvent->wDataSize)) return;
52
53 //處理訊息54 bool bSuccess=false;
55 try
56 {
57 bSuccess=m_pIAttemperEngineSink->OnEventSocketRead(pSocketReadEvent->Command,pSocketReadEvent+1,pSocketReadEvent->wDataSize,pSocketReadEvent);
58 }
59 catch () { }
60 if (bSuccess==false) m_pITCPSocketEngine->CloseSocket(pSocketReadEvent->wIndex,pSocketReadEvent->wRoundID);
61
62 return;
63 }
46 //效驗大小47 NTY_SocketReadEvent * pSocketReadEvent=(NTY_SocketReadEvent *)pBuffer;
48 ASSERT(wDataSize>=sizeof(NTY_SocketReadEvent));
49 ASSERT(wDataSize==(sizeof(NTY_SocketReadEvent)+pSocketReadEvent->wDataSize));
50 if (wDataSize<sizeof(NTY_SocketReadEvent)) return
51 if (wDataSize!=(sizeof(NTY_SocketReadEvent)+pSocketReadEvent->wDataSize)) return;
52
53 //處理訊息54 bool bSuccess=false;
55 try
56 {
57 bSuccess=m_pIAttemperEngineSink->OnEventSocketRead(pSocketReadEvent->Command,pSocketReadEvent+1,pSocketReadEvent->wDataSize,pSocketReadEvent);
58
59 catch () { }
60 if (bSuccess==false) m_pITCPSocketEngine->CloseSocket(pSocketReadEvent->wIndex,pSocketReadEvent->wRoundID);
61
62 return;
63 }