src/rdkafka.c
static int rd_kafka_global_cnt_get (void) {
	int r;
	mtx_lock(&rd_kafka_global_lock);
	r = rd_kafka_global_cnt;
	mtx_unlock(&rd_kafka_global_lock);
	return r;
}
/**
 * @returns the current number of active librdkafka instances
 */
@returns the current number of active librdkafka instances
@returns the current number of active librdkafka instances
static int rd_kafka_global_cnt_get (void) {
	int r;
	mtx_lock(&rd_kafka_global_lock);
	r = rd_kafka_global_cnt;
	mtx_unlock(&rd_kafka_global_lock);
	return r;
}
static int rd_kafka_global_cnt_get ( void ) { int r ; mtx_lock ( & rd_kafka_global_lock ) ; r = rd_kafka_global_cnt ; mtx_unlock ( & rd_kafka_global_lock ) ; return r ; }
@returns the current number of active librdkafka instances
@returns the current number of active librdkafka instances