/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_offset.c | 85 else if (offset == RD_KAFKA_OFFSET_INVALID) in rd_kafka_offset2str() 193 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read() 203 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read() 217 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read() 754 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_reset() 770 if (err_offset == RD_KAFKA_OFFSET_INVALID || err) in rd_kafka_offset_reset() 775 if (offset == RD_KAFKA_OFFSET_INVALID) { in rd_kafka_offset_reset() 805 offset == RD_KAFKA_OFFSET_INVALID) in rd_kafka_offset_reset() 898 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_init() 948 if (offset != RD_KAFKA_OFFSET_INVALID) { in rd_kafka_offset_file_init() [all …]
|
H A D | rdkafka_assignment.c | 182 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_apply_offsets() 277 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_handle_OffsetFetch() 296 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_handle_OffsetFetch() 363 rd_kafka_offset_store0(rktp, RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_serve_removals() 451 rktpar->offset == RD_KAFKA_OFFSET_INVALID || in rd_kafka_assignment_serve_pending() 704 rktpar->offset != RD_KAFKA_OFFSET_INVALID && in rd_kafka_assignment_add() 733 if (rktpar->offset == RD_KAFKA_OFFSET_INVALID) in rd_kafka_assignment_add()
|
H A D | rdkafka_partition.c | 239 rktp->rktp_ls_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 240 rktp->rktp_hi_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 241 rktp->rktp_lo_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 242 rktp->rktp_query_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 243 rktp->rktp_next_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 245 rktp->rktp_app_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 246 rktp->rktp_stored_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 1640 } else if (offset == RD_KAFKA_OFFSET_INVALID) { in rd_kafka_toppar_fetch_start() 2211 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_op_serve() 2845 rktpar->offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_topic_partition_list_add0() [all …]
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_offset.c | 87 else if (offset == RD_KAFKA_OFFSET_INVALID) in rd_kafka_offset2str() 195 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read() 205 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read() 219 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read() 759 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_reset() 776 if (err_offset == RD_KAFKA_OFFSET_INVALID || err) in rd_kafka_offset_reset() 781 if (offset == RD_KAFKA_OFFSET_INVALID) { in rd_kafka_offset_reset() 896 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_init() 946 if (offset != RD_KAFKA_OFFSET_INVALID) { in rd_kafka_offset_file_init() 954 rktp->rktp_committed_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_init() [all …]
|
H A D | rdkafka_partition.c | 220 rktp->rktp_ls_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 221 rktp->rktp_hi_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 222 rktp->rktp_lo_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 223 rktp->rktp_query_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 224 rktp->rktp_next_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 226 rktp->rktp_app_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 227 rktp->rktp_stored_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 1607 } else if (offset == RD_KAFKA_OFFSET_INVALID) { in rd_kafka_toppar_fetch_start() 2158 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_op_serve() 2734 rktpar->offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_topic_partition_list_add0() [all …]
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_offset.c | 85 else if (offset == RD_KAFKA_OFFSET_INVALID) 193 return RD_KAFKA_OFFSET_INVALID; 203 return RD_KAFKA_OFFSET_INVALID; 217 return RD_KAFKA_OFFSET_INVALID; 754 int64_t offset = RD_KAFKA_OFFSET_INVALID; 770 if (err_offset == RD_KAFKA_OFFSET_INVALID || err) 775 if (offset == RD_KAFKA_OFFSET_INVALID) { 883 int64_t offset = RD_KAFKA_OFFSET_INVALID; 933 if (offset != RD_KAFKA_OFFSET_INVALID) { 941 rktp->rktp_committed_offset = RD_KAFKA_OFFSET_INVALID; [all …]
|
H A D | rdkafka_assignment.c | 182 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_apply_offsets() 277 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_handle_OffsetFetch() 296 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_handle_OffsetFetch() 363 rd_kafka_offset_store0(rktp, RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_serve_removals() 451 rktpar->offset == RD_KAFKA_OFFSET_INVALID || in rd_kafka_assignment_serve_pending() 704 rktpar->offset != RD_KAFKA_OFFSET_INVALID && in rd_kafka_assignment_add() 733 if (rktpar->offset == RD_KAFKA_OFFSET_INVALID) in rd_kafka_assignment_add()
|
H A D | rdkafka_partition.c | 239 rktp->rktp_ls_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 240 rktp->rktp_hi_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 241 rktp->rktp_lo_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 242 rktp->rktp_query_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 243 rktp->rktp_next_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 245 rktp->rktp_app_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 246 rktp->rktp_stored_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0() 1625 } else if (offset == RD_KAFKA_OFFSET_INVALID) { in rd_kafka_toppar_fetch_start() 2196 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_op_serve() 2830 rktpar->offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_topic_partition_list_add0() [all …]
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0104-fetch_from_follower_mock.c | 90 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset() 154 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset_lag() 219 RD_KAFKA_OFFSET_INVALID); in do_test_unknown_follower() 298 RD_KAFKA_OFFSET_INVALID); in do_test_replica_not_available()
|
H A D | 0020-destroy_hang.c | 113 RD_KAFKA_OFFSET_INVALID) in nonexist_part()
|
H A D | 0029-assign_offset.c | 84 parts->elems[i].offset = RD_KAFKA_OFFSET_INVALID; in rebalance_cb()
|
H A D | 0117-mock_errors.c | 253 RD_KAFKA_OFFSET_INVALID; in do_test_offset_commit_request_timed_out()
|
H A D | 0026-consume_pause.c | 323 toppar->offset = RD_KAFKA_OFFSET_INVALID; in consume_pause_resume_after_reassign()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0104-fetch_from_follower_mock.c | 90 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset() 154 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset_lag() 219 RD_KAFKA_OFFSET_INVALID); in do_test_unknown_follower() 298 RD_KAFKA_OFFSET_INVALID); in do_test_replica_not_available()
|
H A D | 0020-destroy_hang.c | 113 RD_KAFKA_OFFSET_INVALID) in nonexist_part()
|
H A D | 0029-assign_offset.c | 84 parts->elems[i].offset = RD_KAFKA_OFFSET_INVALID;
|
H A D | 0026-consume_pause.c | 323 toppar->offset = RD_KAFKA_OFFSET_INVALID;
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0104-fetch_from_follower_mock.c | 90 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset() 154 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset_lag() 218 RD_KAFKA_OFFSET_INVALID); in do_test_unknown_follower()
|
H A D | 0020-destroy_hang.c | 113 RD_KAFKA_OFFSET_INVALID) in nonexist_part()
|
H A D | 0029-assign_offset.c | 84 parts->elems[i].offset = RD_KAFKA_OFFSET_INVALID; in rebalance_cb()
|
H A D | 0026-consume_pause.c | 323 toppar->offset = RD_KAFKA_OFFSET_INVALID; in consume_pause_resume_after_reassign()
|
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
H A D | TopicImpl.cpp | 44 const int64_t RdKafka::Topic::OFFSET_INVALID = RD_KAFKA_OFFSET_INVALID;
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/ |
H A D | TopicImpl.cpp | 44 const int64_t RdKafka::Topic::OFFSET_INVALID = RD_KAFKA_OFFSET_INVALID;
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/ |
H A D | TopicImpl.cpp | 44 const int64_t RdKafka::Topic::OFFSET_INVALID = RD_KAFKA_OFFSET_INVALID;
|
/dports/net/kcat/kcat-1.7.0/ |
H A D | kcat.c | 72 .offset = RD_KAFKA_OFFSET_INVALID, 724 if (conf.offset != RD_KAFKA_OFFSET_INVALID) in incremental_rebalance_cb() 794 if (conf.offset != RD_KAFKA_OFFSET_INVALID) { in rebalance_cb() 1037 RD_KAFKA_OFFSET_INVALID ? in consumer_run()
|