Use blocking reads of the CCsession. Updated test to include the optional parameter too. git-svn-id: svn://bind10.isc.org/svn/bind10/branches/trac382@3283 e5f2f494-b856-4b98-b285-d166d9295462
@@ -233,7 +233,7 @@ class CCSessionListener(Listener):
"""
check the cc chanel
- return self.cc_session.check_command()
+ return self.cc_session.check_command(False)
def config_handler(self, new_config):
@@ -90,8 +90,8 @@ class ModuleCCSession(ConfigData):
def close(self):
self._session.close()
- def check_command(self):
- msg, env = self._session.group_recvmsg(False)
+ def check_command(self, nonblock=True):
+ msg, env = self._session.group_recvmsg(nonblock)
if not msg or 'result' in msg:
return
cmd, arg = parse_command(msg)