Fix Journal segment allocation/switch race condition

Patch by Alex Petrov; reviewed by Aleksey Yeschenko for CASSANDRA-19866
This commit is contained in:
Alex Petrov 2024-09-09 15:05:32 +02:00 committed by David Capwell
parent 00ebcdc9f2
commit 1866b8ec73
1 changed files with 4 additions and 0 deletions

View File

@ -198,6 +198,10 @@ public class Journal<K, V> implements Shutdownable
public boolean isFlushed(RecordPointer recordPointer)
{
Segment<K, V> current = currentSegment;
if (current.descriptor.timestamp == recordPointer.segment)
return current.isFlushed(recordPointer.position);
return segments.get().isFlushed(recordPointer);
}