PacketizedTCP.h

Go to the documentation of this file.

#include "NativeFeatureIncludes.h"
#if _RAKNET_SUPPORT_PacketizedTCP==1

#ifndef __PACKETIZED_TCP
#define __PACKETIZED_TCP

#include "TCPInterface.h"
#include "DS_ByteQueue.h"
#include "PluginInterface2.h"
#include "DS_Map.h"

class RAK_DLL_EXPORT PacketizedTCP : public TCPInterface
{
public:
        PacketizedTCP();
        virtual ~PacketizedTCP();

        bool Start(unsigned short port, unsigned short maxIncomingConnections, int threadPriority=-99999);

        void Stop(void);

        void Send( const char *data, unsigned length, SystemAddress systemAddress, bool broadcast );

        // Sends a concatenated list of byte streams
        bool SendList( const char **data, const int *lengths, const int numParameters, SystemAddress systemAddress, bool broadcast );

        Packet* Receive( void );

        void CloseConnection( SystemAddress systemAddress );

        SystemAddress HasCompletedConnectionAttempt(void);

        SystemAddress HasFailedConnectionAttempt(void);

        SystemAddress HasNewIncomingConnection(void);

        SystemAddress HasLostConnection(void);

        // Only currently tested with FileListTransfer!
        void AttachPlugin( PluginInterface2 *plugin );
        void DetachPlugin( PluginInterface2 *plugin );

protected:
        void ClearAllConnections(void);
        void RemoveFromConnectionList(SystemAddress sa);
        void AddToConnectionList(SystemAddress sa);
        void PushNotificationsToQueues(void);
        Packet *ReturnOutgoingPacket(void);

        // Plugins
        DataStructures::List<PluginInterface2*> messageHandlerList;
        // A single TCP recieve may generate multiple split packets. They are stored in the waitingPackets list until Receive is called
        DataStructures::Queue<Packet*> waitingPackets;
        DataStructures::Map<SystemAddress, DataStructures::ByteQueue *> connections;

        // Mirrors single producer / consumer, but processes them in Receive() before returning to user
        DataStructures::Queue<SystemAddress> _newIncomingConnections, _lostConnections, _failedConnectionAttempts, _completedConnectionAttempts;
};

#endif

#endif // _RAKNET_SUPPORT_*