| 1582 | |
| 1583 | |
| 1584 | static void app_inbytes_advance(pn_transport_t *transport, size_t consumed) |
| 1585 | { |
| 1586 | pni_ssl_t *ssl = transport->ssl; |
| 1587 | if (consumed == 0) { |
| 1588 | // more contiguous bytes required |
| 1589 | app_inbytes_progress(transport, ssl->app_inbytes.size + 1); |
| 1590 | return; |
| 1591 | } |
| 1592 | assert(consumed <= ssl->app_inbytes.size); |
| 1593 | ssl->app_inbytes.start += consumed; |
| 1594 | ssl->app_inbytes.size -= consumed; |
| 1595 | if (!ssl->double_buffered) { |
| 1596 | ssl->in_data += consumed; |
| 1597 | ssl->in_data_count -= consumed; |
| 1598 | } |
| 1599 | if (ssl->app_inbytes.size == 0) |
| 1600 | app_inbytes_progress(transport, 0); |
| 1601 | } |
| 1602 | |
| 1603 | static void read_closed(pn_transport_t *transport, unsigned int layer, ssize_t error) |
| 1604 | { |
no test coverage detected