• VPP 源码学习总结


    当我们在VPP/plugins目录下注册了自己的node后, 肯定有一个node.func(), 那这个函数是如何执行到的呢:

    1. 首先我们要看一下这个插件注册的时候做了什么, 假设node 如下:

    编译成功后, 我们可以从函数vlib_plugin_early_init() 中分析, 初始化时,怎么把这个node加到全局链表中的。

    TODO: 大概就是, 在so 目录下去遍历所有so文件,根据注册的名字用头插法把相关node 加入链表中, 并为其分配相关的维护逻辑。

    2. vpp初始化的前两步把插件,加载完了(维护起来了), 那下边我们看下VPP是怎么在后台一直去轮询的呢? 

    由于亿图脑图目前不能保存,节点限制, 先把已经总结放这里(新标签中打开图片可以放大)。

    下图主要以vpp的main()为入口,学习vpp如果调用我注册的node的处理函数的。

    前边马上就要找到调用我们注册的node了, 下边我们看一下dispatch_node()函数。

    在调用的地方我们要注意框起来的这两个参数:

    因为我们注册的NODE是VLIB_NODE_TYPE_INTERNAL类型的, 这里就是了, 我们看下dispatch_node()源码:

    1. static_always_inline u64
    2. dispatch_node (vlib_main_t * vm,
    3. vlib_node_runtime_t * node,
    4. vlib_node_type_t type, // internal 类型的
    5. vlib_node_state_t dispatch_state, // polling 状态 的。
    6. vlib_frame_t * frame, u64 last_time_stamp)
    7. {
    8. uword n, v;
    9. u64 t;
    10. vlib_node_main_t *nm = &vm->node_main;
    11. vlib_next_frame_t *nf;
    12. if (CLIB_DEBUG > 0)
    13. {
    14. vlib_node_t *n = vlib_get_node (vm, node->node_index);
    15. ASSERT (n->type == type);
    16. }
    17. /* Only non-internal nodes may be disabled. */
    18. if (type != VLIB_NODE_TYPE_INTERNAL && node->state != dispatch_state)
    19. {
    20. ASSERT (type != VLIB_NODE_TYPE_INTERNAL);
    21. return last_time_stamp;
    22. }
    23. if ((type == VLIB_NODE_TYPE_PRE_INPUT || type == VLIB_NODE_TYPE_INPUT) // 这里些时进不来
    24. && dispatch_state != VLIB_NODE_STATE_INTERRUPT)
    25. {
    26. u32 c = node->input_main_loops_per_call;
    27. /* Only call node when count reaches zero. */
    28. if (c)
    29. {
    30. node->input_main_loops_per_call = c - 1;
    31. return last_time_stamp;
    32. }
    33. }
    34. /* Speculatively prefetch next frames. */
    35. if (node->n_next_nodes > 0) // 这里是预取, 先不用管
    36. {
    37. nf = vec_elt_at_index (nm->next_frames, node->next_frame_index);
    38. CLIB_PREFETCH (nf, 4 * sizeof (nf[0]), WRITE);
    39. }
    40. vm->cpu_time_last_node_dispatch = last_time_stamp;
    41. if (1 /* || vm->thread_index == node->thread_index */ ) // 这里一定能进来。
    42. {
    43. vlib_main_t *stat_vm;
    44. stat_vm = /* vlib_mains ? vlib_mains[0] : */ vm;
    45. vlib_elog_main_loop_event (vm, node->node_index,
    46. last_time_stamp,
    47. frame ? frame->n_vectors : 0,
    48. /* is_after */ 0);
    49. /*
    50. * Turn this on if you run into
    51. * "bad monkey" contexts, and you want to know exactly
    52. * which nodes they've visited... See ixge.c...
    53. */
    54. if (VLIB_BUFFER_TRACE_TRAJECTORY && frame) // 这里前宏没有定义 , 进不来
    55. {
    56. int i;
    57. u32 *from;
    58. from = vlib_frame_vector_args (frame);
    59. for (i = 0; i < frame->n_vectors; i++)
    60. {
    61. vlib_buffer_t *b = vlib_get_buffer (vm, from[i]);
    62. add_trajectory_trace (b, node->node_index);
    63. }
    64. n = node->function (vm, node, frame);
    65. }
    66. else // 最后走到了这里。
    67. n = node->function (vm, node, frame); // 这里调用的我们加的internal node的执行函数。
    68. /* 因为上层调用的时候 , 是处理所有的internal类型的node, 这里的node 就包含了我们注册的
    69. Node. node->function () 就是调用的我们注册的函数 yb_sample_node_fn() , 上层调用是一个
    70. while() 循环, 所以这些node会一直在后台循环处理, 这样只要有包到我们这个node,
    71. 就会添加进调度链表,并进行处理。*/

    从这个流程上, 就大概知道我们注册的node是如何被调用起来的了。 以后有更多的细节要学习, 可以根据这个流程去找具体的实现逻辑。

  • 相关阅读:
    超详细反编译python打包的exe
    包管理工具与配置文件package.json
    message“: “CSRF token mismatch
    Problem C: 算法2-23:一元多项式加法
    干货丨微课制作素材分享,教师再也不用见微课就发愁
    wsl2收缩虚拟磁盘,减少空间占用
    zemax---Tangential plane, meridian plane and sagittal plane(切线面,子午面与弧矢面)(完结)
    数据结构: 二叉搜索树
    Informatica使用操作流程--聚合、表达式转换、查找、排序组件的使用 案例3
    QML地图Map中使用QPainterPath,并显示任意点经纬度位置
  • 原文地址:https://blog.csdn.net/coolfishbone_joey/article/details/138198460