diff options
| author | Aravinda VK <avishwan@redhat.com> | 2016-11-29 16:32:54 +0530 |
|---|---|---|
| committer | Aravinda VK <avishwan@redhat.com> | 2016-12-02 06:52:55 -0800 |
| commit | 99458974b7d12bd12d78d4b9a19adfb62d771b5c (patch) | |
| tree | e1fe73d5ec323549b7ebace3b62d942099704047 /events/src/glustereventsd.py | |
| parent | 4536f7bdf16f8286d67598eda9a46c029f0c0bf4 (diff) | |
eventsapi: Push Messages to Webhooks in parallel
With this patch, glustereventsd will maintain one thread per
webhook. If a webhook is slow, then all the events to that worker
will be delayed but it will not affect the other webhooks.
Note: Webhook in transit may get missed if glustereventsd reloads due to
new Webhook addition or due configuration changes.
BUG: 1357754
Change-Id: I2d11e01c7ac434355bc356ff75396252f51b339b
Signed-off-by: Aravinda VK <avishwan@redhat.com>
Reviewed-on: http://review.gluster.org/15966
Smoke: Gluster Build System <jenkins@build.gluster.org>
Reviewed-by: Prashanth Pai <ppai@redhat.com>
NetBSD-regression: NetBSD Build System <jenkins@build.gluster.org>
CentOS-regression: Gluster Build System <jenkins@build.gluster.org>
Diffstat (limited to 'events/src/glustereventsd.py')
| -rw-r--r-- | events/src/glustereventsd.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/events/src/glustereventsd.py b/events/src/glustereventsd.py index 86e64b01ad5..4b56eee9131 100644 --- a/events/src/glustereventsd.py +++ b/events/src/glustereventsd.py @@ -80,11 +80,13 @@ class GlusterEventsRequestHandler(SocketServer.BaseRequestHandler): def signal_handler_sigusr2(sig, frame): utils.load_all() + utils.restart_webhook_pool() def init_event_server(): utils.setup_logger() utils.load_all() + utils.init_webhook_pool() port = utils.get_config("port") if port is None: |