| 82 | } |
| 83 | |
| 84 | void message_decode(pn_message_t *m, pn_delivery_t *d, pn_rwbytes_t *buf) { |
| 85 | ssize_t size = pn_delivery_pending(d); |
| 86 | rwbytes_ensure(buf, size); |
| 87 | ssize_t result = pn_link_recv(pn_delivery_link(d), buf->start, size); |
| 88 | REQUIRE(size == result); |
| 89 | pn_message_clear(m); |
| 90 | if (pn_message_decode(m, buf->start, size)) FAIL(pn_message_error(m)); |
| 91 | } |
| 92 | |
| 93 | handler::handler() |
| 94 | : last_condition(pn_condition()), connection(), session(), link(), sender(), |
no test coverage detected