Class ExtMsgReply

src/ExtMsg.actor.h:94–142

};

struct ExtMsgReply : ExtMsg, FastAllocated<ExtMsgReply> {
	enum { opcode = 1 };

	ExtMsgHeader* header;
	bson::BSONObj query;
	std::vector<bson::BSONObj> documents;

	ExtReplyHeader replyHeader;

	// For constructing our own replies, rather than parsing a reply
	// off of the wire
	ExtMsgReply(ExtMsgHeader*, bson::BSONObj const& query);
	explicit ExtMsgReply(ExtMsgHeader*);

	std::string toString() override;
	Future<Void> run(Reference<ExtConnection>) override { UNREACHABLE(); }

	void addDocument(bson::BSONObj doc) {
		documents.push_back(doc.getOwned());
		replyHeader.documentCount++;
	}

	void setError(std::string msg, int code) {
		// Clear if response contains any outstanding documents
		documents.clear();
		replyHeader.documentCount = 0;

		// Set query failure flag
		addResponseFlag(2);

		// clang-format off
		addDocument(BSON("ok" << 0 <<
		                 "$err" << msg <<
		                 "code" << code));
		// clang-format on
	}

	void setError(Error e) { setError(e.what(), e.code()); }

	void setResponseFlags(int32_t flags) { replyHeader.responseFlags = flags; }

	void addResponseFlag(int32_t flag) { replyHeader.responseFlags = replyHeader.responseFlags | flag; }

	void write(Reference<ExtConnection>);

private:
	ExtMsgReply(ExtMsgHeader*, const uint8_t*);
	friend struct ExtMsg::Factory<ExtMsgReply>;
};

struct ExtUpdateCmd {
	bson::BSONObj selector;