MercuryNetServer.h

Go to the documentation of this file.

#ifndef _MERCURY_NET_SERVER_H
#define _MERCURY_NET_SERVER_H

#include "MercuryTimer.h"
#include "global.h"
#include "MercuryVector.h"
#include "MercuryMessages.h"
#include "MercuryTypes.h"
#include "ezSockets.h"

class MercuryODEWorld;
class MercuryNetServer;

struct ODEUnitInfo
{
    MercuryPoint pos;
    MQuaternion rot;
    MercuryPoint linvel;
    MercuryPoint angvel;
};

class MercuryNetServerConnection
{
public:
    MercuryNetServerConnection( ezSockets * pAccepted );
    ~MercuryNetServerConnection();
    void BroadcastToClient( const MString & sMessage, const PStack & pParameters );
    static void * CoreThreadCaller( void * NetClient);
    void CoreThread();
    bool IsActive() { return m_bIsActive; }

    void SendCommand( const MString & sCommandName, const PStack & kParameters );
    void SetNetClass( MercuryObject * pNetClass ) { m_pNetClass = pNetClass; }

    void AttachParent( MercuryNetServer * pParent ) { m_pParent = pParent; }
protected:
    MercuryNetServer * m_pParent;
    MercuryObject * m_pNetClass;
    MercuryThread   m_thdMain;
    bool            m_bIsActive;
    ezSockets   *   m_pConnection;
    float           m_fHalfPing;
    friend class MercuryNetServer;
};

//Default server connection.  Your game probably will not use these.
MercuryNetServerConnection * DefaultSocketConnection(ezSockets * pAccepted); 

typedef MercuryNetServerConnection * (*GenClientFunction)(ezSockets * pAccepted);

class MercuryNetServer
{
public:
    MercuryNetServer();
    ~MercuryNetServer();

    void BroadcastToAllClients( const MString & sMessage, const PStack & pParameters );

    bool BindAndListen( int iPort, GenClientFunction cbFunction = &DefaultSocketConnection);

    void LinkODE( MercuryODEWorld * pWorld ) { m_pWorld = pWorld; }
    void Update( const float dTime );

    static void * CoreThreadCaller( void * NetClient );
    static void * CoreUDPThreadCaller( void * NetClient );
    void CoreThread();
    void CoreUDPThread();

    void UpdateODE( const MString & sNameOfObject = "" );
    void UpdateSingleODE( const MString & sObjectName );

protected:
    ezSockets           * m_pListener;
    ezSockets           * m_pUDPListener;


    GenClientFunction   m_cbGenFunction;
    MercuryThread       m_thdMain;
    MercuryThread       m_thdUDPMain;

    MDeque< MercuryNetServerConnection * >  m_vClients;

    MercuryODEWorld * m_pWorld;
    MercuryTimer    m_tmrSync;
    friend class MercuryNetServerConnection;

    float           m_fTimeSinceLastODE;
};


//Utility functions

void NetEncodePStack( ezSocketsPacket & pPacket, const PStack & pParameters );

void NetDecodePStack( ezSocketsPacket & pPacket, PStack & pParameters );
#endif

---

Hosted by