/*

* 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 server endpoint. Server

*                endpoint waits for incoming connections and it forwards

*

*/

#include "logger.h"

#include "commsserverendpoint.h"

#include "commsmessage.h"

#include "commscontext.h"

namespace java

{

namespace comms

{

OS_EXPORT CommsServerEndpoint::CommsServerEndpoint() : mAddress(0), mAddedToContext(false)

{

    JELOG2(EJavaComms);

    mIpc.reset(IpcConnectionFactory::createServerConnection(this));

}

OS_EXPORT CommsServerEndpoint::CommsServerEndpoint(const std::wstring& aName): mAddress(0), mAddedToContext(true)

{

    JELOG2(EJavaComms);

    mIpc.reset(IpcConnectionFactory::createServerConnection(this));

    CommsContext::getContext().add(this, aName);

}

OS_EXPORT CommsServerEndpoint::~CommsServerEndpoint()

{

    JELOG2(EJavaComms);

    stop();

    // avoid creating context when not needed

    if (mAddedToContext)

    {

        CommsContext::getContext().remove(this);

    }

}

OS_EXPORT CommsServerEndpoint* CommsServerEndpoint::find(const std::wstring& aName)

{

    JELOG2(EJavaComms);

    return CommsContext::getContext().findServer(aName);

}

OS_EXPORT int CommsServerEndpoint::start(int aAddress)

{

    JELOG2(EJavaComms);

    mAddress = aAddress;

    return mIpc->start(aAddress);

}

OS_EXPORT int CommsServerEndpoint::stop()

{

    JELOG2(EJavaComms);

    mIpc->stop();

    return 0;

}

OS_EXPORT int CommsServerEndpoint::send(CommsMessage& aMessage)

{

    JELOG2(EJavaComms);

    char* buf = aMessage.toByteArray();

    int rc =  mIpc->send(reinterpret_cast<ipcMessage_t*>(buf));

    return rc;

}

OS_EXPORT int CommsServerEndpoint::detachFromVm()

{

    JELOG2(EJavaComms);

    CommsEndpoint::detachFromVm();

    int rc = stop();

    rc = start(mAddress);

    return rc;

}

} // namespace comms

} // namespace java