월컴투 디시플 닷골

void
CSocketBase::sendRemainedPackets()
{
this->m_Mutex.Lock();

while (!this->m_SendQueue.empty())
{
SOCKET_SEND_DATA data = this->m_SendQueue.top();

//패킷을 보냈으면..
if (this->sendPacket(data))
{
//팝한다
this->m_SendQueue.pop();
delete[] data.p;
}
}

this->m_Mutex.Unlock();
}

bool
CSocketBase::sendPacket(SOCKET_SEND_DATA &Data)
{
size_t nRest;
int nRet;
char* pData = Data.p;

nRest = Data.size;

while (nRest)
{
nRet = send(this->m_hSocket, pData, (int)nRest, 0);

if (nRet == SOCKET_ERROR)
{
//보내기가 취소 됬으면..
if (WSAGetLastError() == WSAEWOULDBLOCK)
{
}
else
{
//접속이 끊긴것이다.
this->Disconnect();
this->OnDisconnect();

//return true;
}

return false;
}

nRest -= nRet;
pData += nRet;
}

return true;


}

void
CMajakSocketBase::MainLoop()
{
WSANETWORKEVENTS wne;

while (!this->m_bTermSig)
{
if (!this->m_bConnected)
{
Sleep(1);
continue;
}

this->sendRemainedPackets();

//이벤트를 얻자.
WSAWaitForMultipleEvents(1, &this->m_hEvent, false, 10, false);
WSAEnumNetworkEvents(this->m_hSocket, this->m_hEvent, &wne);

if (wne.lNetworkEvents & FD_CONNECT)
{
if (wne.iErrorCode[FD_CONNECT_BIT] != 0)
{
this->m_bConnected = false;
}

this->OnConnect(this->m_bConnected);
}

if (wne.lNetworkEvents & FD_READ)
{
this->recvPacket();

}

if (wne.lNetworkEvents & FD_WRITE)
{
this->sendRemainedPackets();
}

if (wne.lNetworkEvents & FD_CLOSE)
{
if (!this->m_bUserDisconnect)
{
this->Disconnect();
this->OnDisconnect();
}
else
{
this->m_bUserDisconnect = false;
}

}

}//whlie

}