Lines Matching refs:req
233 struct thread_msg_req *req) in thread_msg_send_recv() argument
243 status = rte_ring_sp_enqueue(msgq_req, req); in thread_msg_send_recv()
260 struct thread_msg_req *req; in thread_pipeline_enable() local
309 req = thread_msg_alloc(); in thread_pipeline_enable()
310 if (req == NULL) in thread_pipeline_enable()
314 req->type = THREAD_REQ_PIPELINE_ENABLE; in thread_pipeline_enable()
315 req->pipeline_enable.p = p->p; in thread_pipeline_enable()
317 req->pipeline_enable.table[i].a = in thread_pipeline_enable()
319 req->pipeline_enable.msgq_req = p->msgq_req; in thread_pipeline_enable()
320 req->pipeline_enable.msgq_rsp = p->msgq_rsp; in thread_pipeline_enable()
321 req->pipeline_enable.timer_period_ms = p->timer_period_ms; in thread_pipeline_enable()
322 req->pipeline_enable.n_tables = p->n_tables; in thread_pipeline_enable()
325 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_enable()
349 struct thread_msg_req *req; in thread_pipeline_disable() local
401 req = thread_msg_alloc(); in thread_pipeline_disable()
402 if (req == NULL) in thread_pipeline_disable()
406 req->type = THREAD_REQ_PIPELINE_DISABLE; in thread_pipeline_disable()
407 req->pipeline_disable.p = p->p; in thread_pipeline_disable()
410 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_disable()
433 struct thread_msg_req *req; in thread_msg_recv() local
435 int status = rte_ring_sc_dequeue(msgq_req, (void **) &req); in thread_msg_recv()
440 return req; in thread_msg_recv()
456 struct thread_msg_req *req) in thread_msg_handle_pipeline_enable() argument
458 struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req; in thread_msg_handle_pipeline_enable()
468 t->p[t->n_pipelines] = req->pipeline_enable.p; in thread_msg_handle_pipeline_enable()
470 p->p = req->pipeline_enable.p; in thread_msg_handle_pipeline_enable()
471 for (i = 0; i < req->pipeline_enable.n_tables; i++) in thread_msg_handle_pipeline_enable()
473 req->pipeline_enable.table[i].a; in thread_msg_handle_pipeline_enable()
475 p->n_tables = req->pipeline_enable.n_tables; in thread_msg_handle_pipeline_enable()
477 p->msgq_req = req->pipeline_enable.msgq_req; in thread_msg_handle_pipeline_enable()
478 p->msgq_rsp = req->pipeline_enable.msgq_rsp; in thread_msg_handle_pipeline_enable()
480 (rte_get_tsc_hz() * req->pipeline_enable.timer_period_ms) / 1000; in thread_msg_handle_pipeline_enable()
492 struct thread_msg_req *req) in thread_msg_handle_pipeline_disable() argument
494 struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req; in thread_msg_handle_pipeline_disable()
496 struct rte_pipeline *pipeline = req->pipeline_disable.p; in thread_msg_handle_pipeline_disable()
531 struct thread_msg_req *req; in thread_msg_handle() local
534 req = thread_msg_recv(t->msgq_req); in thread_msg_handle()
535 if (req == NULL) in thread_msg_handle()
538 switch (req->type) { in thread_msg_handle()
540 rsp = thread_msg_handle_pipeline_enable(t, req); in thread_msg_handle()
544 rsp = thread_msg_handle_pipeline_disable(t, req); in thread_msg_handle()
548 rsp = (struct thread_msg_rsp *) req; in thread_msg_handle()
750 struct pipeline_msg_req *req) in pipeline_msg_send_recv() argument
759 status = rte_ring_sp_enqueue(msgq_req, req); in pipeline_msg_send_recv()
777 struct pipeline_msg_req *req; in pipeline_port_in_stats_read() local
801 req = pipeline_msg_alloc(); in pipeline_port_in_stats_read()
802 if (req == NULL) in pipeline_port_in_stats_read()
806 req->type = PIPELINE_REQ_PORT_IN_STATS_READ; in pipeline_port_in_stats_read()
807 req->id = port_id; in pipeline_port_in_stats_read()
808 req->port_in_stats_read.clear = clear; in pipeline_port_in_stats_read()
811 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_stats_read()
829 struct pipeline_msg_req *req; in pipeline_port_in_enable() local
848 req = pipeline_msg_alloc(); in pipeline_port_in_enable()
849 if (req == NULL) in pipeline_port_in_enable()
853 req->type = PIPELINE_REQ_PORT_IN_ENABLE; in pipeline_port_in_enable()
854 req->id = port_id; in pipeline_port_in_enable()
857 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_enable()
873 struct pipeline_msg_req *req; in pipeline_port_in_disable() local
892 req = pipeline_msg_alloc(); in pipeline_port_in_disable()
893 if (req == NULL) in pipeline_port_in_disable()
897 req->type = PIPELINE_REQ_PORT_IN_DISABLE; in pipeline_port_in_disable()
898 req->id = port_id; in pipeline_port_in_disable()
901 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_disable()
919 struct pipeline_msg_req *req; in pipeline_port_out_stats_read() local
943 req = pipeline_msg_alloc(); in pipeline_port_out_stats_read()
944 if (req == NULL) in pipeline_port_out_stats_read()
948 req->type = PIPELINE_REQ_PORT_OUT_STATS_READ; in pipeline_port_out_stats_read()
949 req->id = port_id; in pipeline_port_out_stats_read()
950 req->port_out_stats_read.clear = clear; in pipeline_port_out_stats_read()
953 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_out_stats_read()
973 struct pipeline_msg_req *req; in pipeline_table_stats_read() local
997 req = pipeline_msg_alloc(); in pipeline_table_stats_read()
998 if (req == NULL) in pipeline_table_stats_read()
1002 req->type = PIPELINE_REQ_TABLE_STATS_READ; in pipeline_table_stats_read()
1003 req->id = table_id; in pipeline_table_stats_read()
1004 req->table_stats_read.clear = clear; in pipeline_table_stats_read()
1007 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_stats_read()
1331 struct pipeline_msg_req *req; in pipeline_table_rule_add() local
1409 req = pipeline_msg_alloc(); in pipeline_table_rule_add()
1410 if (req == NULL) { in pipeline_table_rule_add()
1416 req->type = PIPELINE_REQ_TABLE_RULE_ADD; in pipeline_table_rule_add()
1417 req->id = table_id; in pipeline_table_rule_add()
1418 memcpy(&req->table_rule_add.match, match, sizeof(*match)); in pipeline_table_rule_add()
1419 memcpy(&req->table_rule_add.action, action, sizeof(*action)); in pipeline_table_rule_add()
1422 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add()
1445 struct pipeline_msg_req *req; in pipeline_table_rule_add_default() local
1508 req = pipeline_msg_alloc(); in pipeline_table_rule_add_default()
1509 if (req == NULL) { in pipeline_table_rule_add_default()
1515 req->type = PIPELINE_REQ_TABLE_RULE_ADD_DEFAULT; in pipeline_table_rule_add_default()
1516 req->id = table_id; in pipeline_table_rule_add_default()
1517 memcpy(&req->table_rule_add_default.action, action, sizeof(*action)); in pipeline_table_rule_add_default()
1520 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add_default()
1569 struct pipeline_msg_req *req; in pipeline_table_rule_add_bulk() local
1620 req = pipeline_msg_alloc(); in pipeline_table_rule_add_bulk()
1621 if (req == NULL) { in pipeline_table_rule_add_bulk()
1627 req->type = PIPELINE_REQ_TABLE_RULE_ADD_BULK; in pipeline_table_rule_add_bulk()
1628 req->id = table_id; in pipeline_table_rule_add_bulk()
1629 req->table_rule_add_bulk.list = list; in pipeline_table_rule_add_bulk()
1630 req->table_rule_add_bulk.bulk = table->params.match_type == TABLE_ACL; in pipeline_table_rule_add_bulk()
1633 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add_bulk()
1659 struct pipeline_msg_req *req; in pipeline_table_rule_delete() local
1697 req = pipeline_msg_alloc(); in pipeline_table_rule_delete()
1698 if (req == NULL) in pipeline_table_rule_delete()
1702 req->type = PIPELINE_REQ_TABLE_RULE_DELETE; in pipeline_table_rule_delete()
1703 req->id = table_id; in pipeline_table_rule_delete()
1704 memcpy(&req->table_rule_delete.match, match, sizeof(*match)); in pipeline_table_rule_delete()
1707 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_delete()
1726 struct pipeline_msg_req *req; in pipeline_table_rule_delete_default() local
1753 req = pipeline_msg_alloc(); in pipeline_table_rule_delete_default()
1754 if (req == NULL) in pipeline_table_rule_delete_default()
1758 req->type = PIPELINE_REQ_TABLE_RULE_DELETE_DEFAULT; in pipeline_table_rule_delete_default()
1759 req->id = table_id; in pipeline_table_rule_delete_default()
1762 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_delete_default()
1784 struct pipeline_msg_req *req; in pipeline_table_rule_stats_read() local
1816 req = pipeline_msg_alloc(); in pipeline_table_rule_stats_read()
1817 if (req == NULL) in pipeline_table_rule_stats_read()
1821 req->type = PIPELINE_REQ_TABLE_RULE_STATS_READ; in pipeline_table_rule_stats_read()
1822 req->id = table_id; in pipeline_table_rule_stats_read()
1823 req->table_rule_stats_read.data = rule->data; in pipeline_table_rule_stats_read()
1824 req->table_rule_stats_read.clear = clear; in pipeline_table_rule_stats_read()
1827 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_stats_read()
1847 struct pipeline_msg_req *req; in pipeline_table_mtr_profile_add() local
1872 req = pipeline_msg_alloc(); in pipeline_table_mtr_profile_add()
1873 if (req == NULL) in pipeline_table_mtr_profile_add()
1877 req->type = PIPELINE_REQ_TABLE_MTR_PROFILE_ADD; in pipeline_table_mtr_profile_add()
1878 req->id = table_id; in pipeline_table_mtr_profile_add()
1879 req->table_mtr_profile_add.meter_profile_id = meter_profile_id; in pipeline_table_mtr_profile_add()
1880 memcpy(&req->table_mtr_profile_add.profile, profile, sizeof(*profile)); in pipeline_table_mtr_profile_add()
1883 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_mtr_profile_add()
1900 struct pipeline_msg_req *req; in pipeline_table_mtr_profile_delete() local
1923 req = pipeline_msg_alloc(); in pipeline_table_mtr_profile_delete()
1924 if (req == NULL) in pipeline_table_mtr_profile_delete()
1928 req->type = PIPELINE_REQ_TABLE_MTR_PROFILE_DELETE; in pipeline_table_mtr_profile_delete()
1929 req->id = table_id; in pipeline_table_mtr_profile_delete()
1930 req->table_mtr_profile_delete.meter_profile_id = meter_profile_id; in pipeline_table_mtr_profile_delete()
1933 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_mtr_profile_delete()
1953 struct pipeline_msg_req *req; in pipeline_table_rule_mtr_read() local
1989 req = pipeline_msg_alloc(); in pipeline_table_rule_mtr_read()
1990 if (req == NULL) in pipeline_table_rule_mtr_read()
1994 req->type = PIPELINE_REQ_TABLE_RULE_MTR_READ; in pipeline_table_rule_mtr_read()
1995 req->id = table_id; in pipeline_table_rule_mtr_read()
1996 req->table_rule_mtr_read.data = rule->data; in pipeline_table_rule_mtr_read()
1997 req->table_rule_mtr_read.tc_mask = tc_mask; in pipeline_table_rule_mtr_read()
1998 req->table_rule_mtr_read.clear = clear; in pipeline_table_rule_mtr_read()
2001 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_mtr_read()
2021 struct pipeline_msg_req *req; in pipeline_table_dscp_table_update() local
2046 req = pipeline_msg_alloc(); in pipeline_table_dscp_table_update()
2047 if (req == NULL) in pipeline_table_dscp_table_update()
2051 req->type = PIPELINE_REQ_TABLE_DSCP_TABLE_UPDATE; in pipeline_table_dscp_table_update()
2052 req->id = table_id; in pipeline_table_dscp_table_update()
2053 req->table_dscp_table_update.dscp_mask = dscp_mask; in pipeline_table_dscp_table_update()
2054 memcpy(&req->table_dscp_table_update.dscp_table, in pipeline_table_dscp_table_update()
2058 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_dscp_table_update()
2078 struct pipeline_msg_req *req; in pipeline_table_rule_ttl_read() local
2113 req = pipeline_msg_alloc(); in pipeline_table_rule_ttl_read()
2114 if (req == NULL) in pipeline_table_rule_ttl_read()
2118 req->type = PIPELINE_REQ_TABLE_RULE_TTL_READ; in pipeline_table_rule_ttl_read()
2119 req->id = table_id; in pipeline_table_rule_ttl_read()
2120 req->table_rule_ttl_read.data = rule->data; in pipeline_table_rule_ttl_read()
2121 req->table_rule_ttl_read.clear = clear; in pipeline_table_rule_ttl_read()
2124 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_ttl_read()
2145 struct pipeline_msg_req *req; in pipeline_table_rule_time_read() local
2177 req = pipeline_msg_alloc(); in pipeline_table_rule_time_read()
2178 if (req == NULL) in pipeline_table_rule_time_read()
2182 req->type = PIPELINE_REQ_TABLE_RULE_TIME_READ; in pipeline_table_rule_time_read()
2183 req->id = table_id; in pipeline_table_rule_time_read()
2184 req->table_rule_time_read.data = rule->data; in pipeline_table_rule_time_read()
2187 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_time_read()
2206 struct pipeline_msg_req *req; in pipeline_msg_recv() local
2208 int status = rte_ring_sc_dequeue(msgq_req, (void **) &req); in pipeline_msg_recv()
2213 return req; in pipeline_msg_recv()
2229 struct pipeline_msg_req *req) in pipeline_msg_handle_port_in_stats_read() argument
2231 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_stats_read()
2232 uint32_t port_id = req->id; in pipeline_msg_handle_port_in_stats_read()
2233 int clear = req->port_in_stats_read.clear; in pipeline_msg_handle_port_in_stats_read()
2245 struct pipeline_msg_req *req) in pipeline_msg_handle_port_in_enable() argument
2247 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_enable()
2248 uint32_t port_id = req->id; in pipeline_msg_handle_port_in_enable()
2258 struct pipeline_msg_req *req) in pipeline_msg_handle_port_in_disable() argument
2260 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_disable()
2261 uint32_t port_id = req->id; in pipeline_msg_handle_port_in_disable()
2271 struct pipeline_msg_req *req) in pipeline_msg_handle_port_out_stats_read() argument
2273 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_out_stats_read()
2274 uint32_t port_id = req->id; in pipeline_msg_handle_port_out_stats_read()
2275 int clear = req->port_out_stats_read.clear; in pipeline_msg_handle_port_out_stats_read()
2287 struct pipeline_msg_req *req) in pipeline_msg_handle_table_stats_read() argument
2289 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_stats_read()
2290 uint32_t port_id = req->id; in pipeline_msg_handle_table_stats_read()
2291 int clear = req->table_stats_read.clear; in pipeline_msg_handle_table_stats_read()
2713 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_add() argument
2716 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add()
2717 struct table_rule_match *match = &req->table_rule_add.match; in pipeline_msg_handle_table_rule_add()
2718 struct table_rule_action *action = &req->table_rule_add.action; in pipeline_msg_handle_table_rule_add()
2720 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_add()
2760 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_add_default() argument
2762 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add_default()
2763 struct table_rule_action *action = &req->table_rule_add_default.action; in pipeline_msg_handle_table_rule_add_default()
2765 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_add_default()
2797 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_add_bulk() argument
2799 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add_bulk()
2801 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_add_bulk()
2802 struct table_rule_list *list = req->table_rule_add_bulk.list; in pipeline_msg_handle_table_rule_add_bulk()
2803 uint32_t bulk = req->table_rule_add_bulk.bulk; in pipeline_msg_handle_table_rule_add_bulk()
2830 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_delete() argument
2833 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_delete()
2834 struct table_rule_match *match = &req->table_rule_delete.match; in pipeline_msg_handle_table_rule_delete()
2835 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_delete()
2855 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_delete_default() argument
2857 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_delete_default()
2858 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_delete_default()
2869 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_stats_read() argument
2871 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_stats_read()
2872 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_stats_read()
2873 void *data = req->table_rule_stats_read.data; in pipeline_msg_handle_table_rule_stats_read()
2874 int clear = req->table_rule_stats_read.clear; in pipeline_msg_handle_table_rule_stats_read()
2887 struct pipeline_msg_req *req) in pipeline_msg_handle_table_mtr_profile_add() argument
2889 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_mtr_profile_add()
2890 uint32_t table_id = req->id; in pipeline_msg_handle_table_mtr_profile_add()
2891 uint32_t meter_profile_id = req->table_mtr_profile_add.meter_profile_id; in pipeline_msg_handle_table_mtr_profile_add()
2893 &req->table_mtr_profile_add.profile; in pipeline_msg_handle_table_mtr_profile_add()
2905 struct pipeline_msg_req *req) in pipeline_msg_handle_table_mtr_profile_delete() argument
2907 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_mtr_profile_delete()
2908 uint32_t table_id = req->id; in pipeline_msg_handle_table_mtr_profile_delete()
2910 req->table_mtr_profile_delete.meter_profile_id; in pipeline_msg_handle_table_mtr_profile_delete()
2921 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_mtr_read() argument
2923 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_mtr_read()
2924 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_mtr_read()
2925 void *data = req->table_rule_mtr_read.data; in pipeline_msg_handle_table_rule_mtr_read()
2926 uint32_t tc_mask = req->table_rule_mtr_read.tc_mask; in pipeline_msg_handle_table_rule_mtr_read()
2927 int clear = req->table_rule_mtr_read.clear; in pipeline_msg_handle_table_rule_mtr_read()
2941 struct pipeline_msg_req *req) in pipeline_msg_handle_table_dscp_table_update() argument
2943 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_dscp_table_update()
2944 uint32_t table_id = req->id; in pipeline_msg_handle_table_dscp_table_update()
2945 uint64_t dscp_mask = req->table_dscp_table_update.dscp_mask; in pipeline_msg_handle_table_dscp_table_update()
2947 &req->table_dscp_table_update.dscp_table; in pipeline_msg_handle_table_dscp_table_update()
2959 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_ttl_read() argument
2961 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_ttl_read()
2962 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_ttl_read()
2963 void *data = req->table_rule_ttl_read.data; in pipeline_msg_handle_table_rule_ttl_read()
2964 int clear = req->table_rule_ttl_read.clear; in pipeline_msg_handle_table_rule_ttl_read()
2977 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_time_read() argument
2979 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_time_read()
2980 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_time_read()
2981 void *data = req->table_rule_time_read.data; in pipeline_msg_handle_table_rule_time_read()
2995 struct pipeline_msg_req *req; in pipeline_msg_handle() local
2998 req = pipeline_msg_recv(p->msgq_req); in pipeline_msg_handle()
2999 if (req == NULL) in pipeline_msg_handle()
3002 switch (req->type) { in pipeline_msg_handle()
3004 rsp = pipeline_msg_handle_port_in_stats_read(p, req); in pipeline_msg_handle()
3008 rsp = pipeline_msg_handle_port_in_enable(p, req); in pipeline_msg_handle()
3012 rsp = pipeline_msg_handle_port_in_disable(p, req); in pipeline_msg_handle()
3016 rsp = pipeline_msg_handle_port_out_stats_read(p, req); in pipeline_msg_handle()
3020 rsp = pipeline_msg_handle_table_stats_read(p, req); in pipeline_msg_handle()
3024 rsp = pipeline_msg_handle_table_rule_add(p, req); in pipeline_msg_handle()
3028 rsp = pipeline_msg_handle_table_rule_add_default(p, req); in pipeline_msg_handle()
3032 rsp = pipeline_msg_handle_table_rule_add_bulk(p, req); in pipeline_msg_handle()
3036 rsp = pipeline_msg_handle_table_rule_delete(p, req); in pipeline_msg_handle()
3040 rsp = pipeline_msg_handle_table_rule_delete_default(p, req); in pipeline_msg_handle()
3044 rsp = pipeline_msg_handle_table_rule_stats_read(p, req); in pipeline_msg_handle()
3048 rsp = pipeline_msg_handle_table_mtr_profile_add(p, req); in pipeline_msg_handle()
3052 rsp = pipeline_msg_handle_table_mtr_profile_delete(p, req); in pipeline_msg_handle()
3056 rsp = pipeline_msg_handle_table_rule_mtr_read(p, req); in pipeline_msg_handle()
3060 rsp = pipeline_msg_handle_table_dscp_table_update(p, req); in pipeline_msg_handle()
3064 rsp = pipeline_msg_handle_table_rule_ttl_read(p, req); in pipeline_msg_handle()
3068 rsp = pipeline_msg_handle_table_rule_time_read(p, req); in pipeline_msg_handle()
3072 rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle()