src/rdkafka_broker.c
void
rd_kafka_broker_persistent_connection_add (rd_kafka_broker_t *rkb,
                                           rd_atomic32_t *acntp) {

        if (rd_atomic32_add(acntp, 1) == 1) {
                /* First one, trigger event. */
                rd_kafka_broker_schedule_connection(rkb);
        }
}
/**
 * @brief Add need for persistent connection to \p rkb
 *        with rkb_persistconn atomic counter \p acntp
 *
 * @locality any
 * @locks none
 */
@brief Add need for persistent connection to \p rkb
with rkb_persistconn atomic counter \p acntp

@locality any
@locks none
@brief Add need for persistent connection to \ p rkb with rkb_persistconn atomic counter \ p acntp @locality any @locks none
void
rd_kafka_broker_persistent_connection_add (rd_kafka_broker_t *rkb,
                                           rd_atomic32_t *acntp) {
        if (rd_atomic32_add(acntp, 1) == 1) {
                rd_kafka_broker_schedule_connection(rkb);
        }
}
void rd_kafka_broker_persistent_connection_add ( rd_kafka_broker_t * rkb , rd_atomic32_t * acntp ) { if ( rd_atomic32_add ( acntp , 1 ) == 1 ) { rd_kafka_broker_schedule_connection ( rkb ) ; } }
@brief Add need for persistent connection to \p rkb
        with rkb_persistconn atomic counter \p acntp
@brief Add need for persistent connection to \ p rkb with rkb_persistconn atomic counter \ p acntp
/* First one, trigger event. */