Merge changes from topic "TST009_benchmark"
[samplevnf.git] / VNFs / DPPD-PROX / defaults.c
1 /*
2 // Copyright (c) 2010-2017 Intel Corporation
3 //
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
7 //
8 //     http://www.apache.org/licenses/LICENSE-2.0
9 //
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.
15 */
16
17 #include <string.h>
18 #include <libgen.h>
19 #include <rte_sched.h>
20 #include <rte_version.h>
21
22 #include "lconf.h"
23 #include "defaults.h"
24 #include "defines.h"
25 #include "prox_cfg.h"
26 #include "prox_port_cfg.h"
27 #include "etypes.h"
28 #include "toeplitz.h"
29 #include "handle_master.h"
30 #include "prox_compat.h"
31
32 #define TEN_GIGABIT     1250000000
33 #define QUEUE_SIZES     128
34 #define NB_PIPES        32768
35 #define NB_MBUF         4096
36 #define RING_RX_SIZE    256
37 #define NB_RX_RING_DESC 2048
38 #define NB_TX_RING_DESC 2048
39
40 /* 1500000 milliseconds */
41 #define DEFAULT_CPE_TIMEOUT_MS    1500000
42
43 /**/
44 #if DEFAULT_CPE_TIMEOUT_MS < (DRAIN_TIMEOUT/3000000)
45 #error DEFAULT_CPE_TIMEOUT_MS too small (needs to be at least 2 ms)
46 #endif
47
48 static const struct rte_eth_conf default_port_conf = {
49         .rxmode = {
50                 .mq_mode        = 0,
51                 .max_rx_pkt_len = PROX_MTU + PROX_RTE_ETHER_HDR_LEN + PROX_RTE_ETHER_CRC_LEN
52         },
53         .rx_adv_conf = {
54                 .rss_conf = {
55                         .rss_key = NULL,
56                 },
57         },
58         .intr_conf = {
59                 .lsc = 1, /* lsc interrupt feature enabled */
60         },
61 };
62
63 static const struct rte_eth_rxconf default_rx_conf = {
64         .rx_free_thresh = 32,
65 };
66
67 static struct rte_eth_txconf default_tx_conf = {
68         .tx_thresh = {
69                 .pthresh = 32,
70                 .hthresh = 8,
71                 .wthresh = 0,
72         },
73         .tx_free_thresh = 32, /* Use PMD default values */
74         .tx_rs_thresh = 32, /* Use PMD default values */
75 };
76
77 static struct rte_sched_port_params port_params_default = {
78         .name = "port_0",
79         .socket = 0,
80         .mtu = 6 + 6 + 4 + 4 + 2 + 1500,
81         .rate = 0,
82         .frame_overhead = RTE_SCHED_FRAME_OVERHEAD_DEFAULT,
83         .n_subports_per_port = 1,
84         .n_pipes_per_subport = NB_PIPES,
85         .qsize = {QUEUE_SIZES, QUEUE_SIZES, QUEUE_SIZES, QUEUE_SIZES},
86         .pipe_profiles = NULL,
87         .n_pipe_profiles = 1 /* only one profile */
88 };
89
90 static struct rte_sched_pipe_params pipe_params_default = {
91         .tb_rate = TEN_GIGABIT / NB_PIPES,
92         .tb_size = 4000000,
93
94         .tc_rate = {TEN_GIGABIT / NB_PIPES, TEN_GIGABIT / NB_PIPES, TEN_GIGABIT / NB_PIPES, TEN_GIGABIT / NB_PIPES},
95         .tc_period = 40,
96
97 #if RTE_VERSION >= RTE_VERSION_NUM(19,8,0,0)
98         .wrr_weights = {1, 1, 1, 1},
99 #else
100         .wrr_weights = {1, 1, 1, 1,  1, 1, 1, 1,  1, 1, 1, 1,  1, 1, 1, 1},
101 #endif
102 };
103
104 static struct rte_sched_subport_params subport_params_default = {
105         .tb_rate = TEN_GIGABIT,
106         .tb_size = 4000000,
107         .tc_rate = {TEN_GIGABIT, TEN_GIGABIT, TEN_GIGABIT, TEN_GIGABIT},
108         .tc_period = 40, /* default was 10 */
109 };
110
111 void set_global_defaults(__attribute__((unused)) struct prox_cfg *prox_cfg)
112 {
113 }
114
115 void set_task_defaults(struct prox_cfg* prox_cfg, struct lcore_cfg* lcore_cfg_init)
116 {
117         prox_cfg->master = RTE_MAX_LCORE;
118         handle_ctrl_plane = NULL;
119
120         for (uint32_t i = 0; i < RTE_DIM(prox_cfg->cpe_table_ports); ++i) {
121                 prox_cfg->cpe_table_ports[i] = -1;
122         }
123
124         for (uint8_t lcore_id = 0; lcore_id < RTE_MAX_LCORE; ++lcore_id) {
125                 struct lcore_cfg *cur_lcore_cfg_init = &lcore_cfg_init[lcore_id];
126                 cur_lcore_cfg_init->id = lcore_id;
127                 for (uint8_t task_id = 0; task_id < MAX_TASKS_PER_CORE; ++task_id) {
128                         struct task_args *targ = &cur_lcore_cfg_init->targs[task_id];
129                         for (uint8_t port_id = 0; port_id < PROX_MAX_PORTS; ++port_id) {
130                                 targ->rx_port_queue[port_id].port = OUT_DISCARD;
131                         }
132                         targ->flags |= TASK_ARG_DROP;
133                         targ->flags |= TASK_ARG_QINQ_ACL;
134                         targ->cpe_table_timeout_ms = DEFAULT_CPE_TIMEOUT_MS;
135                         targ->n_flows = NB_PIPES;
136                         /* configure default values for QoS (can be overwritten by config) */
137                         targ->qos_conf.port_params = port_params_default;
138                         targ->qos_conf.pipe_params[0] = pipe_params_default;
139                         targ->qos_conf.subport_params[0] = subport_params_default;
140                         targ->qos_conf.port_params.pipe_profiles = targ->qos_conf.pipe_params;
141                         targ->qos_conf.port_params.rate = TEN_GIGABIT;
142                         targ->qinq_tag = ETYPE_8021ad;
143                         targ->n_concur_conn = 8192*2;
144
145                         for (uint8_t port_id = 0; port_id < PROX_MAX_PORTS; ++port_id) {
146                                 targ->tx_port_queue[port_id].port = OUT_DISCARD;
147                         }
148
149                         for (uint8_t i = 0; i < PROX_MAX_PORTS; ++i) {
150                                 targ->mapping[i] = i; // identity
151                         }
152
153                         targ->cbs = PROX_RTE_ETHER_MAX_LEN;
154                         targ->ebs = PROX_RTE_ETHER_MAX_LEN;
155                         targ->pbs = PROX_RTE_ETHER_MAX_LEN;
156
157                         targ->n_max_rules = 1024;
158                         targ->ring_size = RING_RX_SIZE;
159                         targ->nb_cache_mbuf = MAX_PKT_BURST * 4;
160                         targ->overhead = PROX_RTE_ETHER_CRC_LEN + 20;
161
162                         targ->tunnel_hop_limit = 3;
163                         targ->ctrl_freq = 1000;
164                         targ->lb_friend_core = 0xFF;
165                         targ->n_pkts = 0;
166
167                         targ->runtime_flags |= TASK_TX_CRC;
168                         targ->accuracy_limit_nsec = 5000;
169                 }
170         }
171 }
172
173 void set_port_defaults(void)
174 {
175         for (uint8_t i = 0; i < PROX_MAX_PORTS; ++i ) {
176                 prox_port_cfg[i].promiscuous = 1;
177                 prox_port_cfg[i].nb_mc_addr = 0;
178                 prox_port_cfg[i].n_rxd = NB_RX_RING_DESC;
179                 prox_port_cfg[i].n_txd = NB_TX_RING_DESC;
180                 prox_port_cfg[i].port_conf = default_port_conf;
181                 prox_port_cfg[i].tx_conf = default_tx_conf;
182                 prox_port_cfg[i].rx_conf = default_rx_conf;
183                 prox_port_cfg[i].rx_ring[0] = '\0';
184                 prox_port_cfg[i].tx_ring[0] = '\0';
185                 prox_port_cfg[i].mtu = PROX_MTU;
186
187                 // CRC_STRIP becoming the default behavior in DPDK 18.08, and
188                 // DEV_RX_OFFLOAD_CRC_STRIP define has been deleted
189 #if defined (DEV_RX_OFFLOAD_CRC_STRIP)
190                 prox_port_cfg[i].requested_rx_offload = DEV_RX_OFFLOAD_CRC_STRIP;
191 #endif
192                 prox_port_cfg[i].requested_tx_offload = DEV_TX_OFFLOAD_IPV4_CKSUM | DEV_TX_OFFLOAD_UDP_CKSUM;
193         }
194 }