/**
 * Tencent is pleased to support the open source community by making Tars available.
 *
 * Copyright (C) 2016THL A29 Limited, a Tencent company. All rights reserved.
 *
 * Licensed under the BSD 3-Clause License (the "License"); you may not use this file except 
 * in compliance with the License. You may obtain a copy of the License at
 *
 * https://opensource.org/licenses/BSD-3-Clause
 *
 * Unless required by applicable law or agreed to in writing, software distributed 
 * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR 
 * CONDITIONS OF ANY KIND, either express or implied. See the License for the 
 * specific language governing permissions and limitations under the License.
 */

#include "CheckNodeThread.h"

extern TC_Config * g_pconf;

CheckNodeThread::CheckNodeThread()
: _terminate(false)
, _nodeTimeout(60)
, _nodeTimeoutInterval(250)
{
}

CheckNodeThread::~CheckNodeThread()
{
 if (isAlive())
 {
 terminate();
 notifyAll();
 getThreadControl().join();
 }
}


int CheckNodeThread::init()
{
 TLOGDEBUG("CheckNodeThread init"<<endl);

 //初始化配置db连接
 _db.init(g_pconf);

 //node心跳超时时间
 _nodeTimeout = TC_Common::strto<int>((*g_pconf).get("/tars/reap<nodeTimeout>", "250"));
 _nodeTimeout = _nodeTimeout < 15 ? 15 : _nodeTimeout;

 _nodeTimeoutInterval = TC_Common::strto<int>((*g_pconf).get("/tars/reap<nodeTimeoutInterval>", "60"));
 _nodeTimeoutInterval = _nodeTimeoutInterval < 15 ? 5 : _nodeTimeoutInterval;

 TLOGDEBUG("CheckNodeThread init ok."<<endl);

 return 0;
}

void CheckNodeThread::terminate()
{
 TLOGDEBUG("CheckNodeThread terminate" << endl);
 _terminate = true;
}

void CheckNodeThread::run()
{
 time_t tLastCheckNode = 0;
 time_t tNow;
 while(!_terminate)
 {
 try
 {
 tNow = TC_TimeProvider::getInstance()->getNow();
 //轮询心跳超时的node
 if(tNow - tLastCheckNode >= _nodeTimeoutInterval)
 {
 _db.checkNodeTimeout(_nodeTimeout);

 tLastCheckNode = tNow;
 }

 TC_ThreadLock::Lock lock(*this);
 timedWait(1000); //ms
 }
 catch(exception & ex)
 {
 TLOGERROR("CheckNodeThread exception:" << ex.what() << endl);
 }
 catch(...)
 {
 TLOGERROR("CheckNodeThread unknown exception" << endl);
 }
 }
}