src/rdkafka_broker.c
rd_kafka_broker_t *rd_kafka_broker_internal (rd_kafka_t *rk) {
	rd_kafka_broker_t *rkb;

        mtx_lock(&rk->rk_internal_rkb_lock);
	rkb = rk->rk_internal_rkb;
	if (rkb)
		rd_kafka_broker_keep(rkb);
        mtx_unlock(&rk->rk_internal_rkb_lock);

	return rkb;
}
/**
 * Returns the internal broker with refcnt increased.
 */
Returns the internal broker with refcnt increased.
Returns the internal broker with refcnt increased .
rd_kafka_broker_t *rd_kafka_broker_internal (rd_kafka_t *rk) {
	rd_kafka_broker_t *rkb;
        mtx_lock(&rk->rk_internal_rkb_lock);
	rkb = rk->rk_internal_rkb;
	if (rkb)
		rd_kafka_broker_keep(rkb);
        mtx_unlock(&rk->rk_internal_rkb_lock);
	return rkb;
}
rd_kafka_broker_t * rd_kafka_broker_internal ( rd_kafka_t * rk ) { rd_kafka_broker_t * rkb ; mtx_lock ( & rk -> rk_internal_rkb_lock ) ; rkb = rk -> rk_internal_rkb ; if ( rkb ) rd_kafka_broker_keep ( rkb ) ; mtx_unlock ( & rk -> rk_internal_rkb_lock ) ; return rkb ; }
Returns the internal broker with refcnt increased.
Returns the internal broker with refcnt increased .