v114 merge patchr0.0.4_rc3

1 files changed, 2 insertions, 1 deletions

diff --git a/db/query.cpp b/db/query.cpp
index 2a624977630..1cd60df52b4 100644
--- a/db/query.cpp
+++ b/db/query.cpp
@@ -639,7 +639,7 @@ void killCursors(int n, long long *ids) {
 
 auto_ptr<Cursor> findTableScan(const char *ns, JSObj& order);
 
-QueryResult* runQuery(const char *ns, int ntoskip, int _ntoreturn, JSObj jsobj, 
+QueryResult* runQuery(Message& message, const char *ns, int ntoskip, int _ntoreturn, JSObj jsobj, 
 					  auto_ptr< set<string> > filter, stringstream& ss) 
 {
 	bool wantMore = true;
@@ -740,6 +740,7 @@ assert( debug.getN() < 5000 );
 											ClientCursor::add(cc);
 											cc->updateLocation();
 											cc->filter = filter;
+											cc->originalMessage = message;
 										}
 									}
 									break;