Lines Matching refs:req
235 struct thread_msg_req *req) in thread_msg_send_recv() argument
245 status = rte_ring_sp_enqueue(msgq_req, req); in thread_msg_send_recv()
262 struct thread_msg_req *req; in thread_pipeline_enable() local
311 req = thread_msg_alloc(); in thread_pipeline_enable()
312 if (req == NULL) in thread_pipeline_enable()
316 req->type = THREAD_REQ_PIPELINE_ENABLE; in thread_pipeline_enable()
317 req->pipeline_enable.p = p->p; in thread_pipeline_enable()
319 req->pipeline_enable.table[i].a = in thread_pipeline_enable()
321 req->pipeline_enable.msgq_req = p->msgq_req; in thread_pipeline_enable()
322 req->pipeline_enable.msgq_rsp = p->msgq_rsp; in thread_pipeline_enable()
323 req->pipeline_enable.timer_period_ms = p->timer_period_ms; in thread_pipeline_enable()
324 req->pipeline_enable.n_tables = p->n_tables; in thread_pipeline_enable()
327 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_enable()
351 struct thread_msg_req *req; in thread_pipeline_disable() local
403 req = thread_msg_alloc(); in thread_pipeline_disable()
404 if (req == NULL) in thread_pipeline_disable()
408 req->type = THREAD_REQ_PIPELINE_DISABLE; in thread_pipeline_disable()
409 req->pipeline_disable.p = p->p; in thread_pipeline_disable()
412 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_disable()
435 struct thread_msg_req *req; in thread_msg_recv() local
437 int status = rte_ring_sc_dequeue(msgq_req, (void **) &req); in thread_msg_recv()
442 return req; in thread_msg_recv()
458 struct thread_msg_req *req) in thread_msg_handle_pipeline_enable() argument
460 struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req; in thread_msg_handle_pipeline_enable()
470 t->p[t->n_pipelines] = req->pipeline_enable.p; in thread_msg_handle_pipeline_enable()
472 p->p = req->pipeline_enable.p; in thread_msg_handle_pipeline_enable()
473 for (i = 0; i < req->pipeline_enable.n_tables; i++) in thread_msg_handle_pipeline_enable()
475 req->pipeline_enable.table[i].a; in thread_msg_handle_pipeline_enable()
477 p->n_tables = req->pipeline_enable.n_tables; in thread_msg_handle_pipeline_enable()
479 p->msgq_req = req->pipeline_enable.msgq_req; in thread_msg_handle_pipeline_enable()
480 p->msgq_rsp = req->pipeline_enable.msgq_rsp; in thread_msg_handle_pipeline_enable()
482 (rte_get_tsc_hz() * req->pipeline_enable.timer_period_ms) / 1000; in thread_msg_handle_pipeline_enable()
494 struct thread_msg_req *req) in thread_msg_handle_pipeline_disable() argument
496 struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req; in thread_msg_handle_pipeline_disable()
498 struct rte_pipeline *pipeline = req->pipeline_disable.p; in thread_msg_handle_pipeline_disable()
533 struct thread_msg_req *req; in thread_msg_handle() local
536 req = thread_msg_recv(t->msgq_req); in thread_msg_handle()
537 if (req == NULL) in thread_msg_handle()
540 switch (req->type) { in thread_msg_handle()
542 rsp = thread_msg_handle_pipeline_enable(t, req); in thread_msg_handle()
546 rsp = thread_msg_handle_pipeline_disable(t, req); in thread_msg_handle()
550 rsp = (struct thread_msg_rsp *) req; in thread_msg_handle()
752 struct pipeline_msg_req *req) in pipeline_msg_send_recv() argument
761 status = rte_ring_sp_enqueue(msgq_req, req); in pipeline_msg_send_recv()
779 struct pipeline_msg_req *req; in pipeline_port_in_stats_read() local
803 req = pipeline_msg_alloc(); in pipeline_port_in_stats_read()
804 if (req == NULL) in pipeline_port_in_stats_read()
808 req->type = PIPELINE_REQ_PORT_IN_STATS_READ; in pipeline_port_in_stats_read()
809 req->id = port_id; in pipeline_port_in_stats_read()
810 req->port_in_stats_read.clear = clear; in pipeline_port_in_stats_read()
813 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_stats_read()
831 struct pipeline_msg_req *req; in pipeline_port_in_enable() local
850 req = pipeline_msg_alloc(); in pipeline_port_in_enable()
851 if (req == NULL) in pipeline_port_in_enable()
855 req->type = PIPELINE_REQ_PORT_IN_ENABLE; in pipeline_port_in_enable()
856 req->id = port_id; in pipeline_port_in_enable()
859 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_enable()
875 struct pipeline_msg_req *req; in pipeline_port_in_disable() local
894 req = pipeline_msg_alloc(); in pipeline_port_in_disable()
895 if (req == NULL) in pipeline_port_in_disable()
899 req->type = PIPELINE_REQ_PORT_IN_DISABLE; in pipeline_port_in_disable()
900 req->id = port_id; in pipeline_port_in_disable()
903 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_disable()
921 struct pipeline_msg_req *req; in pipeline_port_out_stats_read() local
945 req = pipeline_msg_alloc(); in pipeline_port_out_stats_read()
946 if (req == NULL) in pipeline_port_out_stats_read()
950 req->type = PIPELINE_REQ_PORT_OUT_STATS_READ; in pipeline_port_out_stats_read()
951 req->id = port_id; in pipeline_port_out_stats_read()
952 req->port_out_stats_read.clear = clear; in pipeline_port_out_stats_read()
955 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_out_stats_read()
975 struct pipeline_msg_req *req; in pipeline_table_stats_read() local
999 req = pipeline_msg_alloc(); in pipeline_table_stats_read()
1000 if (req == NULL) in pipeline_table_stats_read()
1004 req->type = PIPELINE_REQ_TABLE_STATS_READ; in pipeline_table_stats_read()
1005 req->id = table_id; in pipeline_table_stats_read()
1006 req->table_stats_read.clear = clear; in pipeline_table_stats_read()
1009 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_stats_read()
1333 struct pipeline_msg_req *req; in pipeline_table_rule_add() local
1411 req = pipeline_msg_alloc(); in pipeline_table_rule_add()
1412 if (req == NULL) { in pipeline_table_rule_add()
1418 req->type = PIPELINE_REQ_TABLE_RULE_ADD; in pipeline_table_rule_add()
1419 req->id = table_id; in pipeline_table_rule_add()
1420 memcpy(&req->table_rule_add.match, match, sizeof(*match)); in pipeline_table_rule_add()
1421 memcpy(&req->table_rule_add.action, action, sizeof(*action)); in pipeline_table_rule_add()
1424 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add()
1447 struct pipeline_msg_req *req; in pipeline_table_rule_add_default() local
1510 req = pipeline_msg_alloc(); in pipeline_table_rule_add_default()
1511 if (req == NULL) { in pipeline_table_rule_add_default()
1517 req->type = PIPELINE_REQ_TABLE_RULE_ADD_DEFAULT; in pipeline_table_rule_add_default()
1518 req->id = table_id; in pipeline_table_rule_add_default()
1519 memcpy(&req->table_rule_add_default.action, action, sizeof(*action)); in pipeline_table_rule_add_default()
1522 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add_default()
1571 struct pipeline_msg_req *req; in pipeline_table_rule_add_bulk() local
1622 req = pipeline_msg_alloc(); in pipeline_table_rule_add_bulk()
1623 if (req == NULL) { in pipeline_table_rule_add_bulk()
1629 req->type = PIPELINE_REQ_TABLE_RULE_ADD_BULK; in pipeline_table_rule_add_bulk()
1630 req->id = table_id; in pipeline_table_rule_add_bulk()
1631 req->table_rule_add_bulk.list = list; in pipeline_table_rule_add_bulk()
1632 req->table_rule_add_bulk.bulk = table->params.match_type == TABLE_ACL; in pipeline_table_rule_add_bulk()
1635 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add_bulk()
1661 struct pipeline_msg_req *req; in pipeline_table_rule_delete() local
1699 req = pipeline_msg_alloc(); in pipeline_table_rule_delete()
1700 if (req == NULL) in pipeline_table_rule_delete()
1704 req->type = PIPELINE_REQ_TABLE_RULE_DELETE; in pipeline_table_rule_delete()
1705 req->id = table_id; in pipeline_table_rule_delete()
1706 memcpy(&req->table_rule_delete.match, match, sizeof(*match)); in pipeline_table_rule_delete()
1709 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_delete()
1728 struct pipeline_msg_req *req; in pipeline_table_rule_delete_default() local
1755 req = pipeline_msg_alloc(); in pipeline_table_rule_delete_default()
1756 if (req == NULL) in pipeline_table_rule_delete_default()
1760 req->type = PIPELINE_REQ_TABLE_RULE_DELETE_DEFAULT; in pipeline_table_rule_delete_default()
1761 req->id = table_id; in pipeline_table_rule_delete_default()
1764 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_delete_default()
1786 struct pipeline_msg_req *req; in pipeline_table_rule_stats_read() local
1818 req = pipeline_msg_alloc(); in pipeline_table_rule_stats_read()
1819 if (req == NULL) in pipeline_table_rule_stats_read()
1823 req->type = PIPELINE_REQ_TABLE_RULE_STATS_READ; in pipeline_table_rule_stats_read()
1824 req->id = table_id; in pipeline_table_rule_stats_read()
1825 req->table_rule_stats_read.data = rule->data; in pipeline_table_rule_stats_read()
1826 req->table_rule_stats_read.clear = clear; in pipeline_table_rule_stats_read()
1829 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_stats_read()
1849 struct pipeline_msg_req *req; in pipeline_table_mtr_profile_add() local
1874 req = pipeline_msg_alloc(); in pipeline_table_mtr_profile_add()
1875 if (req == NULL) in pipeline_table_mtr_profile_add()
1879 req->type = PIPELINE_REQ_TABLE_MTR_PROFILE_ADD; in pipeline_table_mtr_profile_add()
1880 req->id = table_id; in pipeline_table_mtr_profile_add()
1881 req->table_mtr_profile_add.meter_profile_id = meter_profile_id; in pipeline_table_mtr_profile_add()
1882 memcpy(&req->table_mtr_profile_add.profile, profile, sizeof(*profile)); in pipeline_table_mtr_profile_add()
1885 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_mtr_profile_add()
1902 struct pipeline_msg_req *req; in pipeline_table_mtr_profile_delete() local
1925 req = pipeline_msg_alloc(); in pipeline_table_mtr_profile_delete()
1926 if (req == NULL) in pipeline_table_mtr_profile_delete()
1930 req->type = PIPELINE_REQ_TABLE_MTR_PROFILE_DELETE; in pipeline_table_mtr_profile_delete()
1931 req->id = table_id; in pipeline_table_mtr_profile_delete()
1932 req->table_mtr_profile_delete.meter_profile_id = meter_profile_id; in pipeline_table_mtr_profile_delete()
1935 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_mtr_profile_delete()
1955 struct pipeline_msg_req *req; in pipeline_table_rule_mtr_read() local
1991 req = pipeline_msg_alloc(); in pipeline_table_rule_mtr_read()
1992 if (req == NULL) in pipeline_table_rule_mtr_read()
1996 req->type = PIPELINE_REQ_TABLE_RULE_MTR_READ; in pipeline_table_rule_mtr_read()
1997 req->id = table_id; in pipeline_table_rule_mtr_read()
1998 req->table_rule_mtr_read.data = rule->data; in pipeline_table_rule_mtr_read()
1999 req->table_rule_mtr_read.tc_mask = tc_mask; in pipeline_table_rule_mtr_read()
2000 req->table_rule_mtr_read.clear = clear; in pipeline_table_rule_mtr_read()
2003 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_mtr_read()
2023 struct pipeline_msg_req *req; in pipeline_table_dscp_table_update() local
2048 req = pipeline_msg_alloc(); in pipeline_table_dscp_table_update()
2049 if (req == NULL) in pipeline_table_dscp_table_update()
2053 req->type = PIPELINE_REQ_TABLE_DSCP_TABLE_UPDATE; in pipeline_table_dscp_table_update()
2054 req->id = table_id; in pipeline_table_dscp_table_update()
2055 req->table_dscp_table_update.dscp_mask = dscp_mask; in pipeline_table_dscp_table_update()
2056 memcpy(&req->table_dscp_table_update.dscp_table, in pipeline_table_dscp_table_update()
2060 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_dscp_table_update()
2080 struct pipeline_msg_req *req; in pipeline_table_rule_ttl_read() local
2115 req = pipeline_msg_alloc(); in pipeline_table_rule_ttl_read()
2116 if (req == NULL) in pipeline_table_rule_ttl_read()
2120 req->type = PIPELINE_REQ_TABLE_RULE_TTL_READ; in pipeline_table_rule_ttl_read()
2121 req->id = table_id; in pipeline_table_rule_ttl_read()
2122 req->table_rule_ttl_read.data = rule->data; in pipeline_table_rule_ttl_read()
2123 req->table_rule_ttl_read.clear = clear; in pipeline_table_rule_ttl_read()
2126 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_ttl_read()
2147 struct pipeline_msg_req *req; in pipeline_table_rule_time_read() local
2179 req = pipeline_msg_alloc(); in pipeline_table_rule_time_read()
2180 if (req == NULL) in pipeline_table_rule_time_read()
2184 req->type = PIPELINE_REQ_TABLE_RULE_TIME_READ; in pipeline_table_rule_time_read()
2185 req->id = table_id; in pipeline_table_rule_time_read()
2186 req->table_rule_time_read.data = rule->data; in pipeline_table_rule_time_read()
2189 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_time_read()
2208 struct pipeline_msg_req *req; in pipeline_msg_recv() local
2210 int status = rte_ring_sc_dequeue(msgq_req, (void **) &req); in pipeline_msg_recv()
2215 return req; in pipeline_msg_recv()
2231 struct pipeline_msg_req *req) in pipeline_msg_handle_port_in_stats_read() argument
2233 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_stats_read()
2234 uint32_t port_id = req->id; in pipeline_msg_handle_port_in_stats_read()
2235 int clear = req->port_in_stats_read.clear; in pipeline_msg_handle_port_in_stats_read()
2247 struct pipeline_msg_req *req) in pipeline_msg_handle_port_in_enable() argument
2249 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_enable()
2250 uint32_t port_id = req->id; in pipeline_msg_handle_port_in_enable()
2260 struct pipeline_msg_req *req) in pipeline_msg_handle_port_in_disable() argument
2262 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_disable()
2263 uint32_t port_id = req->id; in pipeline_msg_handle_port_in_disable()
2273 struct pipeline_msg_req *req) in pipeline_msg_handle_port_out_stats_read() argument
2275 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_out_stats_read()
2276 uint32_t port_id = req->id; in pipeline_msg_handle_port_out_stats_read()
2277 int clear = req->port_out_stats_read.clear; in pipeline_msg_handle_port_out_stats_read()
2289 struct pipeline_msg_req *req) in pipeline_msg_handle_table_stats_read() argument
2291 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_stats_read()
2292 uint32_t port_id = req->id; in pipeline_msg_handle_table_stats_read()
2293 int clear = req->table_stats_read.clear; in pipeline_msg_handle_table_stats_read()
2715 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_add() argument
2718 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add()
2719 struct table_rule_match *match = &req->table_rule_add.match; in pipeline_msg_handle_table_rule_add()
2720 struct table_rule_action *action = &req->table_rule_add.action; in pipeline_msg_handle_table_rule_add()
2722 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_add()
2762 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_add_default() argument
2764 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add_default()
2765 struct table_rule_action *action = &req->table_rule_add_default.action; in pipeline_msg_handle_table_rule_add_default()
2767 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_add_default()
2799 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_add_bulk() argument
2801 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add_bulk()
2803 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_add_bulk()
2804 struct table_rule_list *list = req->table_rule_add_bulk.list; in pipeline_msg_handle_table_rule_add_bulk()
2805 uint32_t bulk = req->table_rule_add_bulk.bulk; in pipeline_msg_handle_table_rule_add_bulk()
2832 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_delete() argument
2835 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_delete()
2836 struct table_rule_match *match = &req->table_rule_delete.match; in pipeline_msg_handle_table_rule_delete()
2837 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_delete()
2857 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_delete_default() argument
2859 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_delete_default()
2860 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_delete_default()
2871 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_stats_read() argument
2873 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_stats_read()
2874 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_stats_read()
2875 void *data = req->table_rule_stats_read.data; in pipeline_msg_handle_table_rule_stats_read()
2876 int clear = req->table_rule_stats_read.clear; in pipeline_msg_handle_table_rule_stats_read()
2889 struct pipeline_msg_req *req) in pipeline_msg_handle_table_mtr_profile_add() argument
2891 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_mtr_profile_add()
2892 uint32_t table_id = req->id; in pipeline_msg_handle_table_mtr_profile_add()
2893 uint32_t meter_profile_id = req->table_mtr_profile_add.meter_profile_id; in pipeline_msg_handle_table_mtr_profile_add()
2895 &req->table_mtr_profile_add.profile; in pipeline_msg_handle_table_mtr_profile_add()
2907 struct pipeline_msg_req *req) in pipeline_msg_handle_table_mtr_profile_delete() argument
2909 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_mtr_profile_delete()
2910 uint32_t table_id = req->id; in pipeline_msg_handle_table_mtr_profile_delete()
2912 req->table_mtr_profile_delete.meter_profile_id; in pipeline_msg_handle_table_mtr_profile_delete()
2923 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_mtr_read() argument
2925 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_mtr_read()
2926 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_mtr_read()
2927 void *data = req->table_rule_mtr_read.data; in pipeline_msg_handle_table_rule_mtr_read()
2928 uint32_t tc_mask = req->table_rule_mtr_read.tc_mask; in pipeline_msg_handle_table_rule_mtr_read()
2929 int clear = req->table_rule_mtr_read.clear; in pipeline_msg_handle_table_rule_mtr_read()
2943 struct pipeline_msg_req *req) in pipeline_msg_handle_table_dscp_table_update() argument
2945 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_dscp_table_update()
2946 uint32_t table_id = req->id; in pipeline_msg_handle_table_dscp_table_update()
2947 uint64_t dscp_mask = req->table_dscp_table_update.dscp_mask; in pipeline_msg_handle_table_dscp_table_update()
2949 &req->table_dscp_table_update.dscp_table; in pipeline_msg_handle_table_dscp_table_update()
2961 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_ttl_read() argument
2963 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_ttl_read()
2964 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_ttl_read()
2965 void *data = req->table_rule_ttl_read.data; in pipeline_msg_handle_table_rule_ttl_read()
2966 int clear = req->table_rule_ttl_read.clear; in pipeline_msg_handle_table_rule_ttl_read()
2979 struct pipeline_msg_req *req) in pipeline_msg_handle_table_rule_time_read() argument
2981 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_time_read()
2982 uint32_t table_id = req->id; in pipeline_msg_handle_table_rule_time_read()
2983 void *data = req->table_rule_time_read.data; in pipeline_msg_handle_table_rule_time_read()
2997 struct pipeline_msg_req *req; in pipeline_msg_handle() local
3000 req = pipeline_msg_recv(p->msgq_req); in pipeline_msg_handle()
3001 if (req == NULL) in pipeline_msg_handle()
3004 switch (req->type) { in pipeline_msg_handle()
3006 rsp = pipeline_msg_handle_port_in_stats_read(p, req); in pipeline_msg_handle()
3010 rsp = pipeline_msg_handle_port_in_enable(p, req); in pipeline_msg_handle()
3014 rsp = pipeline_msg_handle_port_in_disable(p, req); in pipeline_msg_handle()
3018 rsp = pipeline_msg_handle_port_out_stats_read(p, req); in pipeline_msg_handle()
3022 rsp = pipeline_msg_handle_table_stats_read(p, req); in pipeline_msg_handle()
3026 rsp = pipeline_msg_handle_table_rule_add(p, req); in pipeline_msg_handle()
3030 rsp = pipeline_msg_handle_table_rule_add_default(p, req); in pipeline_msg_handle()
3034 rsp = pipeline_msg_handle_table_rule_add_bulk(p, req); in pipeline_msg_handle()
3038 rsp = pipeline_msg_handle_table_rule_delete(p, req); in pipeline_msg_handle()
3042 rsp = pipeline_msg_handle_table_rule_delete_default(p, req); in pipeline_msg_handle()
3046 rsp = pipeline_msg_handle_table_rule_stats_read(p, req); in pipeline_msg_handle()
3050 rsp = pipeline_msg_handle_table_mtr_profile_add(p, req); in pipeline_msg_handle()
3054 rsp = pipeline_msg_handle_table_mtr_profile_delete(p, req); in pipeline_msg_handle()
3058 rsp = pipeline_msg_handle_table_rule_mtr_read(p, req); in pipeline_msg_handle()
3062 rsp = pipeline_msg_handle_table_dscp_table_update(p, req); in pipeline_msg_handle()
3066 rsp = pipeline_msg_handle_table_rule_ttl_read(p, req); in pipeline_msg_handle()
3070 rsp = pipeline_msg_handle_table_rule_time_read(p, req); in pipeline_msg_handle()
3074 rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle()