60 rd_kafka_toppar_version_new_barrier0 (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_version_new_barrier0()
70 #define rd_kafka_toppar_version_new_barrier(rktp) \  argument
84         rd_kafka_toppar_t *rktp = opaque;  in rd_kafka_toppar_lag_handle_Offset()  local
126 static void rd_kafka_toppar_consumer_lag_req (rd_kafka_toppar_t *rktp) {  in rd_kafka_toppar_consumer_lag_req()
185 	rd_kafka_toppar_t *rktp = arg;  in rd_kafka_toppar_consumer_lag_tmr_cb()  local
197 void rd_kafka_toppar_op_version_bump (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_op_version_bump()
217 	rd_kafka_toppar_t *rktp;  in rd_kafka_toppar_new0()  local
305 static void rd_kafka_toppar_remove (rd_kafka_toppar_t *rktp) {  in rd_kafka_toppar_remove()
323 void rd_kafka_toppar_destroy_final (rd_kafka_toppar_t *rktp) {  in rd_kafka_toppar_destroy_final()
361 void rd_kafka_toppar_set_fetch_state (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_set_fetch_state()
405         rd_kafka_toppar_t *rktp;  in rd_kafka_toppar_get0()  local
434         rd_kafka_toppar_t *rktp;  in rd_kafka_toppar_get2()  local
477 	rd_kafka_toppar_t *rktp;  in rd_kafka_toppar_get_avail()  local
555 	rd_kafka_toppar_t *rktp;  in rd_kafka_toppar_desired_get()  local
572 void rd_kafka_toppar_desired_link (rd_kafka_toppar_t *rktp) {  in rd_kafka_toppar_desired_link()
588 void rd_kafka_toppar_desired_unlink (rd_kafka_toppar_t *rktp) {  in rd_kafka_toppar_desired_unlink()
606 void rd_kafka_toppar_desired_add0 (rd_kafka_toppar_t *rktp) {  in rd_kafka_toppar_desired_add0()
637         rd_kafka_toppar_t *rktp;  in rd_kafka_toppar_desired_add()  local
662 void rd_kafka_toppar_desired_del (rd_kafka_toppar_t *rktp) {  in rd_kafka_toppar_desired_del()
686 void rd_kafka_toppar_enq_msg (rd_kafka_toppar_t *rktp, rd_kafka_msg_t *rkm) {  in rd_kafka_toppar_enq_msg()
941 int rd_kafka_toppar_retry_msgq (rd_kafka_toppar_t *rktp, rd_kafka_msgq_t *rkmq,  in rd_kafka_toppar_retry_msgq()
965 void rd_kafka_toppar_insert_msgq (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_insert_msgq()
979 void rd_kafka_toppar_purge_and_disable_queues (rd_kafka_toppar_t *rktp) {  in rd_kafka_toppar_purge_and_disable_queues()
995 static void rd_kafka_toppar_broker_migrate (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_broker_migrate()
1060 void rd_kafka_toppar_broker_leave_for_remove (rd_kafka_toppar_t *rktp) {  in rd_kafka_toppar_broker_leave_for_remove()
1108 void rd_kafka_toppar_broker_delegate (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_broker_delegate()
1181 rd_kafka_toppar_offset_commit_result (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_offset_commit_result()
1223 void rd_kafka_toppar_next_offset_handle (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_next_offset_handle()
1281 void rd_kafka_toppar_offset_fetch (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_offset_fetch()
1326         rd_kafka_toppar_t *rktp = opaque;  in rd_kafka_toppar_handle_Offset()  local
1455 static void rd_kafka_toppar_offset_retry (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_offset_retry()
1500 void rd_kafka_toppar_offset_request (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_offset_request()
1583 static void rd_kafka_toppar_fetch_start (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_fetch_start()
1670 void rd_kafka_toppar_fetch_stopped (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_fetch_stopped()
1703 void rd_kafka_toppar_fetch_stop (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_fetch_stop()
1748 void rd_kafka_toppar_seek (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_seek()
1821 static void rd_kafka_toppar_pause_resume (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_pause_resume()
1949 rd_ts_t rd_kafka_toppar_fetch_decide (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_fetch_decide()
2114                                                rd_kafka_toppar_t *rktp) {  in rd_kafka_broker_consumer_toppar_serve()
2134 	rd_kafka_toppar_t *rktp = NULL;  in rd_kafka_toppar_op_serve()  local
2291 static void rd_kafka_toppar_op0 (rd_kafka_toppar_t *rktp, rd_kafka_op_t *rko,  in rd_kafka_toppar_op0()
2305 static void rd_kafka_toppar_op (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_op()
2334 rd_kafka_resp_err_t rd_kafka_toppar_op_fetch_start (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_op_fetch_start()
2370 rd_kafka_resp_err_t rd_kafka_toppar_op_fetch_stop (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_op_fetch_stop()
2396 rd_kafka_resp_err_t rd_kafka_toppar_op_seek (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_op_seek()
2428 rd_kafka_toppar_op_pause_resume (rd_kafka_toppar_t *rktp, int pause, int flag,  in rd_kafka_toppar_op_pause_resume()
2462 void rd_kafka_toppar_pause (rd_kafka_toppar_t *rktp, int flag) {  in rd_kafka_toppar_pause()
2476 void rd_kafka_toppar_resume (rd_kafka_toppar_t *rktp, int flag) {  in rd_kafka_toppar_resume()
2515 		rd_kafka_toppar_t *rktp;  in rd_kafka_toppars_pause_resume()  local
2558 void rd_kafka_toppar_enq_error (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_enq_error()
2591 rd_kafka_broker_t *rd_kafka_toppar_broker (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_broker()
2616 void rd_kafka_toppar_leader_unavailable (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_leader_unavailable()
2636         const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar;  in rd_kafka_topic_partition_topic()  local
2642         const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar;  in rd_kafka_topic_partition_partition()  local
2648         const rd_kafka_toppar_t *rktp = (const rd_kafka_toppar_t *)rktpar;  in rd_kafka_topic_partition_get()  local
2730 rd_kafka_topic_partition_new_from_rktp (rd_kafka_toppar_t *rktp) {  in rd_kafka_topic_partition_new_from_rktp()
3025         rd_kafka_toppar_t *rktp;  in rd_kafka_topic_partition_get_toppar()  local
3271                         rd_kafka_toppar_t *rktp = rktpar->_private;  in rd_kafka_topic_partition_list_set_offsets()  local
3871                 rd_kafka_toppar_t *rktp;  in rd_kafka_topic_partition_list_get_topics()  local
4178 static void rd_kafka_toppar_reset_base_msgid (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_reset_base_msgid()
4214 int rd_kafka_toppar_pid_change (rd_kafka_toppar_t *rktp, rd_kafka_pid_t pid,  in rd_kafka_toppar_pid_change()
4272 int rd_kafka_toppar_purge_queues (rd_kafka_toppar_t *rktp,  in rd_kafka_toppar_purge_queues()
4339                 rd_kafka_toppar_t *rktp;  in rd_kafka_purge_ua_toppar_queues()  local