- 论坛徽章:
- 0
|
BOOL RecvTCP_Len(SOCKET sock,fd_set *pFD_read,TIMEVAL *pTime,CHAR *Buf,INT Len)
{
while(TRUE)
{
FD_ZERO(pFD_read);
FD_SET(sock,pFD_read);
int Returned=select(0,pFD_read,NULL,NULL,pTime);
LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "1092行:进入-Returned"<<"returned="<<Returned);
if(Returned>0)
{
LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "1096行:进入-Returned>0,准备recv");
int c = recv(sock,Buf,Len,0);
if(c == SOCKET_ERROR || c == 0)
{
int R=WSAGetLastError();
LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "返回的错误码R="<<R);
LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "c="<<c);
return FALSE;
}
if(c == Len)
{
return TRUE;//返回的是接收到的字节数
}
else
{
LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "c不等于len"<<c);
Buf += c;
Len -= c;
LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "c不等于len,len="<<Len);
}
}
if(Returned==SOCKET_ERROR)
{
int r=WSAGetLastError();
LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "select返回错误"<<r);
return FALSE;
}
}
}
好吧,贴代码。。这是接收数据的,创建了新的socket和connect后,会执行到c == SOCKET_ERROR,此时recv函数中的socket还是旧的那个,并不是新的,不知该咋弄?难道要重新再建立接收数据线程吗 |
|