UDPProxyCoordinator.h

Go to the documentation of this file.

#include "NativeFeatureIncludes.h"
#if _RAKNET_SUPPORT_UDPProxyCoordinator==1 && _RAKNET_SUPPORT_UDPForwarder==1

#ifndef __UDP_PROXY_COORDINATOR_H
#define __UDP_PROXY_COORDINATOR_H

#include "Export.h"
#include "DS_Multilist.h"
#include "RakNetTypes.h"
#include "PluginInterface2.h"
#include "RakString.h"
#include "BitStream.h"

namespace RakNet
{
    class RAK_DLL_EXPORT UDPProxyCoordinator : public PluginInterface2
    {
    public:
        // GetInstance() and DestroyInstance(instance*)
        STATIC_FACTORY_DECLARATIONS(UDPProxyCoordinator)

        UDPProxyCoordinator();
        virtual ~UDPProxyCoordinator();

        void SetRemoteLoginPassword(RakNet::RakString password);

        virtual void Update(void);
        virtual PluginReceiveResult OnReceive(Packet *packet);
        virtual void OnClosedConnection(const SystemAddress &systemAddress, RakNetGUID rakNetGUID, PI2_LostConnectionReason lostConnectionReason );

        struct SenderAndTargetAddress
        {
            SystemAddress senderClientAddress;
            SystemAddress targetClientAddress;
        };

        struct ServerWithPing
        {
            unsigned short ping;
            SystemAddress serverAddress;
        };

        struct ForwardingRequest
        {
            RakNet::TimeMS timeoutOnNoDataMS;
            RakNet::TimeMS timeoutAfterSuccess;
            SenderAndTargetAddress sata;
            SystemAddress requestingAddress; // Which system originally sent the network message to start forwarding
            SystemAddress currentlyAttemptedServerAddress;
            DataStructures::Multilist<ML_QUEUE, SystemAddress> remainingServersToTry;
            RakNet::BitStream serverSelectionBitstream;

            DataStructures::Multilist<ML_STACK, ServerWithPing, unsigned short> sourceServerPings, targetServerPings;
            RakNet::TimeMS timeRequestedPings;
            // Order based on sourceServerPings and targetServerPings
            void OrderRemainingServersToTry(void);
        
        };

    protected:
        void OnForwardingRequestFromClientToCoordinator(Packet *packet);
        void OnLoginRequestFromServerToCoordinator(Packet *packet);
        void OnForwardingReplyFromServerToCoordinator(Packet *packet);
        void OnPingServersReplyFromClientToCoordinator(Packet *packet);
        void TryNextServer(SenderAndTargetAddress sata, ForwardingRequest *fw);
        void SendAllBusy(SystemAddress senderClientAddress, SystemAddress targetClientAddress, SystemAddress requestingAddress);
        void Clear(void);

        void SendForwardingRequest(SystemAddress sourceAddress, SystemAddress targetAddress, SystemAddress serverAddress, RakNet::TimeMS timeoutOnNoDataMS);

        // Logged in servers
        DataStructures::Multilist<ML_UNORDERED_LIST, SystemAddress> serverList;

        // Forwarding requests in progress
        DataStructures::Multilist<ML_ORDERED_LIST, ForwardingRequest*, SenderAndTargetAddress> forwardingRequestList;

        RakNet::RakString remoteLoginPassword;

    };

} // End namespace

#endif

#endif // _RAKNET_SUPPORT_*