BIND 10 track1914, updated. b174ac98fbe2c9bae96edd0faf2e8884cbbac4fd [1914] Store the request into a queue

[BIND 10 source code commits]

The branch, track1914 has been updated
       via  b174ac98fbe2c9bae96edd0faf2e8884cbbac4fd (commit)
      from  4bdecaadf9b845af3c2b2b11213539a4a0226284 (commit)

Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.

- Log -----------------------------------------------------------------
commit b174ac98fbe2c9bae96edd0faf2e8884cbbac4fd
Author: Michal 'vorner' Vaner <michal.vaner at nic.cz>
Date:   Thu May 17 15:32:36 2012 +0200

    [1914] Store the request into a queue
    
    The requests submitted by groupReadMsgAsync are stored into the list.
    The tests still fail, since nothing is interested in the content of the
    list yet.

-----------------------------------------------------------------------

Summary of changes:
 src/lib/config/ccsession.cc |   22 ++++++++++++++++++++++
 src/lib/config/ccsession.h  |    2 +-
 2 files changed, 23 insertions(+), 1 deletions(-)

-----------------------------------------------------------------------
diff --git a/src/lib/config/ccsession.cc b/src/lib/config/ccsession.cc
index 63fa4cd..38474c8 100644
--- a/src/lib/config/ccsession.cc
+++ b/src/lib/config/ccsession.cc
@@ -764,5 +764,27 @@ ModuleCCSession::sendStopping() {
     session_.group_sendmsg(cmd, "ConfigManager");
 }
 
+class ModuleCCSession::AsyncRecvRequest {
+public: // Everything is public here, as the definition is hidden anyway
+    AsyncRecvCallback callback;
+    string recipient;
+    int seq;
+    bool is_reply;
+};
+
+ModuleCCSession::AsyncRecvRequestID
+ModuleCCSession::groupRecvMsgAsync(const AsyncRecvCallback& callback,
+                                   bool is_reply, int seq,
+                                   const string& recipient) {
+    // This just stores the request, the handling is done in checkCommand()
+    boost::shared_ptr<AsyncRecvRequest> request(new AsyncRecvRequest);
+    request->callback = callback;
+    request->recipient = recipient;
+    request->seq = seq;
+    request->is_reply = is_reply;
+    // push_back would be simpler, but it does not return the iterator we need
+    return (async_recv_requests_.insert(async_recv_requests_.end(), request));
+}
+
 }
 }
diff --git a/src/lib/config/ccsession.h b/src/lib/config/ccsession.h
index 66b8896..7d2bb71 100644
--- a/src/lib/config/ccsession.h
+++ b/src/lib/config/ccsession.h
@@ -451,7 +451,7 @@ public:
     ///     callback or can be used to cancel the request by cancelAsyncRecv.
     /// \todo Decide what to do with instance and what was it meant for anyway.
     AsyncRecvRequestID groupRecvMsgAsync(const AsyncRecvCallback& callback,
-                                         bool is_reply = true, int seq = -1,
+                                         bool is_reply, int seq = -1,
                                          const std::string& recipient =
                                          std::string());