summaryrefslogtreecommitdiff
path: root/dbgrid
diff options
context:
space:
mode:
authorDwight <dmerriman@gmail.com>2008-10-13 16:19:39 -0400
committerDwight <dmerriman@gmail.com>2008-10-13 16:19:39 -0400
commit1bef26dcc0f98e628a7c2f15b1b445c419810fe4 (patch)
tree0f8d7b8024e667ee9c5c06ffb7fc01f1b7617feb /dbgrid
parente7931c2ad603a2d1ce597b69cfb4f6d14c08276f (diff)
downloadmongo-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.cpp11
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);