src/rdkafka.c
static void rd_kafka_global_cnt_decr (void) {
	mtx_lock(&rd_kafka_global_lock);
	rd_kafka_assert(NULL, rd_kafka_global_cnt > 0);
	rd_kafka_global_cnt--;
	if (rd_kafka_global_cnt == 0) {
                rd_kafka_sasl_global_term();
#if WITH_SSL
                rd_kafka_ssl_term();
#endif
	}
	mtx_unlock(&rd_kafka_global_lock);
}
/**
 * @brief Decrease counter for active librdkafka instances.
 * If this counter reaches 0 the global destructors will be called, if any.
 */
@brief Decrease counter for active librdkafka instances.
If this counter reaches 0 the global destructors will be called, if any.
@brief Decrease counter for active librdkafka instances . If this counter reaches 0 the global destructors will be called if any .
static void rd_kafka_global_cnt_decr (void) {
	mtx_lock(&rd_kafka_global_lock);
	rd_kafka_assert(NULL, rd_kafka_global_cnt > 0);
	rd_kafka_global_cnt--;
	if (rd_kafka_global_cnt == 0) {
                rd_kafka_sasl_global_term();
#if WITH_SSL
                rd_kafka_ssl_term();
#endif
	}
	mtx_unlock(&rd_kafka_global_lock);
}
static void rd_kafka_global_cnt_decr ( void ) { mtx_lock ( & rd_kafka_global_lock ) ; rd_kafka_assert ( NULL , rd_kafka_global_cnt > 0 ) ; rd_kafka_global_cnt -- ; if ( rd_kafka_global_cnt == 0 ) { rd_kafka_sasl_global_term ( ) ; #if WITH_SSL rd_kafka_ssl_term ( ) ; #endif } mtx_unlock ( & rd_kafka_global_lock ) ; }
@brief Decrease counter for active librdkafka instances.
@brief Decrease counter for active librdkafka instances .