#include "PyPacket.h"

Collaboration diagram for PyCallStream:

Public Member Functions
	PyCallStream ()

	~PyCallStream ()

void	Dump (LogType type, PyVisitor &dumper)

bool	Decode (const std::string &type, PyTuple *&payload)

PyTuple *	Encode ()

PyCallStream *	Clone () const

Public Attributes
uint32	remoteObject

std::string	remoteObjectStr

std::string	method

PyTuple *	arg_tuple

PyDict *	arg_dict

Detailed Description

Definition at line 144 of file PyPacket.h.

Constructor & Destructor Documentation

PyCallStream::PyCallStream ( )

Definition at line 553 of file PyPacket.cpp.

Referenced by Clone().

 : remoteObject(0),
   method(""),
   arg_tuple(nullptr),
   arg_dict(nullptr)
 {
 }

Here is the caller graph for this function:

PyCallStream::~PyCallStream ( )

Definition at line 561 of file PyPacket.cpp.

References arg_dict, arg_tuple, and PySafeDecRef.

                             {
     PySafeDecRef(arg_tuple);
     PySafeDecRef(arg_dict);
 }

Member Function Documentation

PyCallStream * PyCallStream::Clone ( ) const

Definition at line 566 of file PyPacket.cpp.

References arg_dict, arg_tuple, PyRep::AsDict(), PyRep::AsTuple(), PyTuple::Clone(), PyDict::Clone(), method, PyCallStream(), remoteObject, and remoteObjectStr.

                                         {
     PyCallStream *res = new PyCallStream();
     res->remoteObject = remoteObject;
     res->remoteObjectStr = remoteObjectStr;
     res->method = method;
     res->arg_tuple = arg_tuple->Clone()->AsTuple();
     if (arg_dict == nullptr)
         res->arg_dict = nullptr;
     else
         res->arg_dict = arg_dict->Clone()->AsDict();
 
     return res;
 }

Here is the call graph for this function:

bool PyCallStream::Decode	(	const std::string &	type,
		PyTuple *&	payload
	)

Definition at line 598 of file PyPacket.cpp.

References arg_dict, arg_tuple, PyRep::AsTuple(), codelog, PySubStream::decoded(), PySubStream::DecodeData(), PyRep::Dump(), PyRep::IntegerValue(), PyRep::IsTuple(), PyTuple::items, method, PyDecRef, PySafeDecRef, remoteObject, remoteObjectStr, and PyRep::StringContent().

Referenced by EVEPacketDispatcher::DispatchPacket().

                                                                      {
     PyTuple *payload = in_payload;   //copy
     in_payload = nullptr;            //consume
 
     PySafeDecRef(arg_tuple);
     PySafeDecRef(arg_dict);
     arg_tuple = nullptr;
     arg_dict = nullptr;
 
     if (payload == nullptr) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - payload is null.");
         return false;
     }
 
     if (type != "macho.CallReq") {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - packet payload has unknown string type '%s'", type.c_str());
         PyDecRef(payload);
         return false;
     }
 
     if (payload->items.size() != 1) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - invalid tuple length %lu", payload->items.size());
         PyDecRef(payload);
         return false;
     }
     if (!payload->items[0]->IsTuple()) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - non tuple payload[0]");
         PyDecRef(payload);
         return false;
     }
 
     PyTuple *payload2 = payload->items[0]->AsTuple();
     if (payload2 == nullptr) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - payload2 is null.");
         PyDecRef(payload);
         PySafeDecRef(payload2);
         return false;
     }
 
     if (payload2->items.size() != 2) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - invalid tuple2 length %lu", payload2->items.size());
         PyDecRef(payload);
         PySafeDecRef(payload2);
         return false;
     }
 
     //decode inner payload tuple
     //ignore tuple 0, it should be an int, dont know what it is
     if (!payload2->items[1]->IsSubStream()) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - non-substream type");
         PyDecRef(payload);
         PySafeDecRef(payload2);
         return false;
     }
 
     PySubStream *ss = payload2->items[1]->AsSubStream();
     if (ss == nullptr) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - ss is null.");
         PyDecRef(payload);
         PySafeDecRef(payload2);
         return false;
     }
 
     ss->DecodeData();
     if (ss->decoded() == nullptr) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - Unable to decode call stream");
         PyDecRef(payload);
         PySafeDecRef(ss);
         PySafeDecRef(payload2);
         return false;
     }
 
     if (!ss->decoded()->IsTuple()) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - packet body does not contain a tuple");
         PyDecRef(payload);
         PySafeDecRef(ss);
         PySafeDecRef(payload2);
         return false;
     }
 
     PyTuple *maint = ss->decoded()->AsTuple();
     if (maint == nullptr) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - maint is null.");
         return false;
     }
     if (maint->items.size() != 4) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - packet body has %lu elements, expected %d", maint->items.size(), 4);
         PyDecRef(payload);
         PySafeDecRef(ss);
         PySafeDecRef(maint);
         PySafeDecRef(payload2);
         return false;
     }
 
     //parse first tuple element, unknown
     if (maint->items[0]->IsInt()) {
         remoteObject = PyRep::IntegerValue(maint->items[0]);
         remoteObjectStr = "";
     } else if (maint->items[0]->IsString()) {
         remoteObject = 0;
         remoteObjectStr = PyRep::StringContent(maint->items[0]);
     } else {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - maint->items[0] has invalid type %s", maint->items[0]->TypeString());
         codelog(NET__PACKET_ERROR, " in:");
         payload->Dump(NET__PACKET_ERROR, "    ");
         PyDecRef(payload);
         PySafeDecRef(ss);
         PySafeDecRef(maint);
         PySafeDecRef(payload2);
         return false;
     }
 
     //parse tuple[1]: method name
     if (maint->items[1]->IsString()) {
         method = PyRep::StringContent(maint->items[1]);
     } else {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - maint->items[1] has non-string type");
         maint->items[1]->Dump(NET__PACKET_ERROR, " --> ");
         codelog(NET__PACKET_ERROR, " in:");
         payload->Dump(NET__PACKET_ERROR, "    ");
         PyDecRef(payload);
         PySafeDecRef(ss);
         PySafeDecRef(maint);
         PySafeDecRef(payload2);
         return false;
     }
 
     //grab argument list.
     if (!maint->items[2]->IsTuple()) {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - argument list has non-tuple type");
         maint->items[2]->Dump(NET__PACKET_ERROR, " --> ");
         codelog(NET__PACKET_ERROR, "in:");
         payload->Dump(NET__PACKET_ERROR, "    ");
         PyDecRef(payload);
         PySafeDecRef(ss);
         PySafeDecRef(maint);
         PySafeDecRef(payload2);
         return false;
     }
     arg_tuple = maint->items[2]->AsTuple();
 
     //options dict
     if (maint->items[3]->IsNone()) {
         arg_dict = nullptr;
     } else if (maint->items[3]->IsDict()) {
         arg_dict = maint->items[3]->AsDict();
     } else {
         codelog(NET__PACKET_ERROR, "PyCallStream::Decode() - tuple[3] has non-dict type");
         maint->items[3]->Dump(NET__PACKET_ERROR, " --> ");
         codelog(NET__PACKET_ERROR, "in:");
         payload->Dump(NET__PACKET_ERROR, "    ");
         PyDecRef(payload);
         PySafeDecRef(ss);
         PySafeDecRef(maint);
         PySafeDecRef(payload2);
         return false;
     }
 
     PyDecRef(payload);
     PySafeDecRef(ss);
     PySafeDecRef(maint);
     PySafeDecRef(payload2);
     return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void PyCallStream::Dump	(	LogType	type,
		PyVisitor &	dumper
	)

Definition at line 580 of file PyPacket.cpp.

References _log, arg_dict, arg_tuple, method, remoteObject, remoteObjectStr, PyTuple::visit(), and PyDict::visit().

Referenced by EVECollectDispatcher::Handle_CallReq().

 {
     _log(type, "Call Stream:");
     if (remoteObject == 0)
         _log(type, "  Remote Object: '%s'", remoteObjectStr.c_str());
     else
         _log(type, "  Remote Object: %u", remoteObject);
     _log(type, "  Method: %s", method.c_str());
     _log(type, "  Arguments:");
     arg_tuple->visit( dumper );
     if (arg_dict == nullptr) {
         _log(type, "  Named Arguments: None");
     } else {
         _log(type, "  Named Arguments:");
         arg_dict->visit( dumper );
     }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

PyTuple * PyCallStream::Encode ( )

Definition at line 763 of file PyPacket.cpp.

References arg_dict, arg_tuple, PyTuple::items, method, PyStatic, remoteObject, and remoteObjectStr.

                               {
     PyTuple *res_tuple = new PyTuple(4);
 
     //remoteObject
     if (remoteObject == 0)
         res_tuple->items[0] = new PyString(remoteObjectStr.c_str());
     else
         res_tuple->items[0] = new PyInt(remoteObject);
 
     //method name
     res_tuple->items[1] = new PyString(method.c_str());
 
     //args
     res_tuple->items[2] = arg_tuple;     // no need to clone here.  set actual rep in item, and it will be cleaned up by d'tor later
 
     //options
     if (arg_dict == nullptr)
         res_tuple->items[3] = PyStatic.NewNone();
     else
         res_tuple->items[3] = arg_dict;     // no need to clone here.  set actual rep in item, and it will be cleaned up by d'tor later
 
     //now that we have the main arg tuple, build the unknown stuff around it...
     PyTuple *it2 = new PyTuple(2);
         it2->items[0] = new PyInt(remoteObject==0?1:0); /* some sort of flag, "process here or call UP"....*/
         it2->items[1] = new PySubStream(res_tuple);
     PyTuple *it1 = new PyTuple(2);
         it1->items[0] = it2;
         it1->items[1] = PyStatic.NewNone();    //this is the "channel" dict if populated.
     return it1;
 }