vlistenerthread.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 vlistenerthread_h
#define vlistenerthread_h

#include "vsocketthread.h"
#include "vsocket.h"
#include "vmutex.h"

class VSocketFactory;
class VSocketThreadFactory;
class VClientSessionFactory;

class VListenerThread : public VThread {
    public:

        VListenerThread(const VString& threadBaseName, bool deleteSelfAtEnd, bool createDetached, VManagementInterface* manager, int portNumber, const VString& bindAddress, VSocketFactory* socketFactory, VSocketThreadFactory* threadFactory, VClientSessionFactory* sessionFactory = NULL, bool initiallyListening = true);
        virtual ~VListenerThread();

        virtual void stop();
        virtual void run();

        void socketThreadEnded(VSocketThread* socketThread);

        int getPortNumber() const;

        VSocketInfoVector enumerateActiveSockets();

        void stopSocketThread(VSocketID socketID, int localPortNumber);

        void stopAllSocketThreads();
        void startListening() { mShouldListen = true; }
        void stopListening() { mShouldListen = false; }
        bool isListening() const { return mShouldListen; }

    private:

        // Prevent copy construction and assignment since there is no provision for sharing the underlying thread
        // or the pointer instance variables.
        VListenerThread(const VListenerThread& other);
        VListenerThread& operator=(const VListenerThread& other);

        void _runListening();

        int                     mPortNumber;            
        VString                 mBindAddress;           
        bool                    mShouldListen;          
        VSocketFactory*         mSocketFactory;         
        VSocketThreadFactory*   mThreadFactory;         
        VClientSessionFactory*  mSessionFactory;        
        VSocketThreadPtrVector  mSocketThreads;         
        VMutex                  mSocketThreadsMutex;    

};

typedef std::vector<VListenerThread*> VListenerThreadPtrVector;

#endif /* vlistenerthread_h */