diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2019-01-16 00:37:14 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2019-01-16 00:37:14 +0300 |
| commit | 7f60ddffb9b6ea554ffb1ee5509deb46bba2432b (patch) | |
| tree | 1f2deffe335b908f8e42479a8c8534957261ae98 /src | |
| parent | 2593ee9e9f4f8ff1e0821f04f89df5ea46ce420d (diff) | |
| parent | 46d995d1d9a13f3ba9705bbdaa6dc068814dd03c (diff) | |
| download | rabbitmq-server-git-7f60ddffb9b6ea554ffb1ee5509deb46bba2432b.tar.gz | |
Merge branch 'master' into make-mandatory-based-on-routing-only
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_networking.erl | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/src/rabbit_networking.erl b/src/rabbit_networking.erl index 54f4b8a87d..6131e2f294 100644 --- a/src/rabbit_networking.erl +++ b/src/rabbit_networking.erl @@ -35,8 +35,7 @@ connection_info/1, connection_info/2, connection_info_all/0, connection_info_all/1, emit_connection_info_all/4, emit_connection_info_local/3, - close_connection/2, accept_ack/2, - handshake/2, tcp_host/1]). + close_connection/2, handshake/2, tcp_host/1]). %% Used by TCP-based transports, e.g. STOMP adapter -export([tcp_listener_addresses/1, tcp_listener_spec/9, @@ -87,7 +86,6 @@ -spec connection_info_all(rabbit_types:info_keys()) -> [rabbit_types:infos()]. -spec close_connection(pid(), string()) -> 'ok'. --spec accept_ack(any(), rabbit_net:socket()) -> ok. -spec on_node_down(node()) -> 'ok'. -spec tcp_listener_addresses(listener_config()) -> [address()]. @@ -363,16 +361,16 @@ handshake(Ref, ProxyProtocol) -> true -> {ok, ProxyInfo} = ranch:recv_proxy_header(Ref, 1000), {ok, Sock} = ranch:handshake(Ref), - tune_buffer_size(Sock), - ok = file_handle_cache:obtain(), + setup_socket(Sock), {ok, {rabbit_proxy_socket, Sock, ProxyInfo}}; false -> - ranch:handshake(Ref) + {ok, Sock} = ranch:handshake(Ref), + setup_socket(Sock), + {ok, Sock} end. -accept_ack(Ref, Sock) -> - ok = ranch:accept_ack(Ref), - tune_buffer_size(Sock), +setup_socket(Sock) -> + ok = tune_buffer_size(Sock), ok = file_handle_cache:obtain(). tune_buffer_size(Sock) -> |