[svn] commit: r138 - in /trunk/src/lib/cc: python/ISC/CC/session.py ruby/lib/cc/session.rb

[BIND 10 source code commits]

Author: mgraff
Date: Wed Oct 28 21:53:03 2009
New Revision: 138

Log:
add reply() function, and return the sequence numbers

Modified:
    trunk/src/lib/cc/python/ISC/CC/session.py
    trunk/src/lib/cc/ruby/lib/cc/session.rb

Modified: trunk/src/lib/cc/python/ISC/CC/session.py
==============================================================================
--- trunk/src/lib/cc/python/ISC/CC/session.py (original)
+++ trunk/src/lib/cc/python/ISC/CC/session.py Wed Oct 28 21:53:03 2009
@@ -114,15 +114,17 @@
         })
 
     def group_sendmsg(self, msg, group, instance = "*", to = "*"):
+        seq = self._next_sequence()
         self.sendmsg({
             "type": "send",
             "from": self._lname,
             "to": to,
             "group": group,
             "instance": instance,
-            "seq": self._next_sequence(),
+            "seq": seq,
             "msg": Message.to_wire(msg),
         })
+        return seq
 
     def group_recvmsg(self, nonblock = True):
         msg = self.recvmsg(nonblock)
@@ -131,6 +133,20 @@
         data = Message.from_wire(msg["msg"])
         return (data, msg)
 
+    def group_reply(self, routing, msg):
+        seq = self._next_sequence()
+        self.sendmsg({
+            "type": "send",
+            "from": self._lname,
+            "to": routing["from"],
+            "group": routing["group"],
+            "instance": routing["instance"],
+            "seq": seq,
+            "reply": routing["seq"],
+            "msg": Message.to_wire(msg),
+        })
+        return seq
+
 if __name__ == "__main__":
     import doctest
     doctest.testmod()

Modified: trunk/src/lib/cc/ruby/lib/cc/session.rb
==============================================================================
--- trunk/src/lib/cc/ruby/lib/cc/session.rb (original)
+++ trunk/src/lib/cc/ruby/lib/cc/session.rb Wed Oct 28 21:53:03 2009
@@ -115,14 +115,30 @@
   end
 
   def group_sendmsg(msg, group, instance = "*", to = "*")
+    seq = next_sequence
     sendmsg({ :type => "send",
               :from => @lname,
               :to => to,
               :group => group,
               :instance => instance,
-              :seq => next_sequence,
+              :seq => seq,
               :msg => CC::Message.to_wire(msg),
             })
+    seq
+  end
+
+  def group_sendmsg(routing, msg)
+    seq = next_sequence
+    sendmsg({ :type => "send",
+              :from => @lname,
+              :to => routing["from"],
+              :group => routing["group"],
+              :instance => routing["instance"],
+              :seq => seq,
+              :reply => fouring["seq"],
+              :msg => CC::Message.to_wire(msg),
+            })
+    seq
   end
 
   def group_recvmsg(nonblock = true)