| 317 | pn_delivery_t *rd = d.server.handler.delivery; |
| 318 | d.server.handler.delivery = NULL; |
| 319 | CHECKED_IF(rd) { |
| 320 | CHECK(pn_delivery_current(rd)); |
| 321 | std::string rbuf(tag.size() * 2, 'x'); |
| 322 | CHECK(ssize_t(tag.size()) == |
| 323 | pn_link_recv(pn_delivery_link(rd), &rbuf[0], rbuf.size())); |
| 324 | rbuf.resize(tag.size()); |
| 325 | CHECK(tag == rbuf); |
| 326 | } |
| 327 | pn_delivery_settle(rd); |
| 328 | } |
| 329 | } |
no test coverage detected