/*
* 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:  This class implements Comms client endpoint. Client
*                endpoint can be connected to server endpoint and it forwards
*
*/

#include <time.h>
#include <errno.h>
#include <string>

#include "logger.h"

#include "commsclientendpoint.h"
#include "comms.h"
#include "commsmessage.h"
#include "commscontext.h"

namespace java
{
namespace comms
{


OS_EXPORT CommsClientEndpoint::CommsClientEndpoint(): mAddress(0), mAddedToContext(false)
{
    JELOG2(EJavaComms);
    mIpc.reset(IpcConnectionFactory::createConnection(this));
}

OS_EXPORT CommsClientEndpoint::CommsClientEndpoint(const std::wstring& aName): mAddress(0), mAddedToContext(true)
{
    JELOG2(EJavaComms);
    mIpc.reset(IpcConnectionFactory::createConnection(this));
    CommsContext::getContext().add(this, aName);
}

OS_EXPORT CommsClientEndpoint::~CommsClientEndpoint()
{
    JELOG2(EJavaComms);
    disconnect();
    // avoid creating context when not needed
    if (mAddedToContext)
    {
        CommsContext::getContext().remove(this);
    }
}

OS_EXPORT CommsClientEndpoint* CommsClientEndpoint::find(const std::wstring& aName)
{
    JELOG2(EJavaComms);
    return CommsContext::getContext().find(aName);
}

OS_EXPORT int CommsClientEndpoint::connect(int aAddress)
{
    JELOG2(EJavaComms);
    mAddress = aAddress;
    return mIpc->connect(aAddress);
}

OS_EXPORT int CommsClientEndpoint::disconnect()
{
    JELOG2(EJavaComms);
    mIpc->disconnect();
    return 0;
}


OS_EXPORT int CommsClientEndpoint::send(CommsMessage& aMessage)
{
    JELOG2(EJavaComms);
    char* buf = aMessage.toByteArray();
    int rc =  mIpc->send(reinterpret_cast<ipcMessage_t*>(buf));
    return rc;
}


OS_EXPORT int CommsClientEndpoint::detachFromVm()
{
    JELOG2(EJavaComms);
    CommsEndpoint::detachFromVm();

    int rc = disconnect();
    rc = connect(mAddress);

    return rc;
}

} // namespace comms
} // namespace java