This is an automated email from the ASF dual-hosted git repository. cdutz pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/plc4x.git
commit d9e805cb88750b0dc265bf509d94af82d8ea9007 Author: Christofer Dutz <[email protected]> AuthorDate: Tue Sep 24 09:46:30 2019 +0200 - Added filtering capabilities by ip, port and protocol id to the pcap channel --- .../apache/plc4x/java/base/connection/PcapChannelFactory.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/plc4j/protocols/driver-bases/pcap-socket/src/main/java/org/apache/plc4x/java/base/connection/PcapChannelFactory.java b/plc4j/protocols/driver-bases/pcap-socket/src/main/java/org/apache/plc4x/java/base/connection/PcapChannelFactory.java index 7979ca7..6731a76 100644 --- a/plc4j/protocols/driver-bases/pcap-socket/src/main/java/org/apache/plc4x/java/base/connection/PcapChannelFactory.java +++ b/plc4j/protocols/driver-bases/pcap-socket/src/main/java/org/apache/plc4x/java/base/connection/PcapChannelFactory.java @@ -33,17 +33,24 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.File; +import java.net.InetAddress; public class PcapChannelFactory implements ChannelFactory { private static final Logger logger = LoggerFactory.getLogger(PcapChannelFactory.class); private final File pcapFile; + private final InetAddress address; + private final int port; + private final int protocolId; private final float replaySpeedFactor; private final PacketHandler packetHandler; - public PcapChannelFactory(File pcapFile, float replaySpeedFactor, PacketHandler packetHandler) { + public PcapChannelFactory(File pcapFile, InetAddress address, int port, int protocolId, float replaySpeedFactor, PacketHandler packetHandler) { this.pcapFile = pcapFile; + this.address = address; + this.port = port; + this.protocolId = protocolId; this.replaySpeedFactor = replaySpeedFactor; this.packetHandler = packetHandler; } @@ -62,7 +69,7 @@ public class PcapChannelFactory implements ChannelFactory { bootstrap.handler(channelHandler); // Start the client. - ChannelFuture f = bootstrap.connect(new PcapSocketAddress(pcapFile)).sync(); + ChannelFuture f = bootstrap.connect(new PcapSocketAddress(pcapFile, address, port, protocolId)).sync(); f.addListener(new GenericFutureListener<Future<? super Void>>() { @Override public void operationComplete(Future<? super Void> future) throws Exception { if (!future.isSuccess()) {
