/**
 * 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 "AdminRegistryServer.h"
#include "AdminRegistryImp.h"

TC_Config * g_pconf;
AdminRegistryServer g_app;

extern TC_Config * g_pconf;

//内部版本
const string SERVER_VERSION = "B002";

void AdminRegistryServer::initialize()
{
    TLOGDEBUG("AdminRegistryServer::initialize..." << endl);

    try
    {
        string size = Application::getCommunicator()->getProperty("timeout-queue-size", "");
        if(size.empty())
        {
            Application::getCommunicator()->setProperty("timeout-queue-size","100");
        }

        loadServantEndpoint();

        //轮询线程
        _reapThread.init();
        _reapThread.start();

        //供admin client访问的对象
        string adminObj = g_pconf->get("/tars/objname<AdminRegObjName>", "");
        if(adminObj != "")
        {
            addServant<AdminRegistryImp>(adminObj);
        }
    }
    catch(TC_Exception & ex)
    {
        TLOGERROR("RegistryServer initialize exception:" << ex.what() << endl);
        cerr << "RegistryServer initialize exception:" << ex.what() << endl;
        exit(-1);
    }

    TLOGDEBUG("RegistryServer::initialize OK!" << endl);
}

int AdminRegistryServer::loadServantEndpoint()
{
    map<string, string> mapAdapterServant;
    mapAdapterServant = ServantHelperManager::getInstance()->getAdapterServant();

    map<string, string>::iterator iter;
    for(iter = mapAdapterServant.begin(); iter != mapAdapterServant.end(); iter++ )
    {
        TC_Endpoint ep = getEpollServer()->getBindAdapter(iter->first)->getEndpoint();

        _mapServantEndpoint[iter->second] = ep.toString();

        TLOGDEBUG("registry obj: " << iter->second << " = " << ep.toString() <<endl);
    }

    return 0;
}

void AdminRegistryServer::destroyApp()
{
    _reapThread.terminate();

    TLOGDEBUG("AdminRegistryServer::destroyApp ok" << endl);
}


int main(int argc, char *argv[])
{
    try
    {
        g_pconf =  & g_app.getConfig();
        g_app.main(argc, argv);

        g_app.waitForShutdown();
    }
    catch(exception &ex)
    {
        cerr<< ex.what() << endl;
    }

    return 0;
}