Lines Matching defs:req
233 struct thread_msg_req *req)
243 status = rte_ring_sp_enqueue(msgq_req, req);
260 struct thread_msg_req *req;
309 req = thread_msg_alloc();
310 if (req == NULL)
314 req->type = THREAD_REQ_PIPELINE_ENABLE;
315 req->pipeline_enable.p = p->p;
317 req->pipeline_enable.table[i].a =
319 req->pipeline_enable.msgq_req = p->msgq_req;
320 req->pipeline_enable.msgq_rsp = p->msgq_rsp;
321 req->pipeline_enable.timer_period_ms = p->timer_period_ms;
322 req->pipeline_enable.n_tables = p->n_tables;
325 rsp = thread_msg_send_recv(thread_id, req);
349 struct thread_msg_req *req;
401 req = thread_msg_alloc();
402 if (req == NULL)
406 req->type = THREAD_REQ_PIPELINE_DISABLE;
407 req->pipeline_disable.p = p->p;
410 rsp = thread_msg_send_recv(thread_id, req);
433 struct thread_msg_req *req = NULL;
435 int status = rte_ring_sc_dequeue(msgq_req, (void **) &req);
440 return req;
456 struct thread_msg_req *req)
458 struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req;
468 t->p[t->n_pipelines] = req->pipeline_enable.p;
470 p->p = req->pipeline_enable.p;
471 for (i = 0; i < req->pipeline_enable.n_tables; i++)
473 req->pipeline_enable.table[i].a;
475 p->n_tables = req->pipeline_enable.n_tables;
477 p->msgq_req = req->pipeline_enable.msgq_req;
478 p->msgq_rsp = req->pipeline_enable.msgq_rsp;
480 (rte_get_tsc_hz() * req->pipeline_enable.timer_period_ms) / 1000;
492 struct thread_msg_req *req)
494 struct thread_msg_rsp *rsp = (struct thread_msg_rsp *) req;
496 struct rte_pipeline *pipeline = req->pipeline_disable.p;
531 struct thread_msg_req *req;
534 req = thread_msg_recv(t->msgq_req);
535 if (req == NULL)
538 switch (req->type) {
540 rsp = thread_msg_handle_pipeline_enable(t, req);
544 rsp = thread_msg_handle_pipeline_disable(t, req);
548 rsp = (struct thread_msg_rsp *) req;
748 struct pipeline_msg_req *req)
757 status = rte_ring_sp_enqueue(msgq_req, req);
775 struct pipeline_msg_req *req;
799 req = pipeline_msg_alloc();
800 if (req == NULL)
804 req->type = PIPELINE_REQ_PORT_IN_STATS_READ;
805 req->id = port_id;
806 req->port_in_stats_read.clear = clear;
809 rsp = pipeline_msg_send_recv(p, req);
827 struct pipeline_msg_req *req;
846 req = pipeline_msg_alloc();
847 if (req == NULL)
851 req->type = PIPELINE_REQ_PORT_IN_ENABLE;
852 req->id = port_id;
855 rsp = pipeline_msg_send_recv(p, req);
871 struct pipeline_msg_req *req;
890 req = pipeline_msg_alloc();
891 if (req == NULL)
895 req->type = PIPELINE_REQ_PORT_IN_DISABLE;
896 req->id = port_id;
899 rsp = pipeline_msg_send_recv(p, req);
917 struct pipeline_msg_req *req;
941 req = pipeline_msg_alloc();
942 if (req == NULL)
946 req->type = PIPELINE_REQ_PORT_OUT_STATS_READ;
947 req->id = port_id;
948 req->port_out_stats_read.clear = clear;
951 rsp = pipeline_msg_send_recv(p, req);
971 struct pipeline_msg_req *req;
995 req = pipeline_msg_alloc();
996 if (req == NULL)
1000 req->type = PIPELINE_REQ_TABLE_STATS_READ;
1001 req->id = table_id;
1002 req->table_stats_read.clear = clear;
1005 rsp = pipeline_msg_send_recv(p, req);
1329 struct pipeline_msg_req *req;
1407 req = pipeline_msg_alloc();
1408 if (req == NULL) {
1414 req->type = PIPELINE_REQ_TABLE_RULE_ADD;
1415 req->id = table_id;
1416 memcpy(&req->table_rule_add.match, match, sizeof(*match));
1417 memcpy(&req->table_rule_add.action, action, sizeof(*action));
1420 rsp = pipeline_msg_send_recv(p, req);
1443 struct pipeline_msg_req *req;
1506 req = pipeline_msg_alloc();
1507 if (req == NULL) {
1513 req->type = PIPELINE_REQ_TABLE_RULE_ADD_DEFAULT;
1514 req->id = table_id;
1515 memcpy(&req->table_rule_add_default.action, action, sizeof(*action));
1518 rsp = pipeline_msg_send_recv(p, req);
1567 struct pipeline_msg_req *req;
1618 req = pipeline_msg_alloc();
1619 if (req == NULL) {
1625 req->type = PIPELINE_REQ_TABLE_RULE_ADD_BULK;
1626 req->id = table_id;
1627 req->table_rule_add_bulk.list = list;
1628 req->table_rule_add_bulk.bulk = table->params.match_type == TABLE_ACL;
1631 rsp = pipeline_msg_send_recv(p, req);
1657 struct pipeline_msg_req *req;
1695 req = pipeline_msg_alloc();
1696 if (req == NULL)
1700 req->type = PIPELINE_REQ_TABLE_RULE_DELETE;
1701 req->id = table_id;
1702 memcpy(&req->table_rule_delete.match, match, sizeof(*match));
1705 rsp = pipeline_msg_send_recv(p, req);
1724 struct pipeline_msg_req *req;
1751 req = pipeline_msg_alloc();
1752 if (req == NULL)
1756 req->type = PIPELINE_REQ_TABLE_RULE_DELETE_DEFAULT;
1757 req->id = table_id;
1760 rsp = pipeline_msg_send_recv(p, req);
1782 struct pipeline_msg_req *req;
1814 req = pipeline_msg_alloc();
1815 if (req == NULL)
1819 req->type = PIPELINE_REQ_TABLE_RULE_STATS_READ;
1820 req->id = table_id;
1821 req->table_rule_stats_read.data = rule->data;
1822 req->table_rule_stats_read.clear = clear;
1825 rsp = pipeline_msg_send_recv(p, req);
1845 struct pipeline_msg_req *req;
1870 req = pipeline_msg_alloc();
1871 if (req == NULL)
1875 req->type = PIPELINE_REQ_TABLE_MTR_PROFILE_ADD;
1876 req->id = table_id;
1877 req->table_mtr_profile_add.meter_profile_id = meter_profile_id;
1878 memcpy(&req->table_mtr_profile_add.profile, profile, sizeof(*profile));
1881 rsp = pipeline_msg_send_recv(p, req);
1898 struct pipeline_msg_req *req;
1921 req = pipeline_msg_alloc();
1922 if (req == NULL)
1926 req->type = PIPELINE_REQ_TABLE_MTR_PROFILE_DELETE;
1927 req->id = table_id;
1928 req->table_mtr_profile_delete.meter_profile_id = meter_profile_id;
1931 rsp = pipeline_msg_send_recv(p, req);
1951 struct pipeline_msg_req *req;
1987 req = pipeline_msg_alloc();
1988 if (req == NULL)
1992 req->type = PIPELINE_REQ_TABLE_RULE_MTR_READ;
1993 req->id = table_id;
1994 req->table_rule_mtr_read.data = rule->data;
1995 req->table_rule_mtr_read.tc_mask = tc_mask;
1996 req->table_rule_mtr_read.clear = clear;
1999 rsp = pipeline_msg_send_recv(p, req);
2019 struct pipeline_msg_req *req;
2044 req = pipeline_msg_alloc();
2045 if (req == NULL)
2049 req->type = PIPELINE_REQ_TABLE_DSCP_TABLE_UPDATE;
2050 req->id = table_id;
2051 req->table_dscp_table_update.dscp_mask = dscp_mask;
2052 memcpy(&req->table_dscp_table_update.dscp_table,
2056 rsp = pipeline_msg_send_recv(p, req);
2076 struct pipeline_msg_req *req;
2111 req = pipeline_msg_alloc();
2112 if (req == NULL)
2116 req->type = PIPELINE_REQ_TABLE_RULE_TTL_READ;
2117 req->id = table_id;
2118 req->table_rule_ttl_read.data = rule->data;
2119 req->table_rule_ttl_read.clear = clear;
2122 rsp = pipeline_msg_send_recv(p, req);
2143 struct pipeline_msg_req *req;
2175 req = pipeline_msg_alloc();
2176 if (req == NULL)
2180 req->type = PIPELINE_REQ_TABLE_RULE_TIME_READ;
2181 req->id = table_id;
2182 req->table_rule_time_read.data = rule->data;
2185 rsp = pipeline_msg_send_recv(p, req);
2204 struct pipeline_msg_req *req;
2206 int status = rte_ring_sc_dequeue(msgq_req, (void **) &req);
2211 return req;
2227 struct pipeline_msg_req *req)
2229 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2230 uint32_t port_id = req->id;
2231 int clear = req->port_in_stats_read.clear;
2243 struct pipeline_msg_req *req)
2245 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2246 uint32_t port_id = req->id;
2256 struct pipeline_msg_req *req)
2258 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2259 uint32_t port_id = req->id;
2269 struct pipeline_msg_req *req)
2271 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2272 uint32_t port_id = req->id;
2273 int clear = req->port_out_stats_read.clear;
2285 struct pipeline_msg_req *req)
2287 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2288 uint32_t port_id = req->id;
2289 int clear = req->table_stats_read.clear;
2706 struct pipeline_msg_req *req)
2709 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2710 struct table_rule_match *match = &req->table_rule_add.match;
2711 struct table_rule_action *action = &req->table_rule_add.action;
2713 uint32_t table_id = req->id;
2753 struct pipeline_msg_req *req)
2755 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2756 struct table_rule_action *action = &req->table_rule_add_default.action;
2758 uint32_t table_id = req->id;
2790 struct pipeline_msg_req *req)
2792 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2794 uint32_t table_id = req->id;
2795 struct table_rule_list *list = req->table_rule_add_bulk.list;
2796 uint32_t bulk = req->table_rule_add_bulk.bulk;
2823 struct pipeline_msg_req *req)
2826 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2827 struct table_rule_match *match = &req->table_rule_delete.match;
2828 uint32_t table_id = req->id;
2848 struct pipeline_msg_req *req)
2850 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2851 uint32_t table_id = req->id;
2862 struct pipeline_msg_req *req)
2864 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2865 uint32_t table_id = req->id;
2866 void *data = req->table_rule_stats_read.data;
2867 int clear = req->table_rule_stats_read.clear;
2880 struct pipeline_msg_req *req)
2882 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2883 uint32_t table_id = req->id;
2884 uint32_t meter_profile_id = req->table_mtr_profile_add.meter_profile_id;
2886 &req->table_mtr_profile_add.profile;
2898 struct pipeline_msg_req *req)
2900 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2901 uint32_t table_id = req->id;
2903 req->table_mtr_profile_delete.meter_profile_id;
2914 struct pipeline_msg_req *req)
2916 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2917 uint32_t table_id = req->id;
2918 void *data = req->table_rule_mtr_read.data;
2919 uint32_t tc_mask = req->table_rule_mtr_read.tc_mask;
2920 int clear = req->table_rule_mtr_read.clear;
2934 struct pipeline_msg_req *req)
2936 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2937 uint32_t table_id = req->id;
2938 uint64_t dscp_mask = req->table_dscp_table_update.dscp_mask;
2940 &req->table_dscp_table_update.dscp_table;
2952 struct pipeline_msg_req *req)
2954 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2955 uint32_t table_id = req->id;
2956 void *data = req->table_rule_ttl_read.data;
2957 int clear = req->table_rule_ttl_read.clear;
2970 struct pipeline_msg_req *req)
2972 struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
2973 uint32_t table_id = req->id;
2974 void *data = req->table_rule_time_read.data;
2988 struct pipeline_msg_req *req;
2991 req = pipeline_msg_recv(p->msgq_req);
2992 if (req == NULL)
2995 switch (req->type) {
2997 rsp = pipeline_msg_handle_port_in_stats_read(p, req);
3001 rsp = pipeline_msg_handle_port_in_enable(p, req);
3005 rsp = pipeline_msg_handle_port_in_disable(p, req);
3009 rsp = pipeline_msg_handle_port_out_stats_read(p, req);
3013 rsp = pipeline_msg_handle_table_stats_read(p, req);
3017 rsp = pipeline_msg_handle_table_rule_add(p, req);
3021 rsp = pipeline_msg_handle_table_rule_add_default(p, req);
3025 rsp = pipeline_msg_handle_table_rule_add_bulk(p, req);
3029 rsp = pipeline_msg_handle_table_rule_delete(p, req);
3033 rsp = pipeline_msg_handle_table_rule_delete_default(p, req);
3037 rsp = pipeline_msg_handle_table_rule_stats_read(p, req);
3041 rsp = pipeline_msg_handle_table_mtr_profile_add(p, req);
3045 rsp = pipeline_msg_handle_table_mtr_profile_delete(p, req);
3049 rsp = pipeline_msg_handle_table_rule_mtr_read(p, req);
3053 rsp = pipeline_msg_handle_table_dscp_table_update(p, req);
3057 rsp = pipeline_msg_handle_table_rule_ttl_read(p, req);
3061 rsp = pipeline_msg_handle_table_rule_time_read(p, req);
3065 rsp = (struct pipeline_msg_rsp *) req;