UDPProxyClient.h

Go to the documentation of this file.

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

#ifndef __UDP_PROXY_CLIENT_H
#define __UDP_PROXY_CLIENT_H

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


namespace RakNet
{
class UDPProxyClient;

struct UDPProxyClientResultHandler
{
    UDPProxyClientResultHandler() {}
    virtual ~UDPProxyClientResultHandler() {}

    virtual void OnForwardingSuccess(const char *proxyIPAddress, unsigned short proxyPort,
        SystemAddress proxyCoordinator, SystemAddress sourceAddress, SystemAddress targetAddress, RakNet::UDPProxyClient *proxyClientPlugin)=0;

    virtual void OnForwardingNotification(const char *proxyIPAddress, unsigned short proxyPort,
        SystemAddress proxyCoordinator, SystemAddress sourceAddress, SystemAddress targetAddress, RakNet::UDPProxyClient *proxyClientPlugin)=0;

    virtual void OnNoServersOnline(SystemAddress proxyCoordinator, SystemAddress sourceAddress, SystemAddress targetAddress, RakNet::UDPProxyClient *proxyClientPlugin)=0;

    virtual void OnRecipientNotConnected(SystemAddress proxyCoordinator, SystemAddress sourceAddress, SystemAddress targetAddress, RakNetGUID targetGuid, RakNet::UDPProxyClient *proxyClientPlugin)=0;

    virtual void OnAllServersBusy(SystemAddress proxyCoordinator, SystemAddress sourceAddress, SystemAddress targetAddress, RakNet::UDPProxyClient *proxyClientPlugin)=0;

    virtual void OnForwardingInProgress(SystemAddress proxyCoordinator, SystemAddress sourceAddress, SystemAddress targetAddress, RakNet::UDPProxyClient *proxyClientPlugin)=0;
};


class RAK_DLL_EXPORT UDPProxyClient : public PluginInterface2
{
public:
    // GetInstance() and DestroyInstance(instance*)
    STATIC_FACTORY_DECLARATIONS(UDPProxyClient)

    UDPProxyClient();
    ~UDPProxyClient();

    void SetResultHandler(UDPProxyClientResultHandler *rh);

    bool RequestForwarding(SystemAddress proxyCoordinator, SystemAddress sourceAddress, SystemAddress targetAddressAsSeenFromCoordinator, RakNet::TimeMS timeoutOnNoDataMS, RakNet::BitStream *serverSelectionBitstream=0);

    bool RequestForwarding(SystemAddress proxyCoordinator, SystemAddress sourceAddress, RakNetGUID targetGuid, RakNet::TimeMS timeoutOnNoDataMS, RakNet::BitStream *serverSelectionBitstream=0);

    virtual void Update(void);
    virtual PluginReceiveResult OnReceive(Packet *packet);
    virtual void OnRakPeerShutdown(void);
    
    struct ServerWithPing
    {
        unsigned short ping;
        SystemAddress serverAddress;
    };
    struct SenderAndTargetAddress
    {
        SystemAddress senderClientAddress;
        SystemAddress targetClientAddress;
    };
    struct PingServerGroup
    {
        SenderAndTargetAddress sata;
        RakNet::TimeMS startPingTime;
        SystemAddress coordinatorAddressForPings;
        DataStructures::Multilist<ML_UNORDERED_LIST, ServerWithPing> serversToPing;
        bool AreAllServersPinged(void) const;
        void SendPingedServersToCoordinator(RakPeerInterface *rakPeerInterface);
    };
    DataStructures::Multilist<ML_UNORDERED_LIST, PingServerGroup*> pingServerGroups;
protected:

    void OnPingServers(Packet *packet);
    void Clear(void);
    UDPProxyClientResultHandler *resultHandler;

};

} // End namespace

#endif

#endif // _RAKNET_SUPPORT_*