Searched refs:pre_of (Results 1 – 3 of 3) 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_broker.c | 2347 size_t pre_of = rd_slice_offset(&rkbuf->rkbuf_reader); in rd_kafka_send() local 2387 } else if (pre_of > RD_KAFKAP_REQHDR_SIZE) { in rd_kafka_send() 2399 pre_of, rd_slice_size(&rkbuf->rkbuf_reader)); in rd_kafka_send() 2418 (ssize_t)pre_of, r, in rd_kafka_send() 2430 pre_of, rkbuf->rkbuf_corrid); in rd_kafka_send()
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_broker.c | 2592 size_t pre_of = rd_slice_offset(&rkbuf->rkbuf_reader); in rd_kafka_send() local 2667 } else if (pre_of > RD_KAFKAP_REQHDR_SIZE) { in rd_kafka_send() 2679 pre_of, rd_slice_size(&rkbuf->rkbuf_reader)); in rd_kafka_send() 2698 (ssize_t)pre_of, r, in rd_kafka_send() 2710 pre_of, rkbuf->rkbuf_corrid); in rd_kafka_send()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_broker.c | 2579 size_t pre_of = rd_slice_offset(&rkbuf->rkbuf_reader); in rd_kafka_send() local 2619 } else if (pre_of > RD_KAFKAP_REQHDR_SIZE) { in rd_kafka_send() 2631 pre_of, rd_slice_size(&rkbuf->rkbuf_reader)); in rd_kafka_send() 2650 (ssize_t)pre_of, r, in rd_kafka_send() 2662 pre_of, rkbuf->rkbuf_corrid); in rd_kafka_send()
|