Method write

src/ExtMsg.actor.cpp:587–603

}

void ExtMsgReply::write(Reference<ExtConnection> nmc) {
	replyHeader.messageLength = sizeof(replyHeader);
	for (const auto& document : documents) {
		replyHeader.messageLength += document.objsize();
	}

	if (verboseLogging)
		TraceEvent("BD_msgReply").detail("Message", toString()).detail("connId", nmc->connectionId);
	if (verboseConsoleOutput)
		fprintf(stderr, "S -> C: %s\n\n", toString().c_str());

	nmc->bc->write(StringRef((uint8_t*)&replyHeader, sizeof(replyHeader)));

	for (const auto& doc : documents) {
		nmc->bc->write(StringRef((const uint8_t*)doc.objdata(), doc.objsize()));
	}
}

ExtMsgInsert::ExtMsgInsert(ExtMsgHeader* header, const uint8_t* body) : header(header) {
	const uint8_t* ptr = body;