/*
* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description:  Container for sharable endpoints. Sharable endpoints can be
                 found using name (wstring)
*
*/

#include <sstream>
#include <errno.h>

#include "logger.h"
#include "javacommonutils.h"

#include "commscontext.h"
#include "commsclientendpoint.h"

using namespace java::comms;
using java::util::ScopedLock;

using namespace java::util;

CommsContext::CommsContext()
{
}

CommsContext::~CommsContext()
{
    for (endpoints_t::iterator it = mEndpoints.begin(); it != mEndpoints.end(); it++)
    {
        delete it->second;
    }
    mEndpoints.clear();

    for (serverEndpoints_t::iterator it = mServerEndpoints.begin(); it != mServerEndpoints.end(); it++)
    {
        delete it->second;
    }
    mServerEndpoints.clear();
}

#if defined(__SYMBIAN32__) && defined(__WINSCW__)

#include <pls.h>
CommsContext& CommsContext::getContext()
{
    // Access the PLS of this process
    CommsContext* context  = Pls<CommsContext>(TUid::Uid(0x200211DF));
    return *context;
}

#else

static CommsContext* sContext = 0;
CommsContext& CommsContext::getContext()
{

    if (sContext == 0)
    {
        sContext = new CommsContext();
    }
    return *sContext;
}
#endif

void CommsContext::add(CommsClientEndpoint* aEndpoint, const wstring& aName)
{
//    JELOG2(EJavaComms);
    ScopedLock lock(mEndpointsMutex);

    endpoints_t::iterator it = mEndpoints.find(aEndpoint);
    if (it == mEndpoints.end() && find(aName) == 0)
    {
        mEndpoints.insert(std::make_pair(aEndpoint, new wstring(aName)));
        LOG1WSTR(EJavaComms, EInfo, "Added client endpoint=%s", aName);
    }
    else
    {
        ELOG1WSTR(EJavaComms, "Add client endpoint failed, endpoint=%s", aName);
    }
}

void CommsContext::remove(CommsClientEndpoint* aEndpoint)
{
//    JELOG2(EJavaComms);
    ScopedLock lock(mEndpointsMutex);

    endpoints_t::iterator it = mEndpoints.find(aEndpoint);

    if (it != mEndpoints.end())
    {
        LOG1WSTR(EJavaComms, EInfo, "Removed client endpoint=%s", *(it->second));
        delete it->second;
        mEndpoints.erase(it);
    }
}

CommsClientEndpoint* CommsContext::find(const wstring& aName)
{
//    JELOG2(EJavaComms);
    ScopedLock lock(mEndpointsMutex);

    CommsClientEndpoint* client = 0;
    for (endpoints_t::iterator it = mEndpoints.begin(); it != mEndpoints.end(); it++)
    {
        if (aName.compare(*(it->second)) == 0)
        {
            client = it->first;
            LOG1WSTR(EJavaComms, EInfo, "Found client endpoint=%s", aName);
            break;
        }
    }
    return client;
}

void CommsContext::add(CommsServerEndpoint* aEndpoint, const wstring& aName)
{
//    JELOG2(EJavaComms);
    ScopedLock lock(mEndpointsMutex);

    serverEndpoints_t::iterator it = mServerEndpoints.find(aEndpoint);
    if (it == mServerEndpoints.end() && findServer(aName) == 0)
    {
        mServerEndpoints.insert(std::make_pair(aEndpoint, new wstring(aName)));
        LOG1WSTR(EJavaComms, EInfo, "Added server endpoint=%s", aName);
    }
    else
    {
        ELOG1WSTR(EJavaComms, "Add server endpoint failed, endpoint=%s", aName);
    }
}

void CommsContext::remove(CommsServerEndpoint* aEndpoint)
{
//    JELOG2(EJavaComms);
    ScopedLock lock(mEndpointsMutex);

    serverEndpoints_t::iterator it = mServerEndpoints.find(aEndpoint);

    if (it != mServerEndpoints.end())
    {
        LOG1WSTR(EJavaComms, EInfo, "Removed server endpoint=%s", *(it->second));
        delete it->second;
        mServerEndpoints.erase(it);
    }
}

CommsServerEndpoint* CommsContext::findServer(const wstring& aName)
{
//    JELOG2(EJavaComms);
    ScopedLock lock(mEndpointsMutex);

    CommsServerEndpoint* server = 0;
    for (serverEndpoints_t::iterator it = mServerEndpoints.begin(); it != mServerEndpoints.end(); it++)
    {
        if (aName.compare(*(it->second)) == 0)
        {
            server = it->first;
            LOG1WSTR(EJavaComms, EInfo, "Found server endpoint=%s", aName);
            break;
        }
    }
    return server;
}