diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-01-11 13:41:57 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-01-11 13:41:57 +0000 |
| commit | 27fe1d8bf9c554c9aecd667d8f23a965edcbc1d1 (patch) | |
| tree | d627f0bae0b6f25785ebdaf4d91530692abdf9c7 /src | |
| parent | 94782dbb5267516f16ac2b914f3c36f9348033a6 (diff) | |
| download | rabbitmq-server-git-27fe1d8bf9c554c9aecd667d8f23a965edcbc1d1.tar.gz | |
Optimise the heartbeat to death. Honk. And some cosmetics too
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_connection_sup.erl | 1 | ||||
| -rw-r--r-- | src/rabbit_reader.erl | 13 |
2 files changed, 3 insertions, 11 deletions
diff --git a/src/rabbit_connection_sup.erl b/src/rabbit_connection_sup.erl index ff3995b54a..a6b1f7faad 100644 --- a/src/rabbit_connection_sup.erl +++ b/src/rabbit_connection_sup.erl @@ -78,4 +78,3 @@ reader(Pid) -> init([]) -> {ok, {{one_for_all, 0, 1}, []}}. - diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index a3292d35a6..e9f34a0f8c 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -770,17 +770,10 @@ handle_method0(#'connection.tune_ok'{frame_max = FrameMax, not_allowed, "frame_max=~w > ~w max size", [FrameMax, ?FRAME_MAX]); true -> - SendFun = - fun() -> - Frame = rabbit_binary_generator:build_heartbeat_frame(), - catch rabbit_net:send(Sock, Frame) - end, - + Frame = rabbit_binary_generator:build_heartbeat_frame(), + SendFun = fun() -> catch rabbit_net:send(Sock, Frame) end, Parent = self(), - ReceiveFun = - fun() -> - Parent ! timeout - end, + ReceiveFun = fun() -> Parent ! timeout end, Heartbeater = SHF(Sock, ClientHeartbeat, SendFun, ClientHeartbeat, ReceiveFun), State#v1{connection_state = opening, |