NetConnection Class Reference

#include <netConnection.h>

Inheritance diagram for NetConnection:

Detailed Description

Torque network connection.

Introduction

NetConnection is the glue that binds a networked Torque game together. It combines the low-level notify protocol implemented in ConnectionProtocol with a SimGroup to provide a powerful basis for implementing a multiplayer game protocol.

On top of this basis it implements several distinct subsystems:

Event manager, which is responsible for transmitting NetEvents over the wire. It deals with ensuring that the various types of NetEvents are delivered appropriately, and with notifying the event of its delivery status.
Move manager, which is responsible for transferring a Move to the server 32 times a second (on the client) and applying it to the control object (on the server).
Ghost manager, which is responsible for doing scoping calculations (on the server side) and transmitting most-recent ghost information to the client.
File transfer; it is often the case that clients will lack important files when connecting to a server which is running a mod or new map. This subsystem allows the server to transfer such files to the client.
Networked String Table; string data can easily soak up network bandwidth, so for efficiency, we implement a networked string table. We can then notify the connection of strings we will reference often, such as player names, and transmit only a tag, instead of the whole string.
Demo Recording is also implemented in NetConnection. A demo in Torque is a log of the network traffic between client and server; when a NetConnection records a demo, it simply logs this data to a file. When it plays a demo back, it replays the logged data.
The Connection Database is used to keep track of all the NetConnections; it can be iterated over (for instance, to send an event to all active connections), or queried by address.

On Events

The Event Manager is exposed to the outside world via postNetEvent(), which accepts NetEvents.

See also:: NetEvent for a more thorough explanation of how to use events.

On Ghosting and Scoping

Ghosting is the most complex, and most powerful, part of Torque's networking capabilities. It allows the information sent to clients to be very precisely matched to what they need, so that no excess bandwidth is wasted. The control object's onCameraScopeQuery() is called, to determine scoping information for the client; then objects which are in scope are then transmitted to the client, prioritized by the results of their getPriority() method.

There is a cap on the maximum number of ghosts; ghost IDs are currently sent via a 10-bit field, ergo, there is a cap of 1024 objects ghosted per client. This can be easily raised; see the GhostConstants enum.

Each object ghosted is assigned a ghost ID; the client is _only_ aware of the ghost ID. This acts to enhance game security, as it becomes difficult to map objects from one connection to another, or to reliably identify objects from ID alone. IDs are also reassigned based on need, making it hard to track objects that have fallen out of scope (as any object which the player shouldn't see would).

resolveGhost() is used on the client side, and resolveObjectFromGhostIndex() on the server side, to turn ghost IDs into object references.

The NetConnection is a SimGroup. On the client side, it contains all the objects which have been ghosted to that client. On the server side, it is empty; it can be used (typically in script) to hold objects related to the connection. For instance, you might place an observation camera in the NetConnnection. In both cases, when the connection is destroyed, so are the contained objects.

See also:: NetObject, which is the superclass for ghostable objects, and ShapeBase, which is the base for player and vehicle classes.

Ghost manager

enum GhostConstants {
  GhostIdBitSize = 12,
  MaxGhostCount = 1 << GhostIdBitSize,
  GhostLookupTableSize = 1 << GhostIdBitSize,
  GhostIndexBitSize = 4
}

Some configuration values. More...

U32 getGhostsActive ()

bool isGhostingTo ()

Are we ghosting to someone?

bool isGhostingFrom ()

Are we ghosting from someone?

void ghostOnRemove ()

Called by onRemove, to shut down the ghost subsystem.

virtual void doneScopingScene ()

Called when we're done with normal scoping.

void setScopeObject (NetObject *object)

Set the object around which we are currently scoping network traffic.

NetObject * getScopeObject ()

Get the object around which we are currently scoping network traffic.

void objectInScope (NetObject *object)

Add an object to scope.

void objectLocalScopeAlways (NetObject *object)

Add an object to scope, marking that it should always be scoped to this connection.

void objectLocalClearAlways (NetObject *object)

Mark an object that is being ghosted as not always needing to be scoped.

NetObject * resolveGhost (S32 id)

Get a NetObject* from a ghost ID (on client side).

NetObject * resolveObjectFromGhostIndex (S32 id)

Get a NetObject* from a ghost index (on the server side).

S32 getGhostIndex (NetObject *object)

Get the ghost index corresponding to a given NetObject.

void ghostPushNonZero (GhostInfo *gi)

Move a GhostInfo into the nonzero portion of the list (so that we know to update it).

void ghostPushToZero (GhostInfo *gi)

Move a GhostInfo into the zero portion of the list (so that we know not to update it).

void ghostPushZeroToFree (GhostInfo *gi)

Move a GhostInfo from the zero portion of the list to the free portion.

void ghostPushFreeToZero (GhostInfo *info)

Move a GhostInfo from the free portion of the list to the zero portion.

void resetGhosting ()

Stop all ghosting activity and inform the other side about this.

void activateGhosting ()

Activate ghosting, once it's enabled.

bool isGhosting ()

Are we ghosting?

void detachObject (GhostInfo *info)

Begin to stop ghosting an object.

void setGhostAlwaysObject (NetObject *object, U32 index)

Mark an object to be always ghosted. Index is the ghost index of the object.

void sendConnectionMessage (U32 message, U32 sequence=0, U32 ghostCount=0)

Send ghost connection handshake message.

virtual void handleConnectionMessage (U32 message, U32 sequence, U32 ghostCount)

Handle message from sendConnectionMessage().

static Signal< void()> smGhostAlwaysDone

Sends a signal to any object that needs to wait till everything has been ghosted before performing an operation.

enum GhostStates {
  GhostAlwaysDone,
  ReadyForNormalGhosts,
  EndGhosting,
  GhostAlwaysStarting,
  SendNextDownloadRequest,
  FileDownloadSizeMessage,
  NumConnectionMessages
}

void clearGhostInfo ()

bool validateGhostArray ()

void ghostPacketDropped (PacketNotify *notify)

void ghostPacketReceived (PacketNotify *notify)

void ghostWritePacket (BitStream *bstream, PacketNotify *notify)

void ghostReadPacket (BitStream *bstream)

void freeGhostInfo (GhostInfo *)

void ghostWriteStartBlock (ResizeBitStream *stream)

void ghostReadStartBlock (BitStream *stream)

virtual void ghostWriteExtra (NetObject *, BitStream *)

virtual void ghostReadExtra (NetObject *, BitStream *, bool newGhost)

virtual void ghostPreRead (NetObject *, bool newGhost)

GhostInfo ** mGhostArray

Linked list of ghostInfos ghosted by this side of the connection.

U32 mGhostZeroUpdateIndex

Index in mGhostArray of first ghost with 0 update mask.

U32 mGhostFreeIndex

Index in mGhostArray of first free ghost.

U32 mGhostsActive

bool mGhosting

Track actve ghosts on client side Am I currently ghosting objects?

bool mScoping

am I currently scoping objects?

U32 mGhostingSequence

Sequence number describing this ghosting session.

NetObject ** mLocalGhosts

Local ghost for remote object.

GhostInfo * mGhostRefs

Allocated array of ghostInfos. Null if ghostFrom is false.

GhostInfo ** mGhostLookupTable

Table indexed by object id to GhostInfo. Null if ghostFrom is false.

SimObjectPtr< NetObject > mScopeObject

The object around which we are scoping this connection.

Demo Recording

enum DemoBlockTypes {
  BlockTypePacket,
  BlockTypeSendPacket,
  NetConnectionBlockTypeCount
}

enum DemoConstants {
  MaxNumBlockTypes = 16,
  MaxBlockSize = 0x1000
}

bool isRecording ()

bool isPlayingBack ()

U32 getNextBlockType ()

void recordBlock (U32 type, U32 size, void *data)

virtual void handleRecordedBlock (U32 type, U32 size, void *data)

bool processNextBlock ()

bool startDemoRecord (const char *fileName)

bool replayDemoRecord (const char *fileName)

void startDemoRead ()

void stopRecording ()

void stopDemoPlayback ()

virtual void writeDemoStartBlock (ResizeBitStream *stream)

virtual bool readDemoStartBlock (BitStream *stream)

virtual void demoPlaybackComplete ()

Stream * mDemoWriteStream

Stream * mDemoReadStream

U32 mDemoNextBlockType

U32 mDemoNextBlockSize

U32 mDemoWriteStartTime

U32 mDemoReadStartTime

U32 mDemoLastWriteTime

U32 mDemoRealStartTime

Global Connection List

NetConnection * getNext ()

static NetConnection * getConnectionList ()

NetConnection * mNextConnection

Next item in list.

NetConnection * mPrevConnection

Previous item in list.

static NetConnection * mConnectionList

Head of list.

Event Manager

bool postNetEvent (NetEvent *event)

Post an event to this connection.

enum NetEventConstants {
  InvalidSendEventSeq = -1,
  FirstValidSendEventSeq = 0
}

void eventOnRemove ()

void eventPacketDropped (PacketNotify *notify)

void eventPacketReceived (PacketNotify *notify)

void eventWritePacket (BitStream *bstream, PacketNotify *notify)

void eventReadPacket (BitStream *bstream)

void eventWriteStartBlock (ResizeBitStream *stream)

void eventReadStartBlock (BitStream *stream)

NetEventNote * mSendEventQueueHead

NetEventNote * mSendEventQueueTail

NetEventNote * mUnorderedSendEventQueueHead

NetEventNote * mUnorderedSendEventQueueTail

NetEventNote * mWaitSeqEvents

NetEventNote * mNotifyEventList

bool mSendingEvents

S32 mNextSendEventSeq

S32 mNextRecvEventSeq

S32 mLastAckedEventSeq

static FreeListChunker< NetEventNote > mEventNoteChunker

Networked string table

void mapString (U32 netId, NetStringHandle &string)

U32 checkString (NetStringHandle &string, bool *isOnOtherSide=NULL)

U32 getNetSendId (NetStringHandle &string)

void confirmStringReceived (NetStringHandle &string, U32 index)

NetStringHandle translateRemoteStringId (U32 id)

void validateSendString (const char *str)

void packString (BitStream *stream, const char *str)

void unpackString (BitStream *stream, char readBuffer[1024])

void packNetStringHandleU (BitStream *stream, NetStringHandle &h)

NetStringHandle unpackNetStringHandleU (BitStream *stream)

bool mTranslateStrings

ConnectionStringTable * mStringTable

File transfer

bool startSendingFile (const char *fileName)

Start sending the specified file over the link.

void chunkReceived (U8 *chunkData, U32 chunkLen)

Called when we receive a FileChunkEvent.

void sendNextFileDownloadRequest ()

Get the next file...

void sendFileChunk ()

Post the next FileChunkEvent.

virtual void fileDownloadSegmentComplete ()

Called when we finish downloading file data.

void loadNextGhostAlwaysObject (bool hadNewFiles)

This is part of the file transfer logic; basically, we call this every time we finish downloading new files.

Vector< char * > mMissingFileList

List of files missing for this connection.

Stream * mCurrentDownloadingFile

Stream for currently uploading file (if any).

void * mCurrentFileBuffer

Storage for currently downloading file.

U32 mCurrentFileBufferSize

Size of currently downloading file in bytes.

U32 mCurrentFileBufferOffset

Our position in the currently downloading file in bytes.

U32 mNumDownloadedFiles

Number of files we have downloaded.

String mLastFileErrorBuffer

Error storage for file transfers.

Vector< GhostSave > mGhostAlwaysSaveList

List of objects to ghost-always.

Statistics

U32 mLastUpdateTime

F32 mRoundTripTime

F32 mPacketLoss

U32 mSimulatedPing

F32 mSimulatedPacketLoss

State

U32 mProtocolVersion

U32 mSendDelayCredit

U32 mConnectSequence

U32 mAddressDigest [4]

bool mEstablished

bool mMissionPathsSent

NetRate mCurRate

NetRate mMaxRate

SimObjectPtr< NetConnection > mRemoteConnection

If we're doing a "short circuited" connection, this stores a pointer to the other side.

NetAddress mNetAddress

Timeout Management

U32 mPingSendCount

U32 mPingRetryCount

U32 mLastPingSendTime

Connection Table

We store our connections on a hash table so we can quickly find them.

NetConnection * mNextTableHash

static NetConnection * mHashTable [HashTableSize]

Public Types

HashTableSize = 127

ConnectionToServer = BIT(0)

ConnectionToClient = BIT(1)

LocalClientConnection = BIT(2)

NetworkConnection = BIT(3)

NotConnected

AwaitingChallengeResponse

We've sent a challenge request, awaiting the response.

AwaitingConnectRequest

We've received a challenge request and sent a challenge response.

AwaitingConnectResponse

We've received a challenge response and sent a connect request.

Connected

We've accepted a connect request, or we've received a connect response accept.

GhostIdBitSize = 12

MaxGhostCount = 1 << GhostIdBitSize

GhostLookupTableSize = 1 << GhostIdBitSize

GhostIndexBitSize = 4

BlockTypePacket

BlockTypeSendPacket

NetConnectionBlockTypeCount

MaxNumBlockTypes = 16

MaxBlockSize = 0x1000

enum Constants { HashTableSize = 127 }

enum NetConnectionFlags {
  ConnectionToServer = BIT(0),
  ConnectionToClient = BIT(1),
  LocalClientConnection = BIT(2),
  NetworkConnection = BIT(3)
}

enum NetConnectionState {
  NotConnected,
  AwaitingChallengeResponse,
  AwaitingConnectRequest,
  AwaitingConnectResponse,
  Connected
}

Public Member Functions

void sendDisconnectPacket (const char *reason)

virtual bool canRemoteCreate ()

virtual void onTimedOut ()

virtual void onConnectTimedOut ()

virtual void onDisconnect (const char *reason)

virtual void onConnectionRejected (const char *reason)

virtual void onConnectionEstablished (bool isInitiator)

virtual void handleStartupError (const char *errorString)

virtual void writeConnectRequest (BitStream *stream)

virtual bool readConnectRequest (BitStream *stream, const char **errorString)

virtual void writeConnectAccept (BitStream *stream)

virtual bool readConnectAccept (BitStream *stream, const char **errorString)

void connect (const NetAddress *address)

U32 getNetClassGroup ()

void setSimulatedNetParams (F32 packetLoss, U32 ping)

bool isConnectionToServer ()

bool isLocalConnection ()

bool isNetworkConnection ()

void setIsConnectionToServer ()

void setIsLocalClientConnection ()

void setNetworkConnection (bool net)

virtual void setEstablished ()

void setRemoteConnectionObject (NetConnection *connection)

Call this if the "connection" is local to this app. This short-circuits the protocol layer.

void setSequence (U32 connectSequence)

void setAddressDigest (U32 digest[4])

void getAddressDigest (U32 digest[4])

U32 getSequence ()

void setProtocolVersion (U32 protocolVersion)

U32 getProtocolVersion ()

F32 getRoundTripTime ()

F32 getPacketLoss ()

void checkMaxRate ()

void handlePacket (BitStream *stream)

void processRawPacket (BitStream *stream)

void handleNotify (bool recvd)

void handleConnectionEstablished ()

void keepAlive ()

const NetAddress * getNetAddress ()

void setNetAddress (const NetAddress *address)

Net::Error sendPacket (BitStream *stream)

bool checkTimeout (U32 time)

returns true if the connection timed out

void checkPacketSend (bool force)

bool missionPathsSent () const

void setMissionPathsSent (const bool s)

void onRemove ()

Called when the object is removed from the sim.

NetConnection ()

~NetConnection ()

void setConnectionState (U32 state)

U32 getConnectionState ()

void setGhostFrom (bool ghostFrom)

Sets whether ghosts transmit from this side of the connection.

void setGhostTo (bool ghostTo)

Sets whether ghosts are allowed from the other side of the connection.

void setSendingEvents (bool sending)

Sets whether this side actually sends the events that are posted to it.

void setTranslatesStrings (bool xl)

Sets whether this connection is capable of translating strings.

void setNetClassGroup (U32 group)

Sets the group of NetClasses this connection traffics in.

bool isEstablished ()

Is the connection established?

DECLARE_CONOBJECT (NetConnection)

virtual PacketNotify * allocNotify ()

Get a free Notify structure.

Static Public Member Functions

static NetConnection * getConnectionToServer ()

static NetConnection * getLocalClientConnection ()

static void setLocalClientConnection (NetConnection *conn)

static bool filesWereDownloaded ()

static String & getErrorBuffer ()

static void setLastError (const char *fmt,...)

static NetConnection * lookup (const NetAddress *remoteAddress)

Find a NetConnection, if any, with the specified address.

static void consoleInit ()

Register global constant variables and do other one-time initialization tasks in a subclass of ConsoleObject.

Public Attributes

U32 mConnectionSendCount

number of connection messages we've sent.

U32 mConnectionState

State of the connection, from NetConnectionState.

PacketNotify * mNotifyQueueHead

Head of packet notify list.

PacketNotify * mNotifyQueueTail

Tail of packet notify list.

Static Public Attributes

static String mErrorBuffer

Protected Member Functions

SimObjectPtr< NetConnection > getRemoteConnection ()

virtual void readPacket (BitStream *bstream)

virtual void writePacket (BitStream *bstream, PacketNotify *note)

virtual void packetReceived (PacketNotify *note)

virtual void packetDropped (PacketNotify *note)

virtual void connectionError (const char *errorString)

Protected Attributes

U32 mConnectSendCount

U32 mConnectLastSendTime

Static Protected Attributes

static SimObjectPtr< NetConnection > mServerConnection

static SimObjectPtr< NetConnection > mLocalClientConnection

static bool mFilesWereDownloaded

Private Types

typedef SimGroup Parent

InvalidSendEventSeq = -1

FirstValidSendEventSeq = 0

Private Member Functions

void netAddressTableInsert ()

void netAddressTableRemove ()

Private Attributes

BitSet32 mTypeFlags

U32 mNetClassGroup

The NetClassGroup of this connection.

Friends

class NetInterface

Classes

struct GhostRef

Structure to track ghost references in packets. More...

struct GhostSave

Structure to track ghost-always objects and their ghost indices. More...

struct NetRate

struct PacketNotify

Structure to track packets and what we sent over them. More...

Member Typedef Documentation

typedef SimGroup NetConnection::Parent [private]

Reimplemented from SimGroup.

Reimplemented in AIClient, AIConnection, and GameConnection.

Member Enumeration Documentation

enum NetConnection::Constants

Enumerator:

HashTableSize

Reimplemented in GameConnection.

enum NetConnection::NetConnectionFlags

Enumerator:

ConnectionToServer
ConnectionToClient
LocalClientConnection
NetworkConnection

enum NetConnection::NetConnectionState

Enumerator:

NotConnected
AwaitingChallengeResponse	We've sent a challenge request, awaiting the response.
AwaitingConnectRequest	We've received a challenge request and sent a challenge response.
AwaitingConnectResponse	We've received a challenge response and sent a connect request.
Connected	We've accepted a connect request, or we've received a connect response accept.

enum NetConnection::NetEventConstants [private]

Enumerator:

InvalidSendEventSeq
FirstValidSendEventSeq

enum NetConnection::GhostStates [protected]

Enumerator:

GhostAlwaysDone
ReadyForNormalGhosts
EndGhosting
GhostAlwaysStarting
SendNextDownloadRequest
FileDownloadSizeMessage
NumConnectionMessages

enum NetConnection::GhostConstants

Some configuration values.

Enumerator:

GhostIdBitSize
MaxGhostCount
GhostLookupTableSize
GhostIndexBitSize

enum NetConnection::DemoBlockTypes

Enumerator:

BlockTypePacket
BlockTypeSendPacket
NetConnectionBlockTypeCount

enum NetConnection::DemoConstants

Enumerator:

MaxNumBlockTypes
MaxBlockSize

Constructor & Destructor Documentation

NetConnection::NetConnection ( )

NetConnection::~NetConnection ( )

Member Function Documentation

void NetConnection::sendDisconnectPacket ( const char * reason )

virtual bool NetConnection::canRemoteCreate ( ) [virtual]

Reimplemented in GameConnection.

virtual void NetConnection::onTimedOut ( ) [virtual]

Reimplemented in GameConnection.

virtual void NetConnection::onConnectTimedOut ( ) [virtual]

Reimplemented in GameConnection.

virtual void NetConnection::onDisconnect ( const char * reason ) [virtual]

Reimplemented in GameConnection.

virtual void NetConnection::onConnectionRejected ( const char * reason ) [virtual]

Reimplemented in GameConnection.

virtual void NetConnection::onConnectionEstablished ( bool isInitiator ) [virtual]

Reimplemented in GameConnection.

virtual void NetConnection::handleStartupError ( const char * errorString ) [virtual]

Reimplemented in GameConnection.

virtual void NetConnection::writeConnectRequest ( BitStream * stream ) [virtual]

Reimplemented in GameConnection.

virtual bool NetConnection::readConnectRequest	(	BitStream *	stream,
		const char **	errorString
	)			`[virtual]`

Reimplemented in GameConnection.

virtual void NetConnection::writeConnectAccept ( BitStream * stream ) [virtual]

Reimplemented in GameConnection.

virtual bool NetConnection::readConnectAccept	(	BitStream *	stream,
		const char **	errorString
	)			`[virtual]`

Reimplemented in GameConnection.

void NetConnection::connect ( const NetAddress * address )

static NetConnection* NetConnection::getConnectionList ( ) [inline, static]

NetConnection* NetConnection::getNext ( ) [inline]

SimObjectPtr<NetConnection> NetConnection::getRemoteConnection ( ) [inline, protected]

static NetConnection* NetConnection::getConnectionToServer ( ) [inline, static]

Reimplemented in GameConnection.

static NetConnection* NetConnection::getLocalClientConnection ( ) [inline, static]

Reimplemented in GameConnection.

static void NetConnection::setLocalClientConnection ( NetConnection * conn ) [inline, static]

U32 NetConnection::getNetClassGroup ( ) [inline]

static bool NetConnection::filesWereDownloaded ( ) [inline, static]

static String& NetConnection::getErrorBuffer ( ) [inline, static]

void NetConnection::setSimulatedNetParams	(	F32	packetLoss,
		U32	ping
	)			`[inline]`

bool NetConnection::isConnectionToServer ( ) [inline]

bool NetConnection::isLocalConnection ( ) [inline]

bool NetConnection::isNetworkConnection ( ) [inline]

void NetConnection::setIsConnectionToServer ( ) [inline]

void NetConnection::setIsLocalClientConnection ( ) [inline]

void NetConnection::setNetworkConnection ( bool net ) [inline]

virtual void NetConnection::setEstablished ( ) [virtual]

void NetConnection::setRemoteConnectionObject ( NetConnection * connection ) [inline]

Call this if the "connection" is local to this app. This short-circuits the protocol layer.

void NetConnection::setSequence ( U32 connectSequence )

void NetConnection::setAddressDigest ( U32 digest[4] )

void NetConnection::getAddressDigest ( U32 digest[4] )

U32 NetConnection::getSequence ( )

void NetConnection::setProtocolVersion ( U32 protocolVersion ) [inline]

U32 NetConnection::getProtocolVersion ( ) [inline]

F32 NetConnection::getRoundTripTime ( ) [inline]

F32 NetConnection::getPacketLoss ( ) [inline]

static void NetConnection::setLastError	(	const char *	fmt,
			...
	)			`[static]`

void NetConnection::checkMaxRate ( )

void NetConnection::handlePacket ( BitStream * stream ) [virtual]

Implements ConnectionProtocol.

void NetConnection::processRawPacket ( BitStream * stream ) [virtual]

Reimplemented from ConnectionProtocol.

void NetConnection::handleNotify ( bool recvd ) [virtual]

Implements ConnectionProtocol.

void NetConnection::handleConnectionEstablished ( ) [virtual]

Implements ConnectionProtocol.

void NetConnection::keepAlive ( ) [virtual]

Implements ConnectionProtocol.

const NetAddress* NetConnection::getNetAddress ( )

void NetConnection::setNetAddress ( const NetAddress * address )

Net::Error NetConnection::sendPacket ( BitStream * stream ) [virtual]

Implements ConnectionProtocol.

void NetConnection::netAddressTableInsert ( ) [private]

void NetConnection::netAddressTableRemove ( ) [private]

static NetConnection* NetConnection::lookup ( const NetAddress * remoteAddress ) [static]

Find a NetConnection, if any, with the specified address.

bool NetConnection::checkTimeout ( U32 time )

returns true if the connection timed out

void NetConnection::checkPacketSend ( bool force )

bool NetConnection::missionPathsSent ( ) const [inline]

void NetConnection::setMissionPathsSent ( const bool s ) [inline]

static void NetConnection::consoleInit ( ) [static]

See also:: console

Reimplemented from ConsoleObject.

Reimplemented in GameConnection.

void NetConnection::onRemove ( ) [virtual]

Called when the object is removed from the sim.

Reimplemented from SimGroup.

Reimplemented in GameConnection.

void NetConnection::setConnectionState ( U32 state ) [inline]

U32 NetConnection::getConnectionState ( ) [inline]

void NetConnection::setGhostFrom ( bool ghostFrom )

Sets whether ghosts transmit from this side of the connection.

void NetConnection::setGhostTo ( bool ghostTo )

Sets whether ghosts are allowed from the other side of the connection.

void NetConnection::setSendingEvents ( bool sending )

Sets whether this side actually sends the events that are posted to it.

void NetConnection::setTranslatesStrings ( bool xl )

Sets whether this connection is capable of translating strings.

void NetConnection::setNetClassGroup ( U32 group )

Sets the group of NetClasses this connection traffics in.

bool NetConnection::isEstablished ( ) [inline]

Is the connection established?

NetConnection::DECLARE_CONOBJECT ( NetConnection )

virtual PacketNotify* NetConnection::allocNotify ( ) [virtual]

Get a free Notify structure.

Reimplemented from SimObject.

Reimplemented in GameConnection.

virtual void NetConnection::readPacket ( BitStream * bstream ) [protected, virtual]

Reimplemented in GameConnection.

virtual void NetConnection::writePacket	(	BitStream *	bstream,
		PacketNotify *	note
	)			`[protected, virtual]`

virtual void NetConnection::packetReceived ( PacketNotify * note ) [protected, virtual]

virtual void NetConnection::packetDropped ( PacketNotify * note ) [protected, virtual]

virtual void NetConnection::connectionError ( const char * errorString ) [protected, virtual]

Reimplemented in GameConnection.

void NetConnection::eventOnRemove ( ) [private]

void NetConnection::eventPacketDropped ( PacketNotify * notify ) [private]

void NetConnection::eventPacketReceived ( PacketNotify * notify ) [private]

void NetConnection::eventWritePacket	(	BitStream *	bstream,
		PacketNotify *	notify
	)			`[private]`

void NetConnection::eventReadPacket ( BitStream * bstream ) [private]

void NetConnection::eventWriteStartBlock ( ResizeBitStream * stream ) [private]

void NetConnection::eventReadStartBlock ( BitStream * stream ) [private]

bool NetConnection::postNetEvent ( NetEvent * event )

Post an event to this connection.

void NetConnection::mapString	(	U32	netId,
		NetStringHandle &	string
	)			`[inline]`

U32 NetConnection::checkString	(	NetStringHandle &	string,
		bool *	isOnOtherSide = `NULL`
	)			`[inline]`

U32 NetConnection::getNetSendId ( NetStringHandle & string ) [inline]

void NetConnection::confirmStringReceived	(	NetStringHandle &	string,
		U32	index
	)			`[inline]`

NetStringHandle NetConnection::translateRemoteStringId ( U32 id ) [inline]

void NetConnection::validateSendString ( const char * str )

void NetConnection::packString	(	BitStream *	stream,
		const char *	str
	)

void NetConnection::unpackString	(	BitStream *	stream,
		char	readBuffer[1024]
	)

void NetConnection::packNetStringHandleU	(	BitStream *	stream,
		NetStringHandle &	h
	)

NetStringHandle NetConnection::unpackNetStringHandleU ( BitStream * stream )

void NetConnection::clearGhostInfo ( ) [protected]

bool NetConnection::validateGhostArray ( ) [protected]

void NetConnection::ghostPacketDropped ( PacketNotify * notify ) [protected]

void NetConnection::ghostPacketReceived ( PacketNotify * notify ) [protected]

void NetConnection::ghostWritePacket	(	BitStream *	bstream,
		PacketNotify *	notify
	)			`[protected]`

void NetConnection::ghostReadPacket ( BitStream * bstream ) [protected]

void NetConnection::freeGhostInfo ( GhostInfo * ) [protected]

void NetConnection::ghostWriteStartBlock ( ResizeBitStream * stream ) [protected]

void NetConnection::ghostReadStartBlock ( BitStream * stream ) [protected]

virtual void NetConnection::ghostWriteExtra	(	NetObject *	,
		BitStream *
	)			`[inline, protected, virtual]`

Reimplemented in GameConnection.

virtual void NetConnection::ghostReadExtra	(	NetObject *	,
		BitStream *	,
		bool	newGhost
	)			`[inline, protected, virtual]`

Reimplemented in GameConnection.

virtual void NetConnection::ghostPreRead	(	NetObject *	,
		bool	newGhost
	)			`[inline, protected, virtual]`

Reimplemented in GameConnection.

U32 NetConnection::getGhostsActive ( ) [inline]

bool NetConnection::isGhostingTo ( ) [inline]

Are we ghosting to someone?

bool NetConnection::isGhostingFrom ( ) [inline]

Are we ghosting from someone?

void NetConnection::ghostOnRemove ( )

Called by onRemove, to shut down the ghost subsystem.

virtual void NetConnection::doneScopingScene ( ) [inline, virtual]

Called when we're done with normal scoping.

This gives subclasses a chance to shove things into scope, such as the results of a sensor network calculation, that would otherwise be awkward to add.

Reimplemented in GameConnection.

void NetConnection::setScopeObject ( NetObject * object )

Set the object around which we are currently scoping network traffic.

NetObject* NetConnection::getScopeObject ( )

Get the object around which we are currently scoping network traffic.

void NetConnection::objectInScope ( NetObject * object )

Add an object to scope.

void NetConnection::objectLocalScopeAlways ( NetObject * object )

Add an object to scope, marking that it should always be scoped to this connection.

void NetConnection::objectLocalClearAlways ( NetObject * object )

Mark an object that is being ghosted as not always needing to be scoped.

This undoes objectLocalScopeAlways(), but doesn't immediately flush it from scope.

Instead, the standard scoping mechanisms will clear it from scope when it is appropos to do so.

NetObject* NetConnection::resolveGhost ( S32 id )

Get a NetObject* from a ghost ID (on client side).

NetObject* NetConnection::resolveObjectFromGhostIndex ( S32 id )

Get a NetObject* from a ghost index (on the server side).

S32 NetConnection::getGhostIndex ( NetObject * object )

Get the ghost index corresponding to a given NetObject.

This is only meaningful on the server side.

void NetConnection::ghostPushNonZero ( GhostInfo * gi ) [inline]

Move a GhostInfo into the nonzero portion of the list (so that we know to update it).

void NetConnection::ghostPushToZero ( GhostInfo * gi ) [inline]

Move a GhostInfo into the zero portion of the list (so that we know not to update it).

void NetConnection::ghostPushZeroToFree ( GhostInfo * gi ) [inline]

Move a GhostInfo from the zero portion of the list to the free portion.

void NetConnection::ghostPushFreeToZero ( GhostInfo * info ) [inline]

Move a GhostInfo from the free portion of the list to the zero portion.

void NetConnection::resetGhosting ( )

Stop all ghosting activity and inform the other side about this.

Turns off ghosting.

void NetConnection::activateGhosting ( )

Activate ghosting, once it's enabled.

bool NetConnection::isGhosting ( ) [inline]

Are we ghosting?

void NetConnection::detachObject ( GhostInfo * info )

Begin to stop ghosting an object.

void NetConnection::setGhostAlwaysObject	(	NetObject *	object,
		U32	index
	)

Mark an object to be always ghosted. Index is the ghost index of the object.

void NetConnection::sendConnectionMessage	(	U32	message,
		U32	sequence = `0`,
		U32	ghostCount = `0`
	)

Send ghost connection handshake message.

As part of the ghost connection process, extensive hand-shaking must be performed.

This is done by passing ConnectionMessageEvents; this is a helper function to more effectively perform this task. Messages are dealt with by handleConnectionMessage().

Parameters:

	message	One of GhostStates
	sequence	A sequence number, if any.
	ghostCount	A count of ghosts relating to this message.

virtual void NetConnection::handleConnectionMessage	(	U32	message,
		U32	sequence,
		U32	ghostCount
	)			`[virtual]`

Handle message from sendConnectionMessage().

This is called to handle messages sent via sendConnectionMessage.

Parameters:

	message	One of GhostStates
	sequence	A sequence number, if any.
	ghostCount	A count of ghosts relating to this message.

Reimplemented in GameConnection.

bool NetConnection::startSendingFile ( const char * fileName )

Start sending the specified file over the link.

void NetConnection::chunkReceived	(	U8 *	chunkData,
		U32	chunkLen
	)

Called when we receive a FileChunkEvent.

void NetConnection::sendNextFileDownloadRequest ( )

Get the next file...

void NetConnection::sendFileChunk ( )

Post the next FileChunkEvent.

virtual void NetConnection::fileDownloadSegmentComplete ( ) [virtual]

Called when we finish downloading file data.

Reimplemented in GameConnection.

void NetConnection::loadNextGhostAlwaysObject ( bool hadNewFiles )

This is part of the file transfer logic; basically, we call this every time we finish downloading new files.

It attempts to load the GhostAlways objects; if they fail, it marks an error and we have chance to retry.

bool NetConnection::isRecording ( ) [inline]

bool NetConnection::isPlayingBack ( ) [inline]

U32 NetConnection::getNextBlockType ( ) [inline]

void NetConnection::recordBlock	(	U32	type,
		U32	size,
		void *	data
	)

virtual void NetConnection::handleRecordedBlock	(	U32	type,
		U32	size,
		void *	data
	)			`[virtual]`

Reimplemented in GameConnection.

bool NetConnection::processNextBlock ( )

bool NetConnection::startDemoRecord ( const char * fileName )

bool NetConnection::replayDemoRecord ( const char * fileName )

void NetConnection::startDemoRead ( )

void NetConnection::stopRecording ( )

void NetConnection::stopDemoPlayback ( )

virtual void NetConnection::writeDemoStartBlock ( ResizeBitStream * stream ) [virtual]

Reimplemented from ConnectionProtocol.

Reimplemented in GameConnection.

virtual bool NetConnection::readDemoStartBlock ( BitStream * stream ) [virtual]

Reimplemented from ConnectionProtocol.

Reimplemented in GameConnection.

virtual void NetConnection::demoPlaybackComplete ( ) [virtual]

Reimplemented in GameConnection.

Friends And Related Function Documentation

friend class NetInterface [friend]

Member Data Documentation

NetConnection* NetConnection::mNextConnection [private]

Next item in list.

NetConnection* NetConnection::mPrevConnection [private]

Previous item in list.

NetConnection* NetConnection::mConnectionList [static, private]

Head of list.

BitSet32 NetConnection::mTypeFlags [private]

U32 NetConnection::mNetClassGroup [private]

The NetClassGroup of this connection.

U32 NetConnection::mLastUpdateTime [private]

F32 NetConnection::mRoundTripTime [private]

F32 NetConnection::mPacketLoss [private]

U32 NetConnection::mSimulatedPing [private]

F32 NetConnection::mSimulatedPacketLoss [private]

U32 NetConnection::mProtocolVersion [private]

U32 NetConnection::mSendDelayCredit [private]

U32 NetConnection::mConnectSequence [private]

Reimplemented from ConnectionProtocol.

U32 NetConnection::mAddressDigest[4] [private]

bool NetConnection::mEstablished [private]

bool NetConnection::mMissionPathsSent [private]

NetRate NetConnection::mCurRate [private]

NetRate NetConnection::mMaxRate [private]

SimObjectPtr<NetConnection> NetConnection::mRemoteConnection [private]

If we're doing a "short circuited" connection, this stores a pointer to the other side.

NetAddress NetConnection::mNetAddress [private]

U32 NetConnection::mPingSendCount [private]

U32 NetConnection::mPingRetryCount [private]

U32 NetConnection::mLastPingSendTime [private]

NetConnection* NetConnection::mNextTableHash [private]

NetConnection* NetConnection::mHashTable[HashTableSize] [static, private]

SimObjectPtr<NetConnection> NetConnection::mServerConnection [static, protected]

SimObjectPtr<NetConnection> NetConnection::mLocalClientConnection [static, protected]

bool NetConnection::mFilesWereDownloaded [static, protected]

U32 NetConnection::mConnectSendCount [protected]

U32 NetConnection::mConnectLastSendTime [protected]

String NetConnection::mErrorBuffer [static]

U32 NetConnection::mConnectionSendCount

number of connection messages we've sent.

U32 NetConnection::mConnectionState

State of the connection, from NetConnectionState.

PacketNotify* NetConnection::mNotifyQueueHead

Head of packet notify list.

PacketNotify* NetConnection::mNotifyQueueTail

Tail of packet notify list.

NetEventNote* NetConnection::mSendEventQueueHead [private]

NetEventNote* NetConnection::mSendEventQueueTail [private]

NetEventNote* NetConnection::mUnorderedSendEventQueueHead [private]

NetEventNote* NetConnection::mUnorderedSendEventQueueTail [private]

NetEventNote* NetConnection::mWaitSeqEvents [private]

NetEventNote* NetConnection::mNotifyEventList [private]

FreeListChunker<NetEventNote> NetConnection::mEventNoteChunker [static, private]

bool NetConnection::mSendingEvents [private]

S32 NetConnection::mNextSendEventSeq [private]

S32 NetConnection::mNextRecvEventSeq [private]

S32 NetConnection::mLastAckedEventSeq [private]

bool NetConnection::mTranslateStrings [private]

ConnectionStringTable* NetConnection::mStringTable [private]

GhostInfo** NetConnection::mGhostArray [protected]

Linked list of ghostInfos ghosted by this side of the connection.

U32 NetConnection::mGhostZeroUpdateIndex [protected]

Index in mGhostArray of first ghost with 0 update mask.

U32 NetConnection::mGhostFreeIndex [protected]

Index in mGhostArray of first free ghost.

U32 NetConnection::mGhostsActive [protected]

bool NetConnection::mGhosting [protected]

Track actve ghosts on client side Am I currently ghosting objects?

bool NetConnection::mScoping [protected]

am I currently scoping objects?

U32 NetConnection::mGhostingSequence [protected]

Sequence number describing this ghosting session.

NetObject** NetConnection::mLocalGhosts [protected]

Local ghost for remote object.

mLocalGhosts pointer is NULL if mGhostTo is false

GhostInfo* NetConnection::mGhostRefs [protected]

Allocated array of ghostInfos. Null if ghostFrom is false.

GhostInfo** NetConnection::mGhostLookupTable [protected]

Table indexed by object id to GhostInfo. Null if ghostFrom is false.

SimObjectPtr<NetObject> NetConnection::mScopeObject [protected]

The object around which we are scoping this connection.

This is usually the player object, or a related object, like a vehicle that the player is driving.

Signal<void()> NetConnection::smGhostAlwaysDone [static]

Sends a signal to any object that needs to wait till everything has been ghosted before performing an operation.

Vector<char *> NetConnection::mMissingFileList [protected]

List of files missing for this connection.

The currently downloading file is always first in the list (ie, [0]).

Stream* NetConnection::mCurrentDownloadingFile [protected]

Stream for currently uploading file (if any).

void* NetConnection::mCurrentFileBuffer [protected]

Storage for currently downloading file.

U32 NetConnection::mCurrentFileBufferSize [protected]

Size of currently downloading file in bytes.

U32 NetConnection::mCurrentFileBufferOffset [protected]

Our position in the currently downloading file in bytes.

U32 NetConnection::mNumDownloadedFiles [protected]

Number of files we have downloaded.

String NetConnection::mLastFileErrorBuffer [protected]

Error storage for file transfers.

Vector<GhostSave> NetConnection::mGhostAlwaysSaveList [protected]

List of objects to ghost-always.

Stream* NetConnection::mDemoWriteStream [private]

Stream* NetConnection::mDemoReadStream [private]

U32 NetConnection::mDemoNextBlockType [private]

U32 NetConnection::mDemoNextBlockSize [private]

U32 NetConnection::mDemoWriteStartTime [private]

U32 NetConnection::mDemoReadStartTime [private]

U32 NetConnection::mDemoLastWriteTime [private]

U32 NetConnection::mDemoRealStartTime [private]