Package org.apache.drill.exec.store.pcap.decoder

Class Packet

java.lang.Object

org.apache.drill.exec.store.pcap.decoder.Packet

All Implemented Interfaces:

Comparable<Packet>

Direct Known Subclasses:

PacketDecoder

public class Packet
extends Object
implements Comparable<Packet>

Field Summary

Fields

Modifier and Type	Field	Description
protected int	etherProtocol
protected int	ipOffset
protected boolean	isCorrupt
protected boolean	isRoutingV6
protected int	protocol
protected byte[]	raw

Constructor Summary

Constructors

Constructor	Description
Packet()

Method Summary

Modifier and Type	Method	Description
int	compareTo(Packet o)	This function is here so that packets can be sorted for re-sessionization.
int	decodePcap(byte[] buffer, int offset, boolean byteOrder, int maxLength)
static String	formatFlags(int flags)
boolean	getAckFlag()
int	getAckNumber()
boolean	getCwrFlag()
byte[]	getData()
String	getDestinationIpAddressString()
InetAddress	getDst_ip()
int	getDst_port()
boolean	getEceFlag()
String	getEthernetDestination()
String	getEthernetSource()
boolean	getFinFlag()
int	getFlags()
boolean	getNSFlag()
int	getPacketLength()
String	getPacketType()
String	getParsedFlags()
boolean	getPshFlag()
boolean	getRstFlag()
int	getSequenceNumber()
long	getSessionHash()
String	getSourceIpAddressString()
InetAddress	getSrc_ip()
int	getSrc_port()
boolean	getSynFlag()
long	getTimestamp()
long	getTimestampMicro()
boolean	getUrgFlag()
protected int	ipVersion()
boolean	isArpPacket()
boolean	isCorrupt()
boolean	isIcmpPacket()
boolean	isIpV4Packet()
boolean	isIpV6Packet()
boolean	isPPPoV6Packet()
boolean	isTcpPacket()
boolean	isUdpPacket()
protected int	processIpV4Packet()
protected int	processIpV6Packet()
boolean	readPcap(InputStream in, boolean byteOrder, int maxLength)
void	setIsCorrupt(boolean value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

raw

protected byte[] raw

ipOffset

protected int ipOffset

etherProtocol

protected int etherProtocol

protocol

protected int protocol

isRoutingV6

protected boolean isRoutingV6

isCorrupt

protected boolean isCorrupt

Constructor Details

Packet

public Packet()

Method Details

readPcap

public boolean readPcap(InputStream in,
 boolean byteOrder,
 int maxLength)
                 throws IOException

Throws:

IOException

decodePcap

public int decodePcap(byte[] buffer,
 int offset,
 boolean byteOrder,
 int maxLength)

getPacketType

public String getPacketType()

isIpV4Packet

public boolean isIpV4Packet()

isIpV6Packet

public boolean isIpV6Packet()

isPPPoV6Packet

public boolean isPPPoV6Packet()

isTcpPacket

public boolean isTcpPacket()

isUdpPacket

public boolean isUdpPacket()

isArpPacket

public boolean isArpPacket()

isIcmpPacket

public boolean isIcmpPacket()

getSessionHash

public long getSessionHash()

getTimestamp

public long getTimestamp()

getTimestampMicro

public long getTimestampMicro()

getPacketLength

public int getPacketLength()

getSrc_ip

public InetAddress getSrc_ip()

getDst_ip

public InetAddress getDst_ip()

getSourceIpAddressString

public String getSourceIpAddressString()

getDestinationIpAddressString

public String getDestinationIpAddressString()

getEthernetSource

public String getEthernetSource()

getEthernetDestination

public String getEthernetDestination()

getSequenceNumber

public int getSequenceNumber()

getAckNumber

public int getAckNumber()

getFlags

public int getFlags()

getParsedFlags

public String getParsedFlags()

setIsCorrupt

public void setIsCorrupt(boolean value)

getUrgFlag

public boolean getUrgFlag()

getPshFlag

public boolean getPshFlag()

getEceFlag

public boolean getEceFlag()

getSynFlag

public boolean getSynFlag()

getAckFlag

public boolean getAckFlag()

getRstFlag

public boolean getRstFlag()

getFinFlag

public boolean getFinFlag()

getNSFlag

public boolean getNSFlag()

getCwrFlag

public boolean getCwrFlag()

formatFlags

public static String formatFlags(int flags)

getSrc_port

public int getSrc_port()

getDst_port

public int getDst_port()

isCorrupt

public boolean isCorrupt()

getData

public byte[] getData()

ipVersion

protected int ipVersion()

processIpV4Packet

protected int processIpV4Packet()

processIpV6Packet

protected int processIpV6Packet()

compareTo

public int compareTo(Packet o)

This function is here so that packets can be sorted for re-sessionization. Packets in TCP streams are ordered by the sequence number, so being able to order the packets is necessary to reassemble the TCP session.

Specified by:

compareTo in interface Comparable<Packet>

Parameters:

o - The packet to which the current packet is compared to.

Returns:

Returns the difference in sequence number.