/*

* 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:  ?Description

*

*/

#include <sys/socket.h>

#include <unistd.h>

#include <errno.h>

#include <netinet/in.h>

#include <string.h>

#include "logger.h"

#include "serversocket.h"

const int INVALID_SOCKET = 0;

namespace java

{

namespace comms

{

ServerSocket::ServerSocket() : mSocket(INVALID_SOCKET)

{

//  JELOG2(EJavaComms);

}

ServerSocket::~ServerSocket()

{

    close();

}

int ServerSocket::open(int aPort)

{

//    JELOG2(EJavaComms);

    mSocket = socket(AF_INET, SOCK_STREAM, 0);

    if (mSocket == -1)

    {

        return -1;

    }

    int flag = 1;

    setsockopt(mSocket, SOL_SOCKET, SO_REUSEADDR, (char*)&flag, sizeof(int));

    sockaddr_in addr;

    addr.sin_family      = AF_INET;

    addr.sin_port        = htons(aPort);

    addr.sin_addr.s_addr = htonl(INADDR_ANY);

    int rc = bind(mSocket, (sockaddr*)&addr, sizeof(addr));

    if (rc != -1)

    {

        rc = listen(mSocket, 3);

        if (rc != -1)

        {

            return 0;

        }

    }

    ELOG2(EJavaComms, "listen failed %d - %s", errno, strerror(errno));

    close();

    return -1;

}

int ServerSocket::accept()

{

    sockaddr_in sa;

    socklen_t saLen = sizeof(sa);

    int socket = ::accept(mSocket, (sockaddr*)&sa, &saLen);

    if (socket<0) ELOG2(EJavaComms, "accept failed %d - %s", errno, strerror(errno));

    return socket;

}

int ServerSocket::close()

{

    int rc = 0;

    if (mSocket !=INVALID_SOCKET)

    {

        rc = ::close(mSocket);

        if (rc<0) ELOG2(EJavaComms, "close failed %d - %s", errno, strerror(errno));

        mSocket = INVALID_SOCKET;

    }

    return rc;

}

int ServerSocket::getSocket() const

{

    return mSocket;

}

} // namespace comms

} // namespace java