1. int connect_socket_timeout(int sockfd,char *dest_host, int port, int timeout)
2. {
3. 　　struct sockaddr_in address;
4. 　　struct in_addr inaddr;
5. 　　struct hostent *host;
6. 　　int  err, noblock=1 , connect_ok=0, begin_time=time(NULL);
7. 　　log_debug("connect_socket to %s:%dn",dest_host,port);
8. 　　if (inet_aton(dest_host, &inaddr))
9. 　　{
10. 　　       log_debug("inet_aton ok now gethostbyaddr %sn",dest_host);
11. 　　       memcpy(&address.sin_addr, &inaddr, sizeof(address.sin_addr));
12. 　　}
13. 　　else
14. 　　{
15. 　　        log_debug("inet_aton fail now gethostbyname %s n",dest_host);
16. 　　        host = gethostbyname(dest_host);
17. 　        　if (!host) {
18. 　　       /* We can't find an IP number */
19. 　　         log_error("error looking up host  %s : %dn",dest_host,errno);
20. 　          　return -1;
21. 　　         }
22. 　           memcpy(&address.sin_addr, host->h_addr_list[0], sizeof(address.sin_addr));
23. 　　}
24. 　　address.sin_family = AF_INET;
25. 　　address.sin_port = htons(port);
26. 　　/* Take the first IP address associated with this hostname */
27. 　　ioctl(sockfd,FIONBIO,&noblock);
28. 　　/** connect until timeout */
29. 　　/*
30. 　　EINPROGRESS   A nonblocking socket connection cannot be completed immediately.
31. 　　EALREADY     The socket is nonblocking and a  previous connection attempt has not been completed.
32. 　　EISCONN      The socket is already connected.
33. 　　*/
34. 　　if (connect(sockfd, (struct sockaddr *) &address, sizeof(address)) < 0)
35. 　　{
36. 　　err = errno;
37. 　　if (err != EINPROGRESS)
38. 　　{
39. 　       　log_error("connect = %d connecting to host %sn", err,dest_host);
40. 　　}
41. 　　else
42. 　　{
43. 　　//                                log_notice("connect pending, return %d n", err);
44. 　　  while (1) /* is noblocking connect, check it until ok or timeout */
45. 　　  {
46. 　          　connect(sockfd, (struct sockaddr *) &address, sizeof(address));
47. 　　          err = errno;
48. 　　          switch (err)
49. 　          　{
50. 　　                case EISCONN:   /* connect ok */
51. 　　                     connect_ok = 1;
52. 　                      　break;
53. 　               　case EALREADY:  /* is connecting, need to check again */
54. 　　                    //log_info("connect again return EALREADY check again...n");
55. 　　                   usleep(50000);
56. 　　                    break;
57. 　　            default:   /* failed, retry again ? */
58. 　                   　log_error("connect fail err=%d n",err);
59. connect_ok = -1;
60. break;
61. 　           　}
62. 　　        if (connect_ok==1)
63. 　　         {
64. 　　              //log_info ("connect ok try time =%d n", (time(NULL) - begin_time) );
65. 　　              break;
66. 　　         }
67. 　       　 if (connect_ok==-1)
68. 　　        {
69. 　             　log_notice ("connect failed try time =%d n", (time(NULL) - begin_time) );
70. 　
71. 　        　}
72. 　　       if ( (timeout>0) && ((time(NULL) - begin_time)>timeout) )
73. 　　        {
74. 　            　log_notice("connect failed, timeout %d secondsn", (time(NULL) - begin_time));
75. 　             　break;
76. 　　        }
77. 　　      }
78. 　  　}
79. 　　}
80. 　　else        /* Connect successful immediately        */
81. 　　{
82. 　　 // log_info("connect immediate success to host %sn", dest_host);
83. 　　     connect_ok = 1;
84. 　　}
85. 　　/** end of try connect */
86. 　　return ((connect_ok==1)?sockfd:-1);
87. 　　}

1. int connect_nonb(int sockfd, const SA *saptr, socklen_t salen, int nsec)
2. 　{
3. 　　int flags, n, error;
4. 　　socklen_t len;
5. 　　fd_set rset, wset;
6. 　　struct timeval tval;
7. 　　// 获取当前socket的属性， 并设置 noblocking 属性
8. 　　flags = fcntl(sockfd, F_GETFL, 0);
9. 　　fcntl(sockfd, F_SETFL, flags | O_NOBLOCK);
10. 　　errno = 0;
11. 　　if ( (n = connect(sockfd, saptr, salen)) < 0)
12. 　　if (errno != EINPROGRESS)
13. 　     　return (-1);
14. 　　// 可以做任何其它的操作
15. 　　if (n == 0)
16. 　　   goto done; // 一般是同一台主机调用，会返回 0
17. 　　FD_ZERO(&rset);
18. 　　FD_SET(sockfd, &rset);
19. 　　wset = rset;  // 这里会做 block copy
20. 　　tval.tv_sec = nsec;
21. 　　tval.tv_usec = 0;
22. 　　// 如果nsec 为0，将使用缺省的超时时间，即其结构指针为 NULL
23. 　　// 如果tval结构中的时间为0，表示不做任何等待，立刻返回
24. 　　if ((n = select(sockfd+1, &rset, &west, NULL,nsec ?tval:NULL)) == 0) {
25. 　　      close(sockfd);
26. 　        errno = ETIMEOUT;
27. 　         return (-1);
28. 　　}
29. 　　if(FD_ISSET(sockfd, &rset) || FD_ISSET(sockfd, &west)) {
30. 　     　len = sizeof(error);
31. 　　// 如果连接成功，此调用返回 0
32. 　    　if (getsockopt(sockfd, SOL_SOCKET, SO_ERROR, &error, &len) < 0)
33. 　          return (-1);
34. 　　}
35. 　　else
36. err_quit(“select error: sockfd  not set”);
37. 　　done:
38. 　     　fcntl(sockfd, F_SETFL, flags); // 恢复socket 属性
39. 　　    if (error) {
40. 　　       close(sockfd);
41. 　　       errno = error;
42. 　       　return (-1);
43. 　　    }
44. 　　    return (0);
45. 　　}

由epoll负责监听fd的状态，epoll_wait之捕获到EPOLLOUT事件，收到EPOLLOUT也不能认为是

TCP层次上connect(2)已经成功，要调用getsockopt看SOL_SOCKET的SO_ERROR是否为0。若为0，

才表明真正的TCP层次上connect成功。至于应用层次的server是否收/发数据，那是另一回事了。