zishuo/go-libp2p
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p.git synced 2026-04-22 16:17:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(mocknet): make stream deadline methods noop instead of returning error (#3471)

Browse Source
This commit is contained in:
Vlad
2026-03-05 20:20:04 +03:00
committed by GitHub
parent 7198ad347f
commit 67f4f585fb
1 changed files with 6 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
p2p/net/mock/mock_stream.go
+6 -12
View File
@@ -4,7 +4,6 @@ import (
"bytes"
"errors"
"io"
"net"
"strconv"
"sync/atomic"
"time"
@@ -174,17 +173,12 @@ func (s *stream) Conn() network.Conn {
return s.conn
}
func (s *stream) SetDeadline(_ time.Time) error {
return &net.OpError{Op: "set", Net: "pipe", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
}
func (s *stream) SetReadDeadline(_ time.Time) error {
return &net.OpError{Op: "set", Net: "pipe", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
}
func (s *stream) SetWriteDeadline(_ time.Time) error {
return &net.OpError{Op: "set", Net: "pipe", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
}
// SetDeadline is a noop for mocknet streams since the underlying pipe
// transport does not support deadlines. Callers should not treat the
// absence of deadline support as an error.
func (s *stream) SetDeadline(_ time.Time) error { return nil }
func (s *stream) SetReadDeadline(_ time.Time) error { return nil }
func (s *stream) SetWriteDeadline(_ time.Time) error { return nil }
func (s *stream) Read(b []byte) (int, error) {
return s.read.Read(b)