You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by to...@apache.org on 2016/06/01 17:22:55 UTC
couch-replicator commit: updated refs/heads/3010-handle-429 to 81d5544
Repository: couchdb-couch-replicator
Updated Branches:
refs/heads/3010-handle-429 7f0f3d7e8 -> 81d55441f
Change back_off to backoff
COUCHDB-3010
Project: http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/repo
Commit: http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/commit/81d55441
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/tree/81d55441
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/diff/81d55441
Branch: refs/heads/3010-handle-429
Commit: 81d55441f7b9da0c639fb2f02492f1af6d733eb8
Parents: 7f0f3d7
Author: Tony Sun <to...@cloudant.com>
Authored: Wed Jun 1 10:25:17 2016 -0700
Committer: Tony Sun <to...@cloudant.com>
Committed: Wed Jun 1 10:25:17 2016 -0700
----------------------------------------------------------------------
src/couch_replicator_httpc.erl | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/blob/81d55441/src/couch_replicator_httpc.erl
----------------------------------------------------------------------
diff --git a/src/couch_replicator_httpc.erl b/src/couch_replicator_httpc.erl
index f3fbd58..57eb0c3 100644
--- a/src/couch_replicator_httpc.erl
+++ b/src/couch_replicator_httpc.erl
@@ -141,7 +141,7 @@ process_response({ibrowse_req_id, ReqId}, Worker, HttpDb, Params, Callback) ->
process_response({ok, Code, Headers, Body}, Worker, HttpDb, Params, Callback) ->
case list_to_integer(Code) of
429 ->
- maybe_retry(back_off, Worker, HttpDb, Params);
+ maybe_retry(backoff, Worker, HttpDb, Params);
Ok when (Ok >= 200 andalso Ok < 300) ; (Ok >= 400 andalso Ok < 500) ->
couch_stats:increment_counter([couch_replicator, responses, success]),
EJson = case Body of
@@ -167,7 +167,7 @@ process_stream_response(ReqId, Worker, HttpDb, Params, Callback) ->
{ibrowse_async_headers, ReqId, Code, Headers} ->
case list_to_integer(Code) of
429 ->
- maybe_retry(back_off, Worker,
+ maybe_retry(backoff, Worker,
HttpDb#httpdb{timeout = ?MAX_BACKOFF_WAIT}, Params);
Ok when (Ok >= 200 andalso Ok < 300) ; (Ok >= 400 andalso Ok < 500) ->
StreamDataFun = fun() ->