--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/javacommons/gcfprotocols/socket/serverconnection/inc/socketserverconnection.h	Mon May 03 12:27:20 2010 +0300
@@ -0,0 +1,130 @@
+/*
+* 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