diff options
author | gregs <greg@10gen.com> | 2012-10-17 01:39:18 -0400 |
---|---|---|
committer | Greg Studer <greg@10gen.com> | 2012-10-17 10:20:07 -0400 |
commit | b73c4888f7cedb7b22eb211a08685576c3691eb6 (patch) | |
tree | 07d61463e846a3891d958b48e29601e3300966be | |
parent | 4689b378b37d5aec8a197a78437b18de1bdfdcf3 (diff) | |
download | mongo-b73c4888f7cedb7b22eb211a08685576c3691eb6.tar.gz |
SERVER-7376 better logging in moveChunk, don't swallow error reported to mongos
-rw-r--r-- | src/mongo/s/d_migrate.cpp | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/src/mongo/s/d_migrate.cpp b/src/mongo/s/d_migrate.cpp index b30e8422f4b..f5d59566b71 100644 --- a/src/mongo/s/d_migrate.cpp +++ b/src/mongo/s/d_migrate.cpp @@ -193,6 +193,9 @@ namespace mongo { ShardForceVersionOkModeBlock sf; { RemoveSaver rs("moveChunk",ns,"post-cleanup"); + + log() << "moveChunk starting delete for: " << this->toString() << migrateLog; + long long numDeleted = Helpers::removeRange( ns , min , @@ -202,7 +205,9 @@ namespace mongo { secondaryThrottle , cmdLine.moveParanoia ? &rs : 0 , /*callback*/ true ); /*fromMigrate*/ - log() << "moveChunk deleted: " << numDeleted << migrateLog; + + log() << "moveChunk deleted " << numDeleted << " documents for " + << this->toString() << migrateLog; } @@ -666,7 +671,9 @@ namespace mongo { if (!noauth) { cc().getAuthenticationInfo()->authorize("local", internalSecurity.user); } - log() << " (start) waiting to cleanup " << cleanup << " # cursors:" << cleanup.initial.size() << migrateLog; + + log() << " (start) waiting to cleanup " << cleanup + << ", # cursors remaining: " << cleanup.initial.size() << migrateLog; int loops = 0; Timer t; @@ -1006,7 +1013,8 @@ namespace mongo { res ); } catch( DBException& e ){ - errmsg = str::stream() << "moveChunk could not contact to: shard " << to << " to start transfer" << causedBy( e ); + errmsg = str::stream() << "moveChunk could not contact to: shard " + << to << " to start transfer" << causedBy( e ); warning() << errmsg << endl; return false; } @@ -1018,6 +1026,7 @@ namespace mongo { verify( res["errmsg"].type() ); errmsg += res["errmsg"].String(); result.append( "cause" , res ); + warning() << errmsg << endl; return false; } |