src/rdkafka_broker.c
void rd_kafka_brokers_broadcast_state_change (rd_kafka_t *rk) {

        rd_kafka_dbg(rk, GENERIC, "BROADCAST",
                     "Broadcasting state change");

        mtx_lock(&rk->rk_broker_state_change_lock);

        /* Bump version */
        rk->rk_broker_state_change_version++;

        /* Trigger waiters */
        rd_list_apply(&rk->rk_broker_state_change_waiters,
                      rd_kafka_broker_state_change_trigger_eonce, NULL);

        /* Broadcast to listeners */
        cnd_broadcast(&rk->rk_broker_state_change_cnd);

        mtx_unlock(&rk->rk_broker_state_change_lock);
}
/**
 * @brief Broadcast broker state change to listeners, if any.
 *
 * @locality any thread
 */
@brief Broadcast broker state change to listeners, if any.
@locality any thread
@brief Broadcast broker state change to listeners if any . @locality any thread
void rd_kafka_brokers_broadcast_state_change (rd_kafka_t *rk) {
        rd_kafka_dbg(rk, GENERIC, "BROADCAST",
                     "Broadcasting state change");
        mtx_lock(&rk->rk_broker_state_change_lock);
        rk->rk_broker_state_change_version++;
        rd_list_apply(&rk->rk_broker_state_change_waiters,
                      rd_kafka_broker_state_change_trigger_eonce, NULL);
        cnd_broadcast(&rk->rk_broker_state_change_cnd);
        mtx_unlock(&rk->rk_broker_state_change_lock);
}
void rd_kafka_brokers_broadcast_state_change ( rd_kafka_t * rk ) { rd_kafka_dbg ( rk , GENERIC , " " , " " ) ; mtx_lock ( & rk -> rk_broker_state_change_lock ) ; rk -> rk_broker_state_change_version ++ ; rd_list_apply ( & rk -> rk_broker_state_change_waiters , rd_kafka_broker_state_change_trigger_eonce , NULL ) ; cnd_broadcast ( & rk -> rk_broker_state_change_cnd ) ; mtx_unlock ( & rk -> rk_broker_state_change_lock ) ; }
@brief Broadcast broker state change to listeners, if any.
@brief Broadcast broker state change to listeners if any .
/* Bump version */ /* Trigger waiters */ /* Broadcast to listeners */