| 262 | } |
| 263 | |
| 264 | void 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 | |
| 275 | void on_link_remote_open(messaging_handler& handler, pn_event_t* event) { |
| 276 | auto lnk = pn_event_link(event); |
no test coverage detected