/**
 * 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 "NodeRollLogger.h"
#include "servant/Communicator.h"


/////////////////////////////////////////////////////////////////////////////////////
RollLoggerManager::RollLoggerManager()
: _maxSize(1024 * 1024 * 50), _maxNum(10)
{
}

RollLoggerManager::~RollLoggerManager()
{

 map<string, RollLogger*>::iterator it = _loggers.begin();
 while(it != _loggers.end())
 {
 delete it->second;
 ++it;
 }
 _loggers.clear();
}

void RollLoggerManager::setLogInfo(const string &sApp, const string &sServer, const string &sLogpath, int iMaxSize, int iMaxNum, const CommunicatorPtr &comm, const string &sLogObj)
//void RollLoggerManager::setLogInfo(const string &sApp, const string &sServer, const string &sLogpath, int iMaxSize, int iMaxNum, const string &sLogObj)
{
 _app = sApp;
 _server = sServer;
 _logpath = sLogpath;

 _maxSize = iMaxSize;
 _maxNum = iMaxNum;
 _comm = comm;
 _logObj = sLogObj;
 //生成目录
 TC_File::makeDirRecursive(_logpath + "/" + _app + "/" + _server);

 _local.start(1);
}


void RollLoggerManager::sync(RollLogger *pRollLogger, bool bSync)
{
 if(bSync)
 {
 pRollLogger->unSetupThread();
 }
 else
 {
 pRollLogger->setupThread(&_local);
 }
}

/*
void NodeRollLogger::enableDyeing(bool bEnable, const string& sDyeingKey)
{
 _logger.getRoll()->enableDyeing(bEnable, sDyeingKey);
}
*/

RollLoggerManager::RollLogger* RollLoggerManager::logger(const string &sFile)
{
 Lock lock(*this);
 map<string, RollLogger*>::iterator it = _loggers.find(sFile);
 if( it == _loggers.end())
 {
 RollLogger *p = new RollLogger();
 //p->modFlag(RollLogger::HAS_MTIME);
 initRollLogger(p, sFile, "%Y%m%d");
 _loggers[sFile] = p;
 return p;
 }

 return it->second;
}

void RollLoggerManager::initRollLogger(RollLogger *pRollLogger, const string &sFile, const string &sFormat)
{

 //初始化本地循环日志
 pRollLogger->init(_logpath + "/" + _app + "/" + _server + "/" + _app + "." + _server + "_" + sFile, _maxSize, _maxNum);
 pRollLogger->modFlag(TC_DayLogger::HAS_TIME, false);
 pRollLogger->modFlag(TC_DayLogger::HAS_TIME|TC_DayLogger::HAS_LEVEL|TC_DayLogger::HAS_PID, true);

 //设置为异步
 sync(pRollLogger, false);


 //设置染色日志信息
 pRollLogger->getWriteT().setDyeingLogInfo(_app, _server, _logpath, _maxSize, _maxNum, _comm, _logObj);
// pRollLogger->getWriteT().setDyeingLogInfo(_app, _server, _logpath, _maxSize, _maxNum, _logObj);
}