summaryrefslogtreecommitdiff
path: root/src/couchdb
diff options
context:
space:
mode:
authorAdam Kocoloski <kocolosk@apache.org>2009-11-03 17:15:37 +0000
committerAdam Kocoloski <kocolosk@apache.org>2009-11-03 17:15:37 +0000
commit6943c2f9d7117b7e15090bf7ea86bc18d2bd8a85 (patch)
tree3bfa50622399310173e3489ae9ef3b37716f4c1e /src/couchdb
parent5454022f609f88bf67a85d02c39c95c1f3c49a62 (diff)
eliminate new process flood after OS wakes from sleep. COUCHDB-539
git-svn-id: https://svn.apache.org/repos/asf/couchdb/trunk@832477 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'src/couchdb')
-rw-r--r--src/couchdb/couch_stats_aggregator.erl12
1 files changed, 7 insertions, 5 deletions
diff --git a/src/couchdb/couch_stats_aggregator.erl b/src/couchdb/couch_stats_aggregator.erl
index 3292e5f0..2f5c6d13 100644
--- a/src/couchdb/couch_stats_aggregator.erl
+++ b/src/couchdb/couch_stats_aggregator.erl
@@ -86,7 +86,7 @@ get_json(Key, Time) ->
to_json_term(?MODULE:get(Key, Time)).
collect_sample() ->
- gen_server:call(?MODULE, collect_sample).
+ gen_server:call(?MODULE, collect_sample, infinity).
init(StatDescsFileName) ->
@@ -115,13 +115,15 @@ init(StatDescsFileName) ->
Rate = list_to_integer(couch_config:get("stats", "rate", "1000")),
% TODO: Add timer_start to kernel start options.
- timer:apply_interval(Rate, ?MODULE, collect_sample, []).
+ {ok, TRef} = timer:apply_after(Rate, ?MODULE, collect_sample, []),
+ {ok, {TRef, Rate}}.
-terminate(_Reason, TRef) ->
+terminate(_Reason, {TRef, _Rate}) ->
timer:cancel(TRef),
ok.
-handle_call(collect_sample, _, State) ->
+handle_call(collect_sample, _, {_TRef, SampleInterval}) ->
+ {ok, TRef} = timer:apply_after(SampleInterval, ?MODULE, collect_sample, []),
% Gather new stats values to add.
Incs = lists:map(fun({Key, Value}) ->
{Key, {incremental, Value}}
@@ -151,7 +153,7 @@ handle_call(collect_sample, _, State) ->
end,
ets:insert(?MODULE, {{Key, Rate}, NewAgg})
end, ets:tab2list(?MODULE)),
- {reply, ok, State}.
+ {reply, ok, {TRef, SampleInterval}}.
handle_cast(stop, State) ->
{stop, normal, State}.