[svn] commit: r3005 - in /branches/trac349/src/bin: cmdctl/cmdctl.py.in xfrin/xfrin.py.in xfrout/xfrout.py.in zonemgr/zonemgr.py.in

[BIND 10 source code commits]

Author: vorner
Date: Thu Sep 23 06:30:01 2010
New Revision: 3005

Log:
Use block reads in the tight loop

Modified:
    branches/trac349/src/bin/cmdctl/cmdctl.py.in
    branches/trac349/src/bin/xfrin/xfrin.py.in
    branches/trac349/src/bin/xfrout/xfrout.py.in
    branches/trac349/src/bin/zonemgr/zonemgr.py.in

Modified: branches/trac349/src/bin/cmdctl/cmdctl.py.in
==============================================================================
--- branches/trac349/src/bin/cmdctl/cmdctl.py.in (original)
+++ branches/trac349/src/bin/cmdctl/cmdctl.py.in Thu Sep 23 06:30:01 2010
@@ -1,6 +1,7 @@
 #!@PYTHON@
 
 # Copyright (C) 2010  Internet Systems Consortium.
+# Copyright (C) 2010  CZ NIC
 #
 # Permission to use, copy, modify, and distribute this software for any
 # purpose with or without fee is hereby granted, provided that the above
@@ -320,8 +321,8 @@
     def _handle_msg_from_msgq(self):
         '''Process all the received commands with module session. '''
         while self._serving:
-            self._module_cc.check_command() 
- 
+            self._module_cc.check_command(False)
+
     def _parse_command_result(self, rcode, reply):
         '''Ignore the error reason when command rcode isn't 0, '''
         if rcode != 0:

Modified: branches/trac349/src/bin/xfrin/xfrin.py.in
==============================================================================
--- branches/trac349/src/bin/xfrin/xfrin.py.in (original)
+++ branches/trac349/src/bin/xfrin/xfrin.py.in Thu Sep 23 06:30:01 2010
@@ -1,6 +1,7 @@
 #!@PYTHON@
 
 # Copyright (C) 2010  Internet Systems Consortium.
+# Copyright (C) 2010  CZ NIC
 #
 # Permission to use, copy, modify, and distribute this software for any
 # purpose with or without fee is hereby granted, provided that the above
@@ -393,7 +394,7 @@
         '''This is a straightforward wrapper for cc.check_command, 
         but provided as a separate method for the convenience 
         of unit tests.'''
-        self._module_cc.check_command()
+        self._module_cc.check_command(False)
 
     def config_handler(self, new_config):
         self._max_transfers_in = new_config.get("transfers_in") or self._max_transfers_in

Modified: branches/trac349/src/bin/xfrout/xfrout.py.in
==============================================================================
--- branches/trac349/src/bin/xfrout/xfrout.py.in (original)
+++ branches/trac349/src/bin/xfrout/xfrout.py.in Thu Sep 23 06:30:01 2010
@@ -1,6 +1,7 @@
 #!@PYTHON@
 
 # Copyright (C) 2010  Internet Systems Consortium.
+# Copyright (C) 2010  CZ NIC
 #
 # Permission to use, copy, modify, and distribute this software for any
 # purpose with or without fee is hereby granted, provided that the above
@@ -491,7 +492,7 @@
     def run(self):
         '''Get and process all commands sent from cfgmgr or other modules. '''
         while not self._shutdown_event.is_set():
-            self._cc.check_command()
+            self._cc.check_command(False)
 
 
 xfrout_server = None

Modified: branches/trac349/src/bin/zonemgr/zonemgr.py.in
==============================================================================
--- branches/trac349/src/bin/zonemgr/zonemgr.py.in (original)
+++ branches/trac349/src/bin/zonemgr/zonemgr.py.in Thu Sep 23 06:30:01 2010
@@ -1,6 +1,7 @@
 #!@PYTHON@
 
 # Copyright (C) 2010  Internet Systems Consortium.
+# Copyright (C) 2010  CZ NIC
 #
 # Permission to use, copy, modify, and distribute this software for any
 # purpose with or without fee is hereby granted, provided that the above
@@ -485,7 +486,7 @@
 
     def run(self):
         while not self._shutdown_event.is_set():
-            self._module_cc.check_command()
+            self._module_cc.check_command(False)
 
 zonemgrd = None