ByteBuffer Class Reference

#include <ByteBuffer.hpp>

Public Member Functions
	ByteBuffer ()
	ByteBuffer (size_t reserve)
	ByteBuffer (ByteBuffer &&buf)
	ByteBuffer (ByteBuffer &buf, size_t len)
	ByteBuffer (ByteBuffer const &right)
ByteBuffer &	operator= (ByteBuffer const &right)
virtual	~ByteBuffer ()
void	clear ()
void	reset ()
template<typename T >
void	append (T value)
template<typename T >
void	put (size_t pos, T value)
ByteBuffer &	operator<< (uint8_t value)
ByteBuffer &	operator<< (uint16_t value)
ByteBuffer &	operator<< (uint32_t value)
ByteBuffer &	operator<< (uint64_t value)
ByteBuffer &	operator<< (int8_t value)
ByteBuffer &	operator<< (int16_t value)
ByteBuffer &	operator<< (int32_t value)
ByteBuffer &	operator<< (int64_t value)
ByteBuffer &	operator<< (float value)
ByteBuffer &	operator<< (double value)
ByteBuffer &	operator>> (bool &value)
ByteBuffer &	operator>> (uint8_t &value)
ByteBuffer &	operator>> (uint16_t &value)
ByteBuffer &	operator>> (uint32_t &value)
ByteBuffer &	operator>> (uint64_t &value)
ByteBuffer &	operator>> (int8_t &value)
ByteBuffer &	operator>> (int16_t &value)
ByteBuffer &	operator>> (int32_t &value)
ByteBuffer &	operator>> (int64_t &value)
ByteBuffer &	operator>> (float &value)
ByteBuffer &	operator>> (double &value)
uint8_t &	operator[] (size_t const pos)
uint8_t const &	operator[] (size_t const pos) const
size_t	rpos () const
size_t	rpos (size_t rpos_)
uint8_t *	contents ()
uint8_t const *	contents () const
void	finish_reading ()
void	read_completed (size_t bytes)
void	write_completed (size_t bytes)
size_t	wpos () const
uint8_t *	get_base_pointer ()
uint8_t *	get_read_pointer ()
uint8_t *	get_write_pointer ()
std::string	to_string ()
size_t	maximum_length () const
size_t	active_length () const
size_t	remaining_space () const
bool	is_empty () const
void	flush ()
void	ensure_free_space ()
void	resize (size_t new_size)
void	reserve (size_t ressize)
template<typename T >
void	read_skip ()
void	read_skip (size_t skip)
template<typename T >
T	read ()
template<typename T >
T	read (size_t pos) const
void	read (char *dest, size_t len)
void	read (ByteBuffer &buf, size_t len)
void	append (const char *src, size_t size)
void	append (std::string string)
template<class T >
void	append (const T *src, size_t size)
template<class T , class SubT >
void	append (const T *t, size_t t_size, const SubT *sub_t, int count)
void	append (const uint8_t *src, size_t cnt)
void	append (const ByteBuffer &buffer)
void	put (size_t pos, const uint8_t *src, size_t cnt)
void	print_storage () const
void	textlike () const
void	hexlike () const
template<typename SizeT = uint16_t, typename std::enable_if< std::is_integral< SizeT >::value >::type * = nullptr>
void	emplace_size (std::size_t pos=2)
template<>
void	read_skip ()

Static Public Attributes
static const size_t	DEFAULT_SIZE = 0x1000

Protected Attributes
size_t	_rpos {0}
size_t	_wpos {0}
std::vector< uint8_t >	_storage

Constructor & Destructor Documentation

ByteBuffer() [1/5]

ByteBuffer::ByteBuffer ( )

inline

    : _rpos(0), _wpos(0)
    {
        _storage.reserve(DEFAULT_SIZE);
    }

References _storage, and DEFAULT_SIZE.

ByteBuffer() [2/5]

ByteBuffer::ByteBuffer ( size_t  reserve )

inline

    : _rpos(0), _wpos(0)
    {
        _storage.reserve(reserve);
    }

References _storage, and reserve().

Here is the call graph for this function:

ByteBuffer() [3/5]

ByteBuffer::ByteBuffer ( ByteBuffer &&  buf )

inline

    : _rpos(buf._rpos), _wpos(buf._wpos), _storage(std::move(buf._storage))
    { }

ByteBuffer() [4/5]

ByteBuffer::ByteBuffer ( ByteBuffer &  buf, size_t  len  )

inline

    : _rpos(0)
    {   
        _storage.resize(len);
        // copy len bytes from buf
        std::memcpy(&_storage[_wpos], buf.contents(), len);
        _wpos = len;
        buf._rpos += len;
    }

References _rpos, _storage, _wpos, and contents().

Here is the call graph for this function:

ByteBuffer() [5/5]

ByteBuffer::ByteBuffer ( ByteBuffer const &  right )

inline

    : _rpos(right._rpos), _wpos(right._wpos), _storage(right._storage)
    { }

~ByteBuffer()

virtual ByteBuffer::~ByteBuffer ( )

inlinevirtual

    { }

Member Function Documentation

active_length()

size_t ByteBuffer::active_length ( ) const

inline

{ return _wpos - _rpos; }

References _rpos, and _wpos.

Referenced by flush(), hexlike(), GridPlayerNotifier::notify(), Horizon::Auth::AuthSocket::read_handler(), Horizon::Char::CharSocket::read_handler(), Horizon::Zone::ZoneSocket::read_handler(), textlike(), Horizon::Auth::AuthSession::transmit_buffer(), Horizon::Char::CharSession::transmit_buffer(), Horizon::Zone::ZoneSession::transmit_buffer(), and Horizon::Networking::Socket< SocketType >::write_buffer_and_send().

Here is the caller graph for this function:

append() [1/7]

void ByteBuffer::append ( const ByteBuffer &  buffer )

inline

    {
        if (buffer.wpos())
            append(buffer.contents(), buffer.wpos());
    }

References append(), contents(), and wpos().

Here is the call graph for this function:

append() [2/7]

void ByteBuffer::append ( const char *  src, size_t  size  )

inline

    {
        append((const uint8_t *)src, size);
    }

References append().

Here is the call graph for this function:

append() [3/7]

template<class T >

void ByteBuffer::append ( const T *  src, size_t  size  )

inline

    {
        append((const uint8_t *) src, size);
    }

References append().

Here is the call graph for this function:

append() [4/7]

template<class T , class SubT >

void ByteBuffer::append ( const T *  t, size_t  t_size, const SubT *  sub_t, int  count  )

inline

    {
        append((const uint8_t *) t, t_size);
        append((const uint8_t *) sub_t, sizeof(SubT) * count);
    }

References append(), and GridTypeListIterator::count().

Here is the call graph for this function:

append() [5/7]

void ByteBuffer::append ( const uint8_t *  src, size_t  cnt  )

inline

    {
        if (!cnt)
            throw ByteBufferSourceException(_wpos, maximum_length(), cnt);
 
        if (!src)
            throw ByteBufferSourceException(_wpos, maximum_length(), cnt);
 
        assert(maximum_length() < 10000000);
 
        size_t const newSize = _wpos + cnt;
        if (_storage.capacity() < newSize) // custom memory allocation rules
        {
            if (newSize < 100)
                _storage.reserve(300);
            else if (newSize < 750)
                _storage.reserve(2500);
            else if (newSize < 6000)
                _storage.reserve(10000);
            else
                _storage.reserve(400000);
        }
 
        if (_storage.size() < newSize)
            _storage.resize(newSize);
        std::memcpy(&_storage[_wpos], src, cnt);
        _wpos = newSize;
    }

References _storage, _wpos, and maximum_length().

Here is the call graph for this function:

append() [6/7]

void ByteBuffer::append ( std::string  string )

inline

    {
        append(string.c_str(), string.size());
    }

References append().

Here is the call graph for this function:

append() [7/7]

template<typename T >

void ByteBuffer::append ( T  value )

inline

    {
        append((uint8_t *)&value, sizeof(value));
    }

References append().

Referenced by append(), Horizon::Char::HC_ACK_CHARINFO_PER_PAGE::prepare(), Horizon::Char::HC_ACCEPT_ENTER::prepare(), Horizon::Auth::AuthSocket::read_handler(), Horizon::Char::CharSocket::read_handler(), Horizon::Zone::ZoneSocket::read_handler(), Horizon::Auth::AC_ACCEPT_LOGIN::serialize(), Horizon::Auth::AC_LOGIN_OTP::serialize(), Horizon::Auth::AC_REFUSE_LOGIN::serialize(), Horizon::Char::HC_ACCEPT_ENTER2::serialize(), Horizon::Char::HC_ACCEPT_MAKECHAR::serialize(), Horizon::Char::HC_NOTIFY_ZONESVR::serialize(), Horizon::Zone::ZC_ACCEPT_ENTER::serialize(), Horizon::Zone::ZC_ACCEPT_ENTER2::serialize(), Horizon::Zone::ZC_ACCEPT_ENTER3::serialize(), Horizon::Zone::ZC_ACK_ACCOUNTNAME::serialize(), Horizon::Zone::ZC_ACK_BAN_GUILD::serialize(), Horizon::Zone::ZC_ACK_BAN_GUILD_SSO::serialize(), Horizon::Zone::ZC_ACK_CHANGE_GUILD_POSITIONINFO::serialize(), Horizon::Zone::ZC_ACK_LEAVE_GUILD::serialize(), Horizon::Zone::ZC_ACK_RANKING::serialize(), Horizon::Zone::ZC_ACK_REQNAMEALL::serialize(), Horizon::Zone::ZC_ACK_REQNAMEALL2::serialize(), Horizon::Zone::ZC_ACK_REQ_JOIN_GROUP::serialize(), Horizon::Zone::ZC_ADD_MEMBER_TO_GROUP::serialize(), Horizon::Zone::ZC_BAN_LIST::serialize(), Horizon::Zone::ZC_CHANGE_CHATROOM::serialize(), Horizon::Zone::ZC_ENTER_ROOM::serialize(), Horizon::Zone::ZC_GROUP_LIST::serialize(), Horizon::Zone::ZC_GUILD_CHAT::serialize(), Horizon::Zone::ZC_GUILD_INFO::serialize(), Horizon::Zone::ZC_GUILD_INFO2::serialize(), Horizon::Zone::ZC_GUILD_NOTICE::serialize(), Horizon::Zone::ZC_GUILD_POSITION::serialize(), Horizon::Zone::ZC_GUILD_SKILLINFO::serialize(), Horizon::Zone::ZC_INVENTORY_START::serialize(), Horizon::Zone::ZC_MEMBERMGR_INFO::serialize(), Horizon::Zone::ZC_MENU_LIST::serialize(), Horizon::Zone::ZC_MYGUILD_BASIC_INFO::serialize(), Horizon::Zone::ZC_NOTIFY_ACT::serialize(), Horizon::Zone::ZC_NOTIFY_CHAT::serialize(), Horizon::Zone::ZC_NOTIFY_MOVE::serialize(), Horizon::Zone::ZC_NOTIFY_MOVEENTRY11::serialize(), Horizon::Zone::ZC_NOTIFY_NEWENTRY11::serialize(), Horizon::Zone::ZC_NOTIFY_PLAYERCHAT::serialize(), Horizon::Zone::ZC_NOTIFY_PLAYERMOVE::serialize(), Horizon::Zone::ZC_NOTIFY_STANDENTRY11::serialize(), Horizon::Zone::ZC_NPCACK_MAPMOVE::serialize(), Horizon::Zone::ZC_PARTY_JOIN_REQ::serialize(), Horizon::Zone::ZC_PARTY_JOIN_REQ_ACK::serialize(), Horizon::Zone::ZC_POSITION_ID_NAME_INFO::serialize(), Horizon::Zone::ZC_REQ_ADD_FRIENDS::serialize(), Horizon::Zone::ZC_REQ_ALLY_GUILD::serialize(), Horizon::Zone::ZC_REQ_JOIN_GROUP::serialize(), Horizon::Zone::ZC_REQ_JOIN_GUILD::serialize(), Horizon::Zone::ZC_ROLE_CHANGE::serialize(), Horizon::Zone::ZC_ROOM_NEWENTRY::serialize(), Horizon::Zone::ZC_SKILLINFO_LIST::serialize(), Horizon::Zone::ZC_STORE_ITEMLIST_EQUIP_V6::serialize(), Horizon::Zone::ZC_STORE_ITEMLIST_NORMAL_V5::serialize(), Horizon::Zone::ZC_UPDATE_GDID::serialize(), Horizon::Zone::ZC_WHISPER::serialize(), and Horizon::Auth::CA_LOGIN::serialize().

Here is the call graph for this function:

clear()

void ByteBuffer::clear ( )

inline

    {
        _storage.clear();
        reset();
    }

References _storage, and reset().

Here is the call graph for this function:

contents() [1/2]

uint8_t * ByteBuffer::contents ( )

inline

    {
        if (_storage.empty())
            throw ByteBufferException();
        return _storage.data();
    }

References _storage.

Referenced by append(), and ByteBuffer().

Here is the caller graph for this function:

contents() [2/2]

uint8_t const * ByteBuffer::contents ( ) const

inline

    {
        if (_storage.empty())
            throw ByteBufferException();
        return _storage.data();
    }

References _storage.

emplace_size()

template<typename SizeT = uint16_t, typename std::enable_if< std::is_integral< SizeT >::value >::type * = nullptr>

void ByteBuffer::emplace_size ( std::size_t  pos = 2 )

inline

    {
        _storage.emplace(_storage.begin() + pos, 0);
        _storage.emplace(_storage.begin() + pos + 1, 0);
        _wpos += 2;
        put(pos, (uint8_t *) &_wpos, sizeof(SizeT));
    }

References _storage, _wpos, and put().

Here is the call graph for this function:

ensure_free_space()

void ByteBuffer::ensure_free_space ( )

inline

    {
        // resize buffer if it's already full
        if (remaining_space() == 0)
            _storage.resize(_storage.size() * 3 / 2);
    }

References _storage, and remaining_space().

Referenced by Horizon::Networking::Socket< SocketType >::async_read(), and Horizon::Networking::Socket< SocketType >::async_read_with_callback().

Here is the call graph for this function:

Here is the caller graph for this function:

finish_reading()

void ByteBuffer::finish_reading ( )

inline

{ _rpos = wpos(); }

References _rpos, and wpos().

Here is the call graph for this function:

flush()

void ByteBuffer::flush ( )

inline

    {
        if (_rpos) {
            if (_rpos != _wpos)
                memmove(get_base_pointer(), get_read_pointer(), active_length());
            _wpos -= _rpos;
            _rpos = 0;
        }
    }

References _rpos, _wpos, active_length(), get_base_pointer(), and get_read_pointer().

Referenced by Horizon::Networking::Socket< SocketType >::async_read(), and Horizon::Networking::Socket< SocketType >::async_read_with_callback().

Here is the call graph for this function:

Here is the caller graph for this function:

get_base_pointer()

uint8_t * ByteBuffer::get_base_pointer ( )

inline

{ return _storage.data(); }

References _storage.

Referenced by flush(), get_read_pointer(), and get_write_pointer().

Here is the caller graph for this function:

get_read_pointer()

uint8_t * ByteBuffer::get_read_pointer ( )

inline

{ return get_base_pointer() + _rpos; }

References _rpos, and get_base_pointer().

Referenced by flush(), to_string(), Horizon::Auth::AuthSession::transmit_buffer(), Horizon::Char::CharSession::transmit_buffer(), Horizon::Zone::ZoneSession::transmit_buffer(), and Horizon::Networking::Socket< SocketType >::write_buffer_and_send().

Here is the call graph for this function:

Here is the caller graph for this function:

get_write_pointer()

uint8_t * ByteBuffer::get_write_pointer ( )

inline

{ return get_base_pointer() + _wpos; }

References _wpos, and get_base_pointer().

Referenced by Horizon::Networking::Socket< SocketType >::async_read(), Horizon::Networking::Socket< SocketType >::async_read_with_callback(), and to_string().

Here is the call graph for this function:

Here is the caller graph for this function:

hexlike()

void ByteBuffer::hexlike

(

)

const

{
    uint32_t j = 1, k = 1;
 
    std::ostringstream o;
    o << "STORAGE_SIZE: " << active_length();
 
    for (uint32_t i = 0; i < active_length(); ++i)
    {
        char buf[3];
        snprintf(buf, 3, "%2X ", read<uint8_t>(i));
        if ((i == (j * 8)) && ((i != (k * 16))))
        {
            o << "| ";
            ++j;
        }
        else if (i == (k * 16))
        {
            o << "\n";
            ++k;
            ++j;
        }
 
        o << buf;
    }
    o << " ";
 
    std::cout << o.str() << std::endl;
 
    //TC_LOG_TRACE("network", "%s", o.str().c_str());
}

References active_length().

Here is the call graph for this function:

is_empty()

bool ByteBuffer::is_empty ( ) const

inline

{ return _storage.empty(); }

References _storage.

Referenced by Horizon::Auth::AuthSession::transmit_buffer(), Horizon::Char::CharSession::transmit_buffer(), and Horizon::Zone::ZoneSession::transmit_buffer().

Here is the caller graph for this function:

maximum_length()

size_t ByteBuffer::maximum_length ( ) const

inline

{ return _storage.size(); }

References _storage.

Referenced by append(), operator[](), put(), read(), read_skip(), and reserve().

Here is the caller graph for this function:

operator<<() [1/10]

ByteBuffer & ByteBuffer::operator<< ( double  value )

inline

    {
        append<double>(value);
        return *this;
    }

operator<<() [2/10]

ByteBuffer & ByteBuffer::operator<< ( float  value )

inline

    {
        append<float>(value);
        return *this;
    }

operator<<() [3/10]

ByteBuffer & ByteBuffer::operator<< ( int16_t  value )

inline

    {
        append<int16_t>(value);
        return *this;
    }

operator<<() [4/10]

ByteBuffer & ByteBuffer::operator<< ( int32_t  value )

inline

    {
        append<int32_t>(value);
        return *this;
    }

operator<<() [5/10]

ByteBuffer & ByteBuffer::operator<< ( int64_t  value )

inline

    {
        append<int64_t>(value);
        return *this;
    }

operator<<() [6/10]

ByteBuffer & ByteBuffer::operator<< ( int8_t  value )

inline

    {
        append<int8_t>(value);
        return *this;
    }

operator<<() [7/10]

ByteBuffer & ByteBuffer::operator<< ( uint16_t  value )

inline

    {
        append<uint16_t>(value);
        return *this;
    }

operator<<() [8/10]

ByteBuffer & ByteBuffer::operator<< ( uint32_t  value )

inline

    {
        append<uint32_t>(value);
        return *this;
    }

operator<<() [9/10]

ByteBuffer & ByteBuffer::operator<< ( uint64_t  value )

inline

    {
        append<uint64_t>(value);
        return *this;
    }

operator<<() [10/10]

ByteBuffer & ByteBuffer::operator<< ( uint8_t  value )

inline

    {
        append<uint8_t>(value);
        return *this;
    }

operator=()

ByteBuffer & ByteBuffer::operator= ( ByteBuffer const &  right )

inline

    {
        if (this != &right)
        {
            _rpos = right._rpos;
            _wpos = right._wpos;
            _storage = right._storage;
        }
 
        return *this;
    }

References _rpos, _storage, and _wpos.

operator>>() [1/11]

ByteBuffer & ByteBuffer::operator>> ( bool &  value )

inline

    {
        value = read<char>() > 0 ? true : false;
        return *this;
    }

operator>>() [2/11]

ByteBuffer & ByteBuffer::operator>> ( double &  value )

inline

    {
        value = read<double>();
        if (!std::isfinite(value))
            throw ByteBufferException();
        return *this;
    }

operator>>() [3/11]

ByteBuffer & ByteBuffer::operator>> ( float &  value )

inline

    {
        value = read<float>();
        if (!std::isfinite(value))
            throw ByteBufferException();
        return *this;
    }

operator>>() [4/11]

ByteBuffer & ByteBuffer::operator>> ( int16_t &  value )

inline

    {
        value = read<short>();
        return *this;
    }

operator>>() [5/11]

ByteBuffer & ByteBuffer::operator>> ( int32_t &  value )

inline

    {
        value = read<int>();
        return *this;
    }

operator>>() [6/11]

ByteBuffer & ByteBuffer::operator>> ( int64_t &  value )

inline

    {
        value = read<long>();
        return *this;
    }

operator>>() [7/11]

ByteBuffer & ByteBuffer::operator>> ( int8_t &  value )

inline

    {
        value = static_cast<int>(read<signed char>());
        return *this;
    }

operator>>() [8/11]

ByteBuffer & ByteBuffer::operator>> ( uint16_t &  value )

inline

    {
        value = read<unsigned short>();
        return *this;
    }

operator>>() [9/11]

ByteBuffer & ByteBuffer::operator>> ( uint32_t &  value )

inline

    {
        value = read<unsigned int>();
        return *this;
    }

operator>>() [10/11]

ByteBuffer & ByteBuffer::operator>> ( uint64_t &  value )

inline

    {
        value = read<unsigned long>();
        return *this;
    }

operator>>() [11/11]

ByteBuffer & ByteBuffer::operator>> ( uint8_t &  value )

inline

    {
        value = static_cast<int>(read<unsigned char>());
        return *this;
    }

operator[]() [1/2]

uint8_t & ByteBuffer::operator[] ( size_t const  pos )

inline

    {
        if (pos >= maximum_length())
            throw ByteBufferPositionException(false, pos, 1, maximum_length());
        return _storage[pos];
    }

References _storage, and maximum_length().

Here is the call graph for this function:

operator[]() [2/2]

uint8_t const & ByteBuffer::operator[] ( size_t const  pos ) const

inline

    {
        if (pos >= maximum_length())
            throw ByteBufferPositionException(false, pos, 1, maximum_length());
        return _storage[pos];
    }

References _storage, and maximum_length().

Here is the call graph for this function:

print_storage()

void ByteBuffer::print_storage

(

)

const

{
    std::ostringstream o;
    o << "STORAGE_SIZE: " << _storage.size();
    for (uint32_t i = 0; i < _storage.size(); ++i)
        o << read<uint8_t>(i) << " - ";
    o << " ";
 
    std::cout << o.str() << std::endl;
    //TC_LOG_TRACE("network", "%s", o.str().c_str());
}

References _storage.

put() [1/2]

void ByteBuffer::put ( size_t  pos, const uint8_t *  src, size_t  cnt  )

inline

    {
        if (pos + cnt > maximum_length())
            throw ByteBufferPositionException(true, pos, cnt, maximum_length());
 
        if (!src)
            throw ByteBufferSourceException(_wpos, maximum_length(), cnt);
 
        std::memcpy(&_storage[pos], src, cnt);
    }

References _storage, _wpos, and maximum_length().

Here is the call graph for this function:

put() [2/2]

template<typename T >

void ByteBuffer::put ( size_t  pos, T  value  )

inline

    {
        static_assert(std::is_fundamental<T>::value, "append(compound)");
        put(pos, (uint8_t *)&value, sizeof(value));
    }

References put().

Referenced by emplace_size(), and put().

Here is the call graph for this function:

Here is the caller graph for this function:

read() [1/4]

template<typename T >

T ByteBuffer::read ( )

inline

    {
        T r = read<T>(_rpos);
        _rpos += sizeof(T);
        return r;
    }

References _rpos.

Referenced by Horizon::Auth::CA_LOGIN::deserialize(), Horizon::Char::CH_DELETE_CHAR::deserialize(), Horizon::Char::CH_DELETE_CHAR2::deserialize(), Horizon::Char::CH_DELETE_CHAR3::deserialize(), Horizon::Char::CH_EDIT_SECOND_PASSWD::deserialize(), Horizon::Char::CH_MAKE_CHAR::deserialize(), Horizon::Char::CH_MAKE_SECOND_PASSWD::deserialize(), Horizon::Char::CH_SECOND_PASSWD_ACK::deserialize(), Horizon::Zone::CZ_ACK_STORE_PASSWORD::deserialize(), Horizon::Zone::CZ_ADD_FRIENDS::deserialize(), Horizon::Zone::CZ_AUCTION_ITEM_SEARCH::deserialize(), Horizon::Zone::CZ_BATTLEFIELD_CHAT::deserialize(), Horizon::Zone::CZ_BROADCAST::deserialize(), Horizon::Zone::CZ_CHANGE_CHATROOM::deserialize(), Horizon::Zone::CZ_CHECK_RECEIVE_CHARACTER_NAME::deserialize(), Horizon::Zone::CZ_CLAN_CHAT::deserialize(), Horizon::Zone::CZ_CREATE_CHATROOM::deserialize(), Horizon::Zone::CZ_GUILD_CHAT::deserialize(), Horizon::Zone::CZ_GUILD_NOTICE::deserialize(), Horizon::Zone::CZ_INPUT_EDITDLGSTR::deserialize(), Horizon::Zone::CZ_ITEM_CREATE::deserialize(), Horizon::Zone::CZ_ITEM_CREATE_EX::deserialize(), Horizon::Zone::CZ_LOCALBROADCAST::deserialize(), Horizon::Zone::CZ_MAIL_SEND::deserialize(), Horizon::Zone::CZ_MAKE_GROUP::deserialize(), Horizon::Zone::CZ_MAKE_GROUP2::deserialize(), Horizon::Zone::CZ_MOVETO_MAP::deserialize(), Horizon::Zone::CZ_PARTY_JOIN_REQ::deserialize(), Horizon::Zone::CZ_PRIVATE_AIRSHIP_REQUEST::deserialize(), Horizon::Zone::CZ_RECALL::deserialize(), Horizon::Zone::CZ_RECALL_GID::deserialize(), Horizon::Zone::CZ_REGISTER_GUILD_EMBLEM_IMG::deserialize(), Horizon::Zone::CZ_REG_CHANGE_GUILD_POSITIONINFO::deserialize(), Horizon::Zone::CZ_RENAME_MER::deserialize(), Horizon::Zone::CZ_RENAME_PET::deserialize(), Horizon::Zone::CZ_REQUEST_CHAT::deserialize(), Horizon::Zone::CZ_REQUEST_CHAT_PARTY::deserialize(), Horizon::Zone::CZ_REQUEST_MOVE::deserialize(), Horizon::Zone::CZ_REQUEST_MOVE2::deserialize(), Horizon::Zone::CZ_REQUEST_MOVENPC::deserialize(), Horizon::Zone::CZ_REQ_BAN_GUILD::deserialize(), Horizon::Zone::CZ_REQ_DISORGANIZE_GUILD::deserialize(), Horizon::Zone::CZ_REQ_ENTER_ROOM::deserialize(), Horizon::Zone::CZ_REQ_EXPEL_GROUP_MEMBER::deserialize(), Horizon::Zone::CZ_REQ_EXPEL_MEMBER::deserialize(), Horizon::Zone::CZ_REQ_GIVE_MANNER_BYNAME::deserialize(), Horizon::Zone::CZ_REQ_JOIN_GUILD2::deserialize(), Horizon::Zone::CZ_REQ_LEAVE_GUILD::deserialize(), Horizon::Zone::CZ_REQ_MAIL_RETURN::deserialize(), Horizon::Zone::CZ_REQ_MAKE_GUILD::deserialize(), Horizon::Zone::CZ_REQ_OPENSTORE::deserialize(), Horizon::Zone::CZ_REQ_OPENSTORE2::deserialize(), Horizon::Zone::CZ_REQ_OPEN_BUYING_STORE::deserialize(), Horizon::Zone::CZ_REQ_ROLE_CHANGE::deserialize(), Horizon::Zone::CZ_REQ_STATUS_GM::deserialize(), Horizon::Zone::CZ_USE_SKILL_TOGROUND_WITHTALKBOX::deserialize(), Horizon::Zone::CZ_USE_SKILL_TOGROUND_WITHTALKBOX2::deserialize(), and Horizon::Zone::CZ_WHISPER::deserialize().

read() [2/4]

void ByteBuffer::read ( ByteBuffer &  buf, size_t  len  )

inline

    {
        std::memcpy(&buf._storage[buf._wpos], &_storage[_rpos], len);
        buf._wpos += len;
        _rpos += len;
    }

References _rpos, _storage, and _wpos.

read() [3/4]

void ByteBuffer::read ( char *  dest, size_t  len  )

inline

    {
        if (_rpos  + len > maximum_length())
            throw ByteBufferPositionException(false, _rpos, len, maximum_length());
        std::memcpy((void *) dest, &_storage[_rpos], len);
        _rpos += len;
    }

References _rpos, _storage, and maximum_length().

Here is the call graph for this function:

read() [4/4]

template<typename T >

T ByteBuffer::read ( size_t  pos ) const

inline

    {
        if (pos + sizeof(T) > maximum_length())
            throw ByteBufferPositionException(false, pos, sizeof(T), maximum_length());
        T val = *(reinterpret_cast<T const*>(& _storage[pos]));
        return val;
    }

References _storage, and maximum_length().

Here is the call graph for this function:

read_completed()

void ByteBuffer::read_completed ( size_t  bytes )

inline

{ _rpos += bytes; }

References _rpos.

Referenced by Horizon::Auth::AuthSocket::read_handler(), Horizon::Char::CharSocket::read_handler(), and Horizon::Zone::ZoneSocket::read_handler().

Here is the caller graph for this function:

read_skip() [1/3]

template<typename T >

void ByteBuffer::read_skip ( )

inline

{ read_skip(sizeof(T)); }

References read_skip().

Referenced by read_skip().

Here is the call graph for this function:

Here is the caller graph for this function:

read_skip() [2/3]

template<>

void ByteBuffer::read_skip ( )

inline

{
    read_skip<char*>();
}

read_skip() [3/3]

void ByteBuffer::read_skip ( size_t  skip )

inline

    {
        if (_rpos + skip > maximum_length())
            throw ByteBufferPositionException(false, _rpos, skip, maximum_length());
        _rpos += skip;
    }

References _rpos, and maximum_length().

Here is the call graph for this function:

remaining_space()

size_t ByteBuffer::remaining_space ( ) const

inline

{ return _storage.size() - _wpos; }

References _storage, and _wpos.

Referenced by Horizon::Networking::Socket< SocketType >::async_read(), Horizon::Networking::Socket< SocketType >::async_read_with_callback(), and ensure_free_space().

Here is the caller graph for this function:

reserve()

void ByteBuffer::reserve ( size_t  ressize )

inline

    {
        if (ressize > maximum_length())
            _storage.reserve(ressize);
    }

References _storage, and maximum_length().

Referenced by ByteBuffer().

Here is the call graph for this function:

Here is the caller graph for this function:

reset()

void ByteBuffer::reset ( )

inline

    {
        _wpos = 0;
        _rpos = 0;
    }

References _rpos, and _wpos.

Referenced by clear().

Here is the caller graph for this function:

resize()

void ByteBuffer::resize ( size_t  new_size )

inline

    {
        _storage.resize(new_size);
    }

References _storage.

Referenced by Horizon::Networking::Socket< SocketType >::Socket().

Here is the caller graph for this function:

rpos() [1/2]

size_t ByteBuffer::rpos ( ) const

inline

{ return _rpos; }

References _rpos.

rpos() [2/2]

size_t ByteBuffer::rpos ( size_t  rpos_ )

inline

    {
        _rpos = rpos_;
        return _rpos;
    }

References _rpos.

textlike()

void ByteBuffer::textlike

(

)

const

{
    std::ostringstream o;
    o << "STORAGE_SIZE: " << active_length();
    for (uint32_t i = 0; i < active_length(); ++i)
    {
        char buf[2];
        snprintf(buf, 2, "%c", read<uint8_t>(i));
        o << buf;
    }
    o << " ";
    std::cout << o.str() << std::endl;
    //TC_LOG_TRACE("network", "%s", o.str().c_str());
}

References active_length().

Here is the call graph for this function:

to_string()

std::string ByteBuffer::to_string ( )

inline

{ return std::string(get_read_pointer(), get_write_pointer()); }

References get_read_pointer(), and get_write_pointer().

Referenced by Horizon::Char::CharSocket::read_handler(), and Horizon::Auth::AC_ACCEPT_LOGIN::serialize().

Here is the call graph for this function:

Here is the caller graph for this function:

wpos()

size_t ByteBuffer::wpos ( ) const

inline

{ return _wpos; }

References _wpos.

Referenced by append(), and finish_reading().

Here is the caller graph for this function:

write_completed()

void ByteBuffer::write_completed ( size_t  bytes )

inline

{ _wpos += bytes; }

References _wpos.

Referenced by Horizon::Networking::Socket< SocketType >::read_handler_internal().

Here is the caller graph for this function:

Member Data Documentation

_rpos

size_t ByteBuffer::_rpos {0}

protected

Referenced by active_length(), ByteBuffer(), finish_reading(), flush(), get_read_pointer(), operator=(), read(), read_completed(), read_skip(), reset(), and rpos().

_storage

std::vector<uint8_t> ByteBuffer::_storage

protected

Referenced by append(), ByteBuffer(), clear(), contents(), emplace_size(), ensure_free_space(), get_base_pointer(), is_empty(), maximum_length(), operator=(), operator[](), print_storage(), put(), read(), remaining_space(), reserve(), and resize().

_wpos

size_t ByteBuffer::_wpos {0}

protected

Referenced by active_length(), append(), ByteBuffer(), emplace_size(), flush(), get_write_pointer(), operator=(), put(), read(), remaining_space(), reset(), wpos(), and write_completed().

DEFAULT_SIZE

const size_t ByteBuffer::DEFAULT_SIZE = 0x1000

static

Referenced by ByteBuffer().

---

The documentation for this class was generated from the following files:

• src/Libraries/Networking/Buffer/ByteBuffer.hpp
• src/Libraries/Networking/Buffer/ByteBuffer.cpp