Commit 9a179405 authored by Ralph Pichler's avatar Ralph Pichler Committed by GitHub

fix broken retrieval test to implement EachPeerRev instead of EachPeer (#438)

parent c691981e
...@@ -73,7 +73,7 @@ func TestDelivery(t *testing.T) { ...@@ -73,7 +73,7 @@ func TestDelivery(t *testing.T) {
defer cancel() defer cancel()
v, err := client.RetrieveChunk(ctx, reqAddr) v, err := client.RetrieveChunk(ctx, reqAddr)
if err != nil { if err != nil {
return t.Fatal(err)
} }
if !bytes.Equal(v, reqData) { if !bytes.Equal(v, reqData) {
t.Fatalf("request and response data not equal. got %s want %s", v, reqData) t.Fatalf("request and response data not equal. got %s want %s", v, reqData)
...@@ -126,9 +126,9 @@ type mockPeerSuggester struct { ...@@ -126,9 +126,9 @@ type mockPeerSuggester struct {
eachPeerRevFunc func(f topology.EachPeerFunc) error eachPeerRevFunc func(f topology.EachPeerFunc) error
} }
func (s mockPeerSuggester) EachPeer(f topology.EachPeerFunc) error { func (s mockPeerSuggester) EachPeer(topology.EachPeerFunc) error {
return s.eachPeerRevFunc(f)
}
func (s mockPeerSuggester) EachPeerRev(topology.EachPeerFunc) error {
return errors.New("not implemented") return errors.New("not implemented")
} }
func (s mockPeerSuggester) EachPeerRev(f topology.EachPeerFunc) error {
return s.eachPeerRevFunc(f)
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment