98 static void rd_kafka_offset_file_close (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_file_close()
146 static int rd_kafka_offset_file_open (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_file_open()
179 static int64_t rd_kafka_offset_file_read (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_file_read()
236 static int rd_kafka_offset_file_sync (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_file_sync()
262 rd_kafka_offset_file_commit (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_file_commit()
351 		  rd_kafka_toppar_t *rktp,  in rd_kafka_commit0()
505         rd_kafka_toppar_t *rktp;  in rd_kafka_offset_broker_commit_cb()  local
553 rd_kafka_offset_broker_commit (rd_kafka_toppar_t *rktp, const char *reason) {  in rd_kafka_offset_broker_commit()
594 rd_kafka_resp_err_t rd_kafka_offset_commit (rd_kafka_toppar_t *rktp,  in rd_kafka_offset_commit()
633 rd_kafka_resp_err_t rd_kafka_offset_sync (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_sync()
713 static rd_kafka_resp_err_t rd_kafka_offset_file_term (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_file_term()
735 	rd_kafka_toppar_t *rktp =  in rd_kafka_offset_reset_op_cb()  local
757 void rd_kafka_offset_reset (rd_kafka_toppar_t *rktp, int64_t err_offset,  in rd_kafka_offset_reset()
882 	rd_kafka_toppar_t *rktp = arg;  in rd_kafka_offset_sync_tmr_cb()  local
893 static void rd_kafka_offset_file_init (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_file_init()
966 static rd_kafka_resp_err_t rd_kafka_offset_broker_term (rd_kafka_toppar_t *rktp){  in rd_kafka_offset_broker_term()
976 static void rd_kafka_offset_broker_init (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_broker_init()
990 void rd_kafka_offset_store_term (rd_kafka_toppar_t *rktp,  in rd_kafka_offset_store_term()
1040 rd_kafka_resp_err_t rd_kafka_offset_store_stop (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_store_stop()
1084 	rd_kafka_toppar_t *rktp = arg;  in rd_kafka_offset_auto_commit_tmr_cb()  local
1089 	rd_kafka_toppar_t *rktp = arg;  in rd_kafka_offset_query_tmr_cb()  local
1107 void rd_kafka_offset_store_init (rd_kafka_toppar_t *rktp) {  in rd_kafka_offset_store_init()