#include?“EtcdClientV3.h“
#include?
#include?

int?ECSTDCALL?CreateECClient（IEtcdClient**?client?PECParam?param）
{
	int?ret?=?EC_SUCCESS;
	do
	{
		CEtcdClient*?pClient?=?new（std::nothrow）?CEtcdClient（）;
		if?（pClient?==?NULL）
		{
			ret?=?EC_SYSTEM_ERROR;
			break;
		}

		if?（!pClient->Init（param））
		{
			delete?pClient;
			ret?=?EC_SYSTEM_ERROR;
			break;
		}

		*client?=?pClient;

	}?while?（false）;
	
	return?ret;
}

void?ECSTDCALL?ReleaseClient（IEtcdClient*?client）
{
	CEtcdClient*?pClient?=?static_cast（client）;
	pClient->UnInit（）;
}

CEtcdClient::CEtcdClient（）
{
	m_bInit?=?false;
	m_bStop?=?false;
	m_bAlreadyWatch?=?false;
	m_kvClient??????=?NULL;
	m_watchClient???=?NULL;
	m_leaseClient???=?NULL;
	m_leaseID???????=?0;
	m_pThread???????=?NULL;
	m_ttl?=?60;
	m_nCurrentHostIndex?=?0;
}

CEtcdClient::~CEtcdClient（）
{
	UnInit（）;
}

bool?CEtcdClient::SplitHostInfo（std::string?hostAddr）
{
	size_t?pos?=?hostAddr.find_first_of（‘;‘）;
	while?（hostAddr.length（）?>?0）
	{
		std::string?str?=?hostAddr.substr（0?pos）;
		m_hostArray.push_back（str）;
		if?（pos?==?std::string::npos）
			break;
		hostAddr?=?hostAddr.substr（pos?+?1）;
		pos?=?hostAddr.find_first_of（‘;‘）;
	}

	return?m_hostArray.size（）?>?0;
}

std::string?CEtcdClient::GetHost（）
{
	if?（m_hostArray.size（）?>?0）
	{
		int?nIndex?=?m_nCurrentHostIndex;
		m_nCurrentHostIndex?=?（m_nCurrentHostIndex?+?1）?%?m_hostArray.size（）;
		return?m_hostArray[nIndex];
	}

	return?““;
}

bool?CEtcdClient::Init（PECParam?param）
{
	if?（m_bInit）
		return?true;

	do
	{
		m_logManager.CreateLog（）;

		param->server_addr[sizeof（param->server_addr）?-?1]?=?‘\0‘;
		if?（!SplitHostInfo（param->server_addr））
		{
			LOG（“info“?LOG_LEVEL_ERROR?“split?addr?failed?addr:?%s“?param->server_addr）;
			break;
		}

		m_timer.SetTimer（3?*?1000）;
		/*m_ttl?=?param->ttl;
		if?（m_ttl?>?180?||?m_ttl?==?0）
			m_ttl?=?180;*/

		int?loop_count?=?0;
		while?（loop_count++?		{
			string?host?=?GetHost（）;
			m_channel?=?grpc::CreateChannel（host?grpc::InsecureChannelCredentials（））;

			std::chrono::system_clock::time_point?deadline?=
				std::chrono::system_clock::now（）?+?std::chrono::seconds（3）;

			if?（m_channel->WaitForConnected（deadline））
			{
				LOG（“info“?LOG_LEVEL_INFO?“connect?to?host:?%s?successful“?host.c_str（））;
				break;
			}
			else
			{
				m_channel.reset（）;
				LOG（“info“?LOG_LEVEL_ERROR?“connect?to?host:?%s?failed“?host.c_str（））;
			}
		}
		
		m_kvClient?=?new（std::nothrow）?KVClient（m_channel）;
		if?（m_kvClient?==?NULL）
			break;

		m_watchClient?=?new（std::nothrow）?WatchClient（m_channel?this）;
		if?（m_watchClient?==?NULL）
			break;

		m_leaseClient?=?new（std::nothrow）?LeaseClient（m_channel）;
		if?（m_leaseClient?==?NULL）
			break;

		//m_leaseID?=?m_leaseClient->GetLeaseID（m_ttl）;
		//if?（m_leaseID?<=?0）
		//	break;

		m_pThread?=?new（std::

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2018-01-29?10:35??EtcdClientV3\
?????文件????????7206??2017-08-28?20:30??EtcdClientV3\EtcdClientV3.cpp
?????文件????????1716??2017-08-15?10:03??EtcdClientV3\EtcdClientV3.h
?????文件???????10096??2017-07-06?12:13??EtcdClientV3\EtcdClientV3.vcxproj
?????文件????????3389??2017-07-03?14:41??EtcdClientV3\EtcdClientV3.vcxproj.filters
?????文件????????4940??2017-07-03?15:03??EtcdClientV3\LogManager.cpp
?????文件????????1859??2017-07-03?14:27??EtcdClientV3\LogManager.h
?????文件????????1711??2017-07-06?10:48??EtcdClientV3\Makefile
?????文件???????12899??2017-08-15?11:02??EtcdClientV3\RpcClient.cpp
?????文件????????2464??2017-08-14?19:06??EtcdClientV3\RpcClient.h
?????文件????????2026??2017-07-03?13:28??EtcdClientV3\util.h
?????文件????????2097??2017-07-03?09:46??EtcdClientV3.sln
?????目錄???????????0??2018-01-29?10:35??Release\
?????文件?????1741312??2017-08-28?20:32??Release\EtcdClientV3.dll
?????文件?????????855??2017-08-28?20:31??Release\EtcdClientV3.exp
?????文件????15519785??2017-08-28?20:32??Release\EtcdClientV3.iobj
?????文件?????5691696??2017-08-28?20:32??Release\EtcdClientV3.ipdb
?????文件????????2088??2017-08-28?20:31??Release\EtcdClientV3.lib
?????文件????15749120??2017-08-28?20:32??Release\EtcdClientV3.pdb
?????文件?????1262080??2017-06-12?11:05??Release\libeay32.dll
?????文件??????294400??2017-06-12?11:05??Release\ssleay32.dll
?????文件??????391680??2017-06-12?16:40??Release\zlib.dll
?????目錄???????????0??2018-01-29?10:35??TestEtcdClientV3\
?????文件????????7821??2017-07-03?09:52??TestEtcdClientV3\TestEtcdClientV3.vcxproj
?????文件?????????957??2017-07-03?09:46??TestEtcdClientV3\TestEtcdClientV3.vcxproj.filters
?????文件????????5070??2017-12-19?11:11??TestEtcdClientV3\TestEtctClientV3.cpp
?????文件??????????14??2015-09-20?17:20??TestEtcdClientV3\test.h
?????目錄???????????0??2018-01-29?10:35??debug\
?????文件?????8614400??2017-08-28?20:31??debug\EtcdClientV3_d.dll
?????文件?????????857??2017-08-28?20:31??debug\EtcdClientV3_d.exp
?????文件????20595428??2017-08-28?20:31??debug\EtcdClientV3_d.ilk
............此處省略392個文件信息