MCPcopy Create free account
hub / github.com/apache/qpid-proton / app_inbytes_add

Function app_inbytes_add

c/src/ssl/schannel.cpp:1499–1524  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1497}
1498
1499static 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
1527static void app_inbytes_progress(pn_transport_t *transport, size_t minimum)

Callers 1

process_input_sslFunction · 0.85

Calls 5

pn_buffer_availableFunction · 0.85
grow_inbuf2Function · 0.85
_pni_minFunction · 0.85
pn_buffer_appendFunction · 0.85
pn_buffer_bytesFunction · 0.85

Tested by

no test coverage detected