trace peer exchange

2e7cdebf · vyzo · 95d3bbfa · 2e7cdebf · 2e7cdebf · 2e7cdebf
Commit 2e7cdebf authored Nov 23, 2019 by vyzo
Expand all Hide whitespace changes
Inline Side-by-side

Showing with 663 additions and 773 deletions

pb/trace.pb.go pb/trace.pb.go +657 -773

pb/trace.proto pb/trace.proto +1 -0

trace.go trace.go +5 -0

No files found.
--- a/pb/trace.pb.go
+++ b/pb/trace.pb.go
--- a/pb/trace.proto
+++ b/pb/trace.proto
@@ -137,6 +137,7 @@ message TraceEvent {

  message ControlPruneMeta {
    optional string topic = 1;
+    repeated bytes peers = 2;
  }
 }


--- a/trace.go
+++ b/trace.go
@@ -246,8 +246,13 @@ func (t *pubsubTracer) traceRPCMeta(rpc *RPC) *pb.TraceEvent_RPCMeta {

 		var prune []*pb.TraceEvent_ControlPruneMeta
 		for _, ctl := range rpc.Control.Prune {
+			peers := make([][]byte, 0, len(ctl.Peers))
+			for _, pi := range ctl.Peers {
+				peers = append(peers, pi.PeerID)
+			}
 			prune = append(prune, &pb.TraceEvent_ControlPruneMeta{
 				Topic: ctl.TopicID,
+				Peers: peers,
 			})
 		}