summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorgregs <greg@10gen.com>2012-10-17 01:39:18 -0400
committergregs <greg@10gen.com>2012-10-17 01:55:47 -0400
commit69e16e6ff80c653a65488d230fd48924629d6e03 (patch)
tree67f9a03eba91eaf6fa523efac1371380d62622d8
parent70f39c63f5e0023a77690c4de71a8720a5b0ea1b (diff)
downloadmongo-69e16e6ff80c653a65488d230fd48924629d6e03.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 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;
}