Commit1cb39fc

authored

test: ignore more spurious pgcoord errors (#8628)

1 parent71d4e4e commit1cb39fcCopy full SHA for 1cb39fc

File tree

-1

lines changed

-1

lines changed

Lines changed: 6 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -14,6 +14,7 @@ import (`
`14`	`14`	`"github.com/cenkalti/backoff/v4"`
`15`	`15`	`"github.com/google/uuid"`
`16`	`16`	`"golang.org/x/xerrors"`
	`17`	`+"nhooyr.io/websocket"`
`17`	`18`
`18`	`19`	`"cdr.dev/slog"`
`19`	`20`
`@@ -262,7 +263,11 @@ func (c *connIO) recvLoop() {`
`262`	`263`	`varnode agpl.Node`
`263`	`264`	`err:=c.decoder.Decode(&node)`
`264`	`265`	`iferr!=nil {`
`265`		`-ifxerrors.Is(err,io.EOF)\|\|xerrors.Is(err,io.ErrClosedPipe)\|\|xerrors.Is(err,context.Canceled) {`
	`266`	`+ifxerrors.Is(err,io.EOF)\|\|`
	`267`	`+xerrors.Is(err,io.ErrClosedPipe)\|\|`
	`268`	`+xerrors.Is(err,context.Canceled)\|\|`
	`269`	`+xerrors.Is(err,context.DeadlineExceeded)\|\|`
	`270`	`+websocket.CloseStatus(err)>0 {`
`266`	`271`	`c.logger.Debug(c.ctx,"exiting recvLoop",slog.Error(err))`
`267`	`272`	`}else {`
`268`	`273`	`c.logger.Error(c.ctx,"failed to decode Node update",slog.Error(err))`

Comments

(0)