MarshalStream Class Reference

Turns Python objects into marshal bytecode. More...

#include "EVEMarshal.h"

Inheritance diagram for MarshalStream:

Collaboration diagram for MarshalStream:

Public Member Functions
	MarshalStream ()
bool	Save (const PyRep *rep, Buffer &into)

Protected Member Functions
bool	SaveStream (const PyRep *rep)
template<typename T >
void	Put (const T &value)
template<typename Iter >
void	Put (Iter first, Iter last)
void	PutSizeEx (uint32 size)
bool	VisitInteger (const PyInt *rep)
bool	VisitLong (const PyLong *rep)
	Adds a long to the stream. More...
bool	VisitBoolean (const PyBool *rep)
	Adds a boolean to the stream. More...
bool	VisitReal (const PyFloat *rep)
	Adds a double to the stream. More...
bool	VisitNone (const PyNone *rep)
	Adds a None object to the stream. More...
bool	VisitBuffer (const PyBuffer *rep)
	Adds a buffer to the stream. More...
bool	VisitString (const PyString *rep)
	add a string object to the data stream More...
bool	VisitWString (const PyWString *rep)
	add a wide string object to the data stream More...
bool	VisitToken (const PyToken *rep)
	add a token object to the data stream More...
bool	VisitTuple (const PyTuple *rep)
bool	VisitList (const PyList *rep)
bool	VisitDict (const PyDict *rep)
bool	VisitObject (const PyObject *rep)
	Adds an object to the stream. More...
bool	VisitObjectEx (const PyObjectEx *rep)
	Adds a New object to the stream. More...
bool	VisitPackedRow (const PyPackedRow *pyPackedRow)
	Adds a packed row to the stream. More...
bool	VisitSubStruct (const PySubStruct *rep)
	Adds a sub structure to the stream. More...
bool	VisitSubStream (const PySubStream *rep)
	Adds a sub stream to the stream. More...
bool	VisitChecksumedStream (const PyChecksumedStream *rep)
	Adds a checksumed stream to the stream. More...
Protected Member Functions inherited from PyVisitor
virtual	~PyVisitor ()

Private Member Functions
void	SaveVarInteger (const PyLong *v)
bool	SaveRLE (const Buffer &in)

Private Attributes
Buffer *	mBuffer

Detailed Description

Turns Python objects into marshal bytecode.

Author

Captnoord, Bloody.Rabbit

Definition at line 59 of file EVEMarshal.h.

Constructor & Destructor Documentation

MarshalStream::MarshalStream

(

)

initializes object

Definition at line 64 of file EVEMarshal.cpp.

: mBuffer( nullptr )
{
}

Member Function Documentation

template<typename T >

void MarshalStream::Put ( const T &  value )

inlineprotected

adds given value to the data stream

Definition at line 75 of file EVEMarshal.h.

References Buffer::Append(), and mBuffer.

Referenced by SaveRLE(), SaveVarInteger(), VisitBuffer(), VisitString(), VisitSubStream(), VisitToken(), and VisitWString().

{ mBuffer->Append<T>( value ); }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename Iter >

void MarshalStream::Put ( Iter  first, Iter  last  )

inlineprotected

adds given bytes to the data stream

Definition at line 78 of file EVEMarshal.h.

References Buffer::AppendSeq(), and mBuffer.

{ mBuffer->AppendSeq<Iter>( first, last ); }

Here is the call graph for this function:

void MarshalStream::PutSizeEx ( uint32  size )

inlineprotected

utility for extended size.

Definition at line 81 of file EVEMarshal.h.

Referenced by SaveRLE(), SaveVarInteger(), VisitBuffer(), VisitDict(), VisitList(), VisitString(), VisitSubStream(), VisitToken(), VisitTuple(), and VisitWString().

    {
        if( size < 0xFF )
        {
            Put<uint8>( size );
        }
        else
        {
            Put<uint8>( 0xFF );
            Put<uint32>( size );
        }
    }

Here is the caller graph for this function:

bool MarshalStream::Save	(	const PyRep *	rep,
		Buffer &	into
	)

saves given rep to given buffer

Definition at line 69 of file EVEMarshal.cpp.

References mBuffer, and SaveStream().

Referenced by Marshal().

{
    mBuffer = &into;
    bool res(SaveStream(rep));
    mBuffer = nullptr;

    return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool MarshalStream::SaveRLE ( const Buffer &  in )

private

Definition at line 524 of file EVEMarshal.cpp.

References Put(), PutSizeEx(), and Buffer::size().

Referenced by VisitPackedRow().

{
    // TODO: REWRITE THIS, AS IT IS RIGHT NOW IS INEFFICIENT, I'VE CONVERTED THE BUFFER CLASS TO A BASTARDIZED VERSION OF A NORMAL BYTE ARRAY
    // ALMAMU - 2021/04/22 - After many years the buggy "SaveZeroCompressed" function has been laid to rest
    //                       may this todo be a way to remind us how unstable and fragile the EVEmu core is
    //                       this code has been validated against the disassembly of Apocrypha's blue.dll
    //                       for those interested, the function lives in .text:10082D10 of that DLL
    //                       "hopefully" this brings our marshaller closer to fully featured

    // reserve double the buffer size just in case, we do not want to run out of space or else the iterators will start to complain
    Buffer out(in.size() * 2, 0);

    // this code has been used and ported through different projects
    // both ntt's reverence and Captnoord's re-implementation of evemu core have the exact same code
    // after validation against the disassembly (and unless I've missed anything) it seems to be 100% accurate
    // so no real modification to it was done
    int nibble = 0;
    int nibble_ix = 0;
    int in_ix = 0;
    int out_ix = 0;
    int start, end, count;
    int zerochains = 0;
    int in_size = in.size();

    while(in_ix < in_size)
    {
        if(!nibble)
        {
            nibble_ix = out_ix++;
            out[nibble_ix] = 0;
        }

        start = in_ix;
        end = in_ix+8;
        if(end > in_size)
            end = in_size;

        if(in[in_ix])
        {
            zerochains = 0;
            do {
                out[out_ix++] = in[in_ix++];
            } while(in_ix<end && in[in_ix]);
            count = (start - in_ix) + 8;
        }
        else
        {
            zerochains++;
            while(in_ix<end && !in[in_ix])
                in_ix++;
            count = (in_ix - start) + 7;
        }

        if(nibble)
            out[nibble_ix] |= (count << 4);
        else
            out[nibble_ix] = count;
        nibble = !nibble;
    }

    if(nibble && zerochains)
        zerochains++;

    while(zerochains>1)
    {
        zerochains -= 2;
        out_ix -= 1;
    }

    // Write the packed in
    PutSizeEx( (uint32) out_ix);
    if ( 0 < out.size() )
        Put( out.begin<uint8>(), out.begin<uint8>() + out_ix );

    return true;
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool MarshalStream::SaveStream ( const PyRep *  rep )

protected

saves new stream with given rep.

Definition at line 78 of file EVEMarshal.cpp.

References MarshalHeaderByte, and PyRep::visit().

Referenced by Save().

{
    Put<uint8>( MarshalHeaderByte );
    /*
     * Mapcount
     * the amount of referenced objects within a marshal stream.
     * Note: Atm not supported.
     * (allan)  have not found any information on this, so no idea how/when to implement it (or even if we need to)
     */
    Put<uint32>( 0 ); // Mapcount

    return rep->visit( *this );
}

Here is the call graph for this function:

Here is the caller graph for this function:

void MarshalStream::SaveVarInteger ( const PyLong *  v )

private

Definition at line 503 of file EVEMarshal.cpp.

References DoIntegerSizeCheck, Op_PyLongLong, Op_PyVarInteger, Put(), PutSizeEx(), and PyLong::value().

Referenced by VisitLong().

{
    const int64 value(v->value());
    uint8 integerSize(0);

#define DoIntegerSizeCheck(x) if ( ( (uint8*)&value )[x] != 0 ) integerSize = x + 1;
    DoIntegerSizeCheck(4);
    DoIntegerSizeCheck(5);
    DoIntegerSizeCheck(6);
#undef  DoIntegerSizeCheck

    if ( integerSize > 0 && integerSize < 7 ) {
        Put<uint8>(Op_PyVarInteger);
        PutSizeEx(integerSize);
        Put( &( (uint8*)&value )[0], &( (uint8*)&value )[integerSize] );
    } else {
        Put<uint8>(Op_PyLongLong);                    // 1
        Put<int64>(value);                           // 8
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool MarshalStream::VisitBoolean ( const PyBool *  rep )

protectedvirtual

Adds a boolean to the stream.

Reimplemented from PyVisitor.

Definition at line 123 of file EVEMarshal.cpp.

References Op_PyFalse, Op_PyTrue, and PyBool::value().

{
    if (rep->value())
        Put<uint8>( Op_PyTrue );
    else
        Put<uint8>( Op_PyFalse );

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitBuffer ( const PyBuffer *  rep )

protectedvirtual

Adds a buffer to the stream.

Reimplemented from PyVisitor.

Definition at line 151 of file EVEMarshal.cpp.

References PyBuffer::content(), Op_PyBuffer, Put(), and PutSizeEx().

{
    Put<uint8>( Op_PyBuffer );

    const Buffer& buf = rep->content();

    PutSizeEx( (uint32)buf.size() );
    Put( buf.begin<uint8>(), buf.end<uint8>() );

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitChecksumedStream ( const PyChecksumedStream *  rep )

protectedvirtual

Adds a checksumed stream to the stream.

TODO: check the implementation of this...

Reimplemented from PyVisitor.

Definition at line 493 of file EVEMarshal.cpp.

References PyChecksumedStream::checksum(), Op_PyChecksumedStream, and PyVisitor::VisitChecksumedStream().

{
    assert(false && "MarshalStream on the server side should never send checksummed objects");

    Put<uint8>(Op_PyChecksumedStream);

    Put<uint32>( rep->checksum() );
    return PyVisitor::VisitChecksumedStream( rep );
}

Here is the call graph for this function:

bool MarshalStream::VisitDict ( const PyDict *  rep )

protectedvirtual

Add a dict object to the stream

Reimplemented from PyVisitor.

Definition at line 251 of file EVEMarshal.cpp.

References PyDict::begin(), PyDict::end(), Op_PyDict, PutSizeEx(), and PyDict::size().

{
    uint32 size(rep->size());
    Put<uint8>( Op_PyDict );
    PutSizeEx( size );

    //we have to reverse the order of key/value to be value/key, so do not call base class.
    PyDict::const_iterator cur = rep->begin(), end = rep->end();
    for (; cur != end; ++cur) {
        if ( !cur->second->visit( *this ) )
            return false;
        if ( !cur->first->visit( *this ) )
            return false;
    }

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitInteger ( const PyInt *  rep )

protectedvirtual

adds a integer to the data stream

Note

assuming the value is unsigned research shows that Op_PyByte can be negative

Reimplemented from PyVisitor.

Definition at line 92 of file EVEMarshal.cpp.

References Op_PyByte, Op_PyLong, Op_PyMinusOne, Op_PyOneInteger, Op_PySignedShort, Op_PyZeroInteger, and PyInt::value().

{
    const int32 val(rep->value());

    if ( val == -1 ) {
        Put<uint8>( Op_PyMinusOne );
    } else if ( val == 0 ) {
        Put<uint8>( Op_PyZeroInteger );
    } else if ( val == 1 ) {
        Put<uint8>( Op_PyOneInteger );
    } else if ( val + 0x8000u > 0xFFFF ) {
        Put<uint8>( Op_PyLong );
        Put<int32>( val );
    } else if ( val + 0x80u > 0xFF ) {
        Put<uint8>( Op_PySignedShort );
        Put<int16>( val );
    } else {
        Put<uint8>( Op_PyByte );
        Put<int8>( val );
    }

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitList ( const PyList *  rep )

protectedvirtual

Add a list object to the stream

Reimplemented from PyVisitor.

Definition at line 236 of file EVEMarshal.cpp.

References Op_PyEmptyList, Op_PyList, Op_PyOneList, PutSizeEx(), PyList::size(), and PyVisitor::VisitList().

{
    uint32 size(rep->size());
    if ( size == 0 ) {
        Put<uint8>( Op_PyEmptyList );
    } else if ( size == 1 ) {
        Put<uint8>( Op_PyOneList );
    } else {
        Put<uint8>( Op_PyList );
        PutSizeEx( size );
    }

    return PyVisitor::VisitList( rep );
}

Here is the call graph for this function:

bool MarshalStream::VisitLong ( const PyLong *  rep )

protectedvirtual

Adds a long to the stream.

Reimplemented from PyVisitor.

Definition at line 116 of file EVEMarshal.cpp.

References SaveVarInteger().

{
    SaveVarInteger (rep);

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitNone ( const PyNone *  rep )

protectedvirtual

Adds a None object to the stream.

Reimplemented from PyVisitor.

Definition at line 145 of file EVEMarshal.cpp.

References Op_PyNone.

{
    Put<uint8>( Op_PyNone );
    return true;
}

bool MarshalStream::VisitObject ( const PyObject *  rep )

protectedvirtual

Adds an object to the stream.

Reimplemented from PyVisitor.

Definition at line 269 of file EVEMarshal.cpp.

References Op_PyObject, and PyVisitor::VisitObject().

{
    Put<uint8>( Op_PyObject );
    return PyVisitor::VisitObject( rep );
}

Here is the call graph for this function:

bool MarshalStream::VisitObjectEx ( const PyObjectEx *  rep )

protectedvirtual

Adds a New object to the stream.

Reimplemented from PyVisitor.

Definition at line 275 of file EVEMarshal.cpp.

References PyList::begin(), PyDict::begin(), PyObjectEx::dict(), PyList::end(), PyDict::end(), PyObjectEx::header(), PyObjectEx::isType2(), PyObjectEx::list(), Op_PackedTerminator, Op_PyObjectEx1, Op_PyObjectEx2, and PyRep::visit().

{
    if (rep->isType2())
        Put<uint8>( Op_PyObjectEx2 );
    else
        Put<uint8>( Op_PyObjectEx1 );

    if ( !rep->header()->visit( *this ) )
        return false;

    PyObjectEx::const_list_iterator lcur = rep->list().begin(), lend = rep->list().end();
    for (; lcur != lend; ++lcur ) {
        if ( !(*lcur )->visit( *this ) )
            return false;
    }

    Put<uint8>( Op_PackedTerminator );

    PyObjectEx::const_dict_iterator dcur = rep->dict().begin(), dend = rep->dict().end();
    for (; dcur != dend; ++dcur ) {
        if ( !dcur->first->visit( *this ) )
            return false;
        if ( !dcur->second->visit( *this ) )
            return false;
    }

    Put<uint8>( Op_PackedTerminator );

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitPackedRow ( const PyPackedRow *  pyPackedRow )

protectedvirtual

Adds a packed row to the stream.

Reimplemented from PyVisitor.

Definition at line 306 of file EVEMarshal.cpp.

References Buffer::Append(), Buffer::AppendSeq(), PyRep::AsBool(), PyRep::AsFloat(), PyRep::AsInt(), PyRep::AsLong(), Buffer::begin(), DBTYPE_BOOL, DBTYPE_CY, DBTYPE_FILETIME, DBTYPE_GetSizeBits(), DBTYPE_I1, DBTYPE_I2, DBTYPE_I4, DBTYPE_I8, DBTYPE_R4, DBTYPE_R8, DBTYPE_UI1, DBTYPE_UI2, DBTYPE_UI4, DBTYPE_UI8, Buffer::end(), PyPackedRow::GetField(), PyPackedRow::header(), PyRep::IsNone(), Op_PyPackedRow, Buffer::Reserve(), SaveRLE(), EvE::traceStack(), PyInt::value(), PyLong::value(), PyFloat::value(), PyBool::value(), PyRep::visit(), and PyObjectEx::visit().

{
    Put<uint8>( Op_PyPackedRow );

    DBRowDescriptor* header(pyPackedRow->header());
    header->visit( *this );

    // create the sizemap and sort it by bitsize, the value of the map indicates the index of the column
    // this can be used to identify things easily
    std::multimap< uint8, uint32, std::greater< uint8 > > sizeMap;
    std::map<uint8,uint8> booleanColumns;

    uint32 columnCount = header->ColumnCount();
    size_t byteDataBitLength = 0;
    size_t booleansBitLength = 0;
    size_t nullsBitLength = 0;

    // go through all the columns to gather the required information
    for (uint32_t i = 0; i < columnCount; i ++)
    {
        DBTYPE columnType = header->GetColumnType (i);
        uint8_t size = DBTYPE_GetSizeBits (columnType);

        // count booleans
        if (columnType == DBTYPE_BOOL)
        {
            // register the boolean in the list and increase the length
            booleanColumns.insert (std::make_pair (i, booleansBitLength));
            booleansBitLength ++;
        }

        // also count all columns as possible nulls
        nullsBitLength ++;

        // increase the bytedata length only if a column is longer than 7 bits
        // this is used as an indicator of what is written in the first second, or third part
        if (size >= 8)
            byteDataBitLength += size;

        // add the column to the list
        sizeMap.insert (std::make_pair (size, i));
    }

    // reserve the space for the buffers
    Buffer rowData;
    rowData.Reserve<uint8> ((byteDataBitLength >> 3) + ((booleansBitLength + nullsBitLength) >> 3) + 1);
    // to ease working with the bit data, reserve a fixed-size buffer
    // and fill it with 0s
    Buffer bitData(((booleansBitLength + nullsBitLength) >> 3) + 1, 0);

    std::multimap< uint8, uint32, std::greater< uint8 > >::iterator cur, end;
    cur = sizeMap.begin();
    // limit the search to booleans, the rest of the values are encoded differently
    end = sizeMap.lower_bound( 1 );
    PyRep* value(nullptr);
    for (; cur != end; ++cur)
    {
        value = pyPackedRow->GetField(cur->second);

        // handle the column being none
        if (value->IsNone() == true)
        {
            // get the bit this column should be written at
            unsigned long nullBit = cur->second + booleansBitLength;
            unsigned long nullByte = nullBit >> 3;
            // setup the iterator to the proper byte
            Buffer::iterator<uint8> bitIterator = bitData.begin<uint8>() + nullByte;
            // update the proper bit
            *bitIterator |= (1 << (nullBit & 0x7));
        }

        // ensure that the proper value is written
        // the values will be ignored if a none flag is set, but they must be present
        switch (header->GetColumnType (cur->second))
        {
            case DBTYPE_CY:
            case DBTYPE_I8:
            case DBTYPE_UI8:
            case DBTYPE_FILETIME:
                rowData.Append<int64>(value->IsNone() ? 0 : value->AsLong()->value() );
                break;
            case DBTYPE_I4:
                rowData.Append<int32>(value->IsNone() ? 0 : value->AsInt()->value() );
                break;
            case DBTYPE_UI4:
                rowData.Append<uint32>(value->IsNone() ? 0 : value->AsInt()->value() );
                break;
            case DBTYPE_I2:
                rowData.Append<int16>(value->IsNone() ? 0 : value->AsInt()->value() );
                break;
            case DBTYPE_UI2:
                rowData.Append<uint16>(value->IsNone() ? 0 : value->AsInt()->value() );
                break;
            case DBTYPE_I1:
                rowData.Append<int8>(value->IsNone() ? 0 : value->AsInt()->value() );
                break;
            case DBTYPE_UI1:
                rowData.Append<uint8>(value->IsNone() ? 0 : value->AsInt()->value() );
                break;
            case DBTYPE_R8:
                rowData.Append<double>(value->IsNone() ? 0.0 : value->AsFloat()->value() );
                break;
            case DBTYPE_R4:
                rowData.Append<float>(static_cast<float>(value->IsNone() ? 0.0f : value->AsFloat()->value()));
                break;
            // FIXME nothing should hit here ever but better implement some error-handling just in case
            default:
                assert( false );
                EvE::traceStack();
                break;
        }
    }

    cur = sizeMap.lower_bound( 1 );
    end = sizeMap.lower_bound( 0 );
    PyBool* b(nullptr);
    for (; cur != end; ++cur)
    {
        b = pyPackedRow->GetField(cur->second)->AsBool();

        // false values do not need anything to be done
        if (b->value() == false)
            continue;

        // get the bit this boolean should be written at
        unsigned long boolBit = booleanColumns.find (cur->second)->second;
        unsigned long boolByte = boolBit >> 3;
        // setup the iterator to the proper byte
        Buffer::iterator<uint8> bitIterator = bitData.begin<uint8>() + boolByte;
        // update the proper bit
        *bitIterator |= (1 << (boolBit & 0x7));
    }

    // concatenate the bit data to the rowData
    rowData.AppendSeq(bitData.begin<uint8>(), bitData.end<uint8>());

    // run the data through the zero compression algorithm
    if (!SaveRLE(rowData))
        return false;

    // finally append items that are not packed like strings or byte buffers
    cur = sizeMap.lower_bound( 0 );
    end = sizeMap.end();
    for (; cur != end; ++cur) {
        value = pyPackedRow->GetField(cur->second );
        if (!value->visit(*this))
            return false;
    }

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitReal ( const PyFloat *  rep )

protectedvirtual

Adds a double to the stream.

Reimplemented from PyVisitor.

Definition at line 133 of file EVEMarshal.cpp.

References Op_PyReal, Op_PyZeroReal, and PyFloat::value().

{
    if ( rep->value() == 0.0 ) {
        Put<uint8>( Op_PyZeroReal );
    } else {
        Put<uint8>( Op_PyReal );
        Put<double>( rep->value() );
    }

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitString ( const PyString *  rep )

protectedvirtual

add a string object to the data stream

Reimplemented from PyVisitor.

Definition at line 163 of file EVEMarshal.cpp.

References PyString::content(), Op_PyCharString, Op_PyEmptyString, Op_PyLongString, Op_PyStringTableItem, Put(), PutSizeEx(), sMarshalStringTable, and STRING_TABLE_ERROR.

{
    size_t len(rep->content().size());

    if ( len == 0 ) {
        Put<uint8>( Op_PyEmptyString );
    } else if ( len == 1 ) {
        Put<uint8>( Op_PyCharString );
        Put<uint8>( rep->content()[0] );
    } else {
        //string is long enough for a string table entry, check it.
        const uint8 index = sMarshalStringTable.LookupIndex( rep->content() );
        if ( index > STRING_TABLE_ERROR ) {
            Put<uint8>( Op_PyStringTableItem );
            Put<uint8>( index );
        } else {
        // NOTE: they seem to have stopped using Op_PyShortString
            Put<uint8>( Op_PyLongString );
            PutSizeEx( (uint32)len );
            Put( rep->content().begin(), rep->content().end() );
        }
    }

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitSubStream ( const PySubStream *  rep )

protectedvirtual

Adds a sub stream to the stream.

Reimplemented from PyVisitor.

Definition at line 464 of file EVEMarshal.cpp.

References Buffer::begin(), PyBuffer::content(), PySubStream::data(), PySubStream::decoded(), PySubStream::EncodeData(), Buffer::end(), Op_PySubStream, Put(), PutSizeEx(), and Buffer::size().

{
    Put<uint8>(Op_PySubStream);
    if (rep->data() == nullptr) {
        if (rep->decoded() == nullptr) {
            Put<uint8>(0);
            return false;
        }

        //unmarshaled stream
        //we have to marshal the substream.
        rep->EncodeData();
        if (rep->data() == nullptr) {
            Put<uint8>(0);
            return false;
        }
    }

    //we have the marshaled data, use it.
    const Buffer& data = rep->data()->content();

    PutSizeEx( (uint32)data.size() );
    Put( data.begin<uint8>(), data.end<uint8>() );

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitSubStruct ( const PySubStruct *  rep )

protectedvirtual

Adds a sub structure to the stream.

Reimplemented from PyVisitor.

Definition at line 458 of file EVEMarshal.cpp.

References Op_PySubStruct, and PyVisitor::VisitSubStruct().

{
    Put<uint8>(Op_PySubStruct);
    return PyVisitor::VisitSubStruct( rep );
}

Here is the call graph for this function:

bool MarshalStream::VisitToken ( const PyToken *  rep )

protectedvirtual

add a token object to the data stream

Reimplemented from PyVisitor.

Definition at line 207 of file EVEMarshal.cpp.

References PyToken::content(), Op_PyToken, Put(), and PutSizeEx().

{
    Put<uint8>( Op_PyToken );

    const std::string& str = rep->content();

    PutSizeEx( (uint32)str.size() );
    Put( str.begin(), str.end() );

    return true;
}

Here is the call graph for this function:

bool MarshalStream::VisitTuple ( const PyTuple *  rep )

protectedvirtual

Add a tuple object to the stream

Reimplemented from PyVisitor.

Definition at line 219 of file EVEMarshal.cpp.

References Op_PyEmptyTuple, Op_PyOneTuple, Op_PyTuple, Op_PyTwoTuple, PutSizeEx(), PyTuple::size(), and PyVisitor::VisitTuple().

{
    uint32 size(rep->size());
    if ( size == 0 ) {
        Put<uint8>( Op_PyEmptyTuple );
    } else if ( size == 1 ) {
        Put<uint8>( Op_PyOneTuple );
    } else if ( size == 2 ) {
        Put<uint8>( Op_PyTwoTuple );
    } else {
        Put<uint8>( Op_PyTuple );
        PutSizeEx( size );
    }

    return PyVisitor::VisitTuple( rep );
}

Here is the call graph for this function:

bool MarshalStream::VisitWString ( const PyWString *  rep )

protectedvirtual

add a wide string object to the data stream

Reimplemented from PyVisitor.

Definition at line 189 of file EVEMarshal.cpp.

References PyWString::content(), Op_PyEmptyWString, Op_PyWStringUTF8, Put(), and PutSizeEx().

{
    size_t len(rep->content().size());

    if ( len == 0 ) {
        Put<uint8>( Op_PyEmptyWString );
    } else {
        // We don't have to consider any conversions because
        // UTF-8 is more space-efficient than UCS-2.

        Put<uint8>( Op_PyWStringUTF8 );
        PutSizeEx( (uint32)len );
        Put( rep->content().begin(), rep->content().end() );
    }

    return true;
}

Here is the call graph for this function:

Member Data Documentation

Buffer* MarshalStream::mBuffer

private

Definition at line 146 of file EVEMarshal.h.

Referenced by Put(), and Save().

---

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

• /backups/local/src/eve/EvEmu_Crucible/src/eve-common/marshal/EVEMarshal.h
• /backups/local/src/eve/EvEmu_Crucible/src/eve-common/marshal/EVEMarshal.cpp