/*

* Copyright (c) 2008-2009 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:  StorageServer

*

*/

#ifndef STORAGESERVER_H

#define STORAGESERVER_H

#include "commslistener.h"

#include "commsserverendpoint.h"

using java::comms::CommsListener;

using java::comms::CommsMessage;

using java::comms::CommsServerEndpoint;

namespace java

{

namespace util

{

class Monitor;

}

namespace storage

{

class StorageDBHandler;

/**

 * StorageServer serves storage clients.

 * StorageServer servers incoming Comms messages and responds to them. They

 * are handled synchronously. Incoming message is identified and then processed

 * accordingly. Usually call is redirected to underlying database and response

 * contains database response.

 */

class StorageServer : CommsListener

{

public:

    /**

     * Constructor.

     *

     * @param aMonitor for life cycle managenent.

     */

    StorageServer(java::util::Monitor* aMonitor = NULL);

    virtual ~StorageServer();

    /**

     * Start storage server. Comms server is started to allow message

     * receiving.

     */

    void start();

    /**

     * Stop storage server.

     */

    void stop();

    /**

     * Process incoming message and responds to it.

     * Method of CommsListener.

     *

     * @param aMessage incoming message.

     */

    virtual void processMessage(CommsMessage& aMessage);

private:

    /**

     * Send response message.

     *

     * @param aReceivedMessage received message to extract sender information.

     * @param aResponseMessage response message. Receiver information is added.

     */

    void respond(const CommsMessage& aReceivedMessage,

                 CommsMessage& aResponseMessage);

private:

    CommsServerEndpoint     iComms;

    StorageDBHandler*       iDbHandler;

    java::util::Monitor*    iMonitor;

};

}    // java

}    // storage

#endif // STORAGESERVER_H