summaryrefslogtreecommitdiff
path: root/grid
diff options
context:
space:
mode:
authorDwight <dmerriman@gmail.com>2008-06-11 16:58:34 -0400
committerDwight <dmerriman@gmail.com>2008-06-11 16:58:34 -0400
commit1d8c3e37b32a11d2e2b64fee019782f5efdd19c6 (patch)
tree5fd74e79c7ef74ec95725469fad7e6a9fc0b9b5d /grid
parent4bda2a91c6241d9fe7891cb6f3c168373c08169d (diff)
downloadmongo-1d8c3e37b32a11d2e2b64fee019782f5efdd19c6.tar.gz
bad memory issue with cursors
Diffstat (limited to 'grid')
-rw-r--r--grid/message.cpp4
-rw-r--r--grid/message.h2
2 files changed, 6 insertions, 0 deletions
diff --git a/grid/message.cpp b/grid/message.cpp
index cfa9a02a912..c9f512064bf 100644
--- a/grid/message.cpp
+++ b/grid/message.cpp
@@ -163,6 +163,10 @@ void MessagingPort::reply(Message& received, Message& response) {
say(received.from, response, received.data->id);
}
+void MessagingPort::reply(Message& received, Message& response, MSGID responseTo) {
+ say(received.from, response, responseTo);
+}
+
bool MessagingPort::call(SockAddr& to, Message& toSend, Message& response) {
mmm( cout << "*call()" << endl; )
MSGID old = toSend.data->id;
diff --git a/grid/message.h b/grid/message.h
index be2749c8bea..3a26909dec9 100644
--- a/grid/message.h
+++ b/grid/message.h
@@ -22,6 +22,7 @@ private:
class AbstractMessagingPort {
public:
+ virtual void reply(Message& received, Message& response, MSGID responseTo) = 0; // like the reply below, but doesn't rely on received.data still being available
virtual void reply(Message& received, Message& response) = 0;
};
@@ -39,6 +40,7 @@ public:
also, the Message data will go out of scope on the subsequent recv call.
*/
bool recv(Message& m);
+ void reply(Message& received, Message& response, MSGID responseTo);
void reply(Message& received, Message& response);
bool call(SockAddr& to, Message& toSend, Message& response);
void say(SockAddr& to, Message& toSend, int responseTo = -1);