Catch http drain errors in wait_response.

heroku · Jul 4, 2012 · a92b088 · a92b088
1 parent 1ec78aa
commit a92b088
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/logplex_http_drain.erl b/src/logplex_http_drain.erl
@@ -221,7 +221,7 @@ status_action(_) -> temp_fail.
 
 wait_response(Frame = #frame{},
               State = #state{client = Client}) ->
-    case cowboy_client:response(Client) of
+    try cowboy_client:response(Client) of
         {ok, Status, _Headers, Client2} ->
             Result = status_action(Status),
             ?INFO("drain_id=~p channel_id=~p dest=~s at=response "
@@ -244,6 +244,13 @@ wait_response(Frame = #frame{},
                   " result=error tcp_err=~10000p",
                   log_info(State, [Why])),
             http_fail(retry_frame(Frame, State))
+    catch
+        Class:Err ->
+            Report = {Class, Err, erlang:get_stacktrace()},
+            ?WARN("drain_id=~p channel_id=~p dest=~s at=wait_response "
+                  "attempt=fail err=exception data=~p next_state=disconnected",
+                  log_info(State, [Report])),
+            http_fail(retry_frame(Frame,State))
     end.
 
 %% @private