Searched refs:rd_kafka_buf_update_u32 (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_request.c | 834 rd_kafka_buf_update_u32(rkbuf, of_PartCnt, in rd_kafka_OffsetFetchRequest()
854 rd_kafka_buf_update_u32(rkbuf, of_PartCnt, PartCnt); in rd_kafka_OffsetFetchRequest()
857 rd_kafka_buf_update_u32(rkbuf, of_TopicCnt, TopicCnt); in rd_kafka_OffsetFetchRequest()
1099 rd_kafka_buf_update_u32(rkbuf, of_PartCnt, in rd_kafka_OffsetCommitRequest()
1148 rd_kafka_buf_update_u32(rkbuf, of_PartCnt, PartCnt); in rd_kafka_OffsetCommitRequest()
1151 rd_kafka_buf_update_u32(rkbuf, of_TopicCnt, TopicCnt); in rd_kafka_OffsetCommitRequest()
|
| H A D | rdkafka_buf.h | 941 static RD_INLINE void rd_kafka_buf_update_u32 (rd_kafka_buf_t *rkbuf, in rd_kafka_buf_update_u32() function
|
| H A D | rdkafka_msgset_writer.c | 669 rd_kafka_buf_update_u32(rkbuf, of_Crc, in rd_kafka_msgset_writer_write_msg_v0_1()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_buf.h | 1020 static RD_INLINE void rd_kafka_buf_update_u32 (rd_kafka_buf_t *rkbuf, in rd_kafka_buf_update_u32() function
|
| H A D | rdkafka_request.c | 1318 rd_kafka_buf_update_u32(rkbuf, of_PartCnt, in rd_kafka_OffsetCommitRequest()
1367 rd_kafka_buf_update_u32(rkbuf, of_PartCnt, PartCnt); in rd_kafka_OffsetCommitRequest()
1370 rd_kafka_buf_update_u32(rkbuf, of_TopicCnt, TopicCnt); in rd_kafka_OffsetCommitRequest()
|
| H A D | rdkafka_msgset_writer.c | 670 rd_kafka_buf_update_u32(rkbuf, of_Crc, in rd_kafka_msgset_writer_write_msg_v0_1()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_buf.h | 967 static RD_INLINE void rd_kafka_buf_update_u32 (rd_kafka_buf_t *rkbuf,
|
| H A D | rdkafka_request.c | 1243 rd_kafka_buf_update_u32(rkbuf, of_PartCnt, in rd_kafka_OffsetCommitRequest()
1292 rd_kafka_buf_update_u32(rkbuf, of_PartCnt, PartCnt); in rd_kafka_OffsetCommitRequest()
1295 rd_kafka_buf_update_u32(rkbuf, of_TopicCnt, TopicCnt); in rd_kafka_OffsetCommitRequest()
|
| H A D | rdkafka_msgset_writer.c | 670 rd_kafka_buf_update_u32(rkbuf, of_Crc, in rd_kafka_msgset_writer_write_msg_v0_1()
|