ZMQReceiver.cpp File Reference

#include <io/rpc/MessageProcessorBase.h>
#include <io/rpc/Messages.h>
#include <io/rpc/ZMQContext.h>
#include <io/rpc/ZMQReceiver.h>
#include <zmq.hpp>

Include dependency graph for ZMQReceiver.cpp:

Go to the source code of this file.

Namespaces
	cloudViewer
	Generic file read and write utility for python interface.
	cloudViewer::io
	cloudViewer::io::rpc

Macros
#define	PROCESS_MESSAGE(MSGTYPE)

Macro Definition Documentation

PROCESS_MESSAGE

#define PROCESS_MESSAGE

(

MSGTYPE

)

Value:

    else if (MSGTYPE::MsgId() == req.msg_id) {                          \
        auto oh = msgpack::unpack(buffer, buffer_size, offset, nullptr, \
                                  nullptr, limits);                     \
        auto obj = oh.get();                                            \
        MSGTYPE msg;                                                    \
        msg = obj.as<MSGTYPE>();                                        \
        auto reply = processor_->ProcessMessage(req, msg, oh);          \
        if (reply) {                                                    \
            replies.push_back(reply);                                   \
        } else {                                                        \
            replies.push_back(CreateStatusMessage(                      \
                    messages::Status::ErrorProcessingMessage()));       \
        }                                                               \
    }