src/rdkafka.c
static void rd_kafka_global_cnt_incr (void) {
	mtx_lock(&rd_kafka_global_lock);
	rd_kafka_global_cnt++;
	if (rd_kafka_global_cnt == 1) {
		rd_kafka_transport_init();
#if WITH_SSL
                rd_kafka_ssl_init();
#endif
                rd_kafka_sasl_global_init();
	}
	mtx_unlock(&rd_kafka_global_lock);
}
/**
 * @brief Increase counter for active librdkafka instances.
 * If this is the first instance the global constructors will be called, if any.
 */
@brief Increase counter for active librdkafka instances.
If this is the first instance the global constructors will be called, if any.
@brief Increase counter for active librdkafka instances . If this is the first instance the global constructors will be called if any .
static void rd_kafka_global_cnt_incr (void) {
	mtx_lock(&rd_kafka_global_lock);
	rd_kafka_global_cnt++;
	if (rd_kafka_global_cnt == 1) {
		rd_kafka_transport_init();
#if WITH_SSL
                rd_kafka_ssl_init();
#endif
                rd_kafka_sasl_global_init();
	}
	mtx_unlock(&rd_kafka_global_lock);
}
static void rd_kafka_global_cnt_incr ( void ) { mtx_lock ( & rd_kafka_global_lock ) ; rd_kafka_global_cnt ++ ; if ( rd_kafka_global_cnt == 1 ) { rd_kafka_transport_init ( ) ; #if WITH_SSL rd_kafka_ssl_init ( ) ; #endif rd_kafka_sasl_global_init ( ) ; } mtx_unlock ( & rd_kafka_global_lock ) ; }
@brief Increase counter for active librdkafka instances.
@brief Increase counter for active librdkafka instances .