Home
last modified time | relevance | path

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 Drdkafka_broker.c2347 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 Drdkafka_broker.c2592 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 Drdkafka_broker.c2579 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()