|
35 | 35 | connection_info/1, connection_info/2,
|
36 | 36 | connection_info_all/0, connection_info_all/1,
|
37 | 37 | emit_connection_info_all/4, emit_connection_info_local/3,
|
38 |
| - close_connection/2, accept_ack/2, |
39 |
| - handshake/2, tcp_host/1]). |
| 38 | + close_connection/2, handshake/2, tcp_host/1]). |
40 | 39 |
|
41 | 40 | %% Used by TCP-based transports, e.g. STOMP adapter
|
42 | 41 | -export([tcp_listener_addresses/1, tcp_listener_spec/9,
|
|
87 | 86 | -spec connection_info_all(rabbit_types:info_keys()) ->
|
88 | 87 | [rabbit_types:infos()].
|
89 | 88 | -spec close_connection(pid(), string()) -> 'ok'.
|
90 |
| --spec accept_ack(any(), rabbit_net:socket()) -> ok. |
91 | 89 |
|
92 | 90 | -spec on_node_down(node()) -> 'ok'.
|
93 | 91 | -spec tcp_listener_addresses(listener_config()) -> [address()].
|
@@ -363,16 +361,16 @@ handshake(Ref, ProxyProtocol) ->
|
363 | 361 | true ->
|
364 | 362 | {ok, ProxyInfo} = ranch:recv_proxy_header(Ref, 1000),
|
365 | 363 | {ok, Sock} = ranch:handshake(Ref),
|
366 |
| - tune_buffer_size(Sock), |
367 |
| - ok = file_handle_cache:obtain(), |
| 364 | + setup_socket(Sock), |
368 | 365 | {ok, {rabbit_proxy_socket, Sock, ProxyInfo}};
|
369 | 366 | false ->
|
370 |
| - ranch:handshake(Ref) |
| 367 | + {ok, Sock} = ranch:handshake(Ref), |
| 368 | + setup_socket(Sock), |
| 369 | + {ok, Sock} |
371 | 370 | end.
|
372 | 371 |
|
373 |
| -accept_ack(Ref, Sock) -> |
374 |
| - ok = ranch:accept_ack(Ref), |
375 |
| - tune_buffer_size(Sock), |
| 372 | +setup_socket(Sock) -> |
| 373 | + ok = tune_buffer_size(Sock), |
376 | 374 | ok = file_handle_cache:obtain().
|
377 | 375 |
|
378 | 376 | tune_buffer_size(Sock) ->
|
|
0 commit comments