fix nil pointer

drpcorg · Nov 21, 2024 · d42d0ab · d42d0ab
1 parent fb7278c
commit d42d0ab
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/protocol/peer.go b/protocol/peer.go
@@ -88,7 +88,7 @@ func (p *Peer) keepRead(ctx context.Context) error {
 		}
 		p.incomingBuffer.Store(int32(buf.Len()))
 
-		if time.Now().After(*timelimit) || buf.Len() >= p.bufferMinToProcess || buf.Len() >= p.bufferMaxSize {
+		if (timelimit != nil && time.Now().After(*timelimit)) || buf.Len() >= p.bufferMinToProcess || buf.Len() >= p.bufferMaxSize {
 			select {
 			case signal <- struct{}{}:
 				recs, err := Split(&buf)