Merge "Change report_interval from 4 to 30, agent_down_time from 9 to 75"
This commit is contained in:
commit
4a8f514519
@ -225,7 +225,7 @@ notification_driver = neutron.openstack.common.notifier.rpc_notifier
|
||||
# =========== items for agent management extension =============
|
||||
# Seconds to regard the agent as down; should be at least twice
|
||||
# report_interval, to be sure the agent is down for good
|
||||
# agent_down_time = 9
|
||||
# agent_down_time = 75
|
||||
# =========== end of items for agent management extension =====
|
||||
|
||||
# =========== items for agent scheduler extension =============
|
||||
@ -385,7 +385,7 @@ notification_driver = neutron.openstack.common.notifier.rpc_notifier
|
||||
# =========== items for agent management extension =============
|
||||
# seconds between nodes reporting state to server; should be less than
|
||||
# agent_down_time, best if it is half or less than agent_down_time
|
||||
# report_interval = 4
|
||||
# report_interval = 30
|
||||
|
||||
# =========== end of items for agent management extension =====
|
||||
|
||||
|
@ -32,7 +32,7 @@ ROOT_HELPER_OPTS = [
|
||||
]
|
||||
|
||||
AGENT_STATE_OPTS = [
|
||||
cfg.FloatOpt('report_interval', default=4,
|
||||
cfg.FloatOpt('report_interval', default=30,
|
||||
help=_('Seconds between nodes reporting state to server; '
|
||||
'should be less than agent_down_time, best if it '
|
||||
'is half or less than agent_down_time.')),
|
||||
|
@ -33,7 +33,7 @@ from neutron.openstack.common import timeutils
|
||||
|
||||
LOG = logging.getLogger(__name__)
|
||||
cfg.CONF.register_opt(
|
||||
cfg.IntOpt('agent_down_time', default=9,
|
||||
cfg.IntOpt('agent_down_time', default=75,
|
||||
help=_("Seconds to regard the agent is down; should be at "
|
||||
"least twice report_interval, to be sure the "
|
||||
"agent is down for good.")))
|
||||
|
@ -195,7 +195,7 @@ class TestNecAgent(TestNecAgentBase):
|
||||
def test_report_state_installed(self):
|
||||
self.loopingcall.assert_called_once_with(self.agent._report_state)
|
||||
instance = self.loopingcall.return_value
|
||||
instance.start.assert_called_once_with(interval=4)
|
||||
self.assertTrue(instance.start.called)
|
||||
|
||||
def _check_report_state(self, cur_ports, num_ports, fail_mode,
|
||||
first=False):
|
||||
|
Loading…
Reference in New Issue
Block a user