|
@@ -498,8 +498,6 @@ bool CIOCPModel::_DoAccpet( PER_SOCKET_CONTEXT* pSocketContext, PER_IO_CONTEXT*
|
|
|
this->m_lpfnGetAcceptExSockAddrs(pIoContext->m_wsaBuf.buf, pIoContext->m_wsaBuf.len - ((sizeof(SOCKADDR_IN)+16)*2),
|
|
|
sizeof(SOCKADDR_IN)+16, sizeof(SOCKADDR_IN)+16, (LPSOCKADDR*)&LocalAddr, &localLen, (LPSOCKADDR*)&ClientAddr, &remoteLen);
|
|
|
|
|
|
- Global::g_time = time(NULL);
|
|
|
- Global::g_lastTime = COleDateTime::GetCurrentTime();
|
|
|
this->_ShowMessage( _T("客户端 %s:%d 连入."), inet_ntoa(ClientAddr->sin_addr), ntohs(ClientAddr->sin_port) );
|
|
|
//this->_ShowMessage( _T("客户额 %s:%d 信息:%s."),inet_ntoa(ClientAddr->sin_addr), ntohs(ClientAddr->sin_port),pIoContext->m_wsaBuf.buf );
|
|
|
if ( Global::g_bEnableLog )
|
|
@@ -512,7 +510,11 @@ bool CIOCPModel::_DoAccpet( PER_SOCKET_CONTEXT* pSocketContext, PER_IO_CONTEXT*
|
|
|
tlog.report_type = cJSON_GetObjectItem(pJson, _T("ReportType")) ? cJSON_GetObjectItem(pJson, _T("ReportType"))->valuestring : "";
|
|
|
tlog.report_data = cJSON_GetObjectItem(pJson, _T("prinMsg")) ? cJSON_GetObjectItem(pJson, _T("prinMsg"))->valuestring : "";
|
|
|
if ( _tcscmp(tlog.report_type.c_str(), _T("printLog")) == 0 )
|
|
|
+ {
|
|
|
Global::WritePythonLog(tlog.report_data.c_str());
|
|
|
+ Global::g_time = time(NULL);
|
|
|
+ Global::g_lastTime = COleDateTime::GetCurrentTime();
|
|
|
+ }
|
|
|
|
|
|
cJSON_Delete(pJson);
|
|
|
pJson = NULL;
|
|
@@ -589,8 +591,6 @@ bool CIOCPModel::_PostRecv( PER_IO_CONTEXT* pIoContext )
|
|
|
// 在有接收的数据到达的时候,进行处理
|
|
|
bool CIOCPModel::_DoRecv( PER_SOCKET_CONTEXT* pSocketContext, PER_IO_CONTEXT* pIoContext )
|
|
|
{
|
|
|
- Global::g_time = time(NULL);
|
|
|
- Global::g_lastTime = COleDateTime::GetCurrentTime();
|
|
|
// 先把上一次的数据显示出现,然后就重置状态,发出下一个Recv请求
|
|
|
SOCKADDR_IN* ClientAddr = &pSocketContext->m_ClientAddr;
|
|
|
//this->_ShowMessage( _T("收到 %s:%d 信息:%s"),inet_ntoa(ClientAddr->sin_addr), ntohs(ClientAddr->sin_port), pIoContext->m_wsaBuf.buf );
|
|
@@ -605,8 +605,11 @@ bool CIOCPModel::_DoRecv( PER_SOCKET_CONTEXT* pSocketContext, PER_IO_CONTEXT* pI
|
|
|
tlog.report_type = cJSON_GetObjectItem(pJson, _T("ReportType")) ? cJSON_GetObjectItem(pJson, _T("ReportType"))->valuestring : "";
|
|
|
tlog.report_data = cJSON_GetObjectItem(pJson, _T("prinMsg")) ? cJSON_GetObjectItem(pJson, _T("prinMsg"))->valuestring : "";
|
|
|
if ( _tcscmp(tlog.report_type.c_str(), _T("printLog")) == 0 )
|
|
|
+ {
|
|
|
Global::WritePythonLog(tlog.report_data.c_str());
|
|
|
-
|
|
|
+ Global::g_time = time(NULL);
|
|
|
+ Global::g_lastTime = COleDateTime::GetCurrentTime();
|
|
|
+ }
|
|
|
cJSON_Delete(pJson);
|
|
|
pJson = NULL;
|
|
|
}
|