/*
?*?librdkafka?-?Apache?Kafka?C?library
?*
?*?Copyright?（c）?2012-2013?Magnus?Edenhill
?*?All?rights?reserved.
?*?
?*?Redistribution?and?use?in?source?and?binary?forms?with?or?without
?*?modification?are?permitted?provided?that?the?following?conditions?are?met:?
?*?
?*?1.?Redistributions?of?source?code?must?retain?the?above?copyright?notice
?*????this?list?of?conditions?and?the?following?disclaimer.?
?*?2.?Redistributions?in?binary?form?must?reproduce?the?above?copyright?notice
?*????this?list?of?conditions?and?the?following?disclaimer?in?the?documentation
?*????and/or?other?materials?provided?with?the?distribution.?
?*?
?*?THIS?SOFTWARE?IS?PROVIDED?BY?THE?COPYRIGHT?HOLDERS?AND?CONTRIBUTORS?“AS?IS“
?*?AND?ANY?EXPRESS?OR?IMPLIED?WARRANTIES?INCLUDING?BUT?NOT?LIMITED?TO?THE?
?*?IMPLIED?WARRANTIES?OF?MERCHANTABILITY?AND?FITNESS?FOR?A?PARTICULAR?PURPOSE?
?*?ARE?DISCLAIMED.?IN?NO?EVENT?SHALL?THE?COPYRIGHT?OWNER?OR?CONTRIBUTORS?BE?
?*?LIABLE?FOR?ANY?DIRECT?INDIRECT?INCIDENTAL?SPECIAL?EXEMPLARY?OR?
?*?CONSEQUENTIAL?DAMAGES?（INCLUDING?BUT?NOT?LIMITED?TO?PROCUREMENT?OF?
?*?SUBSTITUTE?GOODS?OR?SERVICES;?LOSS?OF?USE?DATA?OR?PROFITS;?OR?BUSINESS?
?*?INTERRUPTION）?HOWEVER?CAUSED?AND?ON?ANY?THEORY?OF?LIABILITY?WHETHER?IN?
?*?CONTRACT?STRICT?LIABILITY?OR?TORT?（INCLUDING?NEGLIGENCE?OR?OTHERWISE）
?*?ARISING?IN?ANY?WAY?OUT?OF?THE?USE?OF?THIS?SOFTWARE?EVEN?IF?ADVISED?OF?THE
?*?POSSIBILITY?OF?SUCH?DAMAGE.
?*/


#define?_GNU_SOURCE
#include?
#include?
#include?
#include?
#include?
#include?

#include?“rdkafka_int.h“
#include?“rdkafka_msg.h“
#include?“rdkafka_broker.h“
#include?“rdkafka_topic.h“
#include?“rdkafka_partition.h“
#include?“rdkafka_offset.h“
#include?“rdkafka_transport.h“
#include?“rdkafka_cgrp.h“
#include?“rdkafka_assignor.h“
#include?“rdkafka_request.h“
#include?“rdkafka_event.h“
#include?“rdkafka_sasl.h“
#include?“rdkafka_interceptor.h“

#include?“rdtime.h“
#include?“crc32c.h“
#include?“rdunittest.h“

#ifdef?_MSC_VER
#include?
#include?
#endif



static?once_flag?rd_kafka_global_init_once?=?ONCE_FLAG_INIT;

/**
?*?@brief?Global?counter+lock?for?all?active?librdkafka?instances
?*/
mtx_t?rd_kafka_global_lock;
int?rd_kafka_global_cnt;


/**
?*?Last?API?error?code?per?thread.
?*?Shared?among?all?rd_kafka_t?instances.
?*/
rd_kafka_resp_err_t?RD_TLS?rd_kafka_last_error_code;


/**
?*?Current?number?of?threads?created?by?rdkafka.
?*?This?is?used?in?regression?tests.
?*/
rd_atomic32_t?rd_kafka_thread_cnt_curr;
int?rd_kafka_thread_cnt?（void）?{
#if?ENABLE_SHAREDPTR_DEBUG
????????rd_shared_ptrs_dump（）;
#endif

	return?rd_atomic32_get（&rd_kafka_thread_cnt_curr）;
}

/**
?*?Current?thread‘s?log?name?（TLS）
?*/
static?char?RD_TLS?rd_kafka_thread_name[64]?=?“app“;

void?rd_kafka_set_thread_name?（const?char?*fmt?...）?{
????????va_list?ap;

????????va_start（ap?fmt）;
????????rd_vsnprintf（rd_kafka_thread_name?sizeof（rd_kafka_thread_name）
?????????????????????fmt

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2018-05-15?15:04??Release\
?????文件?????1179648??2015-11-30?13:46??Release\libeay32.dll
?????文件??????518144??2018-05-14?18:31??Release\librdkafka.dll
?????文件???????26575??2018-05-14?18:31??Release\librdkafka.exp
?????文件???????45144??2018-05-14?18:31??Release\librdkafka.lib
?????文件?????2609152??2018-05-14?18:31??Release\librdkafka.pdb
?????文件???????60416??2018-05-15?08:21??Release\librdkafkacpp.dll
?????文件???????22776??2018-05-15?08:21??Release\librdkafkacpp.exp
?????文件???????37232??2018-05-15?08:21??Release\librdkafkacpp.lib
?????文件?????1290240??2018-05-15?08:21??Release\librdkafkacpp.pdb
?????文件??????116243??2018-04-18?16:59??Release\rdkafka.c
?????文件??????139813??2018-04-18?16:59??Release\rdkafka.h
?????文件???????73400??2018-04-18?16:59??Release\rdkafkacpp.h
?????文件???????41472??2018-05-15?13:48??Release\rdkafka_consumer_example_cpp.exe
?????文件?????2723840??2018-05-15?13:48??Release\rdkafka_consumer_example_cpp.pdb
?????文件???????34816??2018-05-15?13:51??Release\rdkafka_example.exe
?????文件??????962560??2018-05-15?13:51??Release\rdkafka_example.pdb
?????文件???????36864??2018-05-15?13:51??Release\rdkafka_performance.exe
?????文件??????593920??2018-05-15?13:51??Release\rdkafka_performance.pdb
?????文件??????274432??2015-11-30?13:46??Release\ssleay32.dll
?????文件??????614912??2018-05-15?13:51??Release\tests.exe
?????文件?????2617344??2018-05-15?13:51??Release\tests.pdb
?????文件???????70144??2015-05-15?17:18??Release\zlib.dll