Return-Path: X-Original-To: apmail-couchdb-commits-archive@www.apache.org Delivered-To: apmail-couchdb-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id AB3A8180FD for ; Wed, 2 Sep 2015 18:31:00 +0000 (UTC) Received: (qmail 17251 invoked by uid 500); 2 Sep 2015 18:31:00 -0000 Delivered-To: apmail-couchdb-commits-archive@couchdb.apache.org Received: (qmail 17091 invoked by uid 500); 2 Sep 2015 18:31:00 -0000 Mailing-List: contact commits-help@couchdb.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@couchdb.apache.org Delivered-To: mailing list commits@couchdb.apache.org Received: (qmail 16944 invoked by uid 99); 2 Sep 2015 18:31:00 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 02 Sep 2015 18:31:00 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 57A68E7DEC; Wed, 2 Sep 2015 18:31:00 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: rnewson@apache.org To: commits@couchdb.apache.org Date: Wed, 02 Sep 2015 18:31:02 -0000 Message-Id: <524797ee05f24fd184f8e4ad4453187a@git.apache.org> In-Reply-To: <9a7a3bbaaa9e4fefb27c0bb7452412bf@git.apache.org> References: <9a7a3bbaaa9e4fefb27c0bb7452412bf@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [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 Authored: Wed Sep 2 08:11:36 2015 -0700 Committer: ILYA Khlopotov 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).