Module com.slytechs.jnet.jnetpcap

Package com.slytechs.jnet.jnetpcap.internal

Class PacketDissectorReceiver

java.lang.Object

com.slytechs.jnet.jnetpcap.internal.PacketDissectorReceiver

All Implemented Interfaces:

PacketReceiver, AutoCloseable

public class PacketDissectorReceiver
extends Object
implements PacketReceiver

PacketDissectorReceiver relies on preview features of the Java platform:

• PacketDissectorReceiver refers to one or more preview APIs: Arena, MemorySegment.

Programs can only use PacketDissectorReceiver when preview features are enabled.

Preview features may be removed in a future release, or upgraded to permanent features of the Java platform.

A packet dissector and dispatcher.

Author:

Sly Technologies Inc, repos@slytechs.com, Mark Bednarczyk

Constructor Summary

Constructors

Constructor	Description
PacketDissectorReceiver(PacketReceiverConfig config)	Instantiates a new packet dispatcher.

Method Summary

Modifier and Type	Method	Description
void	activate()	Activate.
void	close()	Close.
CaptureStatistics	getCaptureStatistics()	Gets the capture statistics.
com.slytechs.jnet.protocol.core.constants.PacketDescriptorType	getDescriptorType()	Gets the descriptor type.
com.slytechs.jnet.protocol.descriptor.PacketDissector	getDissector()	Gets the current dissector.
long	getDroppedCaplenCount()	Gets the dropped caplen count.
long	getDroppedPacketCount()	Gets the dropped packet count.
long	getDroppedWirelenCount()	Gets the dropped wirelen count.
com.slytechs.jnet.protocol.Packet	getPacketWithNext()	Gets the packet with next.
com.slytechs.jnet.protocol.Packet	getPacketWithNextExtended()	Gets the packet with next extended.
long	getReceivedCaplenCount()	Gets the received caplen count.
long	getReceivedPacketCount()	Gets the received packet count.
long	getReceivedWirelenCount()	Gets the received wirelen count.
void	onNativeCallbackException(Throwable e, int caplen, int wirelen)	On native callback exception.
<U> com.slytechs.jnet.protocol.Packet	processPacket(MemorySegmentPREVIEW pcapHdr, MemorySegmentPREVIEW pktData, ArenaPREVIEW arena)	Process packet.
<U> com.slytechs.jnet.protocol.Packet	processPacket(ByteBuffer buffer, MemorySegmentPREVIEW mpacket, int caplen, int wirelen, long timestamp)	Process packet.
<U> int	receivePacketWithDispatch(int count, PcapProHandler.OfPacket<U> sink, U user)	Dispatch packet.
<U> int	receivePacketWithDispatch(int count, PcapProHandler.OfPacket<U> sink, U user, Supplier<com.slytechs.jnet.protocol.Packet> packetFactory)	Receive packet with dispatch.
<U> int	receivePacketWithLoop(int count, PcapProHandler.OfPacket<U> sink, U user)	Loop packet.
void	setPcapDispatcher(org.jnetpcap.internal.PcapDispatcher pcapDispatcher)	Sets the pcap dispatcher.

Methods inherited from class java.lang.Object

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

Constructor Details

PacketDissectorReceiver

public PacketDissectorReceiver(PacketReceiverConfig config)

Instantiates a new packet dispatcher.

Parameters:

config - the config

Method Details

activate

public void activate()

Activate.

Specified by:

activate in interface PacketReceiver

See Also:

• PacketReceiver.activate()

close

public void close()

Close.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface PacketReceiver

See Also:

• PacketReceiver.close()

getCaptureStatistics

public CaptureStatistics getCaptureStatistics()

Gets the capture statistics.

Specified by:

getCaptureStatistics in interface PacketReceiver

Returns:

the capture statistics

getDescriptorType

public com.slytechs.jnet.protocol.core.constants.PacketDescriptorType getDescriptorType()

Gets the descriptor type.

Specified by:

getDescriptorType in interface PacketReceiver

Returns:

the descriptorType

getDissector

public com.slytechs.jnet.protocol.descriptor.PacketDissector getDissector()

Gets the current dissector.

Specified by:

getDissector in interface PacketReceiver

Returns:

the dissector

getDroppedCaplenCount

public long getDroppedCaplenCount()

Gets the dropped caplen count.

Returns:

the dropped caplen count

See Also:

• CaptureStatistics.getDroppedCaplenCount()

getDroppedPacketCount

public long getDroppedPacketCount()

Gets the dropped packet count.

Returns:

the dropped packet count

See Also:

• CaptureStatistics.getDroppedPacketCount()

getDroppedWirelenCount

public long getDroppedWirelenCount()

Gets the dropped wirelen count.

Returns:

the dropped wirelen count

See Also:

• CaptureStatistics.getDroppedWirelenCount()

getPacketWithNext

public com.slytechs.jnet.protocol.Packet getPacketWithNext()
                                                    throws org.jnetpcap.PcapException

Gets the packet with next.

Specified by:

getPacketWithNext in interface PacketReceiver

Returns:

the packet with next

Throws:

org.jnetpcap.PcapException - the pcap exception

See Also:

• PacketReceiver.getPacketWithNext()

getPacketWithNextExtended

public com.slytechs.jnet.protocol.Packet getPacketWithNextExtended()
                                                            throws org.jnetpcap.PcapException,
TimeoutException

Gets the packet with next extended.

Specified by:

getPacketWithNextExtended in interface PacketReceiver

Returns:

the packet with next extended

Throws:

org.jnetpcap.PcapException - the pcap exception

TimeoutException - the timeout exception

See Also:

• PacketReceiver.getPacketWithNextExtended()

getReceivedCaplenCount

public long getReceivedCaplenCount()

Gets the received caplen count.

Returns:

the received caplen count

See Also:

• CaptureStatistics.getReceivedCaplenCount()

getReceivedPacketCount

public long getReceivedPacketCount()

Gets the received packet count.

Returns:

the received packet count

See Also:

• CaptureStatistics.getReceivedPacketCount()

getReceivedWirelenCount

public long getReceivedWirelenCount()

Gets the received wirelen count.

Returns:

the received wirelen count

See Also:

• CaptureStatistics.getReceivedWirelenCount()

onNativeCallbackException

public void onNativeCallbackException(Throwable e,
 int caplen,
 int wirelen)

Description copied from interface: PacketReceiver

On native callback exception.

Specified by:

onNativeCallbackException in interface PacketReceiver

Parameters:

e - the e

caplen - the caplen

wirelen - the wirelen

See Also:

• PacketReceiver.onNativeCallbackException(java.lang.Throwable, int, int)

processPacket

public <U> com.slytechs.jnet.protocol.Packet processPacket(ByteBuffer buffer,
 MemorySegmentPREVIEW mpacket,
 int caplen,
 int wirelen,
 long timestamp)

Description copied from interface: PacketReceiver

Process packet.

Specified by:

processPacket in interface PacketReceiver

Type Parameters:

U - the generic type

Parameters:

buffer - the buffer

mpacket - the mpacket

caplen - the caplen

wirelen - the wirelen

timestamp - the timestamp

Returns:

the packet

See Also:

• PacketReceiver.processPacket(java.nio.ByteBuffer, java.lang.foreign.MemorySegment, int, int, long)^PREVIEW

processPacket

public <U> com.slytechs.jnet.protocol.Packet processPacket(MemorySegmentPREVIEW pcapHdr,
 MemorySegmentPREVIEW pktData,
 ArenaPREVIEW arena)

Process packet.

Specified by:

processPacket in interface PacketReceiver

Type Parameters:

U - the generic type

Parameters:

pcapHdr - the pcap hdr

pktData - the pkt data

arena - the arena

Returns:

the packet

See Also:

• PacketReceiver.processPacket(java.lang.foreign.MemorySegment, java.lang.foreign.MemorySegment, java.lang.foreign.Arena)^PREVIEW

receivePacketWithDispatch

public <U> int receivePacketWithDispatch(int count,
 PcapProHandler.OfPacket<U> sink,
 U user,
 Supplier<com.slytechs.jnet.protocol.Packet> packetFactory)

Receive packet with dispatch.

Specified by:

receivePacketWithDispatch in interface PacketReceiver

Type Parameters:

U - the generic type

Parameters:

count - the count

sink - the sink

user - the user

packetFactory - the packet factory

Returns:

the int

See Also:

• PacketReceiver.receivePacketWithDispatch(int, com.slytechs.jnetpcap.pro.PcapProHandler.OfPacket, java.lang.Object, java.util.function.Supplier)

receivePacketWithDispatch

public <U> int receivePacketWithDispatch(int count,
 PcapProHandler.OfPacket<U> sink,
 U user)

Dispatch packet.

Specified by:

receivePacketWithDispatch in interface PacketReceiver

Type Parameters:

U - the generic type

Parameters:

count - the count

sink - the sink

user - the user

Returns:

the int

receivePacketWithLoop

public <U> int receivePacketWithLoop(int count,
 PcapProHandler.OfPacket<U> sink,
 U user)

Loop packet.

Specified by:

receivePacketWithLoop in interface PacketReceiver

Type Parameters:

U - the generic type

Parameters:

count - the count

sink - the sink

user - the user

Returns:

the int

setPcapDispatcher

public void setPcapDispatcher(org.jnetpcap.internal.PcapDispatcher pcapDispatcher)

Sets the pcap dispatcher.

Parameters:

pcapDispatcher - the new pcap dispatcher