diff options
author | Dwight <dmerriman@gmail.com> | 2008-10-13 16:19:39 -0400 |
---|---|---|
committer | Dwight <dmerriman@gmail.com> | 2008-10-13 16:19:39 -0400 |
commit | 1bef26dcc0f98e628a7c2f15b1b445c419810fe4 (patch) | |
tree | 0f8d7b8024e667ee9c5c06ffb7fc01f1b7617feb /dbgrid | |
parent | e7931c2ad603a2d1ce597b69cfb4f6d14c08276f (diff) | |
download | mongo-1bef26dcc0f98e628a7c2f15b1b445c419810fe4.tar.gz |
don't exit if client sends us garbage for a queryr0.1.5_rc1
Diffstat (limited to 'dbgrid')
-rw-r--r-- | dbgrid/request.cpp | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/dbgrid/request.cpp b/dbgrid/request.cpp index f5e40e18c28..1777cf05bab 100644 --- a/dbgrid/request.cpp +++ b/dbgrid/request.cpp @@ -27,7 +27,15 @@ void queryOp(Message& m, MessagingPort& p) { cout << "TEMP: " << ns << endl; - ScopedDbConnection c("localhost"); + ScopedDbConnection dbcon("localhost"); + DBClientConnection &c = dbcon.conn(); + + Message response; + bool ok = c.port().call(m, response); + uassert("dbgrid: error calling dbd", ok); +//p.reply + + dbcon.done(); } void writeOp(int op, Message& m, MessagingPort& p) {
@@ -49,6 +57,7 @@ void writeOp(int op, Message& m, MessagingPort& p) { void processRequest(Message& m, MessagingPort& p) { int op = m.data->operation(); if( op == dbQuery ) { + queryOp(m,p); } else { writeOp(op, m, p); |