param["origin"], param["class"], param["datasrc"])
msg = create_command("loadzone", param)
- # catch the exception, in case msgq has been killed.
- try:
- seq = self._send_cc_session.group_sendmsg(msg, AUTH_MODULE_NAME)
- try:
- answer, env = self._send_cc_session.group_recvmsg(False, seq)
- except isc.cc.session.SessionTimeout:
- pass # for now we just ignore the failure
- except socket.error as err:
- logger.error(XFRIN_MSGQ_SEND_ERROR_AUTH, AUTH_MODULE_NAME)
+ seq = self._send_cc_session.group_sendmsg(msg, AUTH_MODULE_NAME)
+ answer, env = self._send_cc_session.group_recvmsg(False, seq)
def publish_xfrin_news(self, zone_name, zone_class, xfr_result):
'''Send command to xfrout/zone manager module.