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

Method next_sequence

cpp/examples/service_bus.cpp:281–290  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

279 }
280
281 void next_sequence() {
282 switch (sequence_no++) {
283 // run these in order exactly once
284 case 0: snd.run(*container); break;
285 case 1: rcv_green.run(*container); break;
286 case 2: rcv_red.run(*container); break;
287 // Run this until the receiver decides there is no messages left to sequence through
288 default: rcv_null.run(*container); break;
289 }
290 }
291};
292
293sequence *sequence::the_sequence = NULL;

Callers 1

do_next_sequenceFunction · 0.80

Calls 1

runMethod · 0.45

Tested by

no test coverage detected