diff options
| author | Aleksandr Nogikh <nogikh@google.com> | 2024-03-19 13:25:24 +0100 |
|---|---|---|
| committer | Aleksandr Nogikh <nogikh@google.com> | 2024-03-19 13:42:28 +0000 |
| commit | f51578614c22875edddf3d0af93e164915ecf751 (patch) | |
| tree | 0b2274827983e76dd9d8aa5da1cd4b5626aa4c1f /syz-manager | |
| parent | e104824c06ba54122c1d17b5b26dd21c57e427b6 (diff) | |
pkg/rpc: measure total RPC traffic
Measure and display the total RPC communication traffic.
It will help better evaluate #4579.
Diffstat (limited to 'syz-manager')
| -rw-r--r-- | syz-manager/rpc.go | 6 | ||||
| -rw-r--r-- | syz-manager/stats.go | 2 |
2 files changed, 8 insertions, 0 deletions
diff --git a/syz-manager/rpc.go b/syz-manager/rpc.go index 0fdaf3b46..37c548dcb 100644 --- a/syz-manager/rpc.go +++ b/syz-manager/rpc.go @@ -90,6 +90,12 @@ func startRPCServer(mgr *Manager) (*RPCServer, error) { log.Logf(0, "serving rpc on tcp://%v", s.Addr()) serv.port = s.Addr().(*net.TCPAddr).Port go s.Serve() + go func() { + for { + time.Sleep(time.Second) + mgr.stats.rpcTraffic.add(int(s.TotalBytes.Swap(0))) + } + }() return serv, nil } diff --git a/syz-manager/stats.go b/syz-manager/stats.go index 3598e66ca..0ab84746d 100644 --- a/syz-manager/stats.go +++ b/syz-manager/stats.go @@ -21,6 +21,7 @@ type Stats struct { newInputs Stat rotatedInputs Stat execTotal Stat + rpcTraffic Stat hubSendProgAdd Stat hubSendProgDel Stat hubSendRepro Stat @@ -73,6 +74,7 @@ func (stats *Stats) all() map[string]uint64 { "filtered coverage": stats.corpusCoverFiltered.get(), "signal": stats.corpusSignal.get(), "max signal": stats.maxSignal.get(), + "rpc traffic (MB)": stats.rpcTraffic.get() / 1e6, } if stats.haveHub { m["hub: send prog add"] = stats.hubSendProgAdd.get() |