self.callbacks[name] = Callback(command=callback, kwargs=kwargs)
except AttributeError:
raise StatsError(STATS_UNKNOWN_COMMAND_IN_SPEC, cmd["command_name"])
+ self.config = {}
self.mccs.start()
# setup my config
self.config = dict([
"""
logger.debug(DBG_STATS_MESSAGING, STATS_RECEIVED_NEW_CONFIG,
new_config)
- # do nothing currently
+ # update to new config
+ if new_config and type(new_config) is dict:
+ # backup old config
+ self.old_config = self.config.copy()
+ self.config.update(new_config)
return isc.config.create_answer(0)
def command_handler(self, command, kwargs):
-# Copyright (C) 2010, 2011 Internet Systems Consortium.
+# Copyright (C) 2010, 2011, 2012 Internet Systems Consortium.
#
# Permission to use, copy, modify, and distribute this software for any
# purpose with or without fee is hereby granted, provided that the above
self.stats_server = ThreadingServerManager(MyStats)
self.stats = self.stats_server.server
self.stats_server.run()
- # config_handler
- self.assertEqual(self.stats.config_handler({'foo':'bar'}),
+ # test updating poll-interval
+ self.assertEqual(self.stats.config['poll-interval'], 60)
+ self.assertEqual(self.stats.config_handler({'poll-interval': 120}),
isc.config.create_answer(0))
+ self.assertEqual(self.stats.config['poll-interval'], 120)
# command_handler
self.base.boss.server._started.wait()