You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by sr...@apache.org on 2021/12/01 10:41:32 UTC
[plc4x] 01/02: feat(plc4go/pcap): dump packages on debug for better inspection
This is an automated email from the ASF dual-hosted git repository.
sruehl pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git
commit cfcd6e363f2d47a87b7ce1c5ada70830f6191e60
Author: Sebastian Rühl <sr...@apache.org>
AuthorDate: Wed Dec 1 11:16:32 2021 +0100
feat(plc4go/pcap): dump packages on debug for better inspection
---
plc4go/internal/plc4go/spi/transports/pcap/Transport.go | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/plc4go/internal/plc4go/spi/transports/pcap/Transport.go b/plc4go/internal/plc4go/spi/transports/pcap/Transport.go
index 77aac03..c4e4902 100644
--- a/plc4go/internal/plc4go/spi/transports/pcap/Transport.go
+++ b/plc4go/internal/plc4go/spi/transports/pcap/Transport.go
@@ -129,10 +129,12 @@ func (m *TransportInstance) Connect() error {
m.reader = bufio.NewReader(buffer)
go func(m *TransportInstance, buffer *bytes.Buffer) {
+ packageCount := 0
var lastPacketTime *time.Time
for m.connected {
packetData, captureInfo, err := m.handle.ReadPacketData()
- log.Info().Msgf("Read new package %#v", captureInfo)
+ packageCount++
+ log.Info().Msgf("Read new package (nr. %d) %#v", packageCount, captureInfo)
if err != nil {
if err == io.EOF {
log.Info().Msg("Done reading pcap")
@@ -150,6 +152,7 @@ func (m *TransportInstance) Connect() error {
// Decode a packet
packet := gopacket.NewPacket(packetData, layers.LayerTypeEthernet, gopacket.Default)
+ log.Debug().Msgf("Packet dump (nr. %d):\n%s", packageCount, packet.Dump())
var payload []byte
switch m.transportType {
case TCP: