interim commit go fmt stuff
Change-Id: I617a7d771b50c2b7999eabbbebbabef4e68d8713
diff --git a/grpc/packetOut.go b/grpc/packetOut.go
index 02920ae..ee58a31 100644
--- a/grpc/packetOut.go
+++ b/grpc/packetOut.go
@@ -17,6 +17,8 @@
package grpc
import (
+ "encoding/json"
+ "github.com/opencord/ofagent-go/openflow"
pb "github.com/opencord/voltha-protos/go/voltha"
"google.golang.org/grpc"
"log"
@@ -31,8 +33,11 @@
log.Printf("Error creating packetout stream %v", err)
}
packetOutChannel := make(chan pb.PacketOut)
+ openflow.SetPacketOutChannel(packetOutChannel)
for {
ofPacketOut := <-packetOutChannel
+ js, _ := json.Marshal(ofPacketOut)
+ log.Printf("RECEIVED PACKET OUT FROM CHANNEL %s", js)
outClient.Send(&ofPacketOut)
}