vmessageinputthread.h

Go to the documentation of this file.

/*
Copyright c1997-2014 Trygve Isaacson. All rights reserved.
This file is part of the Code Vault version 4.1
http://www.bombaydigital.com/
License: MIT. See LICENSE.md in the Vault top level directory.
*/

#ifndef vmessageinputthread_h
#define vmessageinputthread_h

#include "vsocketthread.h"
#include "vsocketstream.h"
#include "vserver.h"
#include "vbinaryiostream.h"
#include "vmessage.h"

class VMessageHandler;

class VMessageInputThread : public VSocketThread {
    public:

        VMessageInputThread(const VString& threadBaseName, VSocket* socket, VListenerThread* ownerThread, VServer* server, const VMessageFactory* messageFactory);
        virtual ~VMessageInputThread();

        virtual void run();

        void attachSession(VClientSessionPtr session);

        void setHasOutputThread(bool hasOutputThread) { mHasOutputThread = hasOutputThread; }

    protected:

        virtual void _processNextRequest();
        virtual void _dispatchMessage(VMessagePtr message);
        virtual void _handleNoMessageHandler(VMessagePtr /*message*/) {}
        virtual void _beforeProcessMessage(VMessageHandler* /*handler*/, VMessagePtr /*message*/) {}
        virtual void _callProcessMessage(VMessageHandler* handler);
        virtual void _afterProcessMessage(VMessageHandler* /*handler*/) {}

        VSocketStream           mSocketStream;      
        VBinaryIOStream         mInputStream;       
        bool                    mConnected;         
        VClientSessionPtr       mSession;           
        VServer*                mServer;            
        const VMessageFactory*  mMessageFactory;    
        volatile bool           mHasOutputThread;   

    private:

        VMessageInputThread(const VMessageInputThread&); // not copyable
        VMessageInputThread& operator=(const VMessageInputThread&); // not assignable
};

class VBentoMessageInputThread : public VMessageInputThread {
    public:

        VBentoMessageInputThread(const VString& threadBaseName, VSocket* socket, VListenerThread* ownerThread, VServer* server, const VMessageFactory* messageFactory);
        ~VBentoMessageInputThread() {}

    protected:

        virtual void _handleNoMessageHandler(VMessagePtr message);
        virtual void _callProcessMessage(VMessageHandler* handler);

};

#endif /* vmessageinputthread_h */