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

Go to the documentation of this file.

#ifndef __JAUS_CORE_TRANSPORT_TCP_SERVER__H
#define __JAUS_CORE_TRANSPORT_TCP_SERVER__H

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

namespace JAUS
{
    class TransportManager;
    typedef CxUtils::IP4Address IP4Address; 

    class JAUS_CORE_DLL JTCP
    {
    public:
        const static unsigned short Port = 3794;         
        const static unsigned int OverheadSizeBytes = 61;
        const static Byte Version = 0x02;                
        JTCP();
        virtual ~JTCP();
        // Initializes, creating a thread for receiving TCP data.
        virtual bool Initialize(TransportManager* manager, CxUtils::Socket* socket);
        // Shutsdown the transport service.
        virtual void Shutdown();
        // Sets the delay time in ms for stream polling loop.
        virtual void SetPacketPollingDelayMs(const unsigned int delayTimeMs = 0);
        // Gets a pointer to the socket.
        CxUtils::Socket* GetSocket() { return mpSocket; }
        // Gets a pointer to the socket.
        const CxUtils::Socket* GetSocket() const { return mpSocket; }
        // Gets the update time (when last message was received).
        JAUS::Time GetUpdateTime() const;
        // Gets the address of the component that last sent a message.
        JAUS::Address GetLastSourceID() const;
        // Flag set if connection is on the current machine.
        bool IsLocalConnection() const { return mLocalConnectionFlag; }
    protected:
        virtual void ProcessPacket(Packet& packet,
                                   Header& header,
                                   const IP4Address& ipAddress,
                                   const unsigned short sourcePort);
        virtual bool ExitThread() const { return false; }
        static void ReceiveThread(void* args);
        Mutex mDataMutex;                         
        Thread mRecvThread;                       
        unsigned int mDelayTimeMs;                
        CxUtils::Socket* mpSocket;                
        TransportManager* mpManager;              
        Time mUpdateTime;                         
        volatile bool mReceivedValidDataFlag;     
        Address mLastSourceID;                    
        bool mLocalConnectionFlag;                
    };
}

#endif
/*  End of File */