| 75 | } |
| 76 | |
| 77 | void rwbytes_ensure(pn_rwbytes_t *buf, size_t size) { |
| 78 | if (buf->start == NULL || buf->size < size) { |
| 79 | buf->start = (char *)realloc(buf->start, size); |
| 80 | buf->size = size; |
| 81 | } |
| 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); |
no outgoing calls
no test coverage detected