private void verifyStoreContents(final LogStoreImpl store, final int count, Writer... writers) throws IOException {
List<Descriptor> descriptors = store.getDescriptors();
long expectedID = 0;
for (Descriptor desc : descriptors) {
SortedRangeSet rangeSet = desc.getRangeSet();
RangeIterator rangeIter = rangeSet.iterator();
while (rangeIter.hasNext()) {
long id = rangeIter.next();
Event expectedEntry = null;
for (int i = 0; (expectedEntry == null) && i < writers.length; i++) {
expectedEntry = writers[i].m_written.remove(id);
}
assertNotNull(expectedEntry, "Event ID #" + id + " never written?!");
assertEquals(expectedEntry.getID(), expectedID++, "Entry ID mismatch?!");
}
}
}
|