| 599 | } |
| 600 | |
| 601 | static inline void |
| 602 | drain_crypto_buffers(struct lcore_conf *qconf) |
| 603 | { |
| 604 | uint32_t i; |
| 605 | struct ipsec_ctx *ctx; |
| 606 | |
| 607 | /* drain inbound buffers*/ |
| 608 | ctx = &qconf->inbound; |
| 609 | for (i = 0; i != ctx->nb_qps; i++) { |
| 610 | if (ctx->tbl[i].len != 0) |
| 611 | enqueue_cop_burst(ctx->tbl + i); |
| 612 | } |
| 613 | |
| 614 | /* drain outbound buffers*/ |
| 615 | ctx = &qconf->outbound; |
| 616 | for (i = 0; i != ctx->nb_qps; i++) { |
| 617 | if (ctx->tbl[i].len != 0) |
| 618 | enqueue_cop_burst(ctx->tbl + i); |
| 619 | } |
| 620 | } |
| 621 | |
| 622 | static void |
| 623 | drain_inbound_crypto_queues(const struct lcore_conf *qconf, |
no test coverage detected