diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-02-15 18:55:47 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-02-15 18:55:47 +0000 |
| commit | 5e7d0a33022b12cb128356c35b0fd601e457bf17 (patch) | |
| tree | b183727247d3beb8163382a4fa6e42afd754d1c1 /src | |
| parent | 25118198ee266ce6864eef53740fa9346d97af45 (diff) | |
| download | rabbitmq-server-git-5e7d0a33022b12cb128356c35b0fd601e457bf17.tar.gz | |
explain a reader sublety
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 203ec3f0c4..af331a6298 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -636,7 +636,9 @@ process_frame(Frame, Channel, State) -> post_process_frame({method, 'channel.close_ok', _}, ChPid, State) -> channel_cleanup(ChPid), - %% this is not strictly necessary, but more obviously correct + %% This is not strictly necessary, but more obviously + %% correct. Also note that we do not need to call maybe_close/1 + %% since we cannot possibly be in the 'closing' state. control_throttle(State); post_process_frame({content_header, _, _, _, _}, _ChPid, State) -> maybe_block(State); |