PacketizedTCP.h

Go to the documentation of this file.

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

#ifndef __PACKETIZED_TCP
#define __PACKETIZED_TCP

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

namespace RakNet
{

class RAK_DLL_EXPORT PacketizedTCP : public TCPInterface
{
public:
    // GetInstance() and DestroyInstance(instance*)
    STATIC_FACTORY_DECLARATIONS(PacketizedTCP)

    PacketizedTCP();
    virtual ~PacketizedTCP();

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

    void Stop(void);

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

    // Sends a concatenated list of byte streams
    bool SendList( const char **data, const int *lengths, const int numParameters, const 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(const SystemAddress &sa);
    void AddToConnectionList(const 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;
};

} // namespace RakNet

#endif

#endif // _RAKNET_SUPPORT_*