* enqueue until actual queue size reaches target level */
| 299 | * enqueue until actual queue size reaches target level |
| 300 | */ |
| 301 | static int |
| 302 | increase_actual_qsize(struct rte_red_config *red_cfg, |
| 303 | struct rte_red *red, |
| 304 | uint32_t *q, |
| 305 | uint32_t level, |
| 306 | uint32_t attempts) |
| 307 | { |
| 308 | uint32_t i = 0; |
| 309 | |
| 310 | for (i = 0; i < attempts; i++) { |
| 311 | int ret = 0; |
| 312 | |
| 313 | /** |
| 314 | * enqueue |
| 315 | */ |
| 316 | ret = rte_red_enqueue(red_cfg, red, *q, get_port_ts() ); |
| 317 | if (ret == 0) { |
| 318 | if (++(*q) >= level) |
| 319 | break; |
| 320 | } |
| 321 | } |
| 322 | /** |
| 323 | * check if target actual queue size has been reached |
| 324 | */ |
| 325 | if (*q != level) |
| 326 | return -1; |
| 327 | /** |
| 328 | * success |
| 329 | */ |
| 330 | return 0; |
| 331 | } |
| 332 | |
| 333 | /** |
| 334 | * enqueue until average queue size reaches target level |
no test coverage detected