From eb79711e0a1db390a66afe99b9226c1addf6be46 Mon Sep 17 00:00:00 2001 From: Alvaro Saurin Date: Thu, 19 Nov 2015 15:05:16 +0100 Subject: [PATCH] Added flow misses count --- router/fastdp.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/router/fastdp.go b/router/fastdp.go index b4e7eeff..c1d30fa2 100644 --- a/router/fastdp.go +++ b/router/fastdp.go @@ -40,6 +40,7 @@ type FastDatapath struct { dpif *odp.Dpif dp odp.DatapathHandle deleteFlowsCount uint64 + missCount uint64 missHandlers map[odp.VportID]missHandler localPeer *mesh.Peer peers *mesh.Peers @@ -216,8 +217,10 @@ func (fastdp fastDatapathBridge) String() string { return fmt.Sprint(fastdp.dpname, " (via ODP)") } -func (fastDatapathBridge) Stats() map[string]int { - return nil +func (fastdp fastDatapathBridge) Stats() map[string]int { + return map[string]int{ + "FlowMisses": int(fastdp.missCount), + } } var routerBridgePortID = bridgePortID{router: true} @@ -937,6 +940,8 @@ func (fastdp *FastDatapath) Miss(packet []byte, fks odp.FlowKeys) error { lock := fastdp.startLock() defer lock.unlock() + fastdp.missCount++ + handler := fastdp.getMissHandler(ingress) if handler == nil { return nil