Commit7b39f6b

authored

fix: improves coordination logging (#14556)

1 parent2e6dbd1 commit7b39f6bCopy full SHA for 7b39f6b

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,7 @@ func newConnIO(coordContext context.Context,`
`65`	`65`	`coordCtx:coordContext,`
`66`	`66`	`peerCtx:peerCtx,`
`67`	`67`	`cancel:cancel,`
`68`		`-logger:logger.With(slog.F("name",name)),`
	`68`	`+logger:logger.With(slog.F("name",name),slog.F("peer_id",id)),`
`69`	`69`	`requests:requests,`
`70`	`70`	`responses:responses,`
`71`	`71`	`bindings:bindings,`
`@@ -135,6 +135,7 @@ func (c connIO) handleRequest(req proto.CoordinateRequest) error {`
`135`	`135`	`c.logger.Debug(c.peerCtx,"got request")`
`136`	`136`	`err:=c.auth.Authorize(req)`
`137`	`137`	`iferr!=nil {`
	`138`	`+c.logger.Warn(c.peerCtx,"unauthorized request",slog.Error(err))`
`138`	`139`	`returnxerrors.Errorf("authorize request: %w",err)`
`139`	`140`	`}`
`140`	`141`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -239,6 +239,7 @@ func (c *configMaps) setTunnelDestination(id uuid.UUID) {`
`239`	`239`	`lc=&peerLifecycle{`
`240`	`240`	`peerID:id,`
`241`	`241`	`}`
	`242`	`+c.logger.Debug(context.Background(),"setting peer tunnel destination",slog.F("peer_id",id))`
`242`	`243`	`c.peers[id]=lc`
`243`	`244`	`}`
`244`	`245`	`lc.isDestination=true`

Lines changed: 3 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -162,12 +162,14 @@ func (c *remoteCoordination) respLoop() {`
`162`	`162`	`for {`
`163`	`163`	`resp,err:=c.protocol.Recv()`
`164`	`164`	`iferr!=nil {`
	`165`	`+c.logger.Debug(context.Background(),"failed to read from protocol",slog.Error(err))`
`165`	`166`	`c.sendErr(xerrors.Errorf("read: %w",err))`
`166`	`167`	`return`
`167`	`168`	`}`
`168`	`169`
`169`	`170`	`err=c.coordinatee.UpdatePeers(resp.GetPeerUpdates())`
`170`	`171`	`iferr!=nil {`
	`172`	`+c.logger.Debug(context.Background(),"failed to update peers",slog.Error(err))`
`171`	`173`	`c.sendErr(xerrors.Errorf("update peers: %w",err))`
`172`	`174`	`return`
`173`	`175`	`}`
`@@ -191,6 +193,7 @@ func (c *remoteCoordination) respLoop() {`
`191`	`193`	`ReadyForHandshake:rfh,`
`192`	`194`	`})`
`193`	`195`	`iferr!=nil {`
	`196`	`+c.logger.Debug(context.Background(),"failed to send ready for handshake",slog.Error(err))`
`194`	`197`	`c.sendErr(xerrors.Errorf("send: %w",err))`
`195`	`198`	`return`
`196`	`199`	`}`

Comments

(0)