219220221222223224225226227228229
" updates " + consumeCount + "/" + updateCount + " bytes " + totalConsumeBytes + "/" + totalUpdateBytes); } // Update segment load size segTarget.decrLoadSize(totalIgnoreBytes); } /** * Consumes a {@link CompactionUpdateBatch} if available. *
400401402403404405406407408409410
if (segPos >= Segment.dataStartPosition) { // get data segment Segment seg = _segmentManager.getSegment(segInd); // read data length if(seg != null) seg.decrLoadSize(4 + ((length == 0) ? seg.readInt(segPos) : length)); } } catch(IOException e1) {} catch(IndexOutOfBoundsException e2) {} }