2 // Copyright (c) 2010-2017 Intel Corporation
4 // Licensed under the Apache License, Version 2.0 (the "License");
5 // you may not use this file except in compliance with the License.
6 // You may obtain a copy of the License at
8 // http://www.apache.org/licenses/LICENSE-2.0
10 // Unless required by applicable law or agreed to in writing, software
11 // distributed under the License is distributed on an "AS IS" BASIS,
12 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 // See the License for the specific language governing permissions and
14 // limitations under the License.
20 #include <sys/queue.h>
22 #include <rte_common.h>
23 #include <rte_sched.h>
24 #include <rte_ether.h>
25 #include "prox_compat.h"
26 #include "task_base.h"
27 #include "prox_globals.h"
29 #include "flow_iter.h"
30 #include "parse_utils.h"
31 #include "prox_compat.h"
36 #if MAX_RINGS_PER_TASK < PROX_MAX_PORTS
37 #error MAX_RINGS_PER_TASK < PROX_MAX_PORTS
40 #define TASK_ARG_DROP 0x01
41 #define TASK_ARG_RX_RING 0x02
42 #define TASK_ARG_RTE_TABLE 0x08
43 #define TASK_ARG_LOCAL_LPM 0x10
44 #define TASK_ARG_QINQ_ACL 0x20
45 #define TASK_ARG_CTRL_RINGS_P 0x40
46 #define TASK_ARG_DST_MAC_SET 0x80
47 #define TASK_ARG_SRC_MAC_SET 0x100
48 #define TASK_ARG_DO_NOT_SET_SRC_MAC 0x200
49 #define TASK_ARG_DO_NOT_SET_DST_MAC 0x400
50 #define TASK_ARG_HW_SRC_MAC 0x800
51 #define TASK_ARG_L3 0x1000
53 #define PROX_MODE_LEN 32
55 enum protocols {IPV4, ARP, IPV6};
58 struct rte_sched_port_params port_params;
59 struct rte_sched_subport_params subport_params[1];
60 struct rte_sched_pipe_params pipe_params[1];
63 enum task_mode {NOT_SET, MASTER, QINQ_DECAP4, QINQ_DECAP6,
64 QINQ_ENCAP4, QINQ_ENCAP6, GRE_DECAP, GRE_ENCAP,CGNAT, ESP_ENC, ESP_DEC, QOS, POLICE
71 char mode_str[PROX_MODE_LEN];
72 char sub_mode_str[PROX_MODE_LEN];
73 void (*early_init)(struct task_args *targ);
74 void (*init)(struct task_base *tbase, struct task_args *targ);
75 int (*handle)(struct task_base *tbase, struct rte_mbuf **mbufs, const uint16_t n_pkts);
76 void (*start)(struct task_base *tbase);
77 void (*stop)(struct task_base *tbase);
78 void (*start_first)(struct task_base *tbase);
79 void (*stop_last)(struct task_base *tbase);
80 int (*thread_x)(struct lcore_cfg* lconf);
81 struct flow_iter flow_iter;
83 uint16_t flag_req_data; /* flags from prox_shared.h */
84 uint64_t flag_features;
85 LIST_ENTRY(task_init) entries;
88 static int task_init_flag_set(struct task_init *task_init, uint64_t flag)
90 return !!(task_init->flag_features & flag);
94 ACT_GREEN = RTE_COLOR_GREEN,
95 ACT_YELLOW = RTE_COLOR_YELLOW,
96 ACT_RED = RTE_COLOR_RED,
101 /* Configuration for task that is only used during startup. */
103 struct task_base *tbase;
104 struct task_init* task_init;
105 struct rte_mempool *pool;
106 char pool_name[MAX_NAME_SIZE];
107 struct lcore_cfg *lconf;
110 uint32_t nb_cache_mbuf;
111 uint8_t nb_slave_threads;
112 uint8_t nb_worker_threads;
113 uint8_t worker_thread_id;
116 struct core_task_set core_task_set[MAX_PROTOCOLS];
117 struct task_args *prev_tasks[MAX_RINGS_PER_TASK];
118 uint32_t n_prev_tasks;
119 uint32_t ring_size; /* default is RX_RING_SIZE */
120 struct qos_cfg qos_conf;
122 uint32_t runtime_flags;
128 uint32_t byte_offset;
129 uint32_t gateway_ipv4;
131 uint32_t remote_ipv4;
132 uint32_t arp_timeout;
133 uint32_t arp_update_time;
134 struct ipv6_addr local_ipv6; /* For IPv6 Tunnel, it's the local tunnel endpoint address */
135 struct rte_ring *rx_rings[MAX_RINGS_PER_TASK];
136 struct rte_ring *tx_rings[MAX_RINGS_PER_TASK];
137 struct rte_ring *ctrl_plane_ring;
138 uint32_t tot_n_txrings_inited;
139 prox_rte_ether_addr edaddr;
140 prox_rte_ether_addr esaddr;
141 struct port_queue tx_port_queue[PROX_MAX_PORTS];
142 struct port_queue rx_port_queue[PROX_MAX_PORTS];
143 /* Used to set up actual task at initialization time. */
145 /* Destination output position in hw or sw when using mac learned dest port. */
146 uint8_t mapping[PROX_MAX_PORTS];
147 struct rte_table_hash *cpe_table;
148 struct rte_table_hash *qinq_gre_table;
149 struct rte_hash *cpe_gre_hash;
150 struct rte_hash *qinq_gre_hash;
151 struct cpe_data *cpe_data;
152 struct cpe_gre_data *cpe_gre_data;
153 struct qinq_gre_data *qinq_gre_data;
155 struct task_args *tx_opt_ring_task;
158 #ifdef ENABLE_EXTRA_USER_STATISTICS
159 uint32_t n_users; // Number of users in user table.
161 uint32_t n_flows; // Number of flows used in policing
168 enum police_action police_act[3][3];
170 uint32_t n_max_rules;
171 uint32_t random_delay_us;
173 uint32_t cpe_table_timeout_ms;
176 uint32_t tb_rate; /**< Pipe token bucket rate (measured in bytes per second) */
177 uint32_t tb_size; /**< Pipe token bucket size (measured in credits) */
179 uint8_t tunnel_hop_limit; /* IPv6 Tunnel - Hop limit */
180 uint16_t lookup_port_mask; /* Ipv6 Tunnel - Mask applied to UDP/TCP port before lookup */
182 uint8_t lb_friend_core;
183 uint8_t lb_friend_task;
187 char rand_str[64][64];
188 uint32_t rand_offset[64];
194 uint32_t packet_id_pos;
195 uint32_t latency_buffer_size;
196 uint32_t bucket_size;
197 uint32_t lat_enabled;
199 uint8_t pkt_inline[MAX_PKT_SIZE];
200 uint32_t probability;
203 char route_table[256];
206 char tun_bindings[256];
207 char cpe_table_name[256];
208 char user_table[256];
209 uint32_t n_concur_conn;
211 uint32_t min_bulk_size;
212 uint32_t max_bulk_size;
213 uint32_t max_setup_rate;
216 uint32_t flow_table_size;
217 char dpi_engine_path[256];
218 char dpi_engine_args[16][256];
219 uint32_t n_dpi_engine_args;
220 uint32_t generator_id;
221 uint32_t accuracy_limit_nsec;
223 uint32_t public_ip_count;
224 struct public_ip_config_info *public_ip_config_info;
225 struct public_entry *public_entries;
226 struct private_flow_entry *private_flow_entries;
227 struct rte_hash *public_ip_port_hash;
228 struct rte_hash *private_ip_port_hash;
229 struct rte_hash *private_ip_hash;
230 struct private_ip_info *private_ip_info;
231 struct rte_ring **ctrl_rx_rings;
232 struct rte_ring **ctrl_tx_rings;
235 struct task_base *tmaster;
236 char sub_mode_str[PROX_MODE_LEN];
237 uint32_t igmp_address;
240 /* Return the first port that is reachable through the task. If the
241 task itself does not send directly to a port, the function will
242 search reachable tasks through each outgoing ring */
243 struct task_args *find_reachable_task_sending_to_port(struct task_args *from);
244 struct prox_port_cfg *find_reachable_port(struct task_args *from);
246 struct task_base *init_task_struct(struct task_args *targ);
247 struct task_init *to_task_init(const char *mode_str, const char *sub_mode_str);
248 void tasks_list(void);
249 int task_is_master(struct task_args *targ);
251 void reg_task(struct task_init* t);
253 #endif /* _TASK_INIT_H_ */