TCP发送源码学习(3)--tcp_transmit_skb

3370阅读　0评论2013-08-21　slp195
分类：LINUX

一、tcp_transmit_skb
  1. static int tcp_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it,
  2.              gfp_t gfp_mask)
  3. {
  4.     const struct inet_connection_sock *icsk = inet_csk(sk);
  5.     struct inet_sock *inet;
  6.     struct tcp_sock *tp;
  7.     struct tcp_skb_cb *tcb;
  8.     struct tcp_out_options opts;
  9.     unsigned tcp_options_size, tcp_header_size;
  10.     struct tcp_md5sig_key *md5;
  11.     struct tcphdr *th;
  12.     int err;

  14.     BUG_ON(!skb || !tcp_skb_pcount(skb));

  16.     /* If congestion control is doing timestamping, we must
  17.      * take such a timestamp before we potentially clone/copy.
  18.      */
  19.   /*如果拥塞控制需要做时间才有，则必须在克隆或者拷贝报文之前设置一个时间戳。
  20.     linux支持了多达十种拥塞控制算法，但并不是每种算中都需要做时间采样的，
  21.     因此在设置时间戳前先判断当前的拥塞算法是否需要做时间采样。*/
  22.     if (icsk->icsk_ca_ops->flags & TCP_CONG_RTT_STAMP)
  23.         __net_timestamp(skb);

  25.     /*根据传递进来的clone_it参数来确定是否需要克隆待发送的报文。*/
  26.     if (likely(clone_it)) {
  27.         /*如果skb已经被clone，则只能复制该skb的数据到新分配的skb中*/
  28.         if (unlikely(skb_cloned(skb)))
  29.             skb = pskb_copy(skb, gfp_mask);
  30.         else
  31.         /*clone新的skb*/
  32.             skb = skb_clone(skb, gfp_mask);
  33.         if (unlikely(!skb))
  34.             return -ENOBUFS;
  35.     }

  37.     /*获取INET层和TCP层的传输控制块、skb中的TCP私有数据块。*/
  38.     inet = inet_sk(sk);
  39.     tp = tcp_sk(sk);
  40.     tcb = TCP_SKB_CB(skb);
  41.     memset(&opts, 0, sizeof(opts));

  43.     /*根据TCP选项重新调整TCP首部的长度。*/
  44.     /*判断当前TCP报文是否是SYN段，因为有些选项只能出现在SYN报文中，需做特别处理。*/
  45.     if (unlikely(tcb->flags & TCPHDR_SYN))
  46.         tcp_options_size = tcp_syn_options(sk, skb, &opts, &md5);
  47.     else
  48.         tcp_options_size = tcp_established_options(sk, skb, &opts, &md5);

  50.     /*tcp首部的总长度等于可选长度加上struct tcphdr。*/
  51.     tcp_header_size = tcp_options_size + sizeof(struct tcphdr);

  53.     /*如果已发出但未确认的数据包数目为零，则只初始化拥塞控制，并开始跟踪该连接的RTT。*/
  54.     if (tcp_packets_in_flight(tp) == 0)
  55.         tcp_ca_event(sk, CA_EVENT_TX_START);
  56.     
  57.     /*调用skb_push()在数据部分的头部添加TCP首部，长度即为之前计算得到的那个tcp_header_size，实际上是把data指针往上移。*/
  58.     skb_push(skb, tcp_header_size);
  59.     skb_reset_transport_header(skb);
  60.     /*SKB已添加到发送队列中，但是从SKB的角度去看还不知道他是属于哪个传输控制块，因此调用skb_set_owner_w设置该SKB的宿主。*/
  61.     skb_set_owner_w(skb, sk);

  63.     /* Build TCP header and checksum it. */
  64.     /*填充TCP首部中的源端口source、目的端口dest、TCP报文的序号seq、确认序号ack_seq以及各个标志位*/
  65.     th = tcp_hdr(skb);
  66.     th->source        = inet->inet_sport;
  67.     th->dest        = inet->inet_dport;
  68.     th->seq            = htonl(tcb->seq);
  69.     th->ack_seq        = htonl(tp->rcv_nxt);
  70.     *(((__be16 *)th) + 6)    = htons(((tcp_header_size >> 2) << 12) |
  71.                     tcb->flags);

  73.     /*分两种情况设置TCP首部的接收窗口的大小*/
  74.     if (unlikely(tcb->flags & TCPHDR_SYN)) {
  75.         /* RFC1323: The window in SYN & SYN/ACK segments
  76.          * is never scaled.
  77.          */
  78.         /*如果是SYN段，则设置接收窗口初始值为rcv_wnd*/
  79.         th->window    = htons(min(tp->rcv_wnd, 65535U));
  80.     } else {
  81.         /*如果是其他的报文，则调用tcp_select_window()计算当前接收窗口的大小。*/
  82.         th->window    = htons(tcp_select_window(sk));
  83.     }
  84.     /*初始化TCP首部的校验码和紧急指针，具体请参考TCP协议中的首部定义。*/
  85.     th->check        = 0;
  86.     th->urg_ptr        = 0;

  88.     /* The urg_mode check is necessary during a below snd_una win probe */
  89.     if (unlikely(tcp_urg_mode(tp) && before(tcb->seq, tp->snd_up))) {
  90.         if (before(tp->snd_up, tcb->seq + 0x10000)) {
  91.             th->urg_ptr = htons(tp->snd_up - tcb->seq);
  92.             th->urg = 1;
  93.         } else if (after(tcb->seq + 0xFFFF, tp->snd_nxt)) {
  94.             th->urg_ptr = htons(0xFFFF);
  95.             th->urg = 1;
  96.         }
  97.     }

  99.     tcp_options_write((__be32 *)(th + 1), tp, &opts);
  100.     if (likely((tcb->flags & TCPHDR_SYN) == 0))
  101.         TCP_ECN_send(sk, skb, tcp_header_size);

  103. #ifdef CONFIG_TCP_MD5SIG
  104.     /* Calculate the MD5 hash, as we have all we need now */
  105.     if (md5) {
  106.         sk_nocaps_add(sk, NETIF_F_GSO_MASK);
  107.         tp->af_specific->calc_md5_hash(opts.hash_location,
  108.                      md5, sk, NULL, skb);
  109.     }
  110. #endif

  112.     icsk->icsk_af_ops->send_check(sk, skb);

  114.     if (likely(tcb->flags & TCPHDR_ACK))
  115.         tcp_event_ack_sent(sk, tcp_skb_pcount(skb));

  117.     if (skb->len != tcp_header_size)
  118.         tcp_event_data_sent(tp, skb, sk);

  120.     if (after(tcb->end_seq, tp->snd_nxt) || tcb->seq == tcb->end_seq)
  121.         TCP_ADD_STATS(sock_net(sk), TCP_MIB_OUTSEGS,
  122.              tcp_skb_pcount(skb));
  123.     /*调用发送接口queue_xmit发送报文，进入到ip层，如果失败返回错误码。在TCP中该接口实现函数为ip_queue_xmit()*/
  124.     err = icsk->icsk_af_ops->queue_xmit(skb);
  125.     if (likely(err <= 0))
  126.         return err;

  128.     tcp_enter_cwr(sk, 1);

  130.     return net_xmit_eval(err);
  131. }

上一篇：linux内核中,tcp连接三次握手过程中的,tcp协议栈中的函数调用关系
下一篇：从编译器角度分析C语言中数组名和指针的区别