diff options
author | Eliot Horowitz <eliot@10gen.com> | 2009-02-03 11:05:16 -0500 |
---|---|---|
committer | Eliot Horowitz <eliot@10gen.com> | 2009-02-03 11:05:16 -0500 |
commit | d0f2dd9169aabfd4faa062becddf70e6eea93c73 (patch) | |
tree | 1fac2c9308aba626398dd38bb426b5d51c45a8c2 /dbgrid | |
parent | 8e5a1a3edfdde53b495455c0192de111436fcb24 (diff) | |
download | mongo-d0f2dd9169aabfd4faa062becddf70e6eea93c73.tar.gz |
make sure to use the original message id when responding
Diffstat (limited to 'dbgrid')
-rw-r--r-- | dbgrid/request.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/dbgrid/request.cpp b/dbgrid/request.cpp index 7aa04052364..370cb3254a2 100644 --- a/dbgrid/request.cpp +++ b/dbgrid/request.cpp @@ -58,12 +58,13 @@ namespace mongo { bool ok = c.port().call(m, response); uassert("dbgrid: getmore: error calling db", ok); p.reply(m, response, m.data->id); - + dbcon.done(); } /* got query operation from a database */ void queryOp(Message& m, MessagingPort& p) { + const MSGID originalID = m.data->id; DbMessage d(m); QueryMessage q(d); bool lateAssert = false; @@ -85,7 +86,7 @@ namespace mongo { bool ok = c.port().call(m, response); uassert("dbgrid: error calling db", ok); lateAssert = true; - p.reply(m, response, m.data->id); + p.reply(m, response, originalID ); dbcon.done(); } catch ( AssertionException& e ) { @@ -97,7 +98,7 @@ namespace mongo { return; } } - + void writeOp(int op, Message& m, MessagingPort& p) { DbMessage d(m); const char *ns = d.getns(); |