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

moveshard cleaning checkpoint

Browse Source
This commit is contained in:
Eliot Horowitz 2009-04-03 16:46:48 -04:00
parent 2c72807a42
commit 74bb4f6029
1 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
s/d_logic.cpp
View File

@ -157,7 +157,7 @@ namespace mongo {
virtual void help( stringstream& help ) const {
help << " example: { getShardVersion : 'alleyinsider.foo' } ";
}
bool run(const char *cmdns, BSONObj& cmdObj, string& errmsg, BSONObjBuilder& result, bool){
string ns = cmdObj["getShardVersion"].valuestrsafe();
if ( ns.size() == 0 ){
@ -179,6 +179,35 @@ namespace mongo {
} getShardVersion;
class MoveShardStartCommand : public MongodShardCommand {
public:
MoveShardStartCommand() : MongodShardCommand( "moveshard.start" ){}
virtual void help( stringstream& help ) const {
help << "should not be calling this directly" << endl;
}
bool run(const char *cmdns, BSONObj& cmdObj, string& errmsg, BSONObjBuilder& result, bool){
// i assume i'm already locked
// so i have to start clone, tell caller its ok to make change
// then finish calls finish, and then deletes data when cursors are done
return false;
}
} moveShardStartCmd;
class MoveShardFinishCommand : public MongodShardCommand {
public:
MoveShardFinishCommand() : MongodShardCommand( "moveshard.finish" ){}
virtual void help( stringstream& help ) const {
help << "should not be calling this directly" << endl;
}
bool run(const char *cmdns, BSONObj& cmdObj, string& errmsg, BSONObjBuilder& result, bool){
// see MoveShardStartCommand::run
return false;
}
} moveShardFinishCmd;
/**
* @ return true if not in sharded mode