You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by rn...@apache.org on 2015/09/02 20:31:02 UTC
[3/5] couchdb-couch-epi git commit: Call maybe_start_keeper for
couch_epi_data_source
Call maybe_start_keeper for couch_epi_data_source
COUCHDB-2796
Project: http://git-wip-us.apache.org/repos/asf/couchdb-couch-epi/repo
Commit: http://git-wip-us.apache.org/repos/asf/couchdb-couch-epi/commit/7f32e4f4
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-couch-epi/tree/7f32e4f4
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-couch-epi/diff/7f32e4f4
Branch: refs/heads/master
Commit: 7f32e4f48d129688f89bfe863be2a33d08e5c46e
Parents: fa12608
Author: ILYA Khlopotov <ii...@ca.ibm.com>
Authored: Wed Sep 2 08:11:36 2015 -0700
Committer: ILYA Khlopotov <ii...@ca.ibm.com>
Committed: Wed Sep 2 09:53:08 2015 -0700
----------------------------------------------------------------------
src/couch_epi_data_source.erl | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/couchdb-couch-epi/blob/7f32e4f4/src/couch_epi_data_source.erl
----------------------------------------------------------------------
diff --git a/src/couch_epi_data_source.erl b/src/couch_epi_data_source.erl
index bbeed70..f44430d 100644
--- a/src/couch_epi_data_source.erl
+++ b/src/couch_epi_data_source.erl
@@ -54,6 +54,7 @@ childspec(Id, App, EpiKey, Locator, Options) ->
}.
start_link(SubscriberApp, {epi_key, Key}, Src, Options) ->
+ maybe_start_keeper(Key),
{ok, Locator} = locate(SubscriberApp, Src),
gen_server:start_link(?MODULE, [SubscriberApp, Locator, Key, Options], []).
@@ -189,3 +190,7 @@ current(Handle, Subscriber) ->
catch error:undef ->
[]
end.
+
+maybe_start_keeper(Key) ->
+ Handle = couch_epi_data_gen:get_handle(Key),
+ couch_epi_module_keeper:maybe_start_keeper(couch_epi_data_gen, Handle).