#include "PyPacket.h"

Collaboration diagram for PyAddress:

Public Types
enum	AddrType { Node = 1, Client = 2, Broadcast = 4, Any = 8, Invalid = 'I' }

Public Member Functions
	PyAddress ()

void	Dump (FILE into, const char pfx) const

void	Dump (LogType type, const char *pfx) const

bool	Decode (PyRep *&object)

PyRep *	Encode ()

void	operator= (const PyAddress &right)

Public Attributes
AddrType	type

int64	objectID

int64	callID

std::string	service

std::string	bcast_idtype

Protected Member Functions
bool	_DecodeService (PyRep *rep)

bool	_DecodeCallID (PyRep *rep)

bool	_DecodeObjectID (PyRep *rep)

Detailed Description

Definition at line 36 of file PyPacket.h.

Member Enumeration Documentation

enum PyAddress::AddrType

Enumerator
Node
Client
Broadcast
Any
Invalid

Definition at line 57 of file PyPacket.h.

                  {
         Node    = 1,
             /*
              * [0]   addressType
              * [1]   nodeID
              * [2]   service
              * [3]   callID
              */
         Client  = 2,
             /* "because it's ID doesn't match"
              * [0]   addressType
              * [1]   clientID
              * [2]   callID
              * [3]   service
              */
         Broadcast = 4,
             /*
              * [0]   addressType
              * [1]   broadcastID
              * [2]   narrowcast         // this part is not understood yet... something about specific nodes for bcast types
              * [3]   idtype
              */
         Any     = 8,
             /*
              * [0]   addressType
              * [1]   service
              * [2]   callID
              */
         Invalid = 'I'   //not real
     } AddrType;

Constructor & Destructor Documentation

PyAddress::PyAddress ( )

Definition at line 275 of file PyPacket.cpp.

 : type(Invalid),
 objectID(0),
 callID(0),
 service("")
 {
 
 }

Member Function Documentation

bool PyAddress::_DecodeCallID ( PyRep * rep )

protected

Definition at line 542 of file PyPacket.cpp.

References callID, and PyRep::IntegerValue().

Referenced by Decode().

                                         {
     callID = PyRep::IntegerValue(rep);
     return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

bool PyAddress::_DecodeObjectID ( PyRep * rep )

protected

Definition at line 547 of file PyPacket.cpp.

References PyRep::IntegerValue(), and objectID.

Referenced by Decode().

                                           {
     objectID = PyRep::IntegerValue(rep);
     return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

bool PyAddress::_DecodeService ( PyRep * rep )

protected

Definition at line 537 of file PyPacket.cpp.

References service, and PyRep::StringContent().

Referenced by Decode().

                                          {
     service = PyRep::StringContent(rep);
     return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

bool PyAddress::Decode ( PyRep *& object )

Definition at line 332 of file PyPacket.cpp.

References _DecodeCallID(), _DecodeObjectID(), _DecodeService(), Any, PyObject::arguments(), PyRep::AsObject(), PyRep::AsTuple(), bcast_idtype, Broadcast, Client, codelog, PyRep::Dump(), PyRep::IntegerValue(), PyRep::IsObject(), PyTuple::items, Node, PyDecRef, PySafeDecRef, service, PyRep::StringContent(), type, and PyRep::TypeString().

Referenced by PyPacket::Decode().

                                         {
     PyRep *base = in_object;
     in_object = nullptr;
 
     if (base == nullptr) {
         codelog(NET__PACKET_ERROR, "PyAddress::Decode() - base is null.");
         return false;
     }
 
     if (!base->IsObject()) {
         codelog(NET__PACKET_ERROR, "Invalid element type, expected object but got %s", base->TypeString());
         PyDecRef(base);
         return false;
     }
 
     PyTuple *tuple = base->AsObject()->arguments()->AsTuple();
     if (tuple == nullptr) {
         codelog(NET__PACKET_ERROR, "PyAddress::Decode() - tuple is null.");
         return false;
     }
 
     if (tuple->items.size() < 3) {
         codelog(NET__PACKET_ERROR, "Not enough elements in address tuple: %u", tuple->items.size());
         tuple->Dump(NET__PACKET_ERROR, "  ");
         PyDecRef(base);
         PyDecRef(tuple);
         return false;
     }
 
     //decode the address type.
     if (!tuple->items[0]->IsInt()) {
         codelog(NET__PACKET_ERROR, "Wrong type on address element (0)");
         tuple->items[0]->Dump(NET__PACKET_ERROR, "  ");
         PyDecRef(base);
         PySafeDecRef(tuple);
         return false;
     }
 
     switch(PyRep::IntegerValue(tuple->items[0])) {
         case Any: {
             if (tuple->items.size() != 3) {
                 codelog(NET__PACKET_ERROR, "Invalid number of elements in Any address tuple: %lu", tuple->items.size());
                 PyDecRef(base);
                 PySafeDecRef(tuple);
                 return false;
             }
             type = Any;
 
             if (!_DecodeService(tuple->items[1])
             or !_DecodeCallID(tuple->items[2])) {
                 PyDecRef(base);
                 PySafeDecRef(tuple);
                 return false;
             }
         }  break;
         case Node: {
             if (tuple->items.size() != 4) {
                 codelog(NET__PACKET_ERROR, "Invalid number of elements in Node address tuple: %lu", tuple->items.size());
                 PyDecRef(base);
                 PySafeDecRef(tuple);
                 return false;
             }
             type = Node;
 
             if (!_DecodeObjectID(tuple->items[1])
             or !_DecodeService(tuple->items[2])
             or !_DecodeCallID(tuple->items[3])) {
                 PyDecRef(base);
                 PySafeDecRef(tuple);
                 return false;
             }
         }  break;
         case Client: {
             if (tuple->items.size() != 4) {
                 codelog(NET__PACKET_ERROR, "Invalid number of elements in Client address tuple: %lu", tuple->items.size());
                 PyDecRef(base);
                 PySafeDecRef(tuple);
                 return false;
             }
             type = Client;
 
             if (!_DecodeObjectID(tuple->items[1])
             or !_DecodeCallID(tuple->items[2])
             or !_DecodeService(tuple->items[3])) {
                 PyDecRef(base);
                 PySafeDecRef(tuple);
                 return false;
             }
         }  break;
         case Broadcast: {
             if (tuple->items.size() != 4) {
                 codelog(NET__PACKET_ERROR, "Invalid number of elements in Broadcast address tuple: %lu", tuple->items.size());
                 PyDecRef(base);
                 PySafeDecRef(tuple);
                 return false;
             }
             type = Broadcast;
 
             if (!tuple->items[1]->IsString()) {
                 codelog(NET__PACKET_ERROR, "Invalid type %s for brodcastID", tuple->items[1]->TypeString());
                 PyDecRef(base);
                 PySafeDecRef(tuple);
                 return false;
             }
             if (!tuple->items[3]->IsString()) {
                 codelog(NET__PACKET_ERROR, "Invalid type %s for idtype", tuple->items[3]->TypeString());
                 PyDecRef(base);
                 PySafeDecRef(tuple);
                 return false;
             }
 
             service = PyRep::StringContent(tuple->items[1]);       //assign op
             bcast_idtype = PyRep::StringContent(tuple->items[3]);  //assign op
 
             //items[2] is either a list or a tuple.
             /*
             //PyList *nclist = (PyList *) tuple->items[2];
             if (!nclist->items.empty()) {
                 printf("Not decoding narrowcast list:");
                 nclist->Dump(NET__PACKET_ERROR, "     ");
             }*/
         }   break;
         default: {
             codelog(NET__PACKET_ERROR, "Unknown address type: %i", PyRep::IntegerValue(tuple->items[0]));
             PyDecRef(base);
             PySafeDecRef(tuple);
             return false;
         }
     }
 
     PyDecRef(base);
     PySafeDecRef(tuple);
     return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void PyAddress::Dump	(	FILE *	into,
		const char *	pfx
	)		const

Definition at line 284 of file PyPacket.cpp.

References Any, bcast_idtype, Broadcast, callID, Invalid, Node, objectID, service, and type.

Referenced by PyPacket::Dump(), EVECollectDispatcher::Handle_CallReq(), Client::Handle_CallReq(), EVECollectDispatcher::Handle_CallRsp(), EVECollectDispatcher::Handle_Notify(), and EVECollectDispatcher::Handle_Other().

                                                       {
     switch(type) {
         case Any:
             fprintf(into, "%sAny: service='%s' callID=%li", pfx, service.c_str(), callID);
         break;
         case Node:
             fprintf(into, "%sNode: nodeID=%li service='%s' callID=%li", pfx, objectID, service.c_str(), callID);
         break;
         case Client:
             fprintf(into, "%sClient: clientID=%li service='%s' callID=%li", pfx, objectID, service.c_str(), callID);
         break;
         case Broadcast:
             fprintf(into, "%sBroadcast: broadcastID='%s' narrowcast=(not implemented) idtype='%s'", pfx, service.c_str(), bcast_idtype.c_str());
         break;
         case Invalid:
         break;
     //no default on purpose
     }
 }

Here is the caller graph for this function:

void PyAddress::Dump	(	LogType	type,
		const char *	pfx
	)		const

Definition at line 304 of file PyPacket.cpp.

References _log, Any, bcast_idtype, Broadcast, callID, Invalid, Node, objectID, service, and type.

                                                          {
     switch(type) {
         case Any:
             _log(ltype, "%sAny: service='%s' callID=%li", pfx, service.c_str(), callID);
         break;
         case Node:
             _log(ltype, "%sNode: nodeID=%li service='%s' callID=%li", pfx, objectID, service.c_str(), callID);
         break;
         case Client:
             _log(ltype, "%sClient: clientID=%li callID=%li service='%s'", pfx, objectID, callID, service.c_str());
         break;
         case Broadcast:
             _log(ltype, "%sBroadcast: broadcastID='%s' narrowcast=(not implemented) idtype='%s'", pfx, service.c_str(), bcast_idtype.c_str());
         break;
         case Invalid:
         break;
     //no default on purpose
     }
 }

PyRep * PyAddress::Encode ( )

Definition at line 467 of file PyPacket.cpp.

References Any, bcast_idtype, Broadcast, callID, Invalid, PyTuple::items, new_tuple(), Node, objectID, PyStatic, service, and type.

Referenced by PyPacket::Encode().

                          {
     PyTuple *t(nullptr);
     switch(type) {
         case Any: {
             t = new PyTuple(3);
             t->items[0] = new PyInt((int)type);
 
             if (service.empty())
                 t->items[1] = PyStatic.NewNone();
             else
                 t->items[1] = new PyString(service.c_str());
 
             if (objectID == 0)
                 t->items[2] = PyStatic.NewNone();
             else
                 t->items[2] = new PyLong(objectID);
         } break;
         case Node: {
             t = new PyTuple(4);
             t->items[0] = new PyInt((int)type);
             t->items[1] = new PyLong(objectID);
 
             if (service.empty())
                 t->items[2] = PyStatic.NewNone();
             else
                 t->items[2] = new PyString(service.c_str());
 
             if (callID == 0)
                 t->items[3] = PyStatic.NewNone();
             else
                 t->items[3] = new PyLong(callID);
         } break;
         case Client: {
             t = new PyTuple(4);
             t->items[0] = new PyInt((int)type);
             t->items[1] = new PyLong(objectID);
 
             if (callID == 0)
                 t->items[2] = PyStatic.NewNone();
             else
                 t->items[2] = new PyLong(callID);
 
             if (service.empty())
                 t->items[3] = PyStatic.NewNone();
             else
                 t->items[3] = new PyString(service.c_str());
         } break;
         case Broadcast: {
             t = new PyTuple(4);
             t->items[0] = new PyInt((int)type);
             //broadcastID
             if (service.empty())
                 t->items[1] = PyStatic.NewNone();
             else
                 t->items[1] = new PyString(service.c_str());
             //narrowcast
             t->items[2] = new PyList(); // LSC uses tuple here, others None() or empty List()
             //typeID
             t->items[3] = new PyString(bcast_idtype.c_str());
         } break;
         case Invalid:
         default: {
             //this still needs to be something which will not crash us.
             t = new_tuple(PyStatic.NewNone());
         } break;
     }
 
     return new PyObject( "macho.MachoAddress", t );
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void PyAddress::operator= ( const PyAddress & right )

Definition at line 324 of file PyPacket.cpp.

References bcast_idtype, callID, objectID, service, and type.

                                                 {
     type = right.type;
     objectID = right.objectID;
     callID = right.callID;
     service = right.service;
     bcast_idtype = right.bcast_idtype;
 }