]>
Commit | Line | Data |
---|---|---|
7c673cae FG |
1 | /*- |
2 | * BSD LICENSE | |
3 | * | |
4 | * Copyright(c) 2010-2014 Intel Corporation. All rights reserved. | |
5 | * All rights reserved. | |
6 | * | |
7 | * Redistribution and use in source and binary forms, with or without | |
8 | * modification, are permitted provided that the following conditions | |
9 | * are met: | |
10 | * | |
11 | * * Redistributions of source code must retain the above copyright | |
12 | * notice, this list of conditions and the following disclaimer. | |
13 | * * Redistributions in binary form must reproduce the above copyright | |
14 | * notice, this list of conditions and the following disclaimer in | |
15 | * the documentation and/or other materials provided with the | |
16 | * distribution. | |
17 | * * Neither the name of Intel Corporation nor the names of its | |
18 | * contributors may be used to endorse or promote products derived | |
19 | * from this software without specific prior written permission. | |
20 | * | |
21 | * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | |
22 | * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | |
23 | * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | |
24 | * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | |
25 | * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | |
26 | * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | |
27 | * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | |
28 | * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | |
29 | * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | |
30 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | |
31 | * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
32 | */ | |
33 | ||
34 | #include <stdio.h> | |
35 | #include <stdlib.h> | |
36 | #include <string.h> | |
37 | #include <ctype.h> | |
38 | #include <rte_string_fns.h> | |
39 | #include <rte_sched.h> | |
40 | ||
41 | #include "cfg_file.h" | |
42 | #include "main.h" | |
43 | ||
44 | ||
45 | /** when we resize a file structure, how many extra entries | |
46 | * for new sections do we add in */ | |
47 | #define CFG_ALLOC_SECTION_BATCH 8 | |
48 | /** when we resize a section structure, how many extra entries | |
49 | * for new entries do we add in */ | |
50 | #define CFG_ALLOC_ENTRY_BATCH 16 | |
51 | ||
52 | int | |
53 | cfg_load_port(struct rte_cfgfile *cfg, struct rte_sched_port_params *port_params) | |
54 | { | |
55 | const char *entry; | |
56 | int j; | |
57 | ||
58 | if (!cfg || !port_params) | |
59 | return -1; | |
60 | ||
61 | entry = rte_cfgfile_get_entry(cfg, "port", "frame overhead"); | |
62 | if (entry) | |
63 | port_params->frame_overhead = (uint32_t)atoi(entry); | |
64 | ||
65 | entry = rte_cfgfile_get_entry(cfg, "port", "number of subports per port"); | |
66 | if (entry) | |
67 | port_params->n_subports_per_port = (uint32_t)atoi(entry); | |
68 | ||
69 | entry = rte_cfgfile_get_entry(cfg, "port", "number of pipes per subport"); | |
70 | if (entry) | |
71 | port_params->n_pipes_per_subport = (uint32_t)atoi(entry); | |
72 | ||
73 | entry = rte_cfgfile_get_entry(cfg, "port", "queue sizes"); | |
74 | if (entry) { | |
75 | char *next; | |
76 | ||
77 | for(j = 0; j < RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE; j++) { | |
78 | port_params->qsize[j] = (uint16_t)strtol(entry, &next, 10); | |
79 | if (next == NULL) | |
80 | break; | |
81 | entry = next; | |
82 | } | |
83 | } | |
84 | ||
85 | #ifdef RTE_SCHED_RED | |
86 | for (j = 0; j < RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE; j++) { | |
87 | char str[32]; | |
88 | ||
89 | /* Parse WRED min thresholds */ | |
90 | snprintf(str, sizeof(str), "tc %d wred min", j); | |
91 | entry = rte_cfgfile_get_entry(cfg, "red", str); | |
92 | if (entry) { | |
93 | char *next; | |
94 | int k; | |
95 | /* for each packet colour (green, yellow, red) */ | |
96 | for (k = 0; k < e_RTE_METER_COLORS; k++) { | |
97 | port_params->red_params[j][k].min_th | |
98 | = (uint16_t)strtol(entry, &next, 10); | |
99 | if (next == NULL) | |
100 | break; | |
101 | entry = next; | |
102 | } | |
103 | } | |
104 | ||
105 | /* Parse WRED max thresholds */ | |
106 | snprintf(str, sizeof(str), "tc %d wred max", j); | |
107 | entry = rte_cfgfile_get_entry(cfg, "red", str); | |
108 | if (entry) { | |
109 | char *next; | |
110 | int k; | |
111 | /* for each packet colour (green, yellow, red) */ | |
112 | for (k = 0; k < e_RTE_METER_COLORS; k++) { | |
113 | port_params->red_params[j][k].max_th | |
114 | = (uint16_t)strtol(entry, &next, 10); | |
115 | if (next == NULL) | |
116 | break; | |
117 | entry = next; | |
118 | } | |
119 | } | |
120 | ||
121 | /* Parse WRED inverse mark probabilities */ | |
122 | snprintf(str, sizeof(str), "tc %d wred inv prob", j); | |
123 | entry = rte_cfgfile_get_entry(cfg, "red", str); | |
124 | if (entry) { | |
125 | char *next; | |
126 | int k; | |
127 | /* for each packet colour (green, yellow, red) */ | |
128 | for (k = 0; k < e_RTE_METER_COLORS; k++) { | |
129 | port_params->red_params[j][k].maxp_inv | |
130 | = (uint8_t)strtol(entry, &next, 10); | |
131 | ||
132 | if (next == NULL) | |
133 | break; | |
134 | entry = next; | |
135 | } | |
136 | } | |
137 | ||
138 | /* Parse WRED EWMA filter weights */ | |
139 | snprintf(str, sizeof(str), "tc %d wred weight", j); | |
140 | entry = rte_cfgfile_get_entry(cfg, "red", str); | |
141 | if (entry) { | |
142 | char *next; | |
143 | int k; | |
144 | /* for each packet colour (green, yellow, red) */ | |
145 | for (k = 0; k < e_RTE_METER_COLORS; k++) { | |
146 | port_params->red_params[j][k].wq_log2 | |
147 | = (uint8_t)strtol(entry, &next, 10); | |
148 | if (next == NULL) | |
149 | break; | |
150 | entry = next; | |
151 | } | |
152 | } | |
153 | } | |
154 | #endif /* RTE_SCHED_RED */ | |
155 | ||
156 | return 0; | |
157 | } | |
158 | ||
159 | int | |
160 | cfg_load_pipe(struct rte_cfgfile *cfg, struct rte_sched_pipe_params *pipe_params) | |
161 | { | |
162 | int i, j; | |
163 | char *next; | |
164 | const char *entry; | |
165 | int profiles; | |
166 | ||
167 | if (!cfg || !pipe_params) | |
168 | return -1; | |
169 | ||
170 | profiles = rte_cfgfile_num_sections(cfg, "pipe profile", sizeof("pipe profile") - 1); | |
171 | port_params.n_pipe_profiles = profiles; | |
172 | ||
173 | for (j = 0; j < profiles; j++) { | |
174 | char pipe_name[32]; | |
175 | snprintf(pipe_name, sizeof(pipe_name), "pipe profile %d", j); | |
176 | ||
177 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tb rate"); | |
178 | if (entry) | |
179 | pipe_params[j].tb_rate = (uint32_t)atoi(entry); | |
180 | ||
181 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tb size"); | |
182 | if (entry) | |
183 | pipe_params[j].tb_size = (uint32_t)atoi(entry); | |
184 | ||
185 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tc period"); | |
186 | if (entry) | |
187 | pipe_params[j].tc_period = (uint32_t)atoi(entry); | |
188 | ||
189 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tc 0 rate"); | |
190 | if (entry) | |
191 | pipe_params[j].tc_rate[0] = (uint32_t)atoi(entry); | |
192 | ||
193 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tc 1 rate"); | |
194 | if (entry) | |
195 | pipe_params[j].tc_rate[1] = (uint32_t)atoi(entry); | |
196 | ||
197 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tc 2 rate"); | |
198 | if (entry) | |
199 | pipe_params[j].tc_rate[2] = (uint32_t)atoi(entry); | |
200 | ||
201 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tc 3 rate"); | |
202 | if (entry) | |
203 | pipe_params[j].tc_rate[3] = (uint32_t)atoi(entry); | |
204 | ||
205 | #ifdef RTE_SCHED_SUBPORT_TC_OV | |
206 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tc 3 oversubscription weight"); | |
207 | if (entry) | |
208 | pipe_params[j].tc_ov_weight = (uint8_t)atoi(entry); | |
209 | #endif | |
210 | ||
211 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tc 0 wrr weights"); | |
212 | if (entry) { | |
213 | for(i = 0; i < RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS; i++) { | |
214 | pipe_params[j].wrr_weights[RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE*0 + i] = | |
215 | (uint8_t)strtol(entry, &next, 10); | |
216 | if (next == NULL) | |
217 | break; | |
218 | entry = next; | |
219 | } | |
220 | } | |
221 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tc 1 wrr weights"); | |
222 | if (entry) { | |
223 | for(i = 0; i < RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS; i++) { | |
224 | pipe_params[j].wrr_weights[RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE*1 + i] = | |
225 | (uint8_t)strtol(entry, &next, 10); | |
226 | if (next == NULL) | |
227 | break; | |
228 | entry = next; | |
229 | } | |
230 | } | |
231 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tc 2 wrr weights"); | |
232 | if (entry) { | |
233 | for(i = 0; i < RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS; i++) { | |
234 | pipe_params[j].wrr_weights[RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE*2 + i] = | |
235 | (uint8_t)strtol(entry, &next, 10); | |
236 | if (next == NULL) | |
237 | break; | |
238 | entry = next; | |
239 | } | |
240 | } | |
241 | entry = rte_cfgfile_get_entry(cfg, pipe_name, "tc 3 wrr weights"); | |
242 | if (entry) { | |
243 | for(i = 0; i < RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS; i++) { | |
244 | pipe_params[j].wrr_weights[RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE*3 + i] = | |
245 | (uint8_t)strtol(entry, &next, 10); | |
246 | if (next == NULL) | |
247 | break; | |
248 | entry = next; | |
249 | } | |
250 | } | |
251 | } | |
252 | return 0; | |
253 | } | |
254 | ||
255 | int | |
256 | cfg_load_subport(struct rte_cfgfile *cfg, struct rte_sched_subport_params *subport_params) | |
257 | { | |
258 | const char *entry; | |
259 | int i, j, k; | |
260 | ||
261 | if (!cfg || !subport_params) | |
262 | return -1; | |
263 | ||
264 | memset(app_pipe_to_profile, -1, sizeof(app_pipe_to_profile)); | |
265 | ||
266 | for (i = 0; i < MAX_SCHED_SUBPORTS; i++) { | |
267 | char sec_name[CFG_NAME_LEN]; | |
268 | snprintf(sec_name, sizeof(sec_name), "subport %d", i); | |
269 | ||
270 | if (rte_cfgfile_has_section(cfg, sec_name)) { | |
271 | entry = rte_cfgfile_get_entry(cfg, sec_name, "tb rate"); | |
272 | if (entry) | |
273 | subport_params[i].tb_rate = (uint32_t)atoi(entry); | |
274 | ||
275 | entry = rte_cfgfile_get_entry(cfg, sec_name, "tb size"); | |
276 | if (entry) | |
277 | subport_params[i].tb_size = (uint32_t)atoi(entry); | |
278 | ||
279 | entry = rte_cfgfile_get_entry(cfg, sec_name, "tc period"); | |
280 | if (entry) | |
281 | subport_params[i].tc_period = (uint32_t)atoi(entry); | |
282 | ||
283 | entry = rte_cfgfile_get_entry(cfg, sec_name, "tc 0 rate"); | |
284 | if (entry) | |
285 | subport_params[i].tc_rate[0] = (uint32_t)atoi(entry); | |
286 | ||
287 | entry = rte_cfgfile_get_entry(cfg, sec_name, "tc 1 rate"); | |
288 | if (entry) | |
289 | subport_params[i].tc_rate[1] = (uint32_t)atoi(entry); | |
290 | ||
291 | entry = rte_cfgfile_get_entry(cfg, sec_name, "tc 2 rate"); | |
292 | if (entry) | |
293 | subport_params[i].tc_rate[2] = (uint32_t)atoi(entry); | |
294 | ||
295 | entry = rte_cfgfile_get_entry(cfg, sec_name, "tc 3 rate"); | |
296 | if (entry) | |
297 | subport_params[i].tc_rate[3] = (uint32_t)atoi(entry); | |
298 | ||
299 | int n_entries = rte_cfgfile_section_num_entries(cfg, sec_name); | |
300 | struct rte_cfgfile_entry entries[n_entries]; | |
301 | ||
302 | rte_cfgfile_section_entries(cfg, sec_name, entries, n_entries); | |
303 | ||
304 | for (j = 0; j < n_entries; j++) { | |
305 | if (strncmp("pipe", entries[j].name, sizeof("pipe") - 1) == 0) { | |
306 | int profile; | |
307 | char *tokens[2] = {NULL, NULL}; | |
308 | int n_tokens; | |
309 | int begin, end; | |
310 | ||
311 | profile = atoi(entries[j].value); | |
312 | n_tokens = rte_strsplit(&entries[j].name[sizeof("pipe")], | |
313 | strnlen(entries[j].name, CFG_NAME_LEN), tokens, 2, '-'); | |
314 | ||
315 | begin = atoi(tokens[0]); | |
316 | if (n_tokens == 2) | |
317 | end = atoi(tokens[1]); | |
318 | else | |
319 | end = begin; | |
320 | ||
321 | if (end >= MAX_SCHED_PIPES || begin > end) | |
322 | return -1; | |
323 | ||
324 | for (k = begin; k <= end; k++) { | |
325 | char profile_name[CFG_NAME_LEN]; | |
326 | ||
327 | snprintf(profile_name, sizeof(profile_name), | |
328 | "pipe profile %d", profile); | |
329 | if (rte_cfgfile_has_section(cfg, profile_name)) | |
330 | app_pipe_to_profile[i][k] = profile; | |
331 | else | |
332 | rte_exit(EXIT_FAILURE, "Wrong pipe profile %s\n", | |
333 | entries[j].value); | |
334 | ||
335 | } | |
336 | } | |
337 | } | |
338 | } | |
339 | } | |
340 | ||
341 | return 0; | |
342 | } |