Method ExtMsgInsert

src/ExtMsg.actor.cpp:605–623

}

ExtMsgInsert::ExtMsgInsert(ExtMsgHeader* header, const uint8_t* body) : header(header) {
	const uint8_t* ptr = body;
	const uint8_t* eom = (const uint8_t*)header + header->messageLength;

	flags = *(int32_t*)ptr;
	ptr += sizeof(int32_t);

	const char* collName = (const char*)ptr;
	ptr += strlen(collName) + 1;
	ns = getDBCollectionPair(collName, std::make_pair("msgType", "OP_INSERT"));

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

	ASSERT(ptr == eom);
}

std::string ExtMsgInsert::toString() {
	std::string buf = "INSERT: documents=[ ";