parameters: (self)
docstring: Runs the configuration manager.
docstring_summary: Runs the configuration manager.
docstring_tokens: Runs the configuration manager .
function: def run(self):
          """Runs the configuration manager."""
          self.running = True
          while self.running:
              # we just wait eternally for any command here, so disable
              # timeouts for this specific recv
              self.cc.set_timeout(0)
              msg, env = self.cc.group_recvmsg(False)
              # and set it back to whatever we default to
              self.cc.set_timeout(bundy.cc.Session.MSGQ_DEFAULT_TIMEOUT)
              # ignore 'None' value (even though they should not occur)
              # and messages that are answers to questions we did
              # not ask
              if msg is not None and not CC_PAYLOAD_RESULT in msg:
                  answer = self.handle_msg(msg);
                  # Only respond if there actually is something to respond with
                  if answer is not None:
                      self.cc.group_reply(env, answer)
          logger.info(CFGMGR_STOPPED_BY_COMMAND)
function_tokens: def run ( self ) : self . running = True while self . running : # we just wait eternally for any command here, so disable # timeouts for this specific recv self . cc . set_timeout ( 0 ) msg , env = self . cc . group_recvmsg ( False ) # and set it back to whatever we default to self . cc . set_timeout ( bundy . cc . Session . MSGQ_DEFAULT_TIMEOUT ) # ignore 'None' value (even though they should not occur) # and messages that are answers to questions we did # not ask if msg is not None and not CC_PAYLOAD_RESULT in msg : answer = self . handle_msg ( msg ) # Only respond if there actually is something to respond with if answer is not None : self . cc . group_reply ( env , answer ) logger . info ( CFGMGR_STOPPED_BY_COMMAND )