asmlinkage long sys_connect(int fd, struct sockaddr __user *uservaddr,
int addrlen)
{
struct socket *sock;
char address[MAX_SOCK_ADDR];
int err, fput_needed;
//根據(jù)文件描述符獲取套接口指針，并且返回是否需要減少對(duì)文件引用計(jì)數(shù)標(biāo)志。
sock = sockfd_lookup_light(fd, &err, &fput_needed);
if (!sock)
goto out;
//將用戶空間的uservaddr數(shù)據(jù)復(fù)制到內(nèi)核空間的address
err = move_addr_to_kernel(uservaddr, addrlen, address);
if (err < 0)
goto out_put;

err =
security_socket_connect(sock, (struct sockaddr *)address, addrlen);
if (err)
goto out_put;

//通過(guò)套接口系統(tǒng)調(diào)用的跳轉(zhuǎn)表proto_ops，調(diào)用connect操作。TCP 中為 inet_stream_connect(), UDP 為 inet_dgram_connect()
err = sock->ops->connect(sock, (struct sockaddr *)address, addrlen,
sock->file->f_flags);
out_put:
// 根據(jù)fput_needed標(biāo)志，調(diào)用fput_light減少對(duì)文件引用計(jì)數(shù)操作
fput_light(sock->file, fput_needed);
out:
return err;
}

int inet_stream_connect(struct socket *sock, struct sockaddr *uaddr,
int addr_len, int flags)
{
struct sock *sk = sock->sk;
int err;
long timeo;

lock_sock(sk);
/* socket的協(xié)議族錯(cuò)誤 */
if (uaddr->sa_family == AF_UNSPEC) {
/* 如果使用的是TCP，則sk_prot為tcp_prot，disconnect為tcp_disconnect() */
err = sk->sk_prot->disconnect(sk, flags);
sock->state = err ? SS_DISCONNECTING : SS_UNCONNECTED;
goto out;
}

switch (sock->state) {
default:
err = -EINVAL;
goto out;
case SS_CONNECTED:
err = -EISCONN;
goto out;
case SS_CONNECTING:
err = -EALREADY;
/* Fall out of switch with err, set for this state */
break;
case SS_UNCONNECTED: /* 此套接口尚未連接對(duì)端的套接口，即連接尚未建立 */
err = -EISCONN;
if (sk->sk_state != TCP_CLOSE)
goto out;

/* 如果使用的是TCP，則sk_prot為tcp_prot，connect為tcp_v4_connect() */
err = sk->sk_prot->connect(sk, uaddr, addr_len); /* 發(fā)送SYN包 */
if (err < 0)
goto out;

/* 發(fā)出SYN包后socket狀態(tài)設(shè)為正在連接 */
sock->state = SS_CONNECTING;

/* Just entered SS_CONNECTING state; the only
* difference is that return value in non-blocking
* case is EINPROGRESS, rather than EALREADY.
*/
err = -EINPROGRESS;
break;
}

/* sock的發(fā)送超時(shí)時(shí)間，非阻塞則為0 */
timeo = sock_sndtimeo(sk, flags & O_NONBLOCK);

/* 發(fā)出SYN包后，等待后續(xù)握手的完成 */
if ((1 << sk->sk_state) & (TCPF_SYN_SENT | TCPF_SYN_RECV)) {
/* Error code is set above */
/* 如果是非阻塞的，那么就直接返回錯(cuò)誤碼-EINPROGRESS。
* socket為阻塞時(shí)，使用inet_wait_for_connect()來(lái)等待協(xié)議棧的處理：
* 1. 使用SO_SNDTIMEO，睡眠時(shí)間超過(guò)timeo就返回0，之后返回錯(cuò)誤碼-EINPROGRESS。
* 2. 收到信號(hào)，就返回剩余的等待時(shí)間。之后會(huì)返回錯(cuò)誤碼-ERESTARTSYS或-EINTR。
* 3. 三次握手成功，被sock I/O事件處理函數(shù)喚醒，之后會(huì)返回0。
*/
if (!timeo || !inet_wait_for_connect(sk, timeo))
goto out;

err = sock_intr_errno(timeo);
/* 進(jìn)程收到信號(hào)，如果err為-ERESTARTSYS，接下來(lái)庫(kù)函數(shù)會(huì)重新調(diào)用connect() */
if (signal_pending(current))
goto out;
}

/* Connection was closed by RST, timeout, ICMP error
* or another process disconnected us.
*/
if (sk->sk_state == TCP_CLOSE)
goto sock_error;

/* sk->sk_err may be not zero now, if RECVERR was ordered by user
* and error was received after socket entered established state.
* Hence, it is handled normally after connect() return successfully.
*/
/* 更新socket狀態(tài)為連接已建立 */
sock->state = SS_CONNECTED;
/* 清除錯(cuò)誤碼 */
err = 0;
out:
release_sock(sk);
return err;

sock_error:
err = sock_error(sk) ? : -ECONNABORTED;
sock->state = SS_UNCONNECTED;
/* 如果使用的是TCP，則sk_prot為tcp_prot，disconnect為tcp_disconnect() */
if (sk->sk_prot->disconnect(sk, flags))
sock->state = SS_DISCONNECTING;
goto out;
}

static long inet_wait_for_connect(struct sock *sk, long timeo)
{
/* 初始化等待任務(wù) */
DEFINE_WAIT(wait);
/* 把等待任務(wù)加入到socket的等待隊(duì)列頭部，把進(jìn)程的狀態(tài)設(shè)為TASK_INTERRUPTIBLE */
prepare_to_wait(sk->sk_sleep, &wait, TASK_INTERRUPTIBLE);

/* Basic assumption: if someone sets sk->sk_err, he _must_
* change state of the socket from TCP_SYN_*.
* Connect() does not allow to get error notifications
* without closing the socket.
*/
/* 完成三次握手后，狀態(tài)就會(huì)變?yōu)門CP_ESTABLISHED，從而退出循環(huán) */
while ((1 << sk->sk_state) & (TCPF_SYN_SENT | TCPF_SYN_RECV)) {
release_sock(sk);
/* 進(jìn)入睡眠，直到超時(shí)或收到信號(hào)，或者被I/O事件處理函數(shù)喚醒。
* 1. 如果是收到信號(hào)退出的，timeo為剩余的jiffies。
* 2. 如果使用了SO_SNDTIMEO選項(xiàng)，超時(shí)退出后，timeo為0。
* 3. 如果沒(méi)有使用SO_SNDTIMEO選項(xiàng)，timeo為無(wú)窮大，即MAX_SCHEDULE_TIMEOUT，
* 那么返回值也是這個(gè)，而超時(shí)時(shí)間不定。為了無(wú)限阻塞，需要上面的while循環(huán)。
*/
timeo = schedule_timeout(timeo);
/* 被喚醒后重新上鎖 */
lock_sock(sk);
/* 如果進(jìn)程有待處理的信號(hào)，或者睡眠超時(shí)了，退出循環(huán)，之后會(huì)返回錯(cuò)誤碼 */
if (signal_pending(current) || !timeo)
break;
/* 繼續(xù)睡眠 */
prepare_to_wait(sk->sk_sleep, &wait, TASK_INTERRUPTIBLE);
}
/* 等待結(jié)束時(shí)，把等待進(jìn)程從等待隊(duì)列中刪除，把當(dāng)前進(jìn)程的狀態(tài)設(shè)為TASK_RUNNING */
finish_wait(sk->sk_sleep, &wait);
return timeo;
}

static int tcp_rcv_synsent_state_process(struct sock *sk, struct sk_buff *skb,
struct tcphdr *th, unsigned len)
{
...

if (!sock_flag(sk, SOCK_DEAD)) {
/* 指向sock_def_wakeup，會(huì)喚醒調(diào)用connect()的進(jìn)程，完成連接的建立 */
sk->sk_state_change(sk);
/* 若采用異步通知，則發(fā)送SIGIO通知進(jìn)程可寫 */
sk_wake_async(sk, 0, POLL_OUT);
}

...
}

static void sock_def_wakeup(struct sock *sk)
{
read_lock(&sk->sk_callback_lock);
/* 有進(jìn)程阻塞在此socket上 */
if (sk->sk_sleep && waitqueue_active(sk->sk_sleep))
/* 喚醒此socket上的所有睡眠進(jìn)程 */
wake_up_interruptible_all(sk->sk_sleep);
read_unlock(&sk->sk_callback_lock);
}