443444445446447448449450451452453
try { // files should be already in place. filesReservedForSync.remove(jc); registerJournal(jc.typeByte, journal); journal.stop(); journal.start(); journal.loadSyncOnly(JournalState.SYNCING_UP_TO_DATE); } finally {
454455456457458459460461462463464
PersistentQueueBindingEncoding bindingEncoding = (PersistentQueueBindingEncoding) JournalStorageManager.newObjectEncoding(info, null); queueBindings.put(bindingEncoding.getId(), bindingEncoding); } } bindingsJournal.stop(); } private void printDataAsXML() { try
334335336337338339340341342343344
pgTXs.add(pageTransactionInfo.getTransactionID()); } } } messageJournal.stop(); removeAcked(acks); } /**
458459460461462463464465466467468
280281282283284285286287288289290
331332333334335336337338339340341
453454455456457458459460461462463
457458459460461462463464465466467
7677787980818283848586
Assert.assertTrue(id4 > id3 && id4 < 2000); batch.close(); journal.stop(); batch = new BatchingIDGenerator(0, 1000, journal); loadIDs(journal, batch); long id5 = batch.generateID(); Assert.assertTrue(id5 > id4 && id5 < 2000);
99100101102103104105106107108109
batch.close(); } close = !close; journal.stop(); batch = new BatchingIDGenerator(0, 1000, journal); loadIDs(journal, batch); } long id = batch.generateID();