Lines Matching refs:rsp
228 thread_msg_free(struct thread_msg_rsp *rsp) in thread_msg_free() argument
230 free(rsp); in thread_msg_free()
240 struct thread_msg_rsp *rsp; in thread_msg_send_recv() local
250 status = rte_ring_sc_dequeue(msgq_rsp, (void **) &rsp); in thread_msg_send_recv()
253 return rsp; in thread_msg_send_recv()
263 struct thread_msg_rsp *rsp; in thread_pipeline_enable() local
327 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_enable()
330 status = rsp->status; in thread_pipeline_enable()
333 thread_msg_free(rsp); in thread_pipeline_enable()
352 struct thread_msg_rsp *rsp; in thread_pipeline_disable() local
412 rsp = thread_msg_send_recv(thread_id, req); in thread_pipeline_disable()
415 status = rsp->status; in thread_pipeline_disable()
418 thread_msg_free(rsp); in thread_pipeline_disable()
447 struct thread_msg_rsp *rsp) in thread_msg_send() argument
452 status = rte_ring_sp_enqueue(msgq_rsp, rsp); in thread_msg_send()
460 struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req; in thread_msg_handle_pipeline_enable() local
466 rsp->status = -1; in thread_msg_handle_pipeline_enable()
467 return rsp; in thread_msg_handle_pipeline_enable()
488 rsp->status = 0; in thread_msg_handle_pipeline_enable()
489 return rsp; in thread_msg_handle_pipeline_enable()
496 struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req; in thread_msg_handle_pipeline_disable() local
520 rsp->status = 0; in thread_msg_handle_pipeline_disable()
521 return rsp; in thread_msg_handle_pipeline_disable()
525 rsp->status = 0; in thread_msg_handle_pipeline_disable()
526 return rsp; in thread_msg_handle_pipeline_disable()
534 struct thread_msg_rsp *rsp; in thread_msg_handle() local
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()
551 rsp->status = -1; in thread_msg_handle()
554 thread_msg_send(t->msgq_rsp, rsp); in thread_msg_handle()
745 pipeline_msg_free(struct pipeline_msg_rsp *rsp) in pipeline_msg_free() argument
747 free(rsp); in pipeline_msg_free()
756 struct pipeline_msg_rsp *rsp; in pipeline_msg_send_recv() local
766 status = rte_ring_sc_dequeue(msgq_rsp, (void **) &rsp); in pipeline_msg_send_recv()
769 return rsp; in pipeline_msg_send_recv()
780 struct pipeline_msg_rsp *rsp; in pipeline_port_in_stats_read() local
813 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_stats_read()
816 status = rsp->status; in pipeline_port_in_stats_read()
818 memcpy(stats, &rsp->port_in_stats_read.stats, sizeof(*stats)); in pipeline_port_in_stats_read()
821 pipeline_msg_free(rsp); in pipeline_port_in_stats_read()
832 struct pipeline_msg_rsp *rsp; in pipeline_port_in_enable() local
859 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_enable()
862 status = rsp->status; in pipeline_port_in_enable()
865 pipeline_msg_free(rsp); in pipeline_port_in_enable()
876 struct pipeline_msg_rsp *rsp; in pipeline_port_in_disable() local
903 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_in_disable()
906 status = rsp->status; in pipeline_port_in_disable()
909 pipeline_msg_free(rsp); in pipeline_port_in_disable()
922 struct pipeline_msg_rsp *rsp; in pipeline_port_out_stats_read() local
955 rsp = pipeline_msg_send_recv(p, req); in pipeline_port_out_stats_read()
958 status = rsp->status; in pipeline_port_out_stats_read()
960 memcpy(stats, &rsp->port_out_stats_read.stats, sizeof(*stats)); in pipeline_port_out_stats_read()
963 pipeline_msg_free(rsp); in pipeline_port_out_stats_read()
976 struct pipeline_msg_rsp *rsp; in pipeline_table_stats_read() local
1009 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_stats_read()
1012 status = rsp->status; in pipeline_table_stats_read()
1014 memcpy(stats, &rsp->table_stats_read.stats, sizeof(*stats)); in pipeline_table_stats_read()
1017 pipeline_msg_free(rsp); in pipeline_table_stats_read()
1334 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_add() local
1424 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add()
1427 status = rsp->status; in pipeline_table_rule_add()
1429 rule->data = rsp->table_rule_add.data; in pipeline_table_rule_add()
1435 pipeline_msg_free(rsp); in pipeline_table_rule_add()
1448 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_add_default() local
1522 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add_default()
1525 status = rsp->status; in pipeline_table_rule_add_default()
1527 rule->data = rsp->table_rule_add_default.data; in pipeline_table_rule_add_default()
1533 pipeline_msg_free(rsp); in pipeline_table_rule_add_default()
1572 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_add_bulk() local
1635 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_add_bulk()
1638 status = rsp->status; in pipeline_table_rule_add_bulk()
1640 *n_rules_added = rsp->table_rule_add_bulk.n_rules; in pipeline_table_rule_add_bulk()
1649 pipeline_msg_free(rsp); in pipeline_table_rule_add_bulk()
1662 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_delete() local
1709 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_delete()
1712 status = rsp->status; in pipeline_table_rule_delete()
1717 pipeline_msg_free(rsp); in pipeline_table_rule_delete()
1729 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_delete_default() local
1764 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_delete_default()
1767 status = rsp->status; in pipeline_table_rule_delete_default()
1772 pipeline_msg_free(rsp); in pipeline_table_rule_delete_default()
1787 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_stats_read() local
1829 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_stats_read()
1832 status = rsp->status; in pipeline_table_rule_stats_read()
1834 memcpy(stats, &rsp->table_rule_stats_read.stats, sizeof(*stats)); in pipeline_table_rule_stats_read()
1837 pipeline_msg_free(rsp); in pipeline_table_rule_stats_read()
1850 struct pipeline_msg_rsp *rsp; in pipeline_table_mtr_profile_add() local
1885 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_mtr_profile_add()
1888 status = rsp->status; in pipeline_table_mtr_profile_add()
1891 pipeline_msg_free(rsp); in pipeline_table_mtr_profile_add()
1903 struct pipeline_msg_rsp *rsp; in pipeline_table_mtr_profile_delete() local
1935 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_mtr_profile_delete()
1938 status = rsp->status; in pipeline_table_mtr_profile_delete()
1941 pipeline_msg_free(rsp); in pipeline_table_mtr_profile_delete()
1956 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_mtr_read() local
2003 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_mtr_read()
2006 status = rsp->status; in pipeline_table_rule_mtr_read()
2008 memcpy(stats, &rsp->table_rule_mtr_read.stats, sizeof(*stats)); in pipeline_table_rule_mtr_read()
2011 pipeline_msg_free(rsp); in pipeline_table_rule_mtr_read()
2024 struct pipeline_msg_rsp *rsp; in pipeline_table_dscp_table_update() local
2060 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_dscp_table_update()
2063 status = rsp->status; in pipeline_table_dscp_table_update()
2066 pipeline_msg_free(rsp); in pipeline_table_dscp_table_update()
2081 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_ttl_read() local
2126 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_ttl_read()
2129 status = rsp->status; in pipeline_table_rule_ttl_read()
2131 memcpy(stats, &rsp->table_rule_ttl_read.stats, sizeof(*stats)); in pipeline_table_rule_ttl_read()
2134 pipeline_msg_free(rsp); in pipeline_table_rule_ttl_read()
2148 struct pipeline_msg_rsp *rsp; in pipeline_table_rule_time_read() local
2189 rsp = pipeline_msg_send_recv(p, req); in pipeline_table_rule_time_read()
2192 status = rsp->status; in pipeline_table_rule_time_read()
2194 *timestamp = rsp->table_rule_time_read.timestamp; in pipeline_table_rule_time_read()
2197 pipeline_msg_free(rsp); in pipeline_table_rule_time_read()
2220 struct pipeline_msg_rsp *rsp) in pipeline_msg_send() argument
2225 status = rte_ring_sp_enqueue(msgq_rsp, rsp); in pipeline_msg_send()
2233 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_stats_read() local
2237 rsp->status = rte_pipeline_port_in_stats_read(p->p, in pipeline_msg_handle_port_in_stats_read()
2239 &rsp->port_in_stats_read.stats, in pipeline_msg_handle_port_in_stats_read()
2242 return rsp; in pipeline_msg_handle_port_in_stats_read()
2249 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_enable() local
2252 rsp->status = rte_pipeline_port_in_enable(p->p, in pipeline_msg_handle_port_in_enable()
2255 return rsp; in pipeline_msg_handle_port_in_enable()
2262 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_in_disable() local
2265 rsp->status = rte_pipeline_port_in_disable(p->p, in pipeline_msg_handle_port_in_disable()
2268 return rsp; in pipeline_msg_handle_port_in_disable()
2275 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_port_out_stats_read() local
2279 rsp->status = rte_pipeline_port_out_stats_read(p->p, in pipeline_msg_handle_port_out_stats_read()
2281 &rsp->port_out_stats_read.stats, in pipeline_msg_handle_port_out_stats_read()
2284 return rsp; in pipeline_msg_handle_port_out_stats_read()
2291 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_stats_read() local
2295 rsp->status = rte_pipeline_table_stats_read(p->p, in pipeline_msg_handle_table_stats_read()
2297 &rsp->table_stats_read.stats, in pipeline_msg_handle_table_stats_read()
2300 return rsp; in pipeline_msg_handle_table_stats_read()
2718 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add() local
2732 rsp->status = -1; in pipeline_msg_handle_table_rule_add()
2733 return rsp; in pipeline_msg_handle_table_rule_add()
2738 rsp->status = -1; in pipeline_msg_handle_table_rule_add()
2739 return rsp; in pipeline_msg_handle_table_rule_add()
2749 rsp->status = -1; in pipeline_msg_handle_table_rule_add()
2750 return rsp; in pipeline_msg_handle_table_rule_add()
2754 rsp->status = 0; in pipeline_msg_handle_table_rule_add()
2755 rsp->table_rule_add.data = data_out; in pipeline_msg_handle_table_rule_add()
2757 return rsp; in pipeline_msg_handle_table_rule_add()
2764 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add_default() local
2786 rsp->status = -1; in pipeline_msg_handle_table_rule_add_default()
2787 return rsp; in pipeline_msg_handle_table_rule_add_default()
2791 rsp->status = 0; in pipeline_msg_handle_table_rule_add_default()
2792 rsp->table_rule_add_default.data = data_out; in pipeline_msg_handle_table_rule_add_default()
2794 return rsp; in pipeline_msg_handle_table_rule_add_default()
2801 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_add_bulk() local
2819 rsp->status = -1; in pipeline_msg_handle_table_rule_add_bulk()
2820 rsp->table_rule_add_bulk.n_rules = 0; in pipeline_msg_handle_table_rule_add_bulk()
2821 return rsp; in pipeline_msg_handle_table_rule_add_bulk()
2825 rsp->status = 0; in pipeline_msg_handle_table_rule_add_bulk()
2826 rsp->table_rule_add_bulk.n_rules = n_rules_added; in pipeline_msg_handle_table_rule_add_bulk()
2827 return rsp; in pipeline_msg_handle_table_rule_add_bulk()
2835 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_delete() local
2842 rsp->status = -1; in pipeline_msg_handle_table_rule_delete()
2843 return rsp; in pipeline_msg_handle_table_rule_delete()
2846 rsp->status = rte_pipeline_table_entry_delete(p->p, in pipeline_msg_handle_table_rule_delete()
2852 return rsp; in pipeline_msg_handle_table_rule_delete()
2859 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_delete_default() local
2862 rsp->status = rte_pipeline_table_default_entry_delete(p->p, in pipeline_msg_handle_table_rule_delete_default()
2866 return rsp; in pipeline_msg_handle_table_rule_delete_default()
2873 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_stats_read() local
2879 rsp->status = rte_table_action_stats_read(a, in pipeline_msg_handle_table_rule_stats_read()
2881 &rsp->table_rule_stats_read.stats, in pipeline_msg_handle_table_rule_stats_read()
2884 return rsp; in pipeline_msg_handle_table_rule_stats_read()
2891 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_mtr_profile_add() local
2898 rsp->status = rte_table_action_meter_profile_add(a, in pipeline_msg_handle_table_mtr_profile_add()
2902 return rsp; in pipeline_msg_handle_table_mtr_profile_add()
2909 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_mtr_profile_delete() local
2915 rsp->status = rte_table_action_meter_profile_delete(a, in pipeline_msg_handle_table_mtr_profile_delete()
2918 return rsp; in pipeline_msg_handle_table_mtr_profile_delete()
2925 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_mtr_read() local
2932 rsp->status = rte_table_action_meter_read(a, in pipeline_msg_handle_table_rule_mtr_read()
2935 &rsp->table_rule_mtr_read.stats, in pipeline_msg_handle_table_rule_mtr_read()
2938 return rsp; in pipeline_msg_handle_table_rule_mtr_read()
2945 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_dscp_table_update() local
2952 rsp->status = rte_table_action_dscp_table_update(a, in pipeline_msg_handle_table_dscp_table_update()
2956 return rsp; in pipeline_msg_handle_table_dscp_table_update()
2963 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_ttl_read() local
2969 rsp->status = rte_table_action_ttl_read(a, in pipeline_msg_handle_table_rule_ttl_read()
2971 &rsp->table_rule_ttl_read.stats, in pipeline_msg_handle_table_rule_ttl_read()
2974 return rsp; in pipeline_msg_handle_table_rule_ttl_read()
2981 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req; in pipeline_msg_handle_table_rule_time_read() local
2986 rsp->status = rte_table_action_time_read(a, in pipeline_msg_handle_table_rule_time_read()
2988 &rsp->table_rule_time_read.timestamp); in pipeline_msg_handle_table_rule_time_read()
2990 return rsp; in pipeline_msg_handle_table_rule_time_read()
2998 struct pipeline_msg_rsp *rsp; in pipeline_msg_handle() local
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()
3075 rsp->status = -1; in pipeline_msg_handle()
3078 pipeline_msg_send(p->msgq_rsp, rsp); in pipeline_msg_handle()