5IA5MlRx0OZhKmsLNPMeJe changeset

Changeset643238616239 (b)
ParentNone (a)
ab
0+Index: src/couchdb/couch_rep_att.erl
0+===================================================================
0+--- src/couchdb/couch_rep_att.erl       (revision 892491)
0++++ src/couchdb/couch_rep_att.erl       (working copy)
0+@@ -79,7 +79,13 @@
0+             ReqId;
0+         {ok, NewReqId} ->
0+             NewReqId
0+-        end
0++        end;
0++    {ibrowse_async_response, ReqId, {error, Err}} ->
0++        ?LOG_ERROR("~p error for ~p, retrying", [Err, Req#http_db.resource]),
0++        start_http_request(Req);
0++    after 10000 ->
0++        ?LOG_ERROR("request for ~p stalled, retrying", [Req#http_db.resource]),
0++        start_http_request(Req)
0+     end.
0+ 
0+ validate_headers(_Req, 200, _Headers) ->
...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
--- Revision None
+++ Revision 643238616239
@@ -0,0 +1,19 @@
+Index: src/couchdb/couch_rep_att.erl
+===================================================================
+--- src/couchdb/couch_rep_att.erl (revision 892491)
++++ src/couchdb/couch_rep_att.erl (working copy)
+@@ -79,7 +79,13 @@
+ ReqId;
+ {ok, NewReqId} ->
+ NewReqId
+- end
++ end;
++ {ibrowse_async_response, ReqId, {error, Err}} ->
++ ?LOG_ERROR("~p error for ~p, retrying", [Err, Req#http_db.resource]),
++ start_http_request(Req);
++ after 10000 ->
++ ?LOG_ERROR("request for ~p stalled, retrying", [Req#http_db.resource]),
++ start_http_request(Req)
+ end.
+
+ validate_headers(_Req, 200, _Headers) ->