summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2012-07-16 08:28:52 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2012-07-16 08:28:52 +0100
commita8aa180d3ee05f2bbf2c75aed3b86fad7d070950 (patch)
tree07df578abea7f795cd4de1e5d6565ecef573957b /src
parent1db89582e86ed9aa0ccab6e9559f04ac30828d38 (diff)
downloadrabbitmq-server-git-a8aa180d3ee05f2bbf2c75aed3b86fad7d070950.tar.gz
refactor: remove gratuitous helper function
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_reader.erl9
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.