(b *testing.B, caller *Caller, remote proto.NodeID)
| 31 | ) |
| 32 | |
| 33 | func benchCaller(b *testing.B, caller *Caller, remote proto.NodeID) { |
| 34 | b.ResetTimer() |
| 35 | b.RunParallel(func(pb *testing.PB) { |
| 36 | for pb.Next() { |
| 37 | err := caller.CallNode(remote, "Count.Add", &AddReq{Delta: 1}, &AddResp{}) |
| 38 | if err != nil { |
| 39 | b.Error("call node failed: ", err) |
| 40 | } |
| 41 | } |
| 42 | }) |
| 43 | } |
| 44 | |
| 45 | func benchPCaller(b *testing.B, caller *PersistentCaller) { |
| 46 | b.ResetTimer() |
no test coverage detected