SEBA-758 send periodic port stats to voltha
SEBA-790 get flow, gemport, and tcont information through API
fix lint errors
Change-Id: I10909e1992eba71d8e54c976ccbcea8778e35539
diff --git a/core/io_worker.go b/core/io_worker.go
index 1c090a8..ec70cc9 100644
--- a/core/io_worker.go
+++ b/core/io_worker.go
@@ -33,7 +33,8 @@
logger.Debug("recvWorker runs. handler: %v", *handler)
packetSource := gopacket.NewPacketSource(handler, handler.LinkType())
for packet := range packetSource.Packets() {
- logger.Debug("recv packet from IF: %v ", *handler)
+ logger.Debug("recv packet from IF: %v", *handler)
+ logger.Debug("Packet received %v", packet)
// logger.Println(packet.Dump())
pkt := Packet{}
pkt.Info = io
@@ -71,10 +72,14 @@
EthernetType: layer.Type,
}
buffer := gopacket.NewSerializeBuffer()
- gopacket.SerializeLayers(buffer, gopacket.SerializeOptions{},
+ err := gopacket.SerializeLayers(buffer, gopacket.SerializeOptions{},
ethernetLayer,
gopacket.Payload(layer.Payload),
)
+ if err != nil {
+ logger.Error("%v", err)
+ }
+
retpkt := gopacket.NewPacket(
buffer.Bytes(),
layers.LayerTypeEthernet,
@@ -102,7 +107,7 @@
}
buffer := gopacket.NewSerializeBuffer()
- gopacket.SerializeLayers(
+ err := gopacket.SerializeLayers(
buffer,
gopacket.SerializeOptions{
FixLengths: false,
@@ -111,6 +116,10 @@
dot1qLayer,
gopacket.Payload(eth.Payload),
)
+ if err != nil {
+ logger.Error("%v", err)
+ }
+
ret := gopacket.NewPacket(
buffer.Bytes(),
layers.LayerTypeEthernet,
@@ -172,13 +181,13 @@
func getVethHandler(vethname string) (*pcap.Handle, error) {
var (
- device = vethname
+ deviceName = vethname
snapshotLen int32 = 1518
promiscuous = false
err error
timeout = pcap.BlockForever
)
- handle, err := pcap.OpenLive(device, snapshotLen, promiscuous, timeout)
+ handle, err := pcap.OpenLive(deviceName, snapshotLen, promiscuous, timeout)
if err != nil {
return nil, err
}