Method ExtMsgQuery

src/ExtMsg.actor.cpp:197–231

}

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

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

	const char* collName = (const char*)ptr;
	ptr += strlen(collName) + 1;

	numberToSkip = *(int32_t*)ptr;
	ptr += sizeof(int32_t);
	numberToReturn = *(int32_t*)ptr;
	ptr += sizeof(int32_t);

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

	if (ptr != eom) {
		returnFieldSelector = bson::BSONObj((const char*)ptr);
		ptr += returnFieldSelector.objsize();
	}

	ns = getDBCollectionPair(collName, std::make_pair(DocLayerConstants::QUERY_FIELD, query.toString()));
	if (ns.second == "$cmd") {
		isCmd = true;
		// Mark it empty for now, command would be responsible for setting collection name later.
		ns.second = "";
	} else {
		isCmd = false;
	}

	/* We should have consumed all the bytes specified by header */
	ASSERT(ptr == eom);
}

std::string ExtMsgQuery::toString() {
	return format("QUERY: %s, collection=%s, flags=%d, numberToSkip=%d, numberToReturn=%d (%s)",