Fix

Author: anakorenko

go/testimonyd/internal/socket/socket.go

@@ -138,7 +138,6 @@ func (s *socket) getNewBlocks() {
 }
 func (s *socket) reportStats() {
 	var totalPackets, totalDrops uint64
-	var totalNotSent float64
 	// getting statistics returns the stats since the last invocation.  We clear
 	// counters by doing an initial read we ignore.
 	s.stats()
@@ -150,34 +149,19 @@ func (s *socket) reportStats() {
 			log.Printf("error getting statistics: %v", err)
 		} else {
 			client_status := "delivered to client"
-			totalPackets += uint64(stats.tp_packets)
-			totalDrops += uint64(stats.tp_drops)
-
-
-			totalNotSent = float64(stats.tp_packets) - (float64(stats.tp_packets) * (float64(len(s.currentConns)) / (float64(s.conf.NumberOfClients * s.conf.FanoutSize))))
-
 			if len(s.currentConns) <= 0 {
 				client_status = "discarded by testimony"
 			}
 			if s.conf.NumberOfClients == 0 {
-				vlog.V(1, " Connected - %d clients", len(s.currentConns))
-
-			} else if len(s.currentConns) > s.conf.NumberOfClients {
-				vlog.V(1, " Connected - %d clients, but waiting only for %d connection(s)", len(s.currentConns), s.conf.NumberOfClients)
+				vlog.V(1, "%v stats: Connected - %d clients", s, len(s.currentConns))
 			} else {
-				totalNotSent = float64(stats.tp_packets) - (float64(stats.tp_packets) * (float64(len(s.currentConns)) / (float64(s.conf.NumberOfClients * s.conf.FanoutSize))))
-				vlog.V(1, " Connected - %d clients, still not connected - %d, therefore %v packets loosed", len(s.currentConns), (s.conf.NumberOfClients*s.conf.FanoutSize)-len(s.currentConns), totalNotSent)
-
-			} else {
-				vlog.V(1, " Connected - %d clients, still not connected - %d, therefore %v packets loosed ", len(s.currentConns), (s.conf.NumberOfClients*s.conf.FanoutSize)-len(s.currentConns), totalNotSent)
-
+				vlog.V(1, "%v stats: connected - %d clients, still not connected - %d, therefore %v packets loosed for each unconnected client", s, len(s.currentConns), s.conf.NumberOfClients-len(s.currentConns), stats.tp_packets)
 			}
 			vlog.V(1, " %v stats: %d packets %v (%.02fpps), %d dropped in kernel (%.02fpps) (%.02f%% dropped) since last log, %d packets, %d drops total (%.02f%% dropped)",
 				s, stats.tp_packets, client_status, float64(stats.tp_packets)/seconds,
 				stats.tp_drops, float64(stats.tp_drops)/seconds,
 				float64(stats.tp_drops)/float64(stats.tp_drops+stats.tp_packets)*100,
 				totalPackets, totalDrops, float64(totalDrops)/float64(totalPackets+totalDrops)*100)
-
 		}
 
 	}