From 8f4a3810a6910e8f3b4f59980b522e20c1781d09 Mon Sep 17 00:00:00 2001 From: Colin Adler Date: Thu, 20 Jul 2023 19:39:32 +0000 Subject: [PATCH] test: ignore more spurious pgcoord errors --- enterprise/tailnet/pgcoord.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/enterprise/tailnet/pgcoord.go b/enterprise/tailnet/pgcoord.go index 7add7bb135c9e..e73c3e29bf56e 100644 --- a/enterprise/tailnet/pgcoord.go +++ b/enterprise/tailnet/pgcoord.go @@ -14,6 +14,7 @@ import ( "github.com/cenkalti/backoff/v4" "github.com/google/uuid" "golang.org/x/xerrors" + "nhooyr.io/websocket" "cdr.dev/slog" @@ -262,7 +263,11 @@ func (c *connIO) recvLoop() { var node agpl.Node err := c.decoder.Decode(&node) if err != nil { - if xerrors.Is(err, io.EOF) || xerrors.Is(err, io.ErrClosedPipe) || xerrors.Is(err, context.Canceled) { + if xerrors.Is(err, io.EOF) || + xerrors.Is(err, io.ErrClosedPipe) || + xerrors.Is(err, context.Canceled) || + xerrors.Is(err, context.DeadlineExceeded) || + websocket.CloseStatus(err) > 0 { c.logger.Debug(c.ctx, "exiting recvLoop", slog.Error(err)) } else { c.logger.Error(c.ctx, "failed to decode Node update", slog.Error(err))