Searched refs:rk_broker_state_change_lock (Results 1 – 9 of 9) sorted by relevance
1037 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_get_state_version()1039 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_get_state_version()1064 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change()1069 &rk->rk_broker_state_change_lock, in rd_kafka_brokers_wait_state_change()1071 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change()1092 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change_async()1101 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change_async()1129 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_broadcast_state_change()1141 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_broadcast_state_change()
244 mtx_t rk_broker_state_change_lock; member
951 mtx_destroy(&rk->rk_broker_state_change_lock); in rd_kafka_destroy_final()1167 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_destroy_internal()1170 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_destroy_internal()2055 mtx_init(&rk->rk_broker_state_change_lock, mtx_plain); in rd_kafka_new()
1180 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_get_state_version()1182 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_get_state_version()1207 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change()1212 &rk->rk_broker_state_change_lock, in rd_kafka_brokers_wait_state_change()1214 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change()1235 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change_async()1244 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change_async()1272 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_broadcast_state_change()1284 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_broadcast_state_change()
248 mtx_t rk_broker_state_change_lock; member
989 mtx_destroy(&rk->rk_broker_state_change_lock); in rd_kafka_destroy_final()1237 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_destroy_internal()1240 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_destroy_internal()2174 mtx_init(&rk->rk_broker_state_change_lock, mtx_plain); in rd_kafka_new()
1167 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_get_state_version()1169 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_get_state_version()1194 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change()1199 &rk->rk_broker_state_change_lock, in rd_kafka_brokers_wait_state_change()1201 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change()1222 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change_async()1231 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_wait_state_change_async()1259 mtx_lock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_broadcast_state_change()1271 mtx_unlock(&rk->rk_broker_state_change_lock); in rd_kafka_brokers_broadcast_state_change()
989 mtx_destroy(&rk->rk_broker_state_change_lock);1237 mtx_lock(&rk->rk_broker_state_change_lock);1240 mtx_unlock(&rk->rk_broker_state_change_lock);2174 mtx_init(&rk->rk_broker_state_change_lock, mtx_plain);