当前位置：首页 → 问答吧 → 有关非阻塞connect

有关非阻塞connect

时间：2010-09-01

来源：互联网

int SocketConnect(int *sock, char *ip, unsigned short port)
{
int ret ;
int sockfd ;
if(*sock<=0)
{
struct sockaddr_in addr;
sockfd = socket(AF_INET, SOCK_STREAM, 0);
if(sockfd == -1)
{
return -1;
}
{
int flag = 1;
#ifdef _WIN32
ioctlsocket(sockfd, FIONBIO, &flag);
#else
flag = fcntl(sockfd, F_GETFL, 0);
fcntl(sockfd, F_SETFL, flag | O_NONBLOCK);
#endif
}
addr.sin_family = AF_INET;
addr.sin_port = htons(port);
addr.sin_addr.s_addr = inet_addr(ip);
ret = connect(sockfd, (struct sockaddr *)&addr, sizeof(addr));
if(ret < 0)
{
#ifdef OS_WIN
if(WSAGetLastError()==EINPROGRESS)
#else
if(errno==EINPROGRESS)
#endif
{
*sock=sockfd;
return 1;
}
else
{
#ifdef OS_WIN
closesocket(sockfd);
#else
close(sockfd);
#endif
return -2;
}
}
return 0;
}
else
{
fd_set fdset;
struct timeval tv;
int valopt;
int lon;
sockfd=*sock;
tv.tv_sec = 0;
tv.tv_usec = 1000;
FD_ZERO(&fdset);
FD_SET(sockfd, &fdset);
ret = select(sockfd+1, NULL, &fdset, NULL, &tv);
if (ret < 0 )//&& errno != EINTR)
{
return 1; //????? 这返回1 ？ 1 是成功，对吗
}
else if (ret > 0)
{
lon = sizeof(int);
if(getsockopt(sockfd, SOL_SOCKET, SO_ERROR, (void*)(&valopt), &lon) < 0 || valopt)
{
#ifdef OS_WIN
closesocket(sockfd);
#else
close(sockfd);
#endif
*sock=0;
return -3;
}
return 0;
}
return 1;
}
}

复制代码

如上代码标记
if (ret < 0 )//&& errno != EINTR)
{
return 1; //????? 这返回1 ？ 1 是成功，对吗
}

作者: sytpb 发布时间: 2010-09-01

On success, select() and pselect() return the number of file descriptors contained in
   the three returned descriptor sets (that is, the total number of bits that are set in
   readfds,  writefds,  exceptfds)  which may be zero if the timeout expires before any-
   thing interesting happens.  On error, -1 is returned, and errno is set appropriately;
   the  sets  and  timeout  become  undefined, so do not rely on their contents after an
   error.

作者: rain_fish 发布时间: 2010-09-01

有关非阻塞connect

热门阅读

热门下载