diff options
| author | Essien Ita Essien <essiene@gmail.com> | 2008-12-16 22:29:16 +0100 |
|---|---|---|
| committer | Essien Ita Essien <essiene@gmail.com> | 2008-12-16 22:29:16 +0100 |
| commit | cd5c1e58d4426d4554a711e0a1f8d31261a2a606 (patch) | |
| tree | 54202e0d190bc3c8dea0bb1d367f4186eeabc493 /src | |
| parent | 3653237636f491b3ea37e95c132d4d4dda9517e9 (diff) | |
| download | rabbitmq-server-git-cd5c1e58d4426d4554a711e0a1f8d31261a2a606.tar.gz | |
Use rabbit_net layer in rabbit_heartbeat.erl
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_heartbeat.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_heartbeat.erl b/src/rabbit_heartbeat.erl index 0a68c9adad..ed0066fe07 100644 --- a/src/rabbit_heartbeat.erl +++ b/src/rabbit_heartbeat.erl @@ -53,7 +53,7 @@ start_heartbeat(Sock, TimeoutSec) -> spawn_link(fun () -> heartbeater(Sock, TimeoutSec * 1000 div 2, send_oct, 0, fun () -> - catch gen_tcp:send(Sock, rabbit_binary_generator:build_heartbeat_frame()), + catch rabbit_net:send(Sock, rabbit_binary_generator:build_heartbeat_frame()), continue end, erlang:monitor(process, Parent)) end), @@ -73,7 +73,7 @@ heartbeater(Sock, TimeoutMillisec, StatName, Threshold, Handler, MonitorRef) -> {'DOWN', MonitorRef, process, _Object, _Info} -> ok; Other -> exit({unexpected_message, Other}) after TimeoutMillisec -> - case inet:getstat(Sock, [StatName]) of + case rabbit_net:getstat(Sock, [StatName]) of {ok, [{StatName, NewStatVal}]} -> if NewStatVal =/= StatVal -> F({NewStatVal, 0}); |