Method ExtMsgDelete

src/ExtMsg.actor.cpp:1198–1219

}

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

	// Mongo OP_DELETE begins with int32 ZERO, reserved for future use
	ptr += sizeof(int32_t);

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

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

	bson::BSONObj selector = bson::BSONObj((const char*)ptr);
	ptr += selector.objsize();

	// If 0th bit is set, limit should be just one document or all documents (0).
	selectors.push_back(BSON("q" << selector << "limit" << (flags & 1)));

	ASSERT(ptr == eom);
}

std::string ExtMsgDelete::toString() {
	std::ostringstream stringStream;