Merge pull request #564 from intel-go/gregory/counters

Implemented send/receive statistic counters for #390

Author: gshimansky

common/common.go

@@ -97,3 +97,9 @@ func dropInvalidCPUs(nums []int, maxcpu int) []int {
 	}
 	return nums[:i]
 }
+
+// RXTXStats describes statistics for sender or receiver flow function
+// node.
+type RXTXStats struct {
+	PacketsProcessed, PacketsDropped, BytesProcessed uint64
+}

examples/forwarding/forwarding.go

@@ -1,10 +1,13 @@
-// Copyright 2017 Intel Corporation.
+// Copyright 2017-2019 Intel Corporation.
 // Use of this source code is governed by a BSD-style
 // license that can be found in the LICENSE file.
 
 package main
 
 import (
+	"flag"
+	"net"
+
 	"github.com/intel-go/nff-go/flow"
 	"github.com/intel-go/nff-go/packet"
 )
@@ -13,10 +16,23 @@ var l3Rules *packet.L3Rules
 
 // Main function for constructing packet processing graph.
 func main() {
+	inport := flag.Uint("inport", 0, "Port for receiving packets.")
+	numflows := flag.Uint("numflows", 5, "Number of output flows to use. First flow with number zero is used for dropped packets.")
+	nostats := flag.Bool("nostats", false, "Disable statics HTTP server.")
+	flag.Parse()
+
 	var err error
+	var statsServerAddres *net.TCPAddr = nil
+	if !*nostats {
+		// Set up address for stats web server
+		statsServerAddres = &net.TCPAddr{
+			Port: 8080,
+		}
+	}
+
 	// Initialize NFF-GO library at 16 cores by default
 	config := flow.Config{
-		CPUList: "0-15",
+		StatsHTTPAddress: statsServerAddres,
 	}
 	flow.CheckFatal(flow.SystemInit(&config))
 
@@ -25,11 +41,11 @@ func main() {
 	flow.CheckFatal(err)
 
 	// Receive packets from zero port. Receive queue will be added automatically.
-	inputFlow, err := flow.SetReceiver(0)
+	inputFlow, err := flow.SetReceiver(uint16(*inport))
 	flow.CheckFatal(err)
 
 	// Split packet flow based on ACL.
-	flowsNumber := uint16(5)
+	flowsNumber := uint16(*numflows)
 	outputFlows, err := flow.SetSplitter(inputFlow, l3Splitter, uint(flowsNumber), nil)
 	flow.CheckFatal(err)