Lines Matching refs:rsp
226 thread_msg_free(struct thread_msg_rsp *rsp) in thread_msg_free() argument
228 free(rsp); in thread_msg_free()
238 struct thread_msg_rsp *rsp; in thread_msg_send_recv() local
248 status = rte_ring_sc_dequeue(msgq_rsp, (void **) &rsp); in thread_msg_send_recv()
251 return rsp; in thread_msg_send_recv()
261 struct thread_msg_rsp *rsp; in thread_pipeline_enable() local
325 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_enable()
328 status = rsp->status; in thread_pipeline_enable()
331 thread_msg_free(rsp); in thread_pipeline_enable()
350 struct thread_msg_rsp *rsp; in thread_pipeline_disable() local
410 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_disable()
413 status = rsp->status; in thread_pipeline_disable()
416 thread_msg_free(rsp); in thread_pipeline_disable()
445 struct thread_msg_rsp *rsp) in thread_msg_send() argument
450 status = rte_ring_sp_enqueue(msgq_rsp, rsp); in thread_msg_send()
458 struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req; in thread_msg_handle_pipeline_enable() local
464 rsp->status = -1; in thread_msg_handle_pipeline_enable()
465 return rsp; in thread_msg_handle_pipeline_enable()
486 rsp->status = 0; in thread_msg_handle_pipeline_enable()
487 return rsp; in thread_msg_handle_pipeline_enable()
494 struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req; in thread_msg_handle_pipeline_disable() local
518 rsp->status = 0; in thread_msg_handle_pipeline_disable()
519 return rsp; in thread_msg_handle_pipeline_disable()
523 rsp->status = 0; in thread_msg_handle_pipeline_disable()
524 return rsp; in thread_msg_handle_pipeline_disable()
532 struct thread_msg_rsp *rsp; in thread_msg_handle() local
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()
549 rsp->status = -1; in thread_msg_handle()
552 thread_msg_send(t->msgq_rsp, rsp); in thread_msg_handle()
743 pipeline_msg_free(struct pipeline_msg_rsp *rsp) in pipeline_msg_free() argument
745 free(rsp); in pipeline_msg_free()
754 struct pipeline_msg_rsp *rsp; in pipeline_msg_send_recv() local
764 status = rte_ring_sc_dequeue(msgq_rsp, (void **) &rsp); in pipeline_msg_send_recv()
767 return rsp; in pipeline_msg_send_recv()
778 struct pipeline_msg_rsp *rsp; in pipeline_port_in_stats_read() local
811 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_stats_read()
814 status = rsp->status; in pipeline_port_in_stats_read()
816 memcpy(stats, &rsp->port_in_stats_read.stats, sizeof(*stats)); in pipeline_port_in_stats_read()
819 pipeline_msg_free(rsp); in pipeline_port_in_stats_read()
830 struct pipeline_msg_rsp *rsp; in pipeline_port_in_enable() local
857 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_enable()
860 status = rsp->status; in pipeline_port_in_enable()
863 pipeline_msg_free(rsp); in pipeline_port_in_enable()
874 struct pipeline_msg_rsp *rsp; in pipeline_port_in_disable() local
901 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_disable()
904 status = rsp->status; in pipeline_port_in_disable()
907 pipeline_msg_free(rsp); in pipeline_port_in_disable()
920 struct pipeline_msg_rsp *rsp; in pipeline_port_out_stats_read() local
953 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_out_stats_read()
956 status = rsp->status; in pipeline_port_out_stats_read()
958 memcpy(stats, &rsp->port_out_stats_read.stats, sizeof(*stats)); in pipeline_port_out_stats_read()
961 pipeline_msg_free(rsp); in pipeline_port_out_stats_read()
974 struct pipeline_msg_rsp *rsp; in pipeline_table_stats_read() local
1007 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_stats_read()
1010 status = rsp->status; in pipeline_table_stats_read()
1012 memcpy(stats, &rsp->table_stats_read.stats, sizeof(*stats)); in pipeline_table_stats_read()
1015 pipeline_msg_free(rsp); in pipeline_table_stats_read()
1332 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_add() local
1422 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add()
1425 status = rsp->status; in pipeline_table_rule_add()
1427 rule->data = rsp->table_rule_add.data; in pipeline_table_rule_add()
1433 pipeline_msg_free(rsp); in pipeline_table_rule_add()
1446 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_add_default() local
1520 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add_default()
1523 status = rsp->status; in pipeline_table_rule_add_default()
1525 rule->data = rsp->table_rule_add_default.data; in pipeline_table_rule_add_default()
1531 pipeline_msg_free(rsp); in pipeline_table_rule_add_default()
1570 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_add_bulk() local
1633 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add_bulk()
1636 status = rsp->status; in pipeline_table_rule_add_bulk()
1638 *n_rules_added = rsp->table_rule_add_bulk.n_rules; in pipeline_table_rule_add_bulk()
1647 pipeline_msg_free(rsp); in pipeline_table_rule_add_bulk()
1660 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_delete() local
1707 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_delete()
1710 status = rsp->status; in pipeline_table_rule_delete()
1715 pipeline_msg_free(rsp); in pipeline_table_rule_delete()
1727 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_delete_default() local
1762 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_delete_default()
1765 status = rsp->status; in pipeline_table_rule_delete_default()
1770 pipeline_msg_free(rsp); in pipeline_table_rule_delete_default()
1785 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_stats_read() local
1827 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_stats_read()
1830 status = rsp->status; in pipeline_table_rule_stats_read()
1832 memcpy(stats, &rsp->table_rule_stats_read.stats, sizeof(*stats)); in pipeline_table_rule_stats_read()
1835 pipeline_msg_free(rsp); in pipeline_table_rule_stats_read()
1848 struct pipeline_msg_rsp *rsp; in pipeline_table_mtr_profile_add() local
1883 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_mtr_profile_add()
1886 status = rsp->status; in pipeline_table_mtr_profile_add()
1889 pipeline_msg_free(rsp); in pipeline_table_mtr_profile_add()
1901 struct pipeline_msg_rsp *rsp; in pipeline_table_mtr_profile_delete() local
1933 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_mtr_profile_delete()
1936 status = rsp->status; in pipeline_table_mtr_profile_delete()
1939 pipeline_msg_free(rsp); in pipeline_table_mtr_profile_delete()
1954 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_mtr_read() local
2001 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_mtr_read()
2004 status = rsp->status; in pipeline_table_rule_mtr_read()
2006 memcpy(stats, &rsp->table_rule_mtr_read.stats, sizeof(*stats)); in pipeline_table_rule_mtr_read()
2009 pipeline_msg_free(rsp); in pipeline_table_rule_mtr_read()
2022 struct pipeline_msg_rsp *rsp; in pipeline_table_dscp_table_update() local
2058 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_dscp_table_update()
2061 status = rsp->status; in pipeline_table_dscp_table_update()
2064 pipeline_msg_free(rsp); in pipeline_table_dscp_table_update()
2079 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_ttl_read() local
2124 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_ttl_read()
2127 status = rsp->status; in pipeline_table_rule_ttl_read()
2129 memcpy(stats, &rsp->table_rule_ttl_read.stats, sizeof(*stats)); in pipeline_table_rule_ttl_read()
2132 pipeline_msg_free(rsp); in pipeline_table_rule_ttl_read()
2146 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_time_read() local
2187 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_time_read()
2190 status = rsp->status; in pipeline_table_rule_time_read()
2192 *timestamp = rsp->table_rule_time_read.timestamp; in pipeline_table_rule_time_read()
2195 pipeline_msg_free(rsp); in pipeline_table_rule_time_read()
2218 struct pipeline_msg_rsp *rsp) in pipeline_msg_send() argument
2223 status = rte_ring_sp_enqueue(msgq_rsp, rsp); in pipeline_msg_send()
2231 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_stats_read() local
2235 rsp->status = rte_pipeline_port_in_stats_read(p->p, in pipeline_msg_handle_port_in_stats_read()
2237 &rsp->port_in_stats_read.stats, in pipeline_msg_handle_port_in_stats_read()
2240 return rsp; in pipeline_msg_handle_port_in_stats_read()
2247 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_enable() local
2250 rsp->status = rte_pipeline_port_in_enable(p->p, in pipeline_msg_handle_port_in_enable()
2253 return rsp; in pipeline_msg_handle_port_in_enable()
2260 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_disable() local
2263 rsp->status = rte_pipeline_port_in_disable(p->p, in pipeline_msg_handle_port_in_disable()
2266 return rsp; in pipeline_msg_handle_port_in_disable()
2273 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_out_stats_read() local
2277 rsp->status = rte_pipeline_port_out_stats_read(p->p, in pipeline_msg_handle_port_out_stats_read()
2279 &rsp->port_out_stats_read.stats, in pipeline_msg_handle_port_out_stats_read()
2282 return rsp; in pipeline_msg_handle_port_out_stats_read()
2289 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_stats_read() local
2293 rsp->status = rte_pipeline_table_stats_read(p->p, in pipeline_msg_handle_table_stats_read()
2295 &rsp->table_stats_read.stats, in pipeline_msg_handle_table_stats_read()
2298 return rsp; in pipeline_msg_handle_table_stats_read()
2716 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add() local
2730 rsp->status = -1; in pipeline_msg_handle_table_rule_add()
2731 return rsp; in pipeline_msg_handle_table_rule_add()
2736 rsp->status = -1; in pipeline_msg_handle_table_rule_add()
2737 return rsp; in pipeline_msg_handle_table_rule_add()
2747 rsp->status = -1; in pipeline_msg_handle_table_rule_add()
2748 return rsp; in pipeline_msg_handle_table_rule_add()
2752 rsp->status = 0; in pipeline_msg_handle_table_rule_add()
2753 rsp->table_rule_add.data = data_out; in pipeline_msg_handle_table_rule_add()
2755 return rsp; in pipeline_msg_handle_table_rule_add()
2762 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add_default() local
2784 rsp->status = -1; in pipeline_msg_handle_table_rule_add_default()
2785 return rsp; in pipeline_msg_handle_table_rule_add_default()
2789 rsp->status = 0; in pipeline_msg_handle_table_rule_add_default()
2790 rsp->table_rule_add_default.data = data_out; in pipeline_msg_handle_table_rule_add_default()
2792 return rsp; in pipeline_msg_handle_table_rule_add_default()
2799 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add_bulk() local
2817 rsp->status = -1; in pipeline_msg_handle_table_rule_add_bulk()
2818 rsp->table_rule_add_bulk.n_rules = 0; in pipeline_msg_handle_table_rule_add_bulk()
2819 return rsp; in pipeline_msg_handle_table_rule_add_bulk()
2823 rsp->status = 0; in pipeline_msg_handle_table_rule_add_bulk()
2824 rsp->table_rule_add_bulk.n_rules = n_rules_added; in pipeline_msg_handle_table_rule_add_bulk()
2825 return rsp; in pipeline_msg_handle_table_rule_add_bulk()
2833 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_delete() local
2840 rsp->status = -1; in pipeline_msg_handle_table_rule_delete()
2841 return rsp; in pipeline_msg_handle_table_rule_delete()
2844 rsp->status = rte_pipeline_table_entry_delete(p->p, in pipeline_msg_handle_table_rule_delete()
2850 return rsp; in pipeline_msg_handle_table_rule_delete()
2857 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_delete_default() local
2860 rsp->status = rte_pipeline_table_default_entry_delete(p->p, in pipeline_msg_handle_table_rule_delete_default()
2864 return rsp; in pipeline_msg_handle_table_rule_delete_default()
2871 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_stats_read() local
2877 rsp->status = rte_table_action_stats_read(a, in pipeline_msg_handle_table_rule_stats_read()
2879 &rsp->table_rule_stats_read.stats, in pipeline_msg_handle_table_rule_stats_read()
2882 return rsp; in pipeline_msg_handle_table_rule_stats_read()
2889 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_mtr_profile_add() local
2896 rsp->status = rte_table_action_meter_profile_add(a, in pipeline_msg_handle_table_mtr_profile_add()
2900 return rsp; in pipeline_msg_handle_table_mtr_profile_add()
2907 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_mtr_profile_delete() local
2913 rsp->status = rte_table_action_meter_profile_delete(a, in pipeline_msg_handle_table_mtr_profile_delete()
2916 return rsp; in pipeline_msg_handle_table_mtr_profile_delete()
2923 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_mtr_read() local
2930 rsp->status = rte_table_action_meter_read(a, in pipeline_msg_handle_table_rule_mtr_read()
2933 &rsp->table_rule_mtr_read.stats, in pipeline_msg_handle_table_rule_mtr_read()
2936 return rsp; in pipeline_msg_handle_table_rule_mtr_read()
2943 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_dscp_table_update() local
2950 rsp->status = rte_table_action_dscp_table_update(a, in pipeline_msg_handle_table_dscp_table_update()
2954 return rsp; in pipeline_msg_handle_table_dscp_table_update()
2961 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_ttl_read() local
2967 rsp->status = rte_table_action_ttl_read(a, in pipeline_msg_handle_table_rule_ttl_read()
2969 &rsp->table_rule_ttl_read.stats, in pipeline_msg_handle_table_rule_ttl_read()
2972 return rsp; in pipeline_msg_handle_table_rule_ttl_read()
2979 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_time_read() local
2984 rsp->status = rte_table_action_time_read(a, in pipeline_msg_handle_table_rule_time_read()
2986 &rsp->table_rule_time_read.timestamp); in pipeline_msg_handle_table_rule_time_read()
2988 return rsp; in pipeline_msg_handle_table_rule_time_read()
2996 struct pipeline_msg_rsp *rsp; in pipeline_msg_handle() local
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()
3073 rsp->status = -1; in pipeline_msg_handle()
3076 pipeline_msg_send(p->msgq_rsp, rsp); in pipeline_msg_handle()