diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-07-20 18:02:03 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-07-20 18:02:03 +0100 |
| commit | 3997c6928b8ec4c5886ceb7ca152a517418a3d2b (patch) | |
| tree | 04879ba6277da27f948a8a90238ed2da9a79ea16 /src | |
| parent | d1406db0fa572727655efde534eaf813e765f3e1 (diff) | |
| download | rabbitmq-server-git-3997c6928b8ec4c5886ceb7ca152a517418a3d2b.tar.gz | |
Rename some variables.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 367290d78e..b1a67640f0 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1161,30 +1161,30 @@ i(prefetch_count, #ch{limiter_pid = LimiterPid}) -> i(Item, _) -> throw({bad_argument, Item}). -incr_exchange_stats(Counts, Item, State = #ch{exchange_stats = Stats}) -> - State#ch{exchange_stats = incr_stats(Counts, Item, Stats)}. +incr_exchange_stats(XCounts, Item, State = #ch{exchange_stats = Stats}) -> + State#ch{exchange_stats = incr_stats(XCounts, Item, Stats)}. -incr_queue_stats(Counts, Item, State = #ch{queue_stats = Stats}) -> - State#ch{queue_stats = incr_stats(Counts, Item, Stats)}. +incr_queue_stats(QCounts, Item, State = #ch{queue_stats = Stats}) -> + State#ch{queue_stats = incr_stats(QCounts, Item, Stats)}. -incr_stats(Counts, Item, Stats) -> +incr_stats(QXCounts, Item, Stats) -> Stats1 = lists:foldl( - fun ({Key, Incr}, Stats0) -> - case is_pid(Key) andalso not dict:is_key(Key, Stats0) of - true -> erlang:monitor(process, Key); + fun ({QX, Inc}, Stats0) -> + case is_pid(QX) andalso not dict:is_key(QX, Stats) of + true -> erlang:monitor(process, QX); _ -> ok end, - dict:update(Key, + dict:update(QX, fun(D) -> Count = case orddict:find(Item, D) of error -> 0; {ok, C} -> C end, - orddict:store(Item, Count + Incr, D) + orddict:store(Item, Count + Inc, D) end, [], Stats0) - end, Stats, Counts), + end, Stats, QXCounts), Stats1. maybe_emit_stats(State = #ch{exchange_stats = ExchangeStats, |