diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-08-19 19:32:42 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-08-19 19:32:42 +0100 |
| commit | 5361e97272fee534ee1ecb7dee38fd514f475f24 (patch) | |
| tree | e6c4f6129d61bcee62674097beecfb9979b94214 /src | |
| parent | b78a8db06e81908db2d2ed75dc0f5eaae54f37f1 (diff) | |
| download | rabbitmq-server-git-5361e97272fee534ee1ecb7dee38fd514f475f24.tar.gz | |
Whoops, forgot that bit.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_msg_store.erl | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index de7a5fc4d6..82ecf676e4 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -1077,6 +1077,10 @@ remove_message(MsgId, CRef, %% Remove eliminated the corresponding write. true = ets:delete(FlyingWritesEts, {MsgId, CRef}), true = 0 =< ets:update_counter(CurFileCacheEts, MsgId, {3, -1}), + %% If the msg has been removed, then it won't be followed + %% by a read, so it's safe to remove from the + %% cur_file_cache_ets. + true = ets:match_delete(CurFileCacheEts, {MsgId, '_', 0}), State end. |