Fix log race

kylecarbs · kylecarbs · commit c484d4704b0a · 2022-02-18T15:01:39.000Z
diff --git a/agent/agent.go b/agent/agent.go
@@ -282,7 +282,7 @@ func (s *server) handlePeerConn(ctx context.Context, conn *peer.Conn) {
 	for {
 		channel, err := conn.Accept(ctx)
 		if err != nil {
-			if s.isClosed() {
+			if errors.Is(err, peer.ErrClosed) || s.isClosed() {
 				return
 			}
 			s.options.Logger.Debug(ctx, "accept channel from peer connection", slog.Error(err))

Original file line number	Diff line number	Diff line change
`@@ -282,7 +282,7 @@ func (s server) handlePeerConn(ctx context.Context, conn peer.Conn) {`
`282`	`282`	`for {`
`283`	`283`	`channel, err := conn.Accept(ctx)`
`284`	`284`	`if err != nil {`
`285`		`- if s.isClosed() {`
	`285`	`+ if errors.Is(err, peer.ErrClosed) \|\| s.isClosed() {`
`286`	`286`	`return`
`287`	`287`	`}`
`288`	`288`	`s.options.Logger.Debug(ctx, "accept channel from peer connection", slog.Error(err))`