mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-11-30 00:56:44 +01:00
Code Issues Releases Activity

Add chunkMap to ChunkManager. Start of SHARDING-79

Browse Source
This commit is contained in:
Mathias Stearn 2010-03-31 14:45:15 -04:00
parent d42bd9af1c
commit 3a25213655
2 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
s/chunk.cpp
View File

@ -138,8 +138,10 @@ namespace mongo {
_markModified();
_manager->_chunks.push_back( s );
_manager->_chunkMap[s->getMax()] = s;
setMax(m.getOwned());
_manager->_chunkMap[_max] = this;
log(1) << " after split:\n"
<< "\t left : " << toString() << "\n"
@ -427,6 +429,7 @@ namespace mongo {
Chunk * c = new Chunk( this );
c->unserialize( d );
_chunks.push_back( c );
_chunkMap[c->getMax()] = c;
c->_id = d["_id"].wrap().getOwned();
}
conn.done();
@ -440,6 +443,7 @@ namespace mongo {
c->_markModified();
_chunks.push_back( c );
_chunkMap[c->getMax()] = c;
log() << "no chunks for:" << ns << " so creating first: " << c->toString() << endl;
}
@ -452,6 +456,7 @@ namespace mongo {
delete( *i );
}
_chunks.clear();
_chunkMap.clear();
}
bool ChunkManager::hasShardKey( const BSONObj& obj ){
@ -459,14 +464,16 @@ namespace mongo {
}
Chunk& ChunkManager::findChunk( const BSONObj & obj ){
for ( vector<Chunk*>::iterator i=_chunks.begin(); i != _chunks.end(); i++ ){
Chunk * c = *i;
BSONObj key = _key.extractKey(obj);
ChunkMap::iterator it = _chunkMap.upper_bound(key);
if (it != _chunkMap.end()){
Chunk* c = it->second;
if ( c->contains( obj ) )
return *c;
}
stringstream ss;
ss << "couldn't find a chunk which should be impossible extracted: " << _key.extractKey( obj );
ss << "couldn't find a chunk which should be impossible extracted: " << key;
throw UserException( 8070 , ss.str() );
}
@ -537,6 +544,7 @@ namespace mongo {
// wipe my meta-data
_chunks.clear();
_chunkMap.clear();
// delete data from mongod

3
s/chunk.h
View File

@ -212,6 +212,9 @@ namespace mongo {
vector<Chunk*> _chunks;
map<string,unsigned long long> _maxMarkers;
typedef map<BSONObj,Chunk*,BSONObjCmp> ChunkMap;
ChunkMap _chunkMap;
unsigned long long _sequenceNumber;
friend class Chunk;