zdoom/gzdoom
0
0
Fork 0
mirror of https://github.com/ZDoom/gzdoom.git synced 2025-03-02 15:42:17 +00:00
Code Issues Projects Releases Packages Wiki Activity

added Zandronum's NETBUFFER_s

Browse source
This commit is contained in:
Benjamin Berkels 2018-07-22 16:01:13 +02:00
parent b3361bb833
commit 7117af6b66
2 changed files with 138 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

101
src/d_netsync.cpp
View file

@ -76,6 +76,22 @@ void NETWORK_WriteByte( BYTESTREAM_s *pByteStream, int Byte )
NETWORK_AdvanceByteStreamPointer ( pByteStream, 1, true );
}
//*****************************************************************************
//
void NETWORK_WriteBuffer( BYTESTREAM_s *pByteStream, const void *pvBuffer, int nLength )
{
if (( pByteStream->pbStream + nLength ) > pByteStream->pbStreamEnd )
{
Printf( "NETWORK_WriteLBuffer: Overflow!\n" );
return;
}
memcpy( pByteStream->pbStream, pvBuffer, nLength );
// Advance the pointer.
NETWORK_AdvanceByteStreamPointer ( pByteStream, nLength, true );
}
//*****************************************************************************
//
void NetSyncData::AssignNetID ( AActor *pActor )
@ -134,6 +150,91 @@ void BYTESTREAM_s::EnsureBitSpace( int bits, bool writing )
}
}
//*****************************************************************************
//
NETBUFFER_s::NETBUFFER_s ( )
{
this->pbData = NULL;
this->ulMaxSize = 0;
this->BufferType = (BUFFERTYPE_e)0;
Clear();
}
//*****************************************************************************
//
NETBUFFER_s::NETBUFFER_s ( const NETBUFFER_s &Buffer )
{
Init ( Buffer.ulMaxSize, Buffer.BufferType );
Clear();
memcpy( this->pbData, Buffer.pbData, Buffer.ulMaxSize );
this->ByteStream.pbStream = this->pbData + ( Buffer.ByteStream.pbStream - Buffer.pbData );
this->ByteStream.pbStreamEnd = this->pbData + ( Buffer.ByteStream.pbStreamEnd - Buffer.pbData );
this->ByteStream.bitShift = Buffer.ByteStream.bitShift;
if ( Buffer.ByteStream.bitBuffer != NULL )
this->ByteStream.bitBuffer = this->ByteStream.pbStream + ( Buffer.ByteStream.bitBuffer - Buffer.ByteStream.pbStream );
this->ulCurrentSize = Buffer.ulCurrentSize;
}
//*****************************************************************************
//
void NETBUFFER_s::Init( unsigned int ulLength, BUFFERTYPE_e BufferType )
{
memset( this, 0, sizeof( *this ));
this->ulMaxSize = ulLength;
this->pbData = new uint8_t[ulLength];
this->BufferType = BufferType;
}
//*****************************************************************************
//
void NETBUFFER_s::Free()
{
if ( this->pbData )
{
delete[] ( this->pbData );
this->pbData = NULL;
}
this->ulMaxSize = 0;
this->BufferType = (BUFFERTYPE_e)0;
}
//*****************************************************************************
//
void NETBUFFER_s::Clear()
{
this->ulCurrentSize = 0;
this->ByteStream.pbStream = this->pbData;
this->ByteStream.bitBuffer = NULL;
this->ByteStream.bitShift = -1;
if ( this->BufferType == BUFFERTYPE_READ )
this->ByteStream.pbStreamEnd = this->ByteStream.pbStream;
else
this->ByteStream.pbStreamEnd = this->ByteStream.pbStream + this->ulMaxSize;
}
//*****************************************************************************
//
int NETBUFFER_s::CalcSize() const
{
if ( this->BufferType == BUFFERTYPE_READ )
return ( int( this->ByteStream.pbStreamEnd - this->ByteStream.pbStream ));
else
return ( int( this->ByteStream.pbStream - this->pbData ));
}
//*****************************************************************************
//
int NETBUFFER_s::WriteTo( BYTESTREAM_s &ByteStream ) const
{
int bufferSize = CalcSize();
if ( bufferSize > 0 )
NETWORK_WriteBuffer( &ByteStream, this->pbData, bufferSize );
return bufferSize;
}
//*****************************************************************************
//
template <typename T>

37
src/d_netsync.h
View file

@ -53,6 +53,43 @@ struct BYTESTREAM_s
int bitShift;
};
//*****************************************************************************
enum BUFFERTYPE_e
{
BUFFERTYPE_READ,
BUFFERTYPE_WRITE,
};
//*****************************************************************************
struct NETBUFFER_s
{
// This is the data in our packet.
uint8_t *pbData;
// The maximum amount of data this packet can hold.
unsigned int ulMaxSize;
// How much data is currently in this packet?
unsigned int ulCurrentSize;
// Byte stream for this buffer for managing our current position and where
// the end of the stream is.
BYTESTREAM_s ByteStream;
// Is this a buffer that we write to, or read from?
BUFFERTYPE_e BufferType;
NETBUFFER_s ( );
NETBUFFER_s ( const NETBUFFER_s &Buffer );
void Init( unsigned int ulLength, BUFFERTYPE_e BufferType );
void Free();
void Clear();
int CalcSize() const;
int WriteTo( BYTESTREAM_s &ByteStream ) const;
};
//==========================================================================
//
// IDList