| 219 | } |
| 220 | |
| 221 | void drain_read_buffer() { |
| 222 | assert(buff_in_use); |
| 223 | send(sockfd, "FOO", 3, 0); |
| 224 | REQUIRE_RUN(p, PN_RAW_CONNECTION_READ); |
| 225 | pn_raw_buffer_t rb = {0}; |
| 226 | REQUIRE(pn_raw_connection_take_read_buffers(server_rc, &rb, 1) == 1); |
| 227 | REQUIRE(rb.size == 3); |
| 228 | buff_in_use = false; |
| 229 | } |
| 230 | |
| 231 | void give_read_buffer() { |
| 232 | assert(!buff_in_use); |
no test coverage detected