| 1497 | } |
| 1498 | |
| 1499 | static void app_inbytes_add(pn_transport_t *transport) |
| 1500 | { |
| 1501 | pni_ssl_t *ssl = transport->ssl; |
| 1502 | if (!ssl->app_inbytes.start) { |
| 1503 | ssl->app_inbytes.start = ssl->in_data; |
| 1504 | ssl->app_inbytes.size = ssl->in_data_count; |
| 1505 | return; |
| 1506 | } |
| 1507 | |
| 1508 | if (ssl->double_buffered) { |
| 1509 | if (pn_buffer_available(ssl->inbuf2) == 0) { |
| 1510 | if (!grow_inbuf2(transport, 1024)) |
| 1511 | // could not add room |
| 1512 | return; |
| 1513 | } |
| 1514 | size_t count = _pni_min(ssl->in_data_count, pn_buffer_available(ssl->inbuf2)); |
| 1515 | pn_buffer_append(ssl->inbuf2, ssl->in_data, count); |
| 1516 | ssl->in_data += count; |
| 1517 | ssl->in_data_count -= count; |
| 1518 | ssl->app_inbytes = pn_buffer_bytes(ssl->inbuf2); |
| 1519 | } else { |
| 1520 | assert(ssl->app_inbytes.size == 0); |
| 1521 | ssl->app_inbytes.start = ssl->in_data; |
| 1522 | ssl->app_inbytes.size = ssl->in_data_count; |
| 1523 | } |
| 1524 | } |
| 1525 | |
| 1526 | |
| 1527 | static void app_inbytes_progress(pn_transport_t *transport, size_t minimum) |
no test coverage detected