diff options
| author | iilyak <iilyak@ca.ibm.com> | 2017-07-17 12:42:40 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-07-17 12:42:40 -0700 |
| commit | cc21e141f71bd4bc314cf08692a3aa3a2698db43 (patch) | |
| tree | d69c33547b085b291c7e18a23a7662bb39ef9c9e | |
| parent | addccbc7ba01416f29e10613350d910923b127c9 (diff) | |
| parent | 4396891560b70336d340f438a458acecbaff9754 (diff) | |
| download | couchdb-cc21e141f71bd4bc314cf08692a3aa3a2698db43.tar.gz | |
Merge pull request #622 from cloudant/89551-keep_sending_changes-hot
Allow keep_sending_changes to use hot code upgrade
| -rw-r--r-- | src/couch/src/couch_changes.erl | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/couch/src/couch_changes.erl b/src/couch/src/couch_changes.erl index 835251d50..861c81a8e 100644 --- a/src/couch/src/couch_changes.erl +++ b/src/couch/src/couch_changes.erl @@ -29,6 +29,12 @@ -export([changes_enumerator/2]). +%% export so we can use fully qualified call to facilitate hot-code upgrade +-export([ + keep_sending_changes/3, + wait_updated/3 +]). + -record(changes_acc, { db, view_name, @@ -644,7 +650,7 @@ keep_sending_changes(Args, Acc0, FirstRound) -> DbOptions1 = [{user_ctx, Db#db.user_ctx} | DbOptions], case couch_db:open(Db#db.name, DbOptions1) of {ok, Db2} -> - keep_sending_changes( + ?MODULE:keep_sending_changes( Args#changes_args{limit=NewLimit}, ChangesAcc#changes_acc{ db = Db2, @@ -867,7 +873,7 @@ wait_updated(Timeout, TimeoutFun, UserAcc) -> {Go, UserAcc2} = TimeoutFun(UserAcc), case Go of ok -> - wait_updated(Timeout, TimeoutFun, UserAcc2); + ?MODULE:wait_updated(Timeout, TimeoutFun, UserAcc2); stop -> {stop, UserAcc2} end |