/*

* Copyright (c) 2007-2007 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:  socketserverconnection.h

*

*/

#ifndef SOCKETSERVERCONNECTION_H

#define SOCKETSERVERCONNECTION_H

#include <string>

#include <sys/socket.h>

#include <sys/select.h>

#include <unistd.h>

#include <errno.h>

#include <arpa/inet.h>

#include <netinet/in.h>

#include <fcntl.h>

#include "serverconnection.h"

#include "javaosheaders.h"

#include "logger.h"

#include "connectionlistener.h"

#include "javacommonutils.h"

#include "monitor.h"

using namespace java::push;

/**

* This is the base class for Native Peer of server socket.

* NativeSocketServerConnection will make calls to this class to create a carry out the all server socket operations.

*/

class SocketServerConnection : public ServerConnection

{

public:

    SocketServerConnection();

    OS_IMPORT SocketServerConnection(const std::wstring& aUri,const std::wstring& aFilter);

    OS_IMPORT virtual ~SocketServerConnection();

    virtual void open(ConnectionListener* aListener);

    virtual void close();

    virtual std::wstring getUri() const;

    virtual std::wstring getFilter() const;

    OS_IMPORT virtual void setFilter(const std::wstring& aFilter);

    OS_IMPORT int open();

    OS_IMPORT int accept();

    OS_IMPORT void setNormalServerConnection();

    OS_IMPORT bool isNormalServerConnection();

    /**

    * close , to close the server connection

    * @param[in]  fd: server socket descriptor.

    * @return 0 on successful completion.. If error, then the

    *         value of errno should be negated and returned. (return -errno)

    */

    OS_IMPORT int close(int fd);

private:

    /**

    * open is called by listening thread to create a new server socket to the specified port.

    * @param[in]  aPort: port on which server listens.

    * @return 0 on successful completion.. If error, then the

    *         value of errno should be negated and returned. (return -errno)

    */

    int open(int aPort);

    /**

    * accept is called by listening thread to accept an incoming connection. This will frist use the select() api to check for any

    * incoming connection. Then it calls the accept() system call to accept the connection

    * @param[in]  fd: server socket descriptor.

    * @return 0 on successful completion.. If error, then the

    *         value of errno should be negated and returned. (return -errno)

    */

    int accept(int fd);

    /**

    * setNonBlocking , to make the server socket as non-blocking. fcntl() system call of OpenC is used to set the socket option O_NONBLOCK.

    * @param[in]  fd: server socket descriptor.

    * @return 0 on successful completion.. If error, then the

    *         value of errno should be negated and returned. (return -errno)

    */

    void setNonBlocking(int fd);

    static void* listenThread(void* params);

    /**

     * SetActivityFlag method  updates status whether

     * ServerConnection object has pending message(= message arrived but not yet read).

     * @param aFlag Updating logic of pending message flag:

     *                    - Set it 'true' when message arrives to the connection.

     *                    - Set it 'false' when ServerConnection::open() operation has been called.

     */

    void setActivityFlag(bool aFlag);

private:

    ConnectionListener* mListener;

    pthread_t mThreadId;

    bool mKeepRunning;

    int mListenSocket;

    int mAcceptSocket;

    std::wstring mUri;

    std::wstring mFilter;

    int mPort;

    bool mIsAppRunning;

    bool mIsNormalServerConnection;

    java::util::Monitor* mOpenMonitor;

    int mError;

};

#endif // SOCKETSERVERCONNECTION_H