src/rdkafka_broker.c
void
rd_kafka_broker_persistent_connection_del (rd_kafka_broker_t *rkb,
                                           rd_atomic32_t *acntp) {
        int32_t r = rd_atomic32_sub(acntp, 1);
        rd_assert(r >= 0);
}
/**
 * @brief Remove need for persistent connection to \p rkb
 *        with rkb_persistconn atomic counter \p acntp
 *
 * @locality any
 * @locks none
 */
@brief Remove need for persistent connection to \p rkb
with rkb_persistconn atomic counter \p acntp

@locality any
@locks none
@brief Remove need for persistent connection to \ p rkb with rkb_persistconn atomic counter \ p acntp @locality any @locks none
void
rd_kafka_broker_persistent_connection_del (rd_kafka_broker_t *rkb,
                                           rd_atomic32_t *acntp) {
        int32_t r = rd_atomic32_sub(acntp, 1);
        rd_assert(r >= 0);
}
void rd_kafka_broker_persistent_connection_del ( rd_kafka_broker_t * rkb , rd_atomic32_t * acntp ) { int32_t r = rd_atomic32_sub ( acntp , 1 ) ; rd_assert ( r >= 0 ) ; }
@brief Remove need for persistent connection to \p rkb
        with rkb_persistconn atomic counter \p acntp
@brief Remove need for persistent connection to \ p rkb with rkb_persistconn atomic counter \ p acntp