MPTCP 源码分析(二) 建立子路径

简述

MPTCP在进行三次握手之后,客户端和服务端会进行地址信息的交换,让对方知道彼此未用的地址信息。

当客户端知道服务端的地址后就可以建立其他子路径。三次握手和建立子路径的过程如图1:

图1

关于Token、随机数R、以及HMAC(Hash-based Message Authentication Code)的详细解释可以阅读参考文献[1]。

MPTCP的内核实现:

这里我们主要关注建立子路径过程中,master sock对slave sock的影响。当客户端发送第一个SYN准备建立子路径的时候就会调用

mptcp_init4_subsockets来创建一个新的socket和相应的sock。

 "net/mptcp/mptcp_ipv4.c" line 328 of 488
328 int mptcp_init4_subsockets(struct sock *meta_sk, const struct mptcp_loc4 *loc,
329                struct mptcp_rem4 *rem)
330 {
331     struct tcp_sock *tp;
332     struct sock *sk;
333     struct sockaddr_in loc_in, rem_in;
334     struct socket sock;
335     int ulid_size = 0, ret;
336
337     /** First, create and prepare the new socket */
338
339     sock.type = meta_sk->sk_socket->type;
340     sock.state = SS_UNCONNECTED;
341     sock.wq = meta_sk->sk_socket->wq;
342     sock.file = meta_sk->sk_socket->file;
343     sock.ops = NULL;
344
345     ret = inet_create(sock_net(meta_sk), &sock, IPPROTO_TCP, 1);
346     if (unlikely(ret < 0)) {
347         mptcp_debug("%s inet_create failed ret: %d\n", __func__, ret);
348         return ret;
349     }
350
351     sk = sock.sk;
352     tp = tcp_sk(sk);

第345行的函数inet_create创建了子路径的socket和sock。

354     /* All subsockets need the MPTCP-lock-class */
355     lockdep_set_class_and_name(&(sk)->sk_lock.slock, &meta_slock_key, "slock-AF_INET-MPTCP");
356     lockdep_init_map(&(sk)->sk_lock.dep_map, "sk_lock-AF_INET-MPTCP", &meta_key, 0);
357
358     if (mptcp_add_sock(meta_sk, sk, loc->loc4_id, rem->rem4_id, GFP_KERNEL))
359         goto error;
360
361     tp->mptcp->slave_sk = 1;
362     tp->mptcp->low_prio = loc->low_prio;
363
364     /* Initializing the timer for an MPTCP subflow */
365     setup_timer(&tp->mptcp->mptcp_ack_timer, mptcp_ack_handler, (unsigned long)sk);

第358行的mptcp_add_sock将master sock 和 子路径的sock联系起来。第361行表面此sock为 slave subsock。

第362行设置此子路径是否为备用路径。只有现在路径都不可用的情况下,才会通过备用子路径发送数据。

第365行设置的定时器用于重发建立子路径的最后一个ACK,这样做是为了保证上图中的HMAC-A可以送达。

368
369     ulid_size = sizeof(struct sockaddr_in);
370     loc_in.sin_family = AF_INET;
371     rem_in.sin_family = AF_INET;
372     loc_in.sin_port = 0;
373     if (rem->port)
374         rem_in.sin_port = rem->port;
375     else
376         rem_in.sin_port = inet_sk(meta_sk)->inet_dport;
377     loc_in.sin_addr = loc->addr;
378     rem_in.sin_addr = rem->addr;
379
380     ret = sock.ops->bind(&sock, (struct sockaddr *)&loc_in, ulid_size);
381     if (ret < 0) {
382         mptcp_debug("%s: MPTCP subsocket bind() failed, error %d\n",
383                 __func__, ret);
384         goto error;
385     }
386
387     mptcp_debug("%s: token %#x pi %d src_addr:%pI4:%d dst_addr:%pI4:%d\n",
388             __func__, tcp_sk(meta_sk)->mpcb->mptcp_loc_token,
389             tp->mptcp->path_index, &loc_in.sin_addr,
390             ntohs(loc_in.sin_port), &rem_in.sin_addr,
391             ntohs(rem_in.sin_port));
392
393     if (tcp_sk(meta_sk)->mpcb->pm_ops->init_subsocket_v4)
394         tcp_sk(meta_sk)->mpcb->pm_ops->init_subsocket_v4(sk, rem->addr);
395
396     ret = sock.ops->connect(&sock, (struct sockaddr *)&rem_in,
397                 ulid_size, O_NONBLOCK);
398     if (ret < 0 && ret != -EINPROGRESS) {
399         mptcp_debug("%s: MPTCP subsocket connect() failed, error %d\n",
400                 __func__, ret);
401         goto error;
402     }

第380行是将子路径的socket的与地址绑定。第396行此套接字将会调用tcp_v4_connect进行连接操作。

403
404     sk_set_socket(sk, meta_sk->sk_socket);
405     sk->sk_wq = meta_sk->sk_wq;
406
407     return 0;
408
409 error:
410     /* May happen if mptcp_add_sock fails first */
411     if (!mptcp(tp)) {
412         tcp_close(sk, 0);
413     } else {
414         local_bh_disable();
415         mptcp_sub_force_close(sk);
416         local_bh_enable();
417     }
418     return ret;
419 }

第404和405行将子路径的sk和master的socket建立联系,因为对于应用程序来说只有

master的socket是可见,而slave subsock的socket是不可见。

下面的情景是服务端收到上图1中ACK/MP_JOIN(HMAC-A)包,这时状态将由SYN_RECV变为ESTABLISHED。函数的调用

关系如下:

tcp_v4_rcv

=》tcp_v4_do_rcv

=》mptcp_v4_do_rcv

=》tcp_v4_hnd_req

=》tcp_check_req

=》mptcp_check_req_child

=》mptcp_add_sock

在函数tcp_check_req中将会建立新的sock。主要代码如下:

"net/ipv4/tcp_minisocks.c" line 766 of 872
760     /* OK, ACK is valid, create big socket and
761      * feed this segment to it. It will repeat all
762      * the tests. THIS SEGMENT MUST MOVE SOCKET TO
763      * ESTABLISHED STATE. If it will be dropped after
764      * socket is created, wait for troubles.
765      */
766 #ifdef CONFIG_MPTCP
767     if (mptcp(tcp_sk(sk)))
768         /* MPTCP: We call the mptcp-specific syn_recv_sock */
769         child = tcp_sk(sk)->mpcb->syn_recv_sock(sk, skb, req, NULL);
770     else
771 #endif
772         child = inet_csk(sk)->icsk_af_ops->syn_recv_sock(sk, skb,
773                 req, NULL);
774
775     if (child == NULL)
776         goto listen_overflow;

第769行将会调用mptcp_syn_recv_sock和tcp_v4_syn_recv_sock和tcp_create_openreq_child创建新的sock并进行初始化。

函数mptcp_check_req_child和mptcp_add_sock会将此sock和master sock建立联系,并且设置此sock的属性slave_sk为1.

结论:

1. MPTCP利用Token、随机数R、以及HMAC(Hash-based Message Authentication Code)这些信息的交换保证构建子路径正确。

2.sub sock是在meta sock基础上建立,只有meta对于应用层是可见,其余sub sock并不可见。

参考文献:

[1] https://tools.ietf.org/html/rfc6824#section-3.2

问题:

1.第394行函数作用未知?

2.函数mptcp_v4_add_lsrr的功能?

时间: 2024-08-29 18:48:12

MPTCP 源码分析(二) 建立子路径的相关文章

MPTCP 源码分析(五) 接收端窗口值

简述: 在TCP协议中影响数据发送的三个因素分别为:发送端窗口值.接收端窗口值和拥塞窗口值. 本文主要分析MPTCP中各个子路径对接收端窗口值rcv_wnd的处理. 接收端窗口值的初始化 根据<MPTCP 源码分析(二) 建立子路径>中描述服务端在发送完SYN/ACK并接收到ACK的时候建立新的sock. 在内核实现中,针对连接请求分为两个步骤处理: SYN队列处理:当服务端收到SYN的时候,此连接请求request_sock将被存放于listening socket的SYN队列,服务端发送S

baksmali和smali源码分析(二)

这一节,主要介绍一下 baksmali代码的框架. 我们经常在反编译android apk包的时候使用apktool这个工具,其实本身这个工具里面对于dex文件解析和重新生成就是使用的baksmali 和smali这两个jar包其中 baksmali是将 dex文件转换成便于阅读的smali文件的,具体使用命令如下:java -jar baksmali.jar classes.dex -o myout其中myout是输出的文件夹 而smali是将smali文件重新生成回 dex文件的具体使用的命

netty 源码分析二

以服务端启动,接收客户端连接整个过程为例分析, 简略分为 五个过程: 1.NioServerSocketChannel 管道生成, 2.NioServerSocketChannel 管道完成初始化, 3.NioServerSocketChannel注册至Selector选择器, 4.NioServerSocketChannel管道绑定到指定端口,启动服务 5.NioServerSocketChannel接受客户端的连接,进行相应IO操作 Ps:netty内部过程远比这复杂,简略记录下方便以后回忆

[Android]Volley源码分析(二)Cache

Cache作为Volley最为核心的一部分,Volley花了重彩来实现它.本章我们顺着Volley的源码思路往下,来看下Volley对Cache的处理逻辑. 我们回想一下昨天的简单代码,我们的入口是从构造一个Request队列开始的,而我们并不直接调用new来构造,而是将控制权反转给Volley这个静态工厂来构造. com.android.volley.toolbox.Volley: public static RequestQueue newRequestQueue(Context conte

哇!板球 源码分析二

游戏主页面布局 创建屏下Score标签 pLabel = CCLabelTTF::create("Score", "Arial", TITLE_FONT_SIZE); //分数标签 //设置标签字体的颜色 pLabel->setColor (ccc3(0, 0, 0)); //设置文本标签的位置 pLabel->setPosition ( ccp ( SCORE_X, //X坐标 SCORE_Y //Y坐标 ) ); //将文本标签添加到布景中 this

【梦幻连连连】源码分析(二)

转载请注明出处:http://blog.csdn.net/oyangyufu/article/details/24736711 GameLayer场景界面效果: 源码分析: GameLayer场景初始化,主要是初始化加载界面及背景音乐 bool GameLayer::init() { float dt=0.0f; if ( !CCLayerColor::initWithColor(ccc4(255, 255, 255, 255))) { return false; } this->initLoa

[Android]Fragment源码分析(二) 状态

我们上一讲,抛出来一个问题,就是当Activity的onCreateView的时候,是如何构造Fragment中的View参数.要回答这个问题我们先要了解Fragment的状态,这是Fragment管理中非常重要的一环.我们先来看一下FragmentActivity提供的一些核心回调: @Override protected void onCreate(Bundle savedInstanceState) { mFragments.attachActivity(this, mContainer,

JAVA Collection 源码分析(二)之SubList

昨天我们分析了ArrayList的源码,我们可以看到,在其中还有一个类,名为SubList,其继承了AbstractList. // AbstractList类型的引用,所有继承了AbstractList都可以传进来 private final AbstractList<E> parent; // 这个是其实就是parent的偏移量,从parent中的第几个元素开始的 private final int parentOffset; private final int offset; int s

Tomcat源码分析二:先看看Tomcat的整体架构

Tomcat源码分析二:先看看Tomcat的整体架构 Tomcat架构图 我们先来看一张比较经典的Tomcat架构图: 从这张图中,我们可以看出Tomcat中含有Server.Service.Connector.Container等组件,接下来我们一起去大致的看看这些组件的作用和他们之间的相互联系.在这之前,我们先补充一个知识点,也就是Tomcat它实现的功能点是什么呢?通过查找一些资料,这里参考下极客时间<深入拆解Tomcat_Jetty>中的总结,即Tomcat 要实现 2 个核心功能: