diff options
author | gregs <greg@10gen.com> | 2012-10-17 01:39:18 -0400 |
---|---|---|
committer | gregs <greg@10gen.com> | 2012-10-17 01:55:47 -0400 |
commit | 69e16e6ff80c653a65488d230fd48924629d6e03 (patch) | |
tree | 67f9a03eba91eaf6fa523efac1371380d62622d8 | |
parent | 70f39c63f5e0023a77690c4de71a8720a5b0ea1b (diff) | |
download | mongo-69e16e6ff80c653a65488d230fd48924629d6e03.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 d6ec108ad47..16569f625a7 100644 --- a/src/mongo/s/d_migrate.cpp +++ b/src/mongo/s/d_migrate.cpp @@ -195,6 +195,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 , @@ -204,7 +207,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; } @@ -687,7 +692,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; @@ -1032,7 +1039,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; } @@ -1044,6 +1052,7 @@ namespace mongo { verify( res["errmsg"].type() ); errmsg += res["errmsg"].String(); result.append( "cause" , res ); + warning() << errmsg << endl; return false; } |