in activeio-core/src/main/java/org/apache/activeio/journal/active/BatchedWrite.java [63:92]
public boolean append(Record record, Location recordMark, boolean force) {
synchronized (this) {
if (appendDisabled)
return false;
appendInProgress = true;
}
if( force && writeDoneCountDownLatch==null)
writeDoneCountDownLatch = new CountDownLatch(1);
record.read(packet);
// if we fit the record in this batch
if ( !record.hasRemaining() ) {
if (recordMark != null)
mark = recordMark;
}
synchronized (this) {
appendInProgress = false;
this.notify();
if (appendDisabled)
return false;
else
return packet.remaining() > 0;
}
}