Add well-known reply timeout error

core/channel.go

@@ -337,7 +337,7 @@ func (ch *Channel) receiveReplyInternal(msg api.Message, expSeqNum uint16) (last
 				"expSeqNum": expSeqNum,
 				"channel":   ch.id,
 			}).Debugf("timeout (%v) waiting for reply: %s", timeout, msg.GetMessageName())
-			err = fmt.Errorf("no reply received within the timeout period %s", timeout)
+			err = fmt.Errorf("%w %s", ErrReplyTimeout, timeout)
 			return false, err
 		}
 	}

core/connection_test.go

@@ -15,6 +15,7 @@
 package core_test
 
 import (
+	"errors"
 	"fmt"
 	"math"
 	"testing"
@@ -341,6 +342,7 @@ func TestSimpleRequestWithTimeout(t *testing.T) {
 	err := reqCtx1.ReceiveReply(reply)
 	Expect(err).ToNot(BeNil())
 	Expect(err.Error()).To(HavePrefix("no reply received within the timeout period"))
+	Expect(errors.Is(err, core.ErrReplyTimeout)).To(Equal(true))
 
 	ctx.mockVpp.MockReplyWithContext(
 		// reply for the previous request
@@ -492,6 +494,7 @@ func TestRequestsOrdering(t *testing.T) {
 	err = reqCtx1.ReceiveReply(reply1)
 	Expect(err).ToNot(BeNil())
 	Expect(err.Error()).To(HavePrefix("no reply received within the timeout period"))
+	Expect(errors.Is(err, core.ErrReplyTimeout)).To(Equal(true))
 }
 
 func TestCycleOverSetOfSequenceNumbers(t *testing.T) {

core/request_handler.go

@@ -31,6 +31,7 @@ var ReplyChannelTimeout = time.Millisecond * 100
 var (
 	ErrNotConnected = errors.New("not connected to VPP, ignoring the request")
 	ErrProbeTimeout = errors.New("probe reply not received within timeout period")
+	ErrReplyTimeout = errors.New("no reply received within the timeout period")
 )
 
 // watchRequests watches for requests on the request API channel and forwards them as messages to VPP.

core/stream.go

@@ -263,7 +263,7 @@ func (s *Stream) recvReply() (*vppReply, error) {
 		}
 		return reply, nil
 	case <-timeoutTimer.C:
-		err := fmt.Errorf("no reply received within the timeout period %s", timeout)
+		err := fmt.Errorf("%w %s", ErrReplyTimeout, timeout)
 		return nil, err
 	case <-s.ctx.Done():
 		return nil, s.ctx.Err()

core/stream_test.go

@@ -2,6 +2,7 @@ package core
 
 import (
 	"context"
+	"errors"
 	"testing"
 	"time"
 
@@ -60,4 +61,5 @@ func TestStreamReply(t *testing.T) {
 	_, err = ctx.stream.RecvMsg()
 	Expect(err).Should(HaveOccurred())
 	Expect(err.Error()).To(HavePrefix("no reply received within the timeout period"))
+	Expect(errors.Is(err, ErrReplyTimeout)).To(Equal(true))
 }