diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-12-30 13:47:41 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-12-30 13:47:41 +0000 |
| commit | 2302e6bba1689f6dc72998ea945c3fff373af5ff (patch) | |
| tree | 55efd475b68f9495b47b7e032a6ec1e8da5c9acd | |
| parent | 1aadea65eac6ede7a43cb55540bca8060f4b6f9e (diff) | |
| download | rabbitmq-server-git-2302e6bba1689f6dc72998ea945c3fff373af5ff.tar.gz | |
carry on accepting tcp connections after an error
| -rw-r--r-- | src/tcp_acceptor.erl | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/tcp_acceptor.erl b/src/tcp_acceptor.erl index 0d50683db7..8678c2c9e0 100644 --- a/src/tcp_acceptor.erl +++ b/src/tcp_acceptor.erl @@ -86,6 +86,13 @@ handle_info({inet_async, LSock, Ref, {error, closed}}, %% know this will fail. {stop, normal, State}; +handle_info({inet_async, LSock, Ref, {error, Reason}}, + State=#state{sock=LSock, ref=Ref}) -> + {Address, Port} = inet_op(fun () -> inet:sockname(LSock) end), + error_logger:error_msg("failed to accept TCP connection on ~s:~p: ~p~n", + [rabbit_misc:ntoab(Address), Port, Reason]), + accept(State); + handle_info(_Info, State) -> {noreply, State}. |