diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-07-16 08:28:52 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-07-16 08:28:52 +0100 |
| commit | a8aa180d3ee05f2bbf2c75aed3b86fad7d070950 (patch) | |
| tree | 07df578abea7f795cd4de1e5d6565ecef573957b /src | |
| parent | 1db89582e86ed9aa0ccab6e9559f04ac30828d38 (diff) | |
| download | rabbitmq-server-git-a8aa180d3ee05f2bbf2c75aed3b86fad7d070950.tar.gz | |
refactor: remove gratuitous helper function
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index ee3bf29aba..7524600785 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -887,8 +887,8 @@ i(SockStat, #v1{sock = Sock}) when SockStat =:= recv_oct; SockStat =:= send_oct; SockStat =:= send_cnt; SockStat =:= send_pend -> - socket_info(fun () -> rabbit_net:getstat(Sock, [SockStat]) end, - fun ([{_, I}]) -> I end); + socket_info(fun (S) -> rabbit_net:getstat(S, [SockStat]) end, + fun ([{_, I}]) -> I end, Sock); i(state, #v1{connection_state = S}) -> S; i(last_blocked_by, #v1{last_blocked_by = By}) -> @@ -924,10 +924,7 @@ i(Item, #v1{}) -> throw({bad_argument, Item}). socket_info(Get, Select, Sock) -> - socket_info(fun() -> Get(Sock) end, Select). - -socket_info(Get, Select) -> - case Get() of + case Get(Sock) of {ok, T} -> Select(T); {error, _} -> '' end. |
