/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_buf.c | 194 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 D | rdkafka_mock.c | 796 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 D | rdkafka_transport.c | 461 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 D | rdkafka_broker.c | 1763 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 D | rdkafka_buf.h | 207 size_t rkbuf_totlen; /* recv: total expected length,
|
H A D | rdkafka_metadata.c | 266 sizeof(*md) + rkb_namelen + (rkbuf->rkbuf_totlen * 4),
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_buf.c | 197 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 D | rdkafka_transport.c | 477 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 D | rdkafka_mock.c | 796 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 D | rdkafka_broker.c | 1776 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 D | rdkafka_buf.h | 249 size_t rkbuf_totlen; /* recv: total expected length, member
|
H A D | rdkafka_metadata.c | 266 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 D | rdkafka_mock.c | 785 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 D | rdkafka_buf.c | 178 rkbuf->rkbuf_totlen = size; in rd_kafka_buf_new_shadow() 307 rkbuf->rkbuf_totlen, rkbuf->rkbuf_corrid, in rd_kafka_bufq_dump()
|
H A D | rdkafka_transport.c | 475 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 D | rdkafka_broker.c | 1559 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 D | rdkafka_buf.h | 585 size_t rkbuf_totlen; /* recv: total expected length, member
|
H A D | rdkafka_metadata.c | 246 sizeof(*md) + rkb_namelen + (rkbuf->rkbuf_totlen * 4), in rd_kafka_parse_Metadata()
|