BIND 10 trac2013, updated. 2f4b6ea6438119eaee2c06c6d97bb66825a174a6 [2013] specify PRESERVE_ORDER for Message.from_wire.

[BIND 10 source code commits]

The branch, trac2013 has been updated
       via  2f4b6ea6438119eaee2c06c6d97bb66825a174a6 (commit)
      from  9e812734e020c04ef076f6b2fc38d3f872a0c361 (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 2f4b6ea6438119eaee2c06c6d97bb66825a174a6
Author: JINMEI Tatuya <jinmei at isc.org>
Date:   Fri Jun 1 23:12:26 2012 -0700

    [2013] specify PRESERVE_ORDER for Message.from_wire.
    
    in update sessin processing we need to handle RRs separately even if they
    belong in the same RRset.

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

Summary of changes:
 src/bin/ddns/ddns.py.in         |    3 ++-
 src/bin/ddns/tests/ddns_test.py |   22 +++++++++++++++++++++-
 2 files changed, 23 insertions(+), 2 deletions(-)

-----------------------------------------------------------------------
diff --git a/src/bin/ddns/ddns.py.in b/src/bin/ddns/ddns.py.in
index 252d3ca..6342940 100755
--- a/src/bin/ddns/ddns.py.in
+++ b/src/bin/ddns/ddns.py.in
@@ -341,7 +341,8 @@ class DDNSServer:
             if sock.proto == socket.IPPROTO_TCP:
                 raise SessionError('TCP requests are not yet supported')
             self.__request_msg.clear(Message.PARSE)
-            self.__request_msg.from_wire(req_data)
+            # specify PRESERVE_ORDER as we need to handle each RR separately.
+            self.__request_msg.from_wire(req_data, Message.PRESERVE_ORDER)
             if self.__request_msg.get_opcode() != Opcode.UPDATE():
                 raise SessionError('Update request has unexpected opcode: ' +
                                    str(self.__request_msg.get_opcode()))
diff --git a/src/bin/ddns/tests/ddns_test.py b/src/bin/ddns/tests/ddns_test.py
index 7415258..2eff84e 100755
--- a/src/bin/ddns/tests/ddns_test.py
+++ b/src/bin/ddns/tests/ddns_test.py
@@ -547,13 +547,16 @@ class TestDDNSServer(unittest.TestCase):
         self.__select_expected = ([1, 2], [], [], None)
         self.assertRaises(select.error, self.ddns_server.run)
 
-def create_msg(opcode=Opcode.UPDATE(), zones=[TEST_ZONE_RECORD], tsigctx=None):
+def create_msg(opcode=Opcode.UPDATE(), zones=[TEST_ZONE_RECORD], prereq=[],
+               tsigctx=None):
     msg = Message(Message.RENDER)
     msg.set_qid(TEST_QID)
     msg.set_opcode(opcode)
     msg.set_rcode(Rcode.NOERROR())
     for z in zones:
         msg.add_question(z)
+    for p in prereq:
+        msg.add_rrset(SECTION_PREREQUISITE, p)
 
     renderer = MessageRenderer()
     if tsigctx is not None:
@@ -584,6 +587,8 @@ class TestDDNSession(unittest.TestCase):
         isc.server_common.tsig_keyring = self.orig_tsig_keyring
 
     def __fake_session_creator(self, req_message, client_addr, zone_config):
+        # remember the passed message for possible inspection later.
+        self.__req_message = req_message
         return FakeUpdateSession(req_message, client_addr, zone_config,
                                  self.__faked_result)
 
@@ -685,6 +690,21 @@ class TestDDNSession(unittest.TestCase):
                                                      create_msg())))
         self.assertEqual((None, None), (s._sent_data, s._sent_addr))
 
+    def test_request_message(self):
+        '''Test if the request message stores RRs separately.'''
+        # Specify 'drop' so the passed message won't be modified.
+        self.__faked_result = UPDATE_DROP
+        # Put the same RR twice in the prerequisite section.  We should see
+        # them as separate RRs.
+        dummy_record = RRset(TEST_ZONE_NAME, TEST_RRCLASS, RRType.NS(),
+                             RRTTL(0))
+        dummy_record.add_rdata(Rdata(RRType.NS(), TEST_RRCLASS, "ns.example"))
+        self.server.handle_request((self.__sock, TEST_SERVER6, TEST_CLIENT6,
+                                    create_msg(prereq=[dummy_record,
+                                                       dummy_record])))
+        num_rrsets = len(self.__req_message.get_section(SECTION_PREREQUISITE))
+        self.assertEqual(2, num_rrsets)
+
     def test_session_with_config(self):
         '''Check a session with more relistic config setups