/** * Copyright (C) 2013 10gen Inc. * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License, version 3, * as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . * * As a special exception, the copyright holders give permission to link the * code of portions of this program with the OpenSSL library under certain * conditions as described in each individual source file and distribute * linked combinations including the program with the OpenSSL library. You * must comply with the GNU Affero General Public License in all respects * for all of the code used other than as permitted herein. If you modify * file(s) with this exception, you may extend this exception to your * version of the file(s), but you are not obligated to do so. If you do not * wish to do so, delete this exception statement from your version. If you * delete this exception statement from all source files in the program, * then also delete it in the license file. */ #include "mongo/platform/basic.h" #include "mongo/db/range_arithmetic.h" namespace mongo { using std::make_pair; using std::pair; using std::string; using std::stringstream; bool rangeContains( const BSONObj& inclusiveLower, const BSONObj& exclusiveUpper, const BSONObj& point ) { return point.woCompare( inclusiveLower ) >= 0 && point.woCompare( exclusiveUpper ) < 0; } bool rangeOverlaps( const BSONObj& inclusiveLower1, const BSONObj& exclusiveUpper1, const BSONObj& inclusiveLower2, const BSONObj& exclusiveUpper2 ) { return ( exclusiveUpper1.woCompare( inclusiveLower2 ) > 0 ) && ( exclusiveUpper2.woCompare( inclusiveLower1 ) > 0 ); } int compareRanges( const BSONObj& rangeMin1, const BSONObj& rangeMax1, const BSONObj& rangeMin2, const BSONObj& rangeMax2 ) { const int minCmp = rangeMin1.woCompare( rangeMin2 ); if ( minCmp != 0 ) return minCmp; return rangeMax1.woCompare( rangeMax2 ); } // Represents the start and end of an overlap of a tested range typedef pair OverlapBounds; // Internal-only, shared functionality OverlapBounds rangeMapOverlapBounds( const RangeMap& ranges, const BSONObj& inclusiveLower, const BSONObj& exclusiveUpper ) { // Returns the first chunk with a min key that is >= lower bound - the previous chunk // might overlap. RangeMap::const_iterator low = ranges.lower_bound( inclusiveLower ); // See if the previous chunk overlaps our range, not clear from just min key if ( low != ranges.begin() ) { RangeMap::const_iterator next = low; --low; // If the previous range's max value is lte our min value if ( low->second.woCompare( inclusiveLower ) < 1 ) { low = next; } } // Returns the first chunk with a max key that is >= upper bound - implies the // chunk does not overlap upper bound RangeMap::const_iterator high = ranges.lower_bound( exclusiveUpper ); return OverlapBounds( low, high ); } void getRangeMapOverlap( const RangeMap& ranges, const BSONObj& inclusiveLower, const BSONObj& exclusiveUpper, RangeVector* overlap ) { overlap->clear(); OverlapBounds bounds = rangeMapOverlapBounds( ranges, inclusiveLower, exclusiveUpper ); for ( RangeMap::const_iterator it = bounds.first; it != bounds.second; ++it ) { overlap->push_back( make_pair( it->first, it->second ) ); } } bool rangeMapOverlaps( const RangeMap& ranges, const BSONObj& inclusiveLower, const BSONObj& exclusiveUpper ) { OverlapBounds bounds = rangeMapOverlapBounds( ranges, inclusiveLower, exclusiveUpper ); return bounds.first != bounds.second; } bool rangeMapContains( const RangeMap& ranges, const BSONObj& inclusiveLower, const BSONObj& exclusiveUpper ) { OverlapBounds bounds = rangeMapOverlapBounds( ranges, inclusiveLower, exclusiveUpper ); if ( bounds.first == ranges.end() ) return false; return bounds.first->first.woCompare( inclusiveLower ) == 0 && bounds.first->second.woCompare( exclusiveUpper ) == 0; } string rangeToString( const BSONObj& inclusiveLower, const BSONObj& exclusiveUpper ) { stringstream ss; ss << "[" << inclusiveLower.toString() << ", " << exclusiveUpper.toString() << ")"; return ss.str(); } string overlapToString( RangeVector overlap ) { stringstream ss; for ( RangeVector::const_iterator it = overlap.begin(); it != overlap.end(); ++it ) { if ( it != overlap.begin() ) ss << ", "; ss << rangeToString( it->first, it->second ); } return ss.str(); } }