Home
last modified time | relevance | path

Searched refs:rkbuf_totlen (Results 1 – 18 of 18) sorted by relevance

/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_buf.c194 rkbuf->rkbuf_totlen = size; in rd_kafka_buf_new_shadow()
323 rkbuf->rkbuf_totlen, rkbuf->rkbuf_corrid, in rd_kafka_bufq_dump()
462 response ? response->rkbuf_totlen : 0, in rd_kafka_buf_callback()
H A Drdkafka_mock.c796 rkbuf->rkbuf_totlen = rkbuf->rkbuf_reqhdr.Size + 4; in rd_kafka_mock_connection_read_request()
798 if (rkbuf->rkbuf_totlen < RD_KAFKAP_REQHDR_SIZE + 2 || in rd_kafka_mock_connection_read_request()
799 rkbuf->rkbuf_totlen > in rd_kafka_mock_connection_read_request()
813 rkbuf->rkbuf_totlen -= RD_KAFKAP_REQHDR_SIZE; in rd_kafka_mock_connection_read_request()
815 if (!rkbuf->rkbuf_totlen) { in rd_kafka_mock_connection_read_request()
824 rkbuf->rkbuf_totlen, in rd_kafka_mock_connection_read_request()
825 rkbuf->rkbuf_totlen); in rd_kafka_mock_connection_read_request()
828 RD_KAFKAP_REQHDR_SIZE == rkbuf->rkbuf_totlen) { in rd_kafka_mock_connection_read_request()
H A Drdkafka_transport.c461 if (rkbuf->rkbuf_totlen == 0) { in rd_kafka_transport_framed_recv()
484 rkbuf->rkbuf_totlen = 4 + frame_len; in rd_kafka_transport_framed_recv()
501 if (rd_buf_write_pos(&rkbuf->rkbuf_buf) == rkbuf->rkbuf_totlen) { in rd_kafka_transport_framed_recv()
H A Drdkafka_broker.c1763 rkbuf->rkbuf_totlen, in rd_kafka_req_response()
1775 rkbuf->rkbuf_totlen, rkbuf->rkbuf_reshdr.CorrId, in rd_kafka_req_response()
1860 if (rkbuf->rkbuf_totlen == 0) { in rd_kafka_recv()
1888 rkbuf->rkbuf_totlen = rkbuf->rkbuf_reshdr.Size; in rd_kafka_recv()
1891 if (rkbuf->rkbuf_totlen < 4/*CorrId*/ || in rd_kafka_recv()
1892 rkbuf->rkbuf_totlen > in rd_kafka_recv()
1904 rkbuf->rkbuf_totlen -= 4; /*CorrId*/ in rd_kafka_recv()
1906 if (rkbuf->rkbuf_totlen > 0) { in rd_kafka_recv()
1912 rkbuf->rkbuf_totlen); in rd_kafka_recv()
1917 rkbuf->rkbuf_totlen) { in rd_kafka_recv()
[all …]
H A Drdkafka_buf.h207 size_t rkbuf_totlen; /* recv: total expected length,
H A Drdkafka_metadata.c266 sizeof(*md) + rkb_namelen + (rkbuf->rkbuf_totlen * 4),
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_buf.c197 rkbuf->rkbuf_totlen = size; in rd_kafka_buf_new_shadow()
326 rkbuf->rkbuf_totlen, rkbuf->rkbuf_corrid, in rd_kafka_bufq_dump()
465 response ? response->rkbuf_totlen : 0, in rd_kafka_buf_callback()
H A Drdkafka_transport.c477 if (rkbuf->rkbuf_totlen == 0) { in rd_kafka_transport_framed_recv()
500 rkbuf->rkbuf_totlen = 4 + frame_len; in rd_kafka_transport_framed_recv()
517 if (rd_buf_write_pos(&rkbuf->rkbuf_buf) == rkbuf->rkbuf_totlen) { in rd_kafka_transport_framed_recv()
H A Drdkafka_mock.c796 rkbuf->rkbuf_totlen = rkbuf->rkbuf_reqhdr.Size + 4; in rd_kafka_mock_connection_read_request()
798 if (rkbuf->rkbuf_totlen < RD_KAFKAP_REQHDR_SIZE + 2 || in rd_kafka_mock_connection_read_request()
799 rkbuf->rkbuf_totlen > in rd_kafka_mock_connection_read_request()
813 rkbuf->rkbuf_totlen -= RD_KAFKAP_REQHDR_SIZE; in rd_kafka_mock_connection_read_request()
815 if (!rkbuf->rkbuf_totlen) { in rd_kafka_mock_connection_read_request()
824 rkbuf->rkbuf_totlen, in rd_kafka_mock_connection_read_request()
825 rkbuf->rkbuf_totlen); in rd_kafka_mock_connection_read_request()
828 RD_KAFKAP_REQHDR_SIZE == rkbuf->rkbuf_totlen) { in rd_kafka_mock_connection_read_request()
H A Drdkafka_broker.c1776 rkbuf->rkbuf_totlen, in rd_kafka_req_response()
1788 rkbuf->rkbuf_totlen, rkbuf->rkbuf_reshdr.CorrId, in rd_kafka_req_response()
1873 if (rkbuf->rkbuf_totlen == 0) { in rd_kafka_recv()
1901 rkbuf->rkbuf_totlen = rkbuf->rkbuf_reshdr.Size; in rd_kafka_recv()
1904 if (rkbuf->rkbuf_totlen < 4/*CorrId*/ || in rd_kafka_recv()
1905 rkbuf->rkbuf_totlen > in rd_kafka_recv()
1917 rkbuf->rkbuf_totlen -= 4; /*CorrId*/ in rd_kafka_recv()
1919 if (rkbuf->rkbuf_totlen > 0) { in rd_kafka_recv()
1925 rkbuf->rkbuf_totlen); in rd_kafka_recv()
1930 rkbuf->rkbuf_totlen) { in rd_kafka_recv()
[all …]
H A Drdkafka_buf.h249 size_t rkbuf_totlen; /* recv: total expected length, member
H A Drdkafka_metadata.c266 sizeof(*md) + rkb_namelen + (rkbuf->rkbuf_totlen * 4), in rd_kafka_parse_Metadata()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_mock.c785 rkbuf->rkbuf_totlen = rkbuf->rkbuf_reqhdr.Size + 4; in rd_kafka_mock_connection_read_request()
787 if (rkbuf->rkbuf_totlen < RD_KAFKAP_REQHDR_SIZE + 2 || in rd_kafka_mock_connection_read_request()
788 rkbuf->rkbuf_totlen > in rd_kafka_mock_connection_read_request()
802 rkbuf->rkbuf_totlen -= RD_KAFKAP_REQHDR_SIZE; in rd_kafka_mock_connection_read_request()
804 if (!rkbuf->rkbuf_totlen) { in rd_kafka_mock_connection_read_request()
813 rkbuf->rkbuf_totlen, in rd_kafka_mock_connection_read_request()
814 rkbuf->rkbuf_totlen); in rd_kafka_mock_connection_read_request()
817 RD_KAFKAP_REQHDR_SIZE == rkbuf->rkbuf_totlen) { in rd_kafka_mock_connection_read_request()
H A Drdkafka_buf.c178 rkbuf->rkbuf_totlen = size; in rd_kafka_buf_new_shadow()
307 rkbuf->rkbuf_totlen, rkbuf->rkbuf_corrid, in rd_kafka_bufq_dump()
H A Drdkafka_transport.c475 if (rkbuf->rkbuf_totlen == 0) { in rd_kafka_transport_framed_recv()
498 rkbuf->rkbuf_totlen = 4 + frame_len; in rd_kafka_transport_framed_recv()
515 if (rd_buf_write_pos(&rkbuf->rkbuf_buf) == rkbuf->rkbuf_totlen) { in rd_kafka_transport_framed_recv()
H A Drdkafka_broker.c1559 rkbuf->rkbuf_totlen, rkbuf->rkbuf_reshdr.CorrId, in rd_kafka_req_response()
1630 if (rkbuf->rkbuf_totlen == 0) { in rd_kafka_recv()
1658 rkbuf->rkbuf_totlen = rkbuf->rkbuf_reshdr.Size; in rd_kafka_recv()
1661 if (rkbuf->rkbuf_totlen < 4/*CorrId*/ || in rd_kafka_recv()
1662 rkbuf->rkbuf_totlen > in rd_kafka_recv()
1674 rkbuf->rkbuf_totlen -= 4; /*CorrId*/ in rd_kafka_recv()
1676 if (rkbuf->rkbuf_totlen > 0) { in rd_kafka_recv()
1682 rkbuf->rkbuf_totlen); in rd_kafka_recv()
1687 rkbuf->rkbuf_totlen) { in rd_kafka_recv()
2363 rkbuf->rkbuf_totlen, in rd_kafka_send()
H A Drdkafka_buf.h585 size_t rkbuf_totlen; /* recv: total expected length, member
H A Drdkafka_metadata.c246 sizeof(*md) + rkb_namelen + (rkbuf->rkbuf_totlen * 4), in rd_kafka_parse_Metadata()