public class org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame extends org.apache.activemq.leveldb.replicated.ReplicationFrame
{
private final long position;
private final org.apache.activemq.leveldb.replicated.FileTransferFrame fileTransferFrame;
private org.fusesource.hawtbuf.Buffer encoded;
public final org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState $outer;
public long position()
{
long v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: long position>;
return v;
}
public org.apache.activemq.leveldb.replicated.FileTransferFrame fileTransferFrame()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame v;
org.apache.activemq.leveldb.replicated.FileTransferFrame v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.apache.activemq.leveldb.replicated.FileTransferFrame fileTransferFrame>;
return v;
}
public org.fusesource.hawtbuf.Buffer encoded()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame v;
org.fusesource.hawtbuf.Buffer v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.fusesource.hawtbuf.Buffer encoded>;
return v;
}
public void encoded_$eq(org.fusesource.hawtbuf.Buffer)
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame v;
org.fusesource.hawtbuf.Buffer v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.fusesource.hawtbuf.Buffer encoded> = v;
return;
}
public long offset()
{
long v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame v;
org.apache.activemq.leveldb.replicated.FileTransferFrame v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.apache.activemq.leveldb.replicated.FileTransferFrame fileTransferFrame()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.FileTransferFrame: long offset()>();
return v;
}
public long length()
{
long v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame v;
org.apache.activemq.leveldb.replicated.FileTransferFrame v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.apache.activemq.leveldb.replicated.FileTransferFrame fileTransferFrame()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.FileTransferFrame: long length()>();
return v;
}
public org.fusesource.hawtbuf.Buffer body()
{
org.apache.activemq.leveldb.util.JsonCodec$ v;
long v, v, v, v;
org.fusesource.hawtbuf.Buffer v, v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v, v;
int v, v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
boolean v;
org.apache.activemq.leveldb.replicated.dto.LogWrite v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame v;
org.apache.activemq.leveldb.replicated.FileTransferFrame v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v, v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.fusesource.hawtbuf.Buffer encoded()>();
if v != null goto label;
v = new org.apache.activemq.leveldb.replicated.dto.LogWrite;
specialinvoke v.<org.apache.activemq.leveldb.replicated.dto.LogWrite: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: long position()>();
v.<org.apache.activemq.leveldb.replicated.dto.LogWrite: long file> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: long offset()>();
v.<org.apache.activemq.leveldb.replicated.dto.LogWrite: long offset> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState org$apache$activemq$leveldb$replicated$MasterLevelDBStore$SlaveState$DeferredReplicationFrame$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore org$apache$activemq$leveldb$replicated$MasterLevelDBStore$SlaveState$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int syncToMask()>();
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: int SYNC_TO_REMOTE_DISK()>();
v = v & v;
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<org.apache.activemq.leveldb.replicated.dto.LogWrite: boolean sync> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.apache.activemq.leveldb.replicated.FileTransferFrame fileTransferFrame()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.FileTransferFrame: long length()>();
v.<org.apache.activemq.leveldb.replicated.dto.LogWrite: long length> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState org$apache$activemq$leveldb$replicated$MasterLevelDBStore$SlaveState$DeferredReplicationFrame$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore org$apache$activemq$leveldb$replicated$MasterLevelDBStore$SlaveState$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: long date()>();
v.<org.apache.activemq.leveldb.replicated.dto.LogWrite: long date> = v;
v = <org.apache.activemq.leveldb.util.JsonCodec$: org.apache.activemq.leveldb.util.JsonCodec$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.util.JsonCodec$: org.fusesource.hawtbuf.Buffer encode(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: void encoded_$eq(org.fusesource.hawtbuf.Buffer)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.fusesource.hawtbuf.Buffer encoded()>();
return v;
}
public void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState, java.io.File, long, long, long)
{
long v, v, v;
java.io.File v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame v;
org.apache.activemq.leveldb.replicated.FileTransferFrame v;
org.fusesource.hawtbuf.AsciiBuffer v;
org.apache.activemq.leveldb.replicated.ReplicationSupport$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame;
v := @parameter: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: java.io.File;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: long position> = v;
if v != null goto label;
throw null;
label:
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState $outer> = v;
v = <org.apache.activemq.leveldb.replicated.ReplicationSupport$: org.apache.activemq.leveldb.replicated.ReplicationSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ReplicationSupport$: org.fusesource.hawtbuf.AsciiBuffer WAL_ACTION()>();
specialinvoke v.<org.apache.activemq.leveldb.replicated.ReplicationFrame: void <init>(org.fusesource.hawtbuf.AsciiBuffer,org.fusesource.hawtbuf.Buffer)>(v, null);
v = new org.apache.activemq.leveldb.replicated.FileTransferFrame;
specialinvoke v.<org.apache.activemq.leveldb.replicated.FileTransferFrame: void <init>(java.io.File,long,long)>(v, v, v);
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.apache.activemq.leveldb.replicated.FileTransferFrame fileTransferFrame> = v;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame: org.fusesource.hawtbuf.Buffer encoded> = null;
return;
}
}