EVECollectDispatcher Class Reference

#include "EVECollectDisp.h"

Inheritance diagram for EVECollectDispatcher:

Collaboration diagram for EVECollectDispatcher:

Public Member Functions
	EVECollectDispatcher ()
virtual	~EVECollectDispatcher ()
Public Member Functions inherited from EVEPacketDispatcher
bool	DispatchPacket (PyPacket *packet)

Public Attributes
PyLookupResolver	lookResolver

Protected Types
typedef void(EVECollectDispatcher::*	_CallReqDispatch )(const PyPacket *packet, PyCallStream **call)
typedef void(EVECollectDispatcher::*	_CallRspDispatch )(const PyPacket *packet, PyRepTuple **res)
typedef void(EVECollectDispatcher::*	_NotifyDispatch )(const PyPacket *packet, EVENotificationStream **notify)
typedef void(EVECollectDispatcher::*	_DestinyDispatch )(const PyPacket *packet, DoDestinyAction *action)

Protected Member Functions
virtual void	Handle_AuthenticationReq (const PyPacket *packet, AuthenticationReq **call)
virtual void	Handle_AuthenticationRsp (const PyPacket *packet, AuthenticationRsp **call)
virtual void	Handle_CallReq (const PyPacket *packet, PyCallStream **call)
virtual void	Handle_CallRsp (const PyPacket *packet, PyRepTuple **res)
virtual void	Handle_Notify (const PyPacket *packet, EVENotificationStream **notify)
virtual void	Handle_SessionChange (const PyPacket *packet, SessionChangeNotification **notify)
virtual void	Handle_ErrorResponse (const PyPacket *packet, ErrorResponseBody **body)
virtual void	Handle_Other (PyPacket **packet)
void	_DumpBalls (const byte *data, uint32 len)
Protected Member Functions inherited from EVEPacketDispatcher
virtual bool	Handle_AuthenticationReq (PyPacket *packet, AuthenticationReq &req)
virtual bool	Handle_AuthenticationRsp (PyPacket *packet, AuthenticationRsp &rsp)
virtual bool	Handle_CallReq (PyPacket *packet, PyCallStream &req)
virtual bool	Handle_CallRsp (PyPacket *packet)
virtual bool	Handle_ErrorResponse (PyPacket *packet, ErrorResponse &error)
virtual bool	Handle_Notify (PyPacket *packet)
virtual bool	Handle_SessionChange (PyPacket *packet, SessionChangeNotification &sessionChange)
virtual bool	Handle_PingReq (PyPacket *packet)
virtual bool	Handle_PingRsp (PyPacket *packet)
virtual bool	Handle_Other (PyPacket *packet)

Protected Attributes
std::map< uint32, std::string >	pendingCalls
std::map< uint32, std::string >	pendingBinds
std::map< std::string, _CallReqDispatch >	m_callReqDisp
std::map< std::string, _CallRspDispatch >	m_callRspDisp
std::map< std::string, _NotifyDispatch >	m_notifyDisp
std::map< std::string, _DestinyDispatch >	m_destinyDisp

Detailed Description

Definition at line 9 of file EVECollectDisp.h.

Member Typedef Documentation

typedef void(EVECollectDispatcher::* EVECollectDispatcher::_CallReqDispatch)(const PyPacket *packet, PyCallStream **call)

protected

Definition at line 33 of file EVECollectDisp.h.

typedef void(EVECollectDispatcher::* EVECollectDispatcher::_CallRspDispatch)(const PyPacket *packet, PyRepTuple **res)

protected

Definition at line 34 of file EVECollectDisp.h.

typedef void(EVECollectDispatcher::* EVECollectDispatcher::_DestinyDispatch)(const PyPacket *packet, DoDestinyAction *action)

protected

Definition at line 49 of file EVECollectDisp.h.

typedef void(EVECollectDispatcher::* EVECollectDispatcher::_NotifyDispatch)(const PyPacket *packet, EVENotificationStream **notify)

protected

Definition at line 35 of file EVECollectDisp.h.

Constructor & Destructor Documentation

EVECollectDispatcher::EVECollectDispatcher

(

)

Definition at line 16 of file EVECollectDisp.cpp.

: EVEPacketDispatcher()
{
#define CALL_REQ_HANDLER(c) m_callReqDisp[#c] = &EVECollectDispatcher::Req_##c;
#define CALL_RSP_HANDLER(c) m_callRspDisp[#c] = &EVECollectDispatcher::Rsp_##c;
#define BOUND_CALL_RSP_HANDLER(c) m_callRspDisp[#c] = &EVECollectDispatcher::Bound_Rsp_##c;
#define NOTIFY_HANDLER(c) m_notifyDisp[#c] = &EVECollectDispatcher::Notify_##c;
    #include "method_types.h"

#define DESTINY_HANDLER(c) m_destinyDisp[#c] = &EVECollectDispatcher::Destiny_##c;
    #include "destiny_types.h"
}

EVECollectDispatcher::~EVECollectDispatcher ( )

virtual

Definition at line 29 of file EVECollectDisp.cpp.

                                            {
}

Member Function Documentation

void EVECollectDispatcher::_DumpBalls ( const byte *  data, uint32  len  )

protected

void EVECollectDispatcher::Handle_AuthenticationReq ( const PyPacket *  packet, AuthenticationReq **  call  )

protectedvirtual

Definition at line 33 of file EVECollectDisp.cpp.

References _log.

                                                                                                    {
    _log(COLLECT__MESSAGE, "Saw AuthenticationReq for %s", (*call)->login.c_str());
}

void EVECollectDispatcher::Handle_AuthenticationRsp ( const PyPacket *  packet, AuthenticationRsp **  call  )

protectedvirtual

Definition at line 37 of file EVECollectDisp.cpp.

References _log.

                                                                                                   {
    _log(COLLECT__MESSAGE, "Saw AuthenticationRsp");
}

void EVECollectDispatcher::Handle_CallReq ( const PyPacket *  packet, PyCallStream **  call  )

protectedvirtual

Definition at line 41 of file EVECollectDisp.cpp.

References _log, PyCallStream::arg_tuple, PyAddress::callID, PyPacket::dest, PyAddress::Dump(), PyCallStream::Dump(), is_log_enabled, lookResolver, m_callReqDisp, PyCallStream::method, pendingCalls, PRIu64, PyAddress::service, PyPacket::source, and PyTuple::visit().

                                                                                        {
    PyCallStream *call = *in_call;
    *in_call = NULL;

    pendingCalls[packet->source.callID] = call->method;


    _log(COLLECT__CALL_SUMMARY, "Call ID %" PRIu64 ": %s          (svc %s)", packet->source.callID, call->method.c_str(), packet->dest.service.c_str());
    packet->source.Dump(COLLECT__PACKET_SRC, "  Src:  ");
    packet->dest.Dump(COLLECT__PACKET_DEST, "  Dest: ");
    if(is_log_enabled(COLLECT__CALL_DUMP)) {
        PyLookupDump dumper(&lookResolver, COLLECT__CALL_DUMP);
        call->Dump(COLLECT__CALL_DUMP, &dumper);
    }


    if(call->method != "MachoBindObject") {    //this is handled elsewhere...
        if(is_log_enabled(COLLECT__CALL_XML)) {
            printf("<element name=\"Call%s\">\n", call->method.c_str());
            PyXMLGenerator gen(stdout);
            call->arg_tuple->visit(&gen);
            printf("</element>\n");
        }
    }

    //send it to a dispatcher if there is one registered
    std::map<std::string, _CallReqDispatch>::const_iterator res;
    res = m_callReqDisp.find(call->method);
    if(res != m_callReqDisp.end()) {
        _CallReqDispatch dsp = res->second;
        (this->*dsp)(packet, &call);
    }

    delete call;
}

Here is the call graph for this function:

void EVECollectDispatcher::Handle_CallRsp ( const PyPacket *  packet, PyRepTuple **  res  )

protectedvirtual

Definition at line 77 of file EVECollectDisp.cpp.

References _log, PyAddress::callID, PyPacket::dest, PyAddress::Dump(), is_log_enabled, lookResolver, m_callRspDisp, Agents::Type::None, pendingCalls, PRIu64, PyAddress::service, and PyPacket::source.

                                                                                        {
    PyRepTuple *result = *in_result;
    *in_result = NULL;

    std::map<uint32, std::string>::iterator res;
    res = pendingCalls.find(packet->dest.callID);
    if(res != pendingCalls.end()) {
        const char *pfx = "";
        if(result->items.size() == 1 && result->items[0]->CheckType(PyRep::SubStream)) {
            PyRepSubStream *ss = (PyRepSubStream *) result->items[0];
            ss->DecodeData();
            if(ss->decoded != NULL) {
                if(ss->decoded->CheckType(PyRep::None))
                    pfx = "Empty ";

                //decode any nested substreams.
                SubStreamDecoder ssd;
                ss->decoded->visit(&ssd);
            }
        }

        _log(COLLECT__CALL_SUMMARY, "%sCall Response for ID %" PRIu64 ": %s           (svc %s)", pfx, packet->dest.callID, res->second.c_str(), packet->source.service.c_str());

        packet->source.Dump(COLLECT__PACKET_SRC, "  Src:  ");
        packet->dest.Dump(COLLECT__PACKET_DEST, "  Dest: ");

        if(is_log_enabled(COLLECT__CALL_DUMP)) {
            if(res->second != "GetCachableObject") {    //these get dumped elsewhere
                SubStreamDecoder v;
                result->visit(&v);
                PyLookupDump dumper(&lookResolver, COLLECT__CALL_DUMP);
                result->visit(&dumper);
            }
        } //end "is dump enabled"

        if(is_log_enabled(COLLECT__CALLRSP_SQL)
           && result != NULL
           && res->second != "MachoBindObject"    //bind object nested calls dumped elsewhere.
        ) {
            //run through the result looking for SQL tables, and dump them.
            SetSQLDumper sql_dumper(stdout, res->second.c_str());
            result->visit(&sql_dumper);
        }

        if(is_log_enabled(COLLECT__CALLRSP_XML)
           && result != NULL
           && res->second != "MachoBindObject"    //bind object nested calls dumped elsewhere.
        ) {
            printf("<element name=\"Rsp%s\">\n", res->second.c_str());
            PyXMLGenerator gen(stdout);
            result->visit(&gen);
            printf("</element>\n");
        }

        //send it to a dispatcher if there is one registered
        std::map<std::string, _CallRspDispatch>::const_iterator res2;
        res2 = m_callRspDisp.find(res->second);
        if(res2 != m_callRspDisp.end()) {
            _CallRspDispatch dsp = res2->second;
            (this->*dsp)(packet, &result);
        }/* else {
            _log(COLLECT__ERROR, "Unable to find handler for '%s'", res->second.c_str());
        }*/

        pendingCalls.erase(res);
    } else {
        _log(COLLECT__CALL_SUMMARY, "Call Response for unknonw call ID %" PRIu64, packet->dest.callID);
    }
    delete result;
}

Here is the call graph for this function:

void EVECollectDispatcher::Handle_ErrorResponse ( const PyPacket *  packet, ErrorResponseBody **  body  )

protectedvirtual

Definition at line 182 of file EVECollectDisp.cpp.

References _log.

                                                                                                {
    _log(COLLECT__ERROR, "Unprocessed ErrorResponse");
}

void EVECollectDispatcher::Handle_Notify ( const PyPacket *  packet, EVENotificationStream **  notify  )

protectedvirtual

Definition at line 148 of file EVECollectDisp.cpp.

References _log, EVENotificationStream::args, PyPacket::dest, PyAddress::Dump(), EVENotificationStream::Dump(), is_log_enabled, lookResolver, m_notifyDisp, PyAddress::service, PyPacket::source, and PyTuple::visit().

                                                                                                  {
    EVENotificationStream *notify = *in_notify;
    *in_notify = NULL;

    _log(COLLECT__NOTIFY_SUMMARY, "Notification of type %s", packet->dest.service.c_str());
    packet->source.Dump(COLLECT__PACKET_SRC, "  Src:  ");
    packet->dest.Dump(COLLECT__PACKET_DEST, "  Dest: ");
    if(is_log_enabled(COLLECT__NOTIFY_DUMP)) {
        PyLookupDump dumper(&lookResolver, COLLECT__NOTIFY_DUMP);
        notify->Dump(COLLECT__NOTIFY_DUMP, &dumper);
    }

    if(is_log_enabled(COLLECT__NOTIFY_XML)) {
        printf("<element name=\"Notify%s\">\n", packet->dest.service.c_str());
        PyXMLGenerator gen(stdout);
        notify->args->visit(&gen);
        printf("</element>\n");
    }

    //send it to a dispatcher if there is one registered
    std::map<std::string, _NotifyDispatch>::const_iterator res;
    res = m_notifyDisp.find(packet->dest.service);
    if(res != m_notifyDisp.end()) {
        _NotifyDispatch dsp = res->second;
        (this->*dsp)(packet, &notify);
    }

    delete notify;
}

Here is the call graph for this function:

void EVECollectDispatcher::Handle_Other ( PyPacket **  packet )

protectedvirtual

Definition at line 186 of file EVECollectDisp.cpp.

References _log, PyPacket::dest, PyAddress::Dump(), PyPacket::Dump(), is_log_enabled, lookResolver, PyPacket::payload, PyPacket::source, and PyTuple::visit().

                                                            {
    PyPacket *packet = *in_packet;
    *in_packet = NULL;

    //everything else...
    if(is_log_enabled(COLLECT__CALL_DUMP)) {
        //semi-hack: if we are dumping general stuff, dump the misc packets directly.

        //decode substreams to facilitate dumping better:
        SubStreamDecoder v;
        packet->payload->visit(&v);

        _log(COLLECT__OTHER_DUMP, "Misc Packet:");

        packet->source.Dump(COLLECT__PACKET_SRC, "  Src:  ");
        packet->dest.Dump(COLLECT__PACKET_DEST, "  Dest: ");

        PyLookupDump dumper(&lookResolver, COLLECT__CALL_DUMP);
        packet->Dump(COLLECT__CALL_DUMP, &dumper);
    }
    if(is_log_enabled(COLLECT__MISC_XML)) {
            printf("<element name=\"??\">\n");
            PyXMLGenerator gen(stdout);
            packet->payload->visit(&gen);
            printf("</element>\n");
    }

    delete packet;
}

Here is the call graph for this function:

void EVECollectDispatcher::Handle_SessionChange ( const PyPacket *  packet, SessionChangeNotification **  notify  )

protectedvirtual

Definition at line 178 of file EVECollectDisp.cpp.

References _log.

                                                                                                          {
    _log(COLLECT__ERROR, "Unprocessed SessionChange");
}

Member Data Documentation

PyLookupResolver EVECollectDispatcher::lookResolver

Definition at line 15 of file EVECollectDisp.h.

Referenced by Handle_CallReq(), Handle_CallRsp(), Handle_Notify(), Handle_Other(), main(), and tcp_callback().

std::map<std::string, _CallReqDispatch> EVECollectDispatcher::m_callReqDisp

protected

Definition at line 36 of file EVECollectDisp.h.

Referenced by Handle_CallReq().

std::map<std::string, _CallRspDispatch> EVECollectDispatcher::m_callRspDisp

protected

Definition at line 37 of file EVECollectDisp.h.

Referenced by Handle_CallRsp().

std::map<std::string, _DestinyDispatch> EVECollectDispatcher::m_destinyDisp

protected

Definition at line 50 of file EVECollectDisp.h.

std::map<std::string, _NotifyDispatch> EVECollectDispatcher::m_notifyDisp

protected

Definition at line 38 of file EVECollectDisp.h.

Referenced by Handle_Notify().

std::map<uint32, std::string> EVECollectDispatcher::pendingBinds

protected

Definition at line 28 of file EVECollectDisp.h.

std::map<uint32, std::string> EVECollectDispatcher::pendingCalls

protected

Definition at line 27 of file EVECollectDisp.h.

Referenced by Handle_CallReq(), and Handle_CallRsp().

---

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

• /backups/local/src/eve/EvEmu_Crucible/src/eve-collector/EVECollectDisp.h
• /backups/local/src/eve/EvEmu_Crucible/src/eve-collector/EVECollectDisp.cpp