Searched defs:toppar (Results 1 – 6 of 6) sorted by relevance
250 rd_kafka_topic_partition_t *toppar; in consume_pause_resume_after_reassign() local
1402 const rd_kafka_topic_partition_t *toppar; in rd_kafka_cooperative_protocol_adjust_assignment() local5909 rd_kafka_topic_partition_t *toppar; in unittest_set_intersect() local5988 rd_kafka_topic_partition_t *toppar; in unittest_set_subtract() local6076 rd_kafka_topic_partition_t *toppar; in unittest_list_to_map() local
234 const rd_kafka_topic_partition_t *toppar) { in PartitionMovements_removeMovementRecordOfPartition()261 const rd_kafka_topic_partition_t *toppar, in PartitionMovements_addPartitionMovementRecord()283 const rd_kafka_topic_partition_t *toppar, in PartitionMovements_movePartition()314 const rd_kafka_topic_partition_t *toppar, in PartitionMovements_getTheActualPartitionToBeMoved()
1339 const rd_kafka_topic_partition_t *toppar; in rd_kafka_cooperative_protocol_adjust_assignment() local5761 rd_kafka_topic_partition_t *toppar; in unittest_set_intersect() local5840 rd_kafka_topic_partition_t *toppar; in unittest_set_subtract() local5928 rd_kafka_topic_partition_t *toppar; in unittest_list_to_map() local
55 } toppar; typedef