5lLJ0ORh3KPCm1xwwY8Tye changeset

Changeset373862393834 (b)
ParentNone (a)
ab
0+diff --git a/src/couchdb/couch_rep_changes_feed.erl b/src/couchdb/couch_rep_changes_feed.erl
0+index 7f7d3a3..4d1afcb 100644
0+--- a/src/couchdb/couch_rep_changes_feed.erl
0++++ b/src/couchdb/couch_rep_changes_feed.erl
0+@@ -204,6 +204,9 @@ handle_info({ibrowse_async_response_end, Id}, #state{reqid=Id} = State) ->
0+ handle_info({'EXIT', From, normal}, #state{changes_loop=From} = State) ->
0+     handle_feed_completion(State);
0+ 
0++handle_info({'EXIT', From, normal}, #state{conn=From, complete=true} = State) ->
0++    {noreply, State};
0++
0+ handle_info({'EXIT', From, Reason}, #state{changes_loop=From} = State) ->
0+     ?LOG_ERROR("changes_loop died with reason ~p", [Reason]),
0+     {stop, changes_loop_died, State};
...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
--- Revision None
+++ Revision 373862393834
@@ -0,0 +1,14 @@
+diff --git a/src/couchdb/couch_rep_changes_feed.erl b/src/couchdb/couch_rep_changes_feed.erl
+index 7f7d3a3..4d1afcb 100644
+--- a/src/couchdb/couch_rep_changes_feed.erl
++++ b/src/couchdb/couch_rep_changes_feed.erl
+@@ -204,6 +204,9 @@ handle_info({ibrowse_async_response_end, Id}, #state{reqid=Id} = State) ->
+ handle_info({'EXIT', From, normal}, #state{changes_loop=From} = State) ->
+ handle_feed_completion(State);
+
++handle_info({'EXIT', From, normal}, #state{conn=From, complete=true} = State) ->
++ {noreply, State};
++
+ handle_info({'EXIT', From, Reason}, #state{changes_loop=From} = State) ->
+ ?LOG_ERROR("changes_loop died with reason ~p", [Reason]),
+ {stop, changes_loop_died, State};