diff options
| author | Jay Doane <jay.s.doane@gmail.com> | 2017-05-07 22:49:06 -0700 |
|---|---|---|
| committer | Nick Vatamaniuc <nickva@users.noreply.github.com> | 2017-05-10 12:16:12 -0400 |
| commit | 9d99d6e8ef9b7076b9a25cffcb9ebd08655bbef6 (patch) | |
| tree | 960e207cca5f75e3ce8b9838b5d6565daea3d135 | |
| parent | 0460a70d1499d805388fc14edcc4e1e7c57e0be4 (diff) | |
| download | couchdb-9d99d6e8ef9b7076b9a25cffcb9ebd08655bbef6.tar.gz | |
Expose mem3_shards:get_changes_pid/0
Simplify getting changes listener pid for testing
| -rw-r--r-- | src/mem3/src/mem3_shards.erl | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/mem3/src/mem3_shards.erl b/src/mem3/src/mem3_shards.erl index 3c2001b1b..a419e45a2 100644 --- a/src/mem3/src/mem3_shards.erl +++ b/src/mem3/src/mem3_shards.erl @@ -23,6 +23,7 @@ -export([for_db/1, for_db/2, for_docid/2, for_docid/3, get/3, local/1, fold/2]). -export([for_shard_name/1]). -export([set_max_size/1]). +-export([get_changes_pid/0]). -record(st, { max_size = 25000, @@ -169,6 +170,9 @@ fold(Fun, Acc) -> set_max_size(Size) when is_integer(Size), Size > 0 -> gen_server:call(?MODULE, {set_max_size, Size}). +get_changes_pid() -> + gen_server:call(?MODULE, get_changes_pid). + handle_config_change("mem3", "shard_cache_size", SizeList, _, _) -> Size = list_to_integer(SizeList), {ok, gen_server:call(?MODULE, {set_max_size, Size}, infinity)}; @@ -219,6 +223,8 @@ handle_call(shard_db_changed, _From, St) -> {reply, ok, St}; handle_call({set_write_timeout, Timeout}, _From, St) -> {reply, ok, St#st{write_timeout = Timeout}}; +handle_call(get_changes_pid, _From, St) -> + {reply, {ok, St#st.changes_pid}, St}; handle_call(_Call, _From, St) -> {noreply, St}. |