diff options
Diffstat (limited to 'src/couchdb/couch_db_update_notifier_sup.erl')
| -rw-r--r-- | src/couchdb/couch_db_update_notifier_sup.erl | 25 |
1 files changed, 20 insertions, 5 deletions
diff --git a/src/couchdb/couch_db_update_notifier_sup.erl b/src/couchdb/couch_db_update_notifier_sup.erl index 0662fe77..69d6b1b0 100644 --- a/src/couchdb/couch_db_update_notifier_sup.erl +++ b/src/couchdb/couch_db_update_notifier_sup.erl @@ -31,12 +31,11 @@ start_link() -> init([]) -> Self = self(), ok = couch_config:register( - fun("update_notification", _) -> - exit(Self, reload_config) - end), + fun("update_notification", Key, Value) -> reload_config(Key, Value) end + ), UpdateNotifierExes = couch_config:get("update_notification"), - + {ok, {{one_for_one, 10, 3600}, lists:map(fun({Name, UpdateNotifierExe}) -> @@ -46,4 +45,20 @@ init([]) -> 1000, supervisor, [couch_db_update_notifier]} - end, UpdateNotifierExes)}}.
\ No newline at end of file + end, UpdateNotifierExes)}}. + +%% @doc when update_notification configuration changes, terminate the process +%% for that notifier and start a new one with the updated config +reload_config(Id, Exe) -> + ChildSpec = { + Id, + {couch_db_update_notifier, start_link, [Exe]}, + permanent, + 1000, + supervisor, + [couch_db_update_notifier] + }, + supervisor:terminate_child(couch_db_update_notifier_sup, Id), + supervisor:delete_child(couch_db_update_notifier_sup, Id), + supervisor:start_child(couch_db_update_notifier_sup, ChildSpec). + |