diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-10-17 14:42:37 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-10-17 14:42:37 +0100 |
| commit | 2f8ab8bbf679effb2048e050c0ba3757f167bdf0 (patch) | |
| tree | 0c458adc6cce7cce13b7555426aeba7ed57b13ab /src | |
| parent | 2e63caebdcc684aff35f18aefa1156cd3fa73b82 (diff) | |
| download | rabbitmq-server-git-2f8ab8bbf679effb2048e050c0ba3757f167bdf0.tar.gz | |
Rephrase to make Matthias happier...
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_msg_store.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 67940963f2..9049c67162 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -803,13 +803,13 @@ handle_cast({write, CRef, MsgId}, ignored, State), %% If all writes get eliminated, cur_file_cache_ets could %% grow unbounded. To prevent that we delete the cache - %% entry here, but only if the message hasn't been written - %% into the current file. That way reads of the message - %% can continue to be done client side, from either the - %% cache or the non-current files. If the message *is* in - %% the current file then the cache entry will be removed - %% by the normal logic for that in write_message/4 and - %% maybe_roll_to_new_file/2. + %% entry here, but only if the message isn't in the + %% current file (i.e. it has only ever been ignored). That + %% way reads of the message can continue to be done client + %% side, from either the cache or the non-current + %% files. If the message *is* in the current file then the + %% cache entry will be removed by the normal logic for + %% that in write_message/4 and maybe_roll_to_new_file/2. case index_lookup(MsgId, State1) of [#msg_location { file = File }] when File == State1 #msstate.current_file -> |
