diff options
| author | Antonin Kral <a.kral@bobek.cz> | 2011-12-15 10:02:19 +0100 |
|---|---|---|
| committer | Antonin Kral <a.kral@bobek.cz> | 2011-12-15 10:02:46 +0100 |
| commit | 0b48f8ada2acb0de830b23f8cefc8e3fea28d915 (patch) | |
| tree | f7c2811269b6b53199412be2dd5ec02eea15d55d /s/d_logic.cpp | |
| parent | 85f1cd56145b90a32b7ccdc750000deeed54fe22 (diff) | |
| parent | f0d9a01bccdaeb466c12c92057914bbfef59526c (diff) | |
| download | mongodb-0b48f8ada2acb0de830b23f8cefc8e3fea28d915.tar.gz | |
Merge branch 'upstream/2.0.2'
Diffstat (limited to 's/d_logic.cpp')
| -rw-r--r-- | s/d_logic.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/s/d_logic.cpp b/s/d_logic.cpp index 9d4fd74..fd281ac 100644 --- a/s/d_logic.cpp +++ b/s/d_logic.cpp @@ -107,7 +107,10 @@ namespace mongo { b.append( "connectionId" , cc().getConnectionId() ); b.append( "instanceIdent" , prettyHostName() ); b.appendTimestamp( "version" , shardingState.getVersion( ns ) ); - b.appendTimestamp( "yourVersion" , ShardedConnectionInfo::get( true )->getVersion( ns ) ); + + ShardedConnectionInfo* info = ShardedConnectionInfo::get( false ); + b.appendTimestamp( "yourVersion" , info ? info->getVersion(ns) : (ConfigVersion)0 ); + b.appendBinData( "msg" , m.header()->len , bdtCustom , (char*)(m.singleData()) ); LOG(2) << "writing back msg with len: " << m.header()->len << " op: " << m.operation() << endl; writeBackManager.queueWriteBack( clientID.str() , b.obj() ); |
