Lines Matching refs:newps
2047 rd_kafka_NewPartitions_t *newps; in rd_kafka_NewPartitions_new() local
2057 newps = rd_malloc(sizeof(*newps) + tsize); in rd_kafka_NewPartitions_new()
2058 newps->total_cnt = new_total_cnt; in rd_kafka_NewPartitions_new()
2059 newps->topic = newps->data; in rd_kafka_NewPartitions_new()
2060 memcpy(newps->topic, topic, tsize); in rd_kafka_NewPartitions_new()
2063 rd_list_init(&newps->replicas, 0, rd_list_destroy_free); in rd_kafka_NewPartitions_new()
2064 rd_list_prealloc_elems(&newps->replicas, 0, new_total_cnt, 0/*nozero*/); in rd_kafka_NewPartitions_new()
2066 return newps; in rd_kafka_NewPartitions_new()
2095 void rd_kafka_NewPartitions_destroy (rd_kafka_NewPartitions_t *newps) { in rd_kafka_NewPartitions_destroy() argument
2096 rd_list_destroy(&newps->replicas); in rd_kafka_NewPartitions_destroy()
2097 rd_free(newps); in rd_kafka_NewPartitions_destroy()
2105 void rd_kafka_NewPartitions_destroy_array (rd_kafka_NewPartitions_t **newps, in rd_kafka_NewPartitions_destroy_array() argument
2109 rd_kafka_NewPartitions_destroy(newps[i]); in rd_kafka_NewPartitions_destroy_array()
2282 rd_kafka_NewPartitions_t **newps, in rd_kafka_CreatePartitions() argument
2306 rd_kafka_NewPartitions_copy(newps[i])); in rd_kafka_CreatePartitions()