Searched refs:rd_kafka_buf_skip (Results 1 – 9 of 9) sorted by relevance
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_buf.h | 233 #define rd_kafka_buf_skip(rkbuf, len) do { \ macro 429 rd_kafka_buf_skip(rkbuf, RD_KAFKAP_STR_LEN0(_slen)); \ 511 rd_kafka_buf_skip(rkbuf, (size_t)(_taglen - 1)); \
|
H A D | rdkafka_msgset_reader.c | 803 rd_kafka_buf_skip(rkbuf, (int32_t)(message_end in rd_kafka_msgset_reader_msg_v2() 1048 rd_kafka_buf_skip(rkbuf, payload_size); in rd_kafka_msgset_reader_v2() 1107 rd_kafka_buf_skip(rkbuf, payload_size); in rd_kafka_msgset_reader_v2() 1202 rd_kafka_buf_skip(rkbuf, Length); in rd_kafka_msgset_reader_peek_msg_version()
|
H A D | rdkafka_broker.c | 3999 rd_kafka_buf_skip(rkbuf, in rd_kafka_fetch_reply_handle() 4066 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle() 4103 rd_kafka_buf_skip(rkbuf, in rd_kafka_fetch_reply_handle() 4127 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle() 4157 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle() 4303 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle()
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_msgset_reader.c | 810 rd_kafka_buf_skip(rkbuf, (int32_t)(message_end in rd_kafka_msgset_reader_msg_v2() 987 rd_kafka_buf_skip(msetr->msetr_rkbuf, rd_slice_remains( in rd_kafka_msgset_reader_msgs_v2() 1106 rd_kafka_buf_skip(rkbuf, payload_size); in rd_kafka_msgset_reader_v2() 1228 rd_kafka_buf_skip(rkbuf, Length); in rd_kafka_msgset_reader_peek_msg_version()
|
H A D | rdkafka_buf.h | 489 #define rd_kafka_buf_skip(rkbuf, len) do { \ macro 671 rd_kafka_buf_skip(rkbuf, RD_KAFKAP_STR_LEN0(_slen)); \ 753 rd_kafka_buf_skip(rkbuf, (size_t)(_taglen - 1)); \
|
H A D | rdkafka_broker.c | 4471 rd_kafka_buf_skip(rkbuf, in rd_kafka_fetch_reply_handle() 4539 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle() 4574 rd_kafka_buf_skip(rkbuf, in rd_kafka_fetch_reply_handle() 4598 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle() 4628 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle() 4670 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_msgset_reader.c | 810 rd_kafka_buf_skip(rkbuf, (int32_t)(message_end in rd_kafka_msgset_reader_msg_v2() 987 rd_kafka_buf_skip(msetr->msetr_rkbuf, rd_slice_remains( in rd_kafka_msgset_reader_msgs_v2() 1106 rd_kafka_buf_skip(rkbuf, payload_size); in rd_kafka_msgset_reader_v2() 1228 rd_kafka_buf_skip(rkbuf, Length); in rd_kafka_msgset_reader_peek_msg_version()
|
H A D | rdkafka_buf.h | 436 #define rd_kafka_buf_skip(rkbuf, len) do { \ 618 rd_kafka_buf_skip(rkbuf, RD_KAFKAP_STR_LEN0(_slen)); \ 700 rd_kafka_buf_skip(rkbuf, (size_t)(_taglen - 1)); \
|
H A D | rdkafka_broker.c | 4416 rd_kafka_buf_skip(rkbuf, in rd_kafka_fetch_reply_handle() 4484 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle() 4519 rd_kafka_buf_skip(rkbuf, in rd_kafka_fetch_reply_handle() 4543 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle() 4573 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle() 4615 rd_kafka_buf_skip(rkbuf, hdr.MessageSetSize); in rd_kafka_fetch_reply_handle()
|