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

Function on_link_local_open

cpp/src/messaging_adapter.cpp:264–273  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

262}
263
264void on_link_local_open(messaging_handler& handler, pn_event_t* event) {
265 pn_link_t* lnk = pn_event_link(event);
266 if ( pn_link_is_receiver(lnk) ) {
267 credit_topup(lnk);
268 // We know local is active so don't check for it
269 } else if ( pn_link_state(lnk)&PN_REMOTE_ACTIVE && pn_link_credit(lnk) > 0) {
270 sender s(make_wrapper<sender>(lnk));
271 handler.on_sendable(s);
272 }
273}
274
275void on_link_remote_open(messaging_handler& handler, pn_event_t* event) {
276 auto lnk = pn_event_link(event);

Callers 1

dispatchMethod · 0.85

Calls 6

pn_event_linkFunction · 0.85
pn_link_is_receiverFunction · 0.85
credit_topupFunction · 0.85
pn_link_stateFunction · 0.85
pn_link_creditFunction · 0.85
on_sendableMethod · 0.45

Tested by

no test coverage detected