jaus++/2.0/include/jaus/core/transport/transportmanager.h

Go to the documentation of this file.

#ifndef __JAUS_CORE_TRANSPORT_TRANSPORT_TransportManager__H
#define __JAUS_CORE_TRANSPORT_TRANSPORT_TransportManager__H


#include "jaus/core/message.h"
#include "jaus/core/transport/jtcpclient.h"
#include <cxutils/networking/udpclient.h>
#include <cxutils/networking/tcpserver.h>

namespace JAUS
{
    class JAUS_CORE_DLL TransportManager
    {
    public:
        static const int TCP    = 0;
        static const int UDP    = 1;
        static const int Serial = 2;
        TransportManager();
        virtual ~TransportManager();
        // Check if this TransportManager is active.
        bool IsInitialized() const { return mTcpListenThread.IsThreadActive(); }
        // Loads settings from a JAUS file.
        virtual bool LoadSettings(const std::string& filename);
        // Initializes using loaded/pre-defines settings.
        virtual bool Initialize();
        // Shutsdown all transport comms.
        virtual void Shutdown();
        // Method called periodically by Component or other Services, can be used for periodic udpdates.
        virtual void CheckServiceStatus(const unsigned int timeSinceLastCheckMs);
        // Process packet data that needs to be routed
        void ProcessPacket(Packet& packet,
                           Header& header,
                           const IP4Address& ipAddress,
                           const unsigned short sourcePort,
                           const int transport);
        // Turns on debug messages to console window.
        virtual void EnableDebugMessages(const bool on) { mDebugMessagesFlag = true; }
        // Adds a connection to a specific IP address.
        bool AddConnection(const IP4Address& networkIP,
                           const Address& jausID);
        // Gets the number of internal local connections.
        unsigned int GetNumLocalClients() const;
    protected:
        static void TcpListenThread(void* args);        
        static void UdpReceiveThread(void* args);       
        bool mUseTcpFlag;                               
        IP4Address mHostIP;                             
        Mutex mDebugMessagesMutex;                      
        volatile bool mDebugMessagesFlag;               
        unsigned int mDelayTimeMs;                      
        // JUDP Data
        CxUtils::Mutex mUdpMutex;                       
        CxUtils::UdpClient  mUdpSocket;                 
        unsigned int mMaxPayloadSize;                   
        unsigned char mTimeToLive;                      
        CxUtils::IP4Address mMulticastIP;               
        bool mUseBroadcastingFlag;                      
        Time::Stamp mDisconnectTimeMs;                  
        CxUtils::Thread mUdpReceiveThread;              
        std::map<Address, CxUtils::UdpClient*> mUdpConnections; 
        std::map<Address, Time::Stamp> mUpdateTimes;    
        // JTCP Data
        Mutex mTcpMutex;                                
        CxUtils::TcpListenSocket mListenSocket;         
        CxUtils::Thread mTcpListenThread;               
        std::map<Address, JTCP*> mTcpConnections;       
        std::vector<JTCP*> mUnknownConnections;         
        // Other information
        std::map<Address, IP4Address> mPermanentConnections; 
    };
}

#endif
/*  End of File */