| 2497 | } |
| 2498 | |
| 2499 | static pn_event_batch_t *psocket_process(psocket_t *ps, iocp_result_t *result, reaper *rpr) { |
| 2500 | if (ps) { |
| 2501 | pconnection_t *pc = as_pconnection_t(ps); |
| 2502 | if (pc) { |
| 2503 | return pconnection_process(pc, result, false); |
| 2504 | } else { |
| 2505 | pn_listener_t *l = as_listener(ps); |
| 2506 | if (l) |
| 2507 | return listener_process(l, result); |
| 2508 | } |
| 2509 | } |
| 2510 | rpr->process(result); |
| 2511 | return NULL; |
| 2512 | } |
| 2513 | |
| 2514 | static pn_event_batch_t *proactor_completion_loop(struct pn_proactor_t* p, bool can_block) { |
| 2515 | // Proact! Process inbound completions of async activity until one |
no test coverage detected