summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorgregs <greg@10gen.com>2012-10-17 01:39:18 -0400
committerGreg Studer <greg@10gen.com>2012-10-17 10:20:07 -0400
commitb73c4888f7cedb7b22eb211a08685576c3691eb6 (patch)
tree07d61463e846a3891d958b48e29601e3300966be
parent4689b378b37d5aec8a197a78437b18de1bdfdcf3 (diff)
downloadmongo-b73c4888f7cedb7b22eb211a08685576c3691eb6.tar.gz
SERVER-7376 better logging in moveChunk, don't swallow error reported to mongos
-rw-r--r--src/mongo/s/d_migrate.cpp15
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;
}