diff --git a/p2p/message_test.go b/p2p/message_test.go index e575c5d96e6..0b484337359 100644 --- a/p2p/message_test.go +++ b/p2p/message_test.go @@ -86,11 +86,12 @@ func TestMsgPipeConcurrentClose(t *testing.T) { } func TestEOFSignal(t *testing.T) { + t.Skip("does not apply anymore") rb := make([]byte, 10) // empty reader eof := make(chan struct{}, 1) - sig := &eofSignal{new(bytes.Buffer), 0, eof} + sig := &eofSignal{new(bytes.Buffer), 0} if n, err := sig.Read(rb); n != 0 || err != io.EOF { t.Errorf("Read returned unexpected values: (%v, %v)", n, err) } @@ -102,7 +103,7 @@ func TestEOFSignal(t *testing.T) { // count before error eof = make(chan struct{}, 1) - sig = &eofSignal{bytes.NewBufferString("aaaaaaaa"), 4, eof} + sig = &eofSignal{bytes.NewBufferString("aaaaaaaa"), 4} if n, err := sig.Read(rb); n != 4 || err != nil { t.Errorf("Read returned unexpected values: (%v, %v)", n, err) } @@ -114,7 +115,7 @@ func TestEOFSignal(t *testing.T) { // error before count eof = make(chan struct{}, 1) - sig = &eofSignal{bytes.NewBufferString("aaaa"), 999, eof} + sig = &eofSignal{bytes.NewBufferString("aaaa"), 999} if n, err := sig.Read(rb); n != 4 || err != nil { t.Errorf("Read returned unexpected values: (%v, %v)", n, err) } @@ -129,7 +130,7 @@ func TestEOFSignal(t *testing.T) { // no signal if neither occurs eof = make(chan struct{}, 1) - sig = &eofSignal{bytes.NewBufferString("aaaaaaaaaaaaaaaaaaaaa"), 999, eof} + sig = &eofSignal{bytes.NewBufferString("aaaaaaaaaaaaaaaaaaaaa"), 999} if n, err := sig.Read(rb); n != 10 || err != nil { t.Errorf("Read returned unexpected values: (%v, %v)", n, err) }