Home
last modified time | relevance | path

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 Drdkafka_buf.h233 #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 Drdkafka_msgset_reader.c803 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 Drdkafka_broker.c3999 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 Drdkafka_msgset_reader.c810 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 Drdkafka_buf.h489 #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 Drdkafka_broker.c4471 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 Drdkafka_msgset_reader.c810 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 Drdkafka_buf.h436 #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 Drdkafka_broker.c4416 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()