Skip to content

Commit 8c01c86

Browse files
wolfgangmmwolfgangmm
authored
Merge pull request #2292 from adamretter/hotfix/journal-2gb-limit-4.x.x
(4.x.x) Remove the 2GB log file limit for the Journal
2 parents 015b920 + 69403ca commit 8c01c86

File tree

19 files changed

+287
-123
lines changed

19 files changed

+287
-123
lines changed

‎extensions/indexes/ngram/src/org/exist/indexing/ngram/NGramIndex.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@
4242
*/
4343
public class NGramIndex extends AbstractIndex implements RawBackupSupport {
4444

45-
public static final short FILE_FORMAT_VERSION_ID = 13;
45+
public static final short FILE_FORMAT_VERSION_ID = 14;
4646

4747
public final static String ID = NGramIndex.class.getName();
4848

‎extensions/indexes/sort/src/org/exist/indexing/sort/SortIndex.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public class SortIndex extends AbstractIndex implements RawBackupSupport {
3434

3535
public static final String ID = SortIndex.class.getName();
3636
public static final String FILE_NAME = "sort.dbx";
37-
public final static short FILE_FORMAT_VERSION_ID = 2;
37+
public final static short FILE_FORMAT_VERSION_ID = 3;
3838
public static final byte SORT_INDEX_ID = 0x10;
3939
protected static final Logger LOG = LogManager.getLogger(SortIndex.class);
4040
protected BTreeStore btree;

‎src/org/exist/storage/NativeValueIndex.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ public class NativeValueIndex implements ContentLoadingObserver {
118118
private final static Logger LOG = LogManager.getLogger(NativeValueIndex.class);
119119

120120
public static final String FILE_NAME = "values.dbx";
121-
public static final short FILE_FORMAT_VERSION_ID = 13;
121+
public static final short FILE_FORMAT_VERSION_ID = 14;
122122
public static final String FILE_KEY_IN_CONFIG = "db-connection.values";
123123

124124
private static final double DEFAULT_VALUE_CACHE_GROWTH = 1.25;

‎src/org/exist/storage/btree/BTree.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -754,7 +754,7 @@ private void writeToLog(final Loggable loggable, final BTreeNode node) {
754754
}
755755

756756
protected boolean requiresRedo(final Loggable loggable, final Page page) {
757-
return loggable.getLsn() > page.getPageHeader().getLsn();
757+
return loggable.getLsn().compareTo(page.getPageHeader().getLsn()) > 0;
758758
}
759759

760760
protected void redoCreateBTNode(final CreateBTNodeLoggable loggable) throws LogException {
@@ -766,7 +766,7 @@ protected void redoCreateBTNode(final CreateBTNodeLoggable loggable) throws LogE
766766
page.read();
767767
if ((page.getPageHeader().getStatus() == BRANCH ||
768768
page.getPageHeader().getStatus() == LEAF) &&
769-
page.getPageHeader().getLsn() != Lsn.LSN_INVALID &&
769+
(!page.getPageHeader().getLsn().equals(Lsn.LSN_INVALID)) &&
770770
!requiresRedo(loggable, page)) {
771771
// node already found on disk: read it
772772
node = new BTreeNode(page, false);
@@ -809,7 +809,7 @@ protected void undoInsertValue(final InsertValueLoggable loggable) throws LogExc
809809

810810
protected void redoUpdateValue(final UpdateValueLoggable loggable) throws LogException {
811811
final BTreeNode node = getBTreeNode(loggable.pageNum);
812-
if (node.page.getPageHeader().getLsn() != Page.NO_PAGE && requiresRedo(loggable, node.page)) {
812+
if (!node.page.getPageHeader().getLsn().equals(Lsn.LSN_INVALID) && requiresRedo(loggable, node.page)) {
813813
if (loggable.idx > node.ptrs.length) {
814814
LOG.warn(node.page.getPageInfo() +
815815
"; loggable.idx = " + loggable.idx + "; node.ptrs.length = " + node.ptrs.length);
@@ -839,7 +839,7 @@ protected void undoUpdateValue(final UpdateValueLoggable loggable) throws LogExc
839839

840840
protected void redoRemoveValue(final RemoveValueLoggable loggable) throws LogException {
841841
final BTreeNode node = getBTreeNode(loggable.pageNum);
842-
if (node.page.getPageHeader().getLsn() != Page.NO_PAGE && requiresRedo(loggable, node.page)) {
842+
if (!node.page.getPageHeader().getLsn().equals(Lsn.LSN_INVALID) && requiresRedo(loggable, node.page)) {
843843
node.removeKey(loggable.idx);
844844
node.removePointer(loggable.idx);
845845
node.recalculateDataLen();

‎src/org/exist/storage/btree/Paged.java‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1014,15 +1014,15 @@ public static abstract class PageHeader {
10141014
public static final int LENGTH_PAGE_STATUS = 1; //sizeof byte
10151015
public static final int LENGTH_PAGE_DATA_LENGTH = 4; //sizeof int
10161016
public static final int LENGTH_PAGE_NEXT_PAGE = 8; //sizeof long
1017-
public static final int LENGTH_PAGE_LSN = 8; //sizeof long
1017+
public static final int LENGTH_PAGE_LSN = Lsn.RAW_LENGTH;
10181018

10191019
private int dataLen = 0;
10201020
private boolean dirty = false;
10211021
private long nextPage = Page.NO_PAGE;
10221022

10231023
private byte status = UNUSED;
10241024

1025-
private long lsn = Lsn.LSN_INVALID;
1025+
private Lsn lsn = Lsn.LSN_INVALID;
10261026

10271027
public PageHeader() {
10281028
}
@@ -1081,11 +1081,11 @@ public final boolean isDirty() {
10811081
*
10821082
* @return log sequence number of the last operation that modified this page.
10831083
*/
1084-
public final long getLsn() {
1084+
public final Lsn getLsn() {
10851085
return lsn;
10861086
}
10871087

1088-
public final void setLsn(final long lsn) {
1088+
public final void setLsn(final Lsn lsn) {
10891089
this.lsn = lsn;
10901090
}
10911091

@@ -1096,7 +1096,7 @@ public int read(final byte[] data, int offset) throws IOException {
10961096
offset += LENGTH_PAGE_DATA_LENGTH;
10971097
nextPage = ByteConversion.byteToLong(data, offset);
10981098
offset += LENGTH_PAGE_NEXT_PAGE;
1099-
lsn = ByteConversion.byteToLong(data, offset);
1099+
lsn = Lsn.read(data, offset);
11001100
offset += LENGTH_PAGE_LSN;
11011101
return offset;
11021102
}
@@ -1108,7 +1108,7 @@ public int write(final byte[] data, int offset) throws IOException {
11081108
offset += LENGTH_PAGE_DATA_LENGTH;
11091109
ByteConversion.longToByte(nextPage, data, offset);
11101110
offset += LENGTH_PAGE_NEXT_PAGE;
1111-
ByteConversion.longToByte(lsn, data, offset);
1111+
lsn.write(data, offset);
11121112
offset += LENGTH_PAGE_LSN;
11131113
dirty = false;
11141114
return offset;

‎src/org/exist/storage/dom/DOMFile.java‎

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,7 @@ public class DOMFile extends BTree implements Lockable {
164164
LogEntryTypes.addEntryType(LOG_UPDATE_LINK, UpdateLinkLoggable::new);
165165
}
166166

167-
public final static short FILE_FORMAT_VERSION_ID = 9;
167+
public final static short FILE_FORMAT_VERSION_ID = 10;
168168

169169
//Page types
170170
public final static byte LOB = 21;
@@ -2178,13 +2178,13 @@ public synchronized final void setOwnerObject(final Object ownerObject) {
21782178
*/
21792179

21802180
private boolean requiresRedo(final Loggable loggable, final DOMPage page) {
2181-
return loggable.getLsn() > page.getPageHeader().getLsn();
2181+
return loggable.getLsn().compareTo(page.getPageHeader().getLsn()) > 0;
21822182
}
21832183

21842184
protected void redoCreatePage(final CreatePageLoggable loggable) {
21852185
final DOMPage newPage = getDOMPage(loggable.newPage);
21862186
final DOMFilePageHeader newPageHeader = newPage.getPageHeader();
2187-
if (newPageHeader.getLsn() == Lsn.LSN_INVALID || requiresRedo(loggable, newPage)) {
2187+
if (newPageHeader.getLsn().equals(Lsn.LSN_INVALID) || requiresRedo(loggable, newPage)) {
21882188
try {
21892189
dropFreePageList();
21902190
newPageHeader.setStatus(RECORD);
@@ -2240,7 +2240,7 @@ protected void undoCreatePage(final CreatePageLoggable loggable) {
22402240
protected void redoAddValue(final AddValueLoggable loggable) {
22412241
final DOMPage page = getDOMPage(loggable.pageNum);
22422242
final DOMFilePageHeader pageHeader = page.getPageHeader();
2243-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2243+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
22442244
try {
22452245
ByteConversion.shortToByte(loggable.tid, page.data, page.len);
22462246
page.len += LENGTH_TID;
@@ -2272,7 +2272,7 @@ protected void undoAddValue(final AddValueLoggable loggable) {
22722272
final DOMFilePageHeader pageHeader = page.getPageHeader();
22732273

22742274
// is there anything to undo?
2275-
if (pageHeader.getLsn() == Lsn.LSN_INVALID || pageHeader.getStatus() == UNUSED) {
2275+
if (pageHeader.getLsn().equals(Lsn.LSN_INVALID) || pageHeader.getStatus() == UNUSED) {
22762276
LOG.warn("Nothing to undo, but received: AddValueLoggable(txnId=" + loggable.getTransactionId()
22772277
+ ", lsn=" + loggable.getLsn() + ", pageNum=" + loggable.pageNum
22782278
+ ", isOverflow=" + loggable.isOverflow + ")");
@@ -2304,7 +2304,7 @@ protected void undoAddValue(final AddValueLoggable loggable) {
23042304
protected void redoUpdateValue(final UpdateValueLoggable loggable) {
23052305
final DOMPage page = getDOMPage(loggable.pageNum);
23062306
final DOMFilePageHeader ph = page.getPageHeader();
2307-
if (ph.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2307+
if ((!ph.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
23082308
final RecordPos rec = page.findRecord(ItemId.getId(loggable.tid));
23092309
SanityCheck.THROW_ASSERT(rec != null,
23102310
"tid " + ItemId.getId(loggable.tid) +
@@ -2344,7 +2344,7 @@ protected void undoUpdateValue(final UpdateValueLoggable loggable) {
23442344
protected void redoRemoveValue(final RemoveValueLoggable loggable) {
23452345
final DOMPage page = getDOMPage(loggable.pageNum);
23462346
final DOMFilePageHeader pageHeader = page.getPageHeader();
2347-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2347+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
23482348
final RecordPos pos = page.findRecord(ItemId.getId(loggable.tid));
23492349
SanityCheck.ASSERT(pos != null,
23502350
"Record not found: " + ItemId.getId(loggable.tid) + ": " +
@@ -2447,7 +2447,7 @@ protected void undoRemoveValue(final RemoveValueLoggable loggable) {
24472447
protected void redoRemoveEmptyPage(final RemoveEmptyPageLoggable loggable) {
24482448
final DOMPage page = getDOMPage(loggable.pageNum);
24492449
final DOMFilePageHeader pageHeader = page.getPageHeader();
2450-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2450+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
24512451
removePage(page);
24522452
}
24532453
}
@@ -2489,7 +2489,7 @@ protected void undoRemoveEmptyPage(final RemoveEmptyPageLoggable loggable) {
24892489
protected void redoRemovePage(final RemovePageLoggable loggable) {
24902490
final DOMPage page = getDOMPage(loggable.pageNum);
24912491
final DOMFilePageHeader pageHeader = page.getPageHeader();
2492-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2492+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
24932493
try {
24942494
pageHeader.setNextDataPage(Page.NO_PAGE);
24952495
pageHeader.setPrevDataPage(Page.NO_PAGE);
@@ -2533,7 +2533,7 @@ protected void redoWriteOverflow(final WriteOverflowPageLoggable loggable) {
25332533
try {
25342534
final Page page = getPage(loggable.pageNum);
25352535
final PageHeader pageHeader = page.getPageHeader();
2536-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2536+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
25372537

25382538
dropFreePageList();
25392539
pageHeader.setStatus(RECORD);
@@ -2568,7 +2568,7 @@ protected void redoRemoveOverflow(final RemoveOverflowLoggable loggable) {
25682568
final Page page = getPage(loggable.pageNum);
25692569
page.read();
25702570
final PageHeader pageHeader = page.getPageHeader();
2571-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2571+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
25722572
unlinkPages(page);
25732573
}
25742574
} catch (final IOException e) {
@@ -2599,7 +2599,7 @@ protected void undoRemoveOverflow(final RemoveOverflowLoggable loggable) {
25992599
protected void redoInsertValue(final InsertValueLoggable loggable) {
26002600
final DOMPage page = getDOMPage(loggable.pageNum);
26012601
final DOMFilePageHeader pageHeader = page.getPageHeader();
2602-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2602+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
26032603
final int dlen = pageHeader.getDataLength();
26042604
int offset = loggable.offset;
26052605
// insert in the middle of the page?
@@ -2686,7 +2686,7 @@ protected void undoInsertValue(final InsertValueLoggable loggable) {
26862686
protected void redoSplitPage(final SplitPageLoggable loggable) {
26872687
final DOMPage page = getDOMPage(loggable.pageNum);
26882688
final DOMFilePageHeader pageHeader = page.getPageHeader();
2689-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2689+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
26902690
final byte[] oldData = page.data;
26912691
page.data = new byte[fileHeader.getWorkSize()];
26922692
System.arraycopy(oldData, 0, page.data, 0, loggable.splitOffset);
@@ -2718,7 +2718,7 @@ protected void undoSplitPage(final SplitPageLoggable loggable) {
27182718
protected void redoAddLink(final AddLinkLoggable loggable) {
27192719
final DOMPage page = getDOMPage(loggable.pageNum);
27202720
final DOMFilePageHeader pageHeader = page.getPageHeader();
2721-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2721+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
27222722
ByteConversion.shortToByte(ItemId.setIsLink(loggable.tid), page.data, page.len);
27232723
page.len += LENGTH_TID;
27242724
ByteConversion.longToByte(loggable.link, page.data, page.len);
@@ -2754,7 +2754,7 @@ protected void undoAddLink(final AddLinkLoggable loggable) {
27542754
protected void redoUpdateLink(final UpdateLinkLoggable loggable) {
27552755
final DOMPage page = getDOMPage(loggable.pageNum);
27562756
final DOMFilePageHeader pageHeader = page.getPageHeader();
2757-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2757+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
27582758
ByteConversion.longToByte(loggable.link, page.data, loggable.offset);
27592759
pageHeader.setLsn(loggable.getLsn());
27602760
page.setDirty(true);
@@ -2774,7 +2774,7 @@ protected void undoUpdateLink(final UpdateLinkLoggable loggable) {
27742774
protected void redoAddMovedValue(final AddMovedValueLoggable loggable) {
27752775
final DOMPage page = getDOMPage(loggable.pageNum);
27762776
final DOMFilePageHeader pageHeader = page.getPageHeader();
2777-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2777+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
27782778
try {
27792779
ByteConversion.shortToByte(ItemId.setIsRelocated(loggable.tid), page.data, page.len);
27802780
page.len += LENGTH_TID;
@@ -2842,7 +2842,7 @@ protected void undoAddMovedValue(final AddMovedValueLoggable loggable) {
28422842
protected void redoUpdateHeader(final UpdateHeaderLoggable loggable) {
28432843
final DOMPage page = getDOMPage(loggable.pageNum);
28442844
final DOMFilePageHeader pageHeader = page.getPageHeader();
2845-
if (pageHeader.getLsn() != Lsn.LSN_INVALID && requiresRedo(loggable, page)) {
2845+
if ((!pageHeader.getLsn().equals(Lsn.LSN_INVALID)) && requiresRedo(loggable, page)) {
28462846
if (loggable.nextPage != Page.NO_PAGE) {
28472847
pageHeader.setNextDataPage(loggable.nextPage);
28482848
}
@@ -3192,7 +3192,7 @@ public String dumpPage() {
31923192
public boolean sync(final boolean syncJournal) {
31933193
if (isDirty()) {
31943194
write();
3195-
if (isRecoveryEnabled() && syncJournal && logManager.get().lastWrittenLsn() < pageHeader.getLsn()) {
3195+
if (isRecoveryEnabled() && syncJournal && logManager.get().lastWrittenLsn().compareTo(pageHeader.getLsn()) < 0) {
31963196
logManager.get().flush(true, false);
31973197
}
31983198
return true;

‎src/org/exist/storage/index/BFile.java‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -990,11 +990,11 @@ private SinglePage getSinglePageForRedo(final Loggable loggable, final long pos)
990990
}
991991

992992
private boolean isUptodate(final Page page, final Loggable loggable) {
993-
return page.getPageHeader().getLsn() >= loggable.getLsn();
993+
return page.getPageHeader().getLsn().compareTo(loggable.getLsn()) >= 0;
994994
}
995995

996996
private boolean requiresRedo(final Loggable loggable, final DataPage page) {
997-
return loggable.getLsn() > page.getPageHeader().getLsn();
997+
return loggable.getLsn().compareTo(page.getPageHeader().getLsn()) > 0;
998998
}
999999

10001000
protected void redoStoreValue(final StoreValueLoggable loggable) {
@@ -1048,7 +1048,7 @@ protected void redoRemoveValue(final RemoveValueLoggable loggable) {
10481048
}
10491049
wp = new SinglePage(page, data, true);
10501050
}
1051-
if (wp.ph.getLsn() != Page.NO_PAGE && requiresRedo(loggable, wp)) {
1051+
if (!wp.ph.getLsn().equals(Lsn.LSN_INVALID) && requiresRedo(loggable, wp)) {
10521052
removeValueHelper(loggable, loggable.tid, wp);
10531053
}
10541054
} catch (final IOException e) {
@@ -1081,7 +1081,7 @@ protected void redoRemovePage(final RemoveEmptyPageLoggable loggable) {
10811081
}
10821082
wp = new SinglePage(page, data, false);
10831083
}
1084-
if (wp.getPageHeader().getLsn() == Lsn.LSN_INVALID || requiresRedo(loggable, wp)) {
1084+
if (wp.getPageHeader().getLsn().equals(Lsn.LSN_INVALID) || requiresRedo(loggable, wp)) {
10851085
fileHeader.removeFreeSpace(fileHeader.getFreeSpace(wp.getPageNum()));
10861086
dataCache.remove(wp);
10871087
wp.delete();
@@ -1101,7 +1101,7 @@ protected void redoCreateOverflow(final OverflowCreateLoggable loggable) {
11011101
if (firstPage == null) {
11021102
final Page page = getPage(loggable.pageNum);
11031103
byte[] data = page.read();
1104-
if (page.getPageHeader().getLsn() == Lsn.LSN_INVALID || requiresRedo(loggable, page)) {
1104+
if (page.getPageHeader().getLsn().equals(Lsn.LSN_INVALID) || requiresRedo(loggable, page)) {
11051105
dropFreePageList();
11061106
final BFilePageHeader ph = (BFilePageHeader) page.getPageHeader();
11071107
ph.setStatus(MULTI_PAGE);
@@ -1116,7 +1116,7 @@ protected void redoCreateOverflow(final OverflowCreateLoggable loggable) {
11161116
firstPage = new SinglePage(page, data, false);
11171117
}
11181118
}
1119-
if (firstPage.getPageHeader().getLsn() != Page.NO_PAGE && requiresRedo(loggable, firstPage)) {
1119+
if (!firstPage.getPageHeader().getLsn().equals(Lsn.LSN_INVALID) && requiresRedo(loggable, firstPage)) {
11201120
firstPage.getPageHeader().setLsn(loggable.getLsn());
11211121
firstPage.setDirty(true);
11221122
}
@@ -1371,7 +1371,7 @@ private DataPage createPageHelper(final Loggable loggable, final long newPage, f
13711371
if (dp == null) {
13721372
final Page page = getPage(newPage);
13731373
byte[] data = page.read();
1374-
if (page.getPageHeader().getLsn() == Lsn.LSN_INVALID || (loggable != null && requiresRedo(loggable, page)) ) {
1374+
if (page.getPageHeader().getLsn().equals(Lsn.LSN_INVALID) || (loggable != null && requiresRedo(loggable, page)) ) {
13751375
if (reuseDeleted) {
13761376
reuseDeleted(page);
13771377
} else {
@@ -1388,7 +1388,7 @@ private DataPage createPageHelper(final Loggable loggable, final long newPage, f
13881388
dp = new SinglePage(page, data, true);
13891389
}
13901390
}
1391-
if (loggable != null && loggable.getLsn() > dp.getPageHeader().getLsn()) {
1391+
if (loggable != null && loggable.getLsn().compareTo(dp.getPageHeader().getLsn()) > 0) {
13921392
dp.getPageHeader().setLsn(loggable.getLsn());
13931393
}
13941394
dp.setDirty(true);
@@ -1626,7 +1626,7 @@ public boolean sync(final boolean syncJournal) {
16261626
if (isDirty()) {
16271627
try {
16281628
write();
1629-
if (isRecoveryEnabled() && syncJournal && logManager.get().lastWrittenLsn() < getPageHeader().getLsn()) {
1629+
if (isRecoveryEnabled() && syncJournal && logManager.get().lastWrittenLsn().compareTo(getPageHeader().getLsn()) < 0) {
16301630
logManager.get().flush(true, false);
16311631
}
16321632
return true;

0 commit comments

Comments
 (0)