MCPcopy Create free account
hub / github.com/apache/qpid-proton / proactor_update_batch

Function proactor_update_batch

c/src/proactor/win_iocp.cpp:3223–3242  ·  view source on GitHub ↗

Call with lock held. Leave unchanged if events pending. Return true if there is an event in the collector

Source from the content-addressed store, hash-verified

3221// Call with lock held. Leave unchanged if events pending.
3222// Return true if there is an event in the collector
3223static bool proactor_update_batch(pn_proactor_t *p) {
3224 if (proactor_has_event(p))
3225 return true;
3226 if (p->need_timeout) {
3227 p->need_timeout = false;
3228 proactor_add_event(p, PN_PROACTOR_TIMEOUT);
3229 return true;
3230 }
3231 if (p->need_interrupt) {
3232 p->need_interrupt = false;
3233 proactor_add_event(p, PN_PROACTOR_INTERRUPT);
3234 return true;
3235 }
3236 if (p->need_inactive) {
3237 p->need_inactive = false;
3238 proactor_add_event(p, PN_PROACTOR_INACTIVE);
3239 return true;
3240 }
3241 return false;
3242}
3243
3244static pn_event_t *proactor_batch_next(pn_event_batch_t *batch) {
3245 pn_proactor_t *p = batch_proactor(batch);

Callers 3

pn_proactor_doneFunction · 0.70
proactor_processFunction · 0.70
proactor_batch_nextFunction · 0.70

Calls 2

proactor_has_eventFunction · 0.70
proactor_add_eventFunction · 0.70

Tested by

no test coverage detected