Searched defs:absof (Results 1 – 3 of 3) sorted by relevance
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_idempotence.c | 220 case RD_KAFKA_IDEMP_STATE_TERM: in rd_buf_write_ensure()
258 errstr, sizeof(errstr)); in rd_buf_write_ensure()
512 * are drained to reset and re-request a new PID. in rd_segment_write_update()
535 "coordinator to bump epoch (currently %s)", in rd_segment_write_update()
599 /* Check right away if the drain could be done. */ in rd_buf_erase()
678 * @brief Mark partition as having a ProduceRequest in-flight. in rd_buf_write_seek()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdbuf.c | 220 size_t absof) { in rd_buf_get_segment_at_offset()
259 size_t absof) { in rd_segment_split()
510 static size_t rd_segment_write_update (rd_segment_t *seg, size_t absof, in rd_segment_write_update()
535 size_t rd_buf_write_update (rd_buf_t *rbuf, size_t absof, in rd_buf_write_update()
598 size_t rd_buf_erase (rd_buf_t *rbuf, size_t absof, size_t size) { in rd_buf_erase()
678 int rd_buf_write_seek (rd_buf_t *rbuf, size_t absof) { in rd_buf_write_seek()
802 size_t absof, size_t size) { in rd_slice_init()
1025 size_t absof = slice->start + offset; in rd_slice_seek() local
1347 #define do_unittest_read_verify(b,absof,len,verify) do { \ argument
1355 do_unittest_read_verify0 (const rd_buf_t *b, size_t absof, size_t len, in do_unittest_read_verify0()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdbuf.c | 220 size_t absof) { in rd_buf_get_segment_at_offset()
259 size_t absof) { in rd_segment_split()
511 static size_t rd_segment_write_update (rd_segment_t *seg, size_t absof, in rd_segment_write_update()
536 size_t rd_buf_write_update (rd_buf_t *rbuf, size_t absof, in rd_buf_write_update()
603 int rd_buf_write_seek (rd_buf_t *rbuf, size_t absof) { in rd_buf_write_seek()
727 size_t absof, size_t size) { in rd_slice_init()
950 size_t absof = slice->start + offset; in rd_slice_seek() local
1272 #define do_unittest_read_verify(b,absof,len,verify) do { \ argument
1280 do_unittest_read_verify0 (const rd_buf_t *b, size_t absof, size_t len, in do_unittest_read_verify0()
|