| 2485 | } |
| 2486 | |
| 2487 | static pn_event_batch_t *proactor_process(pn_proactor_t *p) { |
| 2488 | csguard g(&p->context.cslock); |
| 2489 | proactor_wake_complete(p); |
| 2490 | if (!p->context.working) { /* Can generate proactor events */ |
| 2491 | if (proactor_update_batch(p)) { |
| 2492 | p->context.working = true; |
| 2493 | return &p->batch; |
| 2494 | } |
| 2495 | } |
| 2496 | return NULL; |
| 2497 | } |
| 2498 | |
| 2499 | static pn_event_batch_t *psocket_process(psocket_t *ps, iocp_result_t *result, reaper *rpr) { |
| 2500 | if (ps) { |
no test coverage detected