diff options
| author | Jenkins <jenkins@review.openstack.org> | 2017-03-14 10:15:35 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2017-03-14 10:15:35 +0000 |
| commit | 857dac474cb61ac1c419ccbc37188c3ee28edaa2 (patch) | |
| tree | 2285f9936aeccddbb5e6df51126dcfef9eb8d77c /ceilometer/notification.py | |
| parent | ca607c4ef3c743938358210ca2cedc3ac23a2928 (diff) | |
| parent | 9fcd66ec66657c4b597096a946635956c2b493f5 (diff) | |
| download | ceilometer-857dac474cb61ac1c419ccbc37188c3ee28edaa2.tar.gz | |
Merge "add jitter to notification agent"
Diffstat (limited to 'ceilometer/notification.py')
| -rw-r--r-- | ceilometer/notification.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/ceilometer/notification.py b/ceilometer/notification.py index a4440e52..5303d79b 100644 --- a/ceilometer/notification.py +++ b/ceilometer/notification.py @@ -15,6 +15,7 @@ import itertools import threading +import time from ceilometer.agent import plugin_base from concurrent import futures @@ -108,6 +109,7 @@ class NotificationService(cotyledon.Service): def __init__(self, worker_id, conf): super(NotificationService, self).__init__(worker_id) + self.startup_delay = worker_id self.conf = conf @classmethod @@ -156,6 +158,9 @@ class NotificationService(cotyledon.Service): return event_pipe_manager def run(self): + # Delay startup so workers are jittered + time.sleep(self.startup_delay) + super(NotificationService, self).run() self.shutdown = False self.periodic = None |