You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by kx...@apache.org on 2014/10/13 19:21:39 UTC
[2/2] git commit: Allow to customize concurrency value
Allow to customize concurrency value
Project: http://git-wip-us.apache.org/repos/asf/couchdb-ioq/repo
Commit: http://git-wip-us.apache.org/repos/asf/couchdb-ioq/commit/c552c665
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-ioq/tree/c552c665
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-ioq/diff/c552c665
Branch: refs/heads/master
Commit: c552c665dc6af0ca750ce074c816c4fcb0f05962
Parents: 40d157f
Author: Alexander Shorin <kx...@apache.org>
Authored: Mon Sep 22 17:35:37 2014 +0400
Committer: Alexander Shorin <kx...@apache.org>
Committed: Mon Oct 13 21:21:03 2014 +0400
----------------------------------------------------------------------
src/ioq.erl | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/couchdb-ioq/blob/c552c665/src/ioq.erl
----------------------------------------------------------------------
diff --git a/src/ioq.erl b/src/ioq.erl
index 9bfb1f8..4598c37 100644
--- a/src/ioq.erl
+++ b/src/ioq.erl
@@ -21,7 +21,7 @@
-export([handle_config_change/5]).
-record(state, {
- concurrency=10,
+ concurrency,
ratio,
interactive=queue:new(),
compaction=queue:new(),
@@ -55,7 +55,8 @@ init(_) ->
read_config(State) ->
Ratio = list_to_float(config:get("ioq", "ratio", "0.01")),
- State#state{ratio=Ratio}.
+ Concurrency = list_to_integer(config:get("ioq", "concurrency", "10")),
+ State#state{concurrency=Concurrency, ratio=Ratio}.
handle_call(#request{}=Request, From, State) ->
{noreply, enqueue_request(Request#request{from=From}, State), 0}.