public class org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch extends org.apache.activemq.store.kahadb.disk.journal.DataFileAppender$WriteBatch
{
org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream buff;
private boolean forceToDisk;
final org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender this$0;
public void <init>(org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender, org.apache.activemq.store.kahadb.disk.journal.DataFile, int, org.apache.activemq.store.kahadb.disk.journal.Journal$WriteCommand) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream[] v;
org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch v;
org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender v, v, v;
byte v, v, v;
org.apache.activemq.store.kahadb.disk.journal.Journal$WriteCommand v;
int v;
org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream v, v;
org.apache.activemq.store.kahadb.disk.journal.DataFile v;
v := @this: org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch;
v := @parameter: org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender;
v := @parameter: org.apache.activemq.store.kahadb.disk.journal.DataFile;
v := @parameter: int;
v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Journal$WriteCommand;
v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch: org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender this$0> = v;
specialinvoke v.<org.apache.activemq.store.kahadb.disk.journal.DataFileAppender$WriteBatch: void <init>(org.apache.activemq.store.kahadb.disk.journal.DataFileAppender,org.apache.activemq.store.kahadb.disk.journal.DataFile,int)>(v, v, v);
v = v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch: org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender this$0>;
v = v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender: org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream[] cachedBuffers>;
v = v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch: org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender this$0>;
v = v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender: byte flip>;
v = v ^ 1;
v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender: byte flip> = v;
v = v[v];
v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch: org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream buff> = v;
v = v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch: org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream buff>;
specialinvoke v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender: void initBuffer(org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream)>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch: void append(org.apache.activemq.store.kahadb.disk.journal.Journal$WriteCommand)>(v);
return;
}
public void append(org.apache.activemq.store.kahadb.disk.journal.Journal$WriteCommand) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch v;
org.apache.activemq.store.kahadb.disk.journal.Journal$WriteCommand v;
org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender v;
org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream v;
boolean v, v, v;
v := @this: org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch;
v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Journal$WriteCommand;
specialinvoke v.<org.apache.activemq.store.kahadb.disk.journal.DataFileAppender$WriteBatch: void append(org.apache.activemq.store.kahadb.disk.journal.Journal$WriteCommand)>(v);
v = v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch: boolean forceToDisk>;
v = v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch: org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender this$0>;
v = v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch: org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream buff>;
v = specialinvoke v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender: boolean appendToBuffer(org.apache.activemq.store.kahadb.disk.journal.Journal$WriteCommand,org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream)>(v, v);
v = v | v;
v.<org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender$WriteBatch: boolean forceToDisk> = v;
return;
}
}