diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-02-09 16:12:36 +0000 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-02-09 16:12:36 +0000 |
| commit | 27fd4874cf2c6f418655c95829a2d22d3aacf721 (patch) | |
| tree | fb4e2bfb31c5f5dddd5da9d8e5de7cbf3a57c809 /src | |
| parent | a2fc0dd8355f18cf31c25389c7147ba5965e35fd (diff) | |
| download | rabbitmq-server-git-27fd4874cf2c6f418655c95829a2d22d3aacf721.tar.gz | |
Taking is_dirty into account in needs_sync/1.
Diffstat (limited to 'src')
| -rw-r--r-- | src/file_handle_cache.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/file_handle_cache.erl b/src/file_handle_cache.erl index 65cbe2c8be..6f38181717 100644 --- a/src/file_handle_cache.erl +++ b/src/file_handle_cache.erl @@ -376,8 +376,9 @@ sync(Ref) -> needs_sync(Ref) -> with_handles( [Ref], - fun ([#handle { write_buffer = [] }]) -> false; - ([_Handle]) -> true + fun ([#handle { write_buffer = [_|_] }]) -> true; + ([#handle { is_dirty = true }]) -> true; + ([_Handle]) -> false end). position(Ref, NewOffset) -> |