Class ExtMsg

src/ExtMsg.actor.h:43–68

#include "flow/actorcompiler.h" // This must be the last #include.

struct ExtMsg : IDispatched<ExtMsg, int32_t, std::function<ExtMsg*(ExtMsgHeader*, const uint8_t*)>>,
                ReferenceCounted<ExtMsg> {
	static Reference<ExtMsg> create(ExtMsgHeader* header, const uint8_t* body, Promise<Void> finished) {
		Reference<ExtMsg> r(dispatch(header->opCode)(header, body));
		r->break_when_finished = finished;
		return r;
	}

	/**
	 * This promise will be broken only when this class is destructed, which triggers
	 * the release of the underlying memory
	 */
	Promise<Void> break_when_finished;

	virtual ~ExtMsg() = default;

	virtual std::string toString() = 0;
	virtual Future<Void> run(Reference<ExtConnection>) = 0;

	template <class ExtMsgType>
	struct Factory {
		static ExtMsg* create(ExtMsgHeader* header, const uint8_t* body) {
			return (ExtMsg*)(new ExtMsgType(header, body));
		}
	};
};

#define REGISTER_MSG(Msg) REGISTER_FACTORY(ExtMsg, Msg, opcode)