StreamPacketizer Class Reference

#include "StreamPacketizer.h"

Collaboration diagram for StreamPacketizer:

Public Member Functions
	~StreamPacketizer ()
void	InputData (const Buffer &data)
void	Process ()
Buffer *	PopPacket ()
void	ClearBuffers ()

Protected Attributes
Buffer	mBuffer
std::queue< Buffer * >	mPackets

Detailed Description

Definition at line 31 of file StreamPacketizer.h.

Constructor & Destructor Documentation

StreamPacketizer::~StreamPacketizer

(

)

Definition at line 30 of file StreamPacketizer.cpp.

References ClearBuffers().

{
    ClearBuffers();
}

Here is the call graph for this function:

Member Function Documentation

void StreamPacketizer::ClearBuffers

(

)

Definition at line 72 of file StreamPacketizer.cpp.

References PopPacket(), and SafeDelete().

Referenced by EVETCPConnection::ClearBuffers(), and ~StreamPacketizer().

{
    Buffer* buf(nullptr);
    while ((buf = PopPacket()))
        SafeDelete( buf );
}

Here is the call graph for this function:

Here is the caller graph for this function:

void StreamPacketizer::InputData

(

const Buffer &

data

)

Definition at line 35 of file StreamPacketizer.cpp.

References Buffer::AppendSeq(), Buffer::begin(), Buffer::end(), and mBuffer.

Referenced by EVETCPConnection::ProcessReceivedData().

{
    mBuffer.AppendSeq( data.begin<uint8>(), data.end<uint8>() );
}

Here is the call graph for this function:

Here is the caller graph for this function:

Buffer * StreamPacketizer::PopPacket

(

)

Definition at line 61 of file StreamPacketizer.cpp.

References mPackets.

Referenced by ClearBuffers(), EVETCPConnection::PopRep(), and tcp_callback().

{
    Buffer* buf(nullptr);
    if (!mPackets.empty()) {
        buf = mPackets.front();
        mPackets.pop();
    }

    return buf;
}

Here is the caller graph for this function:

void StreamPacketizer::Process

(

)

Definition at line 40 of file StreamPacketizer.cpp.

References Buffer::const_iterator< T >::As(), Buffer::AssignSeq(), Buffer::begin(), Buffer::end(), mBuffer, and mPackets.

Referenced by EVETCPConnection::ProcessReceivedData().

{
    Buffer::const_iterator<uint8> cur = mBuffer.begin<uint8>(), end = mBuffer.end<uint8>();
    while( true ) {
        if (sizeof(uint32) > (end - cur))
            break;

        const Buffer::const_iterator<uint32> len = cur.As<uint32>();
        const Buffer::const_iterator<uint8> start = ( len + 1 ).As<uint8>();

        if (*len > (uint32)(end - start))
            break;

        mPackets.push( new Buffer(start, start + *len));
        cur = (start + *len);
    }

    if( cur != mBuffer.begin<uint8>() )
        mBuffer.AssignSeq( cur, end );
}

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

Buffer StreamPacketizer::mBuffer

protected

Definition at line 44 of file StreamPacketizer.h.

Referenced by InputData(), and Process().

std::queue<Buffer*> StreamPacketizer::mPackets

protected

Definition at line 46 of file StreamPacketizer.h.

Referenced by PopPacket(), and Process().

---

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

• /backups/local/src/eve/EvEmu_Crucible/src/eve-core/network/StreamPacketizer.h
• /backups/local/src/eve/EvEmu_Crucible/src/eve-core/network/StreamPacketizer.cpp