Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
| inline |
side by side
Synchronize SegmentedJournal.open()
[controller.git]
/
third-party
/
atomix
/
storage
/
src
/
main
/
java
/
io
/
atomix
/
storage
/
journal
/
SegmentedJournal.java
diff --git
a/third-party/atomix/storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java
b/third-party/atomix/storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java
index fed7ab8d3e6c19fc69df5fe3cdc6bd7ff26196f3..45490757f8685b5bd529fa7888c2dab716afb52e 100644
(file)
--- a/
third-party/atomix/storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java
+++ b/
third-party/atomix/storage/src/main/java/io/atomix/storage/journal/SegmentedJournal.java
@@
-230,7
+230,7
@@
public final class SegmentedJournal<E> implements Journal<E> {
/**
* Opens the segments.
*/
- private void open() {
+ private
synchronized
void open() {
// Load existing log segments from disk.
for (JournalSegment<E> segment : loadSegments()) {
segments.put(segment.descriptor().index(), segment);