| 493 | } |
| 494 | |
| 495 | static void |
| 496 | trigger_async_action(struct pending_request *sr) |
| 497 | { |
| 498 | struct async_request_param *param; |
| 499 | struct rte_mp_reply *reply; |
| 500 | |
| 501 | param = sr->async.param; |
| 502 | reply = ¶m->user_reply; |
| 503 | |
| 504 | param->clb(sr->request, reply); |
| 505 | |
| 506 | /* clean up */ |
| 507 | free(sr->async.param->user_reply.msgs); |
| 508 | free(sr->async.param); |
| 509 | free(sr->request); |
| 510 | free(sr); |
| 511 | } |
| 512 | |
| 513 | static struct pending_request * |
| 514 | async_reply_handle_thread_unsafe(void *arg) |
no test coverage detected