Method ExtMsgReply

src/ExtMsg.actor.cpp:548–561

}

ExtMsgReply::ExtMsgReply(ExtMsgHeader* header, const uint8_t* body) : header(nullptr) {
	memcpy(&replyHeader, header, sizeof(ExtReplyHeader));

	const uint8_t* ptr = (const uint8_t*)header + sizeof(ExtReplyHeader);
	const uint8_t* eom = (const uint8_t*)header + header->messageLength;

	while (ptr < eom) {
		bson::BSONObj doc((const char*)ptr);
		ptr += doc.objsize();
		documents.push_back(doc);
	}

	ASSERT(ptr == eom);
}

ExtMsgReply::ExtMsgReply(ExtMsgHeader* header, bson::BSONObj const& query) : header(header), query(query) {
	replyHeader.responseTo = header->requestID;