public class org.apache.drill.exec.store.pcap.decoder.TcpSession extends java.lang.Object
{
private final java.util.List packetsFromSender;
private final java.util.List packetsFromReceiver;
private final org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake;
private final long sessionID;
private long startTime;
private long endTime;
private int packetCount;
private java.net.InetAddress srcIP;
private java.net.InetAddress dstIP;
private int srcPort;
private int dstPort;
private java.lang.String srcMac;
private java.lang.String dstMac;
private long synTime;
private long ackTime;
private long connectTime;
private byte[] sentData;
private byte[] receivedData;
private int sentDataSize;
private int receivedDataSize;
private boolean hasCorruptedData;
private static final org.slf4j.Logger logger;
public void <init>(long)
{
long v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
java.util.ArrayList v, v;
org.apache.drill.exec.store.pcap.decoder.TcpHandshake v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v := @parameter: long;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: boolean hasCorruptedData> = 0;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromSender> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromReceiver> = v;
v = new org.apache.drill.exec.store.pcap.decoder.TcpHandshake;
specialinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: void <init>()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake> = v;
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long sessionID> = v;
return;
}
public void addPacket(org.apache.drill.exec.store.pcap.decoder.Packet)
{
byte[] v, v, v, v;
java.net.InetAddress v, v, v, v, v, v, v, v, v, v;
byte v, v, v;
java.lang.Long v;
long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.store.pcap.decoder.TcpHandshake$State v, v;
java.util.List v, v;
org.apache.drill.exec.store.pcap.decoder.Packet v;
int v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v;
org.apache.drill.exec.store.pcap.decoder.TcpHandshake v, v, v, v, v, v, v, v, v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v := @parameter: org.apache.drill.exec.store.pcap.decoder.Packet;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: java.lang.String getPacketType()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("TCP");
if v != 0 goto label;
return;
label:
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int packetCount>;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: java.net.InetAddress getSrc_ip()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.net.InetAddress srcIP> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: java.net.InetAddress getDst_ip()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.net.InetAddress dstIP> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: int getSrc_port()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int srcPort> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: int getDst_port()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int dstPort> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: java.lang.String getEthernetSource()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.lang.String srcMac> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: java.lang.String getEthernetDestination()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.lang.String dstMac> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: long getTimestamp()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long startTime> = v;
goto label;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: long getSessionHash()>();
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long sessionID>;
v = v cmp v;
if v == 0 goto label;
v = <org.apache.drill.exec.store.pcap.decoder.TcpSession: org.slf4j.Logger logger>;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long sessionID>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("Attempting to add session {} to incorrect TCP session.", v);
return;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: java.net.InetAddress getSrc_ip()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.net.InetAddress srcIP>;
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromSender>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: byte[] getData()>();
if v == null goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int sentDataSize>;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: byte[] getData()>();
v = lengthof v;
v = v + v;
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int sentDataSize> = v;
goto label;
label:
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromReceiver>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: byte[] getData()>();
if v == null goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int receivedDataSize>;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: byte[] getData()>();
v = lengthof v;
v = v + v;
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int receivedDataSize> = v;
label:
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: boolean isConnected()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: boolean getSynFlag()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: java.net.InetAddress getSrc_ip()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.net.InetAddress srcIP>;
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: void setSyn()>();
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: long getTimestamp()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long synTime> = v;
goto label;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: boolean getSynFlag()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: boolean getAckFlag()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: java.net.InetAddress getSrc_ip()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.net.InetAddress dstIP>;
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: void setAck()>();
goto label;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: boolean getAckFlag()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: java.net.InetAddress getSrc_ip()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.net.InetAddress srcIP>;
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: void setAck()>();
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: long getTimestamp()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long ackTime> = v;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long ackTime>;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long synTime>;
v = v - v;
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long connectTime> = v;
goto label;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: boolean getRstFlag()>();
if v == 0 goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: void setRst()>();
goto label;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: boolean getFinFlag()>();
if v == 0 goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: void setFin()>();
goto label;
label:
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: org.apache.drill.exec.store.pcap.decoder.TcpHandshake$State getCurrentSessionState()>();
v = <org.apache.drill.exec.store.pcap.decoder.TcpHandshake$State: org.apache.drill.exec.store.pcap.decoder.TcpHandshake$State CLOSE_WAIT>;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: boolean getAckFlag()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: boolean getFinFlag()>();
if v == 0 goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: void setAck()>();
label:
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int packetCount>;
v = v + 1;
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int packetCount> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: boolean isCorrupt()>();
if v == 0 goto label;
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: boolean hasCorruptedData> = 1;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: long getTimestampMicro()>();
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long startTime>;
v = v cmp v;
if v >= 0 goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: long getTimestamp()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long startTime> = v;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: long getTimestampMicro()>();
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long endTime>;
v = v cmp v;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: long getTimestamp()>();
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long endTime> = v;
label:
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: boolean isClosed()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: void closeSession()>();
label:
return;
}
public boolean connectionEstablished()
{
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
boolean v;
org.apache.drill.exec.store.pcap.decoder.TcpHandshake v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: boolean isConnected()>();
return v;
}
public boolean connectionClosed()
{
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
boolean v;
org.apache.drill.exec.store.pcap.decoder.TcpHandshake v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.apache.drill.exec.store.pcap.decoder.TcpHandshake handshake>;
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.TcpHandshake: boolean isClosed()>();
return v;
}
public void closeSession()
{
byte[] v, v, v, v, v, v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
byte v, v;
java.lang.Long v;
java.util.List v, v, v, v, v, v;
long v;
int v, v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v;
java.lang.Object v, v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = <org.apache.drill.exec.store.pcap.decoder.TcpSession: org.slf4j.Logger logger>;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long sessionID>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Closing session {}", v);
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromSender>;
staticinvoke <java.util.Collections: void sort(java.util.List)>(v);
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromReceiver>;
staticinvoke <java.util.Collections: void sort(java.util.List)>(v);
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int sentDataSize>;
v = newarray (byte)[v];
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: byte[] sentData> = v;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int receivedDataSize>;
v = newarray (byte)[v];
v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: byte[] receivedData> = v;
v = 0;
v = 0;
label:
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromSender>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromSender>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: byte[] getData()>();
if v == null goto label;
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: byte[] sentData>;
v = v[v];
v[v] = v;
v = v + 1;
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = 0;
v = 0;
label:
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromReceiver>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromReceiver>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.pcap.decoder.Packet: byte[] getData()>();
if v == null goto label;
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: byte[] receivedData>;
v = v[v];
v[v] = v;
v = v + 1;
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
return;
}
public java.time.Instant getSessionStartTime()
{
long v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
java.time.Instant v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long startTime>;
v = staticinvoke <java.time.Instant: java.time.Instant ofEpochMilli(long)>(v);
return v;
}
public org.joda.time.Period getSessionDuration()
{
org.joda.time.Period v;
long v, v, v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = new org.joda.time.Period;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long endTime>;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long startTime>;
v = v - v;
specialinvoke v.<org.joda.time.Period: void <init>(long)>(v);
return v;
}
public org.joda.time.Period getConnectionTime()
{
org.joda.time.Period v;
long v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = new org.joda.time.Period;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long connectTime>;
specialinvoke v.<org.joda.time.Period: void <init>(long)>(v);
return v;
}
public java.time.Instant getSessionEndTime()
{
long v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
java.time.Instant v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long endTime>;
v = staticinvoke <java.time.Instant: java.time.Instant ofEpochMilli(long)>(v);
return v;
}
public java.lang.String getSrcMac()
{
java.lang.String v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.lang.String srcMac>;
return v;
}
public java.lang.String getDstMac()
{
java.lang.String v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.lang.String dstMac>;
return v;
}
public java.lang.String getSrcIP()
{
java.net.InetAddress v;
java.lang.String v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.net.InetAddress srcIP>;
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
return v;
}
public java.lang.String getDstIP()
{
java.net.InetAddress v;
java.lang.String v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.net.InetAddress dstIP>;
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
return v;
}
public int getSrcPort()
{
int v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int srcPort>;
return v;
}
public int getDstPort()
{
int v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: int dstPort>;
return v;
}
public long getSessionID()
{
long v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: long sessionID>;
return v;
}
public int getPacketCount()
{
java.util.List v, v;
int v, v, v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromReceiver>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromSender>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + v;
return v;
}
public int getPacketCountFromOrigin()
{
int v;
java.util.List v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromSender>;
v = interfaceinvoke v.<java.util.List: int size()>();
return v;
}
public int getPacketCountFromRemote()
{
int v;
java.util.List v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: java.util.List packetsFromReceiver>;
v = interfaceinvoke v.<java.util.List: int size()>();
return v;
}
public boolean hasCorruptedData()
{
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
boolean v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: boolean hasCorruptedData>;
return v;
}
public int getDataVolumeFromOrigin()
{
int v;
byte[] v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: byte[] sentData>;
v = lengthof v;
return v;
}
public int getDataVolumeFromRemote()
{
int v;
byte[] v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: byte[] receivedData>;
v = lengthof v;
return v;
}
public byte[] getDataFromOriginator()
{
byte[] v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: byte[] sentData>;
return v;
}
public java.lang.String getDataFromOriginatorAsString()
{
byte[] v;
java.lang.String v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: byte[] sentData>;
v = staticinvoke <org.apache.drill.exec.store.pcap.PcapFormatUtils: java.lang.String parseBytesToASCII(byte[])>(v);
return v;
}
public byte[] getDataFromRemote()
{
byte[] v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: byte[] receivedData>;
return v;
}
public java.lang.String getDataFromRemoteAsString()
{
byte[] v;
java.lang.String v;
org.apache.drill.exec.store.pcap.decoder.TcpSession v;
v := @this: org.apache.drill.exec.store.pcap.decoder.TcpSession;
v = v.<org.apache.drill.exec.store.pcap.decoder.TcpSession: byte[] receivedData>;
v = staticinvoke <org.apache.drill.exec.store.pcap.PcapFormatUtils: java.lang.String parseBytesToASCII(byte[])>(v);
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/drill/exec/store/pcap/decoder/TcpSession;");
<org.apache.drill.exec.store.pcap.decoder.TcpSession: org.slf4j.Logger logger> = v;
return;
}
}