mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

ChunkManger::reload() helper

Browse Source
This commit is contained in:
Mathias Stearn 2011-05-06 13:53:32 -04:00
parent 58f9b93b07
commit fafe6cb761
2 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
s/chunk.cpp
View File

@ -264,8 +264,8 @@ namespace mongo {
conn.done();
// reloading won't stricly solve all problems, e.g. the collection's metdata lock can be taken
// but we issue here so that mongos may refresh wihtout needing to be written/read against
grid.getDBConfig( getns() )->getChunkManager( getns() , true );
// but we issue here so that mongos may refresh without needing to be written/read against
_manager->reload();
return false;
}
@ -273,7 +273,7 @@ namespace mongo {
conn.done();
// force reload of config
grid.getDBConfig( getns() )->getChunkManager( getns() , true );
_manager->reload();
return true;
}
@ -305,7 +305,7 @@ namespace mongo {
// if succeeded, needs to reload to pick up the new location
// if failed, mongos may be stale
// reload is excessive here as the failure could be simply because collection metadata is taken
grid.getDBConfig( getns() )->getChunkManager( getns() , true );
_manager->reload();
return worked;
}
@ -355,7 +355,7 @@ namespace mongo {
return true; // we did split even if we didn't migrate
}
ChunkManagerPtr cm = grid.getDBConfig(getns())->getChunkManager(getns(), false/*reloaded by split*/);
ChunkManagerPtr cm = _manager->reload(false/*just reloaded in mulitsplit*/);
ChunkPtr toMove = cm->findChunk(min);
if ( ! (toMove->getMin() == min && toMove->getMax() == max) ){
@ -371,7 +371,7 @@ namespace mongo {
toMove->moveAndCommit( newLocation , MaxChunkSize , res ) );
// update our config
grid.getDBConfig( toMove->getns() )->getChunkManager( toMove->getns() , true );
_manager->reload();
}
return true;
@ -502,6 +502,11 @@ namespace mongo {
_shards.clear();
}
ChunkManagerPtr ChunkManager::reload(bool force) const {
return grid.getDBConfig(getns())->getChunkManager(getns(), force);
}
void ChunkManager::_reload_inlock() {
int tries = 3;
while (tries--) {

2
s/chunk.h
View File

@ -333,6 +333,8 @@ namespace mongo {
int getCurrentDesiredChunkSize() const;
private:
ChunkManagerPtr reload(bool force=true) const; // doesn't modify self!
void _reload_inlock();
void _load();