couchdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kxe...@apache.org
Subject [1/3] couchdb-ioq git commit: Update config_listener behaviuor
Date Wed, 04 Feb 2015 15:49:43 GMT
Repository: couchdb-ioq
Updated Branches:
  refs/heads/master 217503577 -> c7c75ebea


Update config_listener behaviuor

COUCHDB-2561


Project: http://git-wip-us.apache.org/repos/asf/couchdb-ioq/repo
Commit: http://git-wip-us.apache.org/repos/asf/couchdb-ioq/commit/ad60d329
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-ioq/tree/ad60d329
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-ioq/diff/ad60d329

Branch: refs/heads/master
Commit: ad60d329a038d2b1aa5ee083f22b1ee7906ec31d
Parents: 2175035
Author: ILYA Khlopotov <iilyak@ca.ibm.com>
Authored: Fri Jan 30 10:59:43 2015 -0800
Committer: ILYA Khlopotov <iilyak@ca.ibm.com>
Committed: Fri Jan 30 10:59:43 2015 -0800

----------------------------------------------------------------------
 src/ioq.erl | 15 ++++++++-------
 1 file changed, 8 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/couchdb-ioq/blob/ad60d329/src/ioq.erl
----------------------------------------------------------------------
diff --git a/src/ioq.erl b/src/ioq.erl
index 6c01b9c..c4b3b4e 100644
--- a/src/ioq.erl
+++ b/src/ioq.erl
@@ -18,7 +18,7 @@
 -export([init/1, handle_call/3, handle_cast/2, handle_info/2, code_change/3, terminate/2]).
 
 % config_listener api
--export([handle_config_change/5]).
+-export([handle_config_change/5, handle_config_terminate/3]).
 
 -record(state, {
     concurrency,
@@ -83,12 +83,6 @@ handle_info({'DOWN', Ref, _, _, Reason}, State) ->
         false ->
             {noreply, State, 0}
     end;
-handle_info({gen_event_EXIT, {config_listener, ?MODULE}, _Reason}, State) ->
-    erlang:send_after(5000, self(), restart_config_listener),
-    {noreply, State};
-handle_info(restart_config_listener, State) ->
-    ok = config:listen_for_changes(?MODULE, nil),
-    {noreply, State};
 handle_info(timeout, State) ->
     {noreply, maybe_submit_request(State)}.
 
@@ -97,6 +91,13 @@ handle_config_change("ioq", _, _, _, _) ->
 handle_config_change(_, _, _, _, _) ->
     {ok, nil}.
 
+handle_config_terminate(_, _, _) ->
+    spawn(fun() ->
+        timer:sleep(5000),
+        config:listen_for_changes(?MODULE, nil)
+    end),
+    ok.
+
 code_change(_Vsn, State, _Extra) ->
     {ok, State}.
 


Mime
View raw message