Commit968526d

committed

Remove unused fn

🤦

1 parent57f464a commit968526dCopy full SHA for 968526d

File tree

-4

lines changed

-4

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -132,7 +132,7 @@ func (rpty *bufferedReconnectingPTY) lifecycle(ctx context.Context, logger slog.`
`132`	`132`	`logger.Debug(ctx,"reconnecting pty ready")`
`133`	`133`	`rpty.state.setState(StateReady,nil)`
`134`	`134`
`135`		`-state,reasonErr:=rpty.state.waitForStateOrContext(ctx,StateClosing,nil)`
	`135`	`+state,reasonErr:=rpty.state.waitForStateOrContext(ctx,StateClosing)`
`136`	`136`	`ifstate<StateClosing {`
`137`	`137`	`// If we have not closed yet then the context is what unblocked us (which`
`138`	`138`	`// means the agent is shutting down) so move into the closing phase.`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -168,7 +168,7 @@ func (s *ptyState) waitForState(state State) (State, error) {`
`168`	`168`
`169`	`169`	`// waitForStateOrContext blocks until the state or a greater one is reached or`
`170`	`170`	`// the provided context ends.`
`171`		`-func (s*ptyState)waitForStateOrContext(ctx context.Context,stateState,fnfunc(stateState)error) (State,error) {`
	`171`	`+func (s*ptyState)waitForStateOrContext(ctx context.Context,stateState) (State,error) {`
`172`	`172`	`s.cond.L.Lock()`
`173`	`173`	`defers.cond.L.Unlock()`
`174`	`174`	`returns.waitForStateOrContextLocked(ctx,state)`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -130,7 +130,7 @@ func (rpty *screenReconnectingPTY) lifecycle(ctx context.Context, logger slog.Lo`
`130`	`130`	`logger.Debug(ctx,"reconnecting pty ready")`
`131`	`131`	`rpty.state.setState(StateReady,nil)`
`132`	`132`
`133`		`-state,reasonErr:=rpty.state.waitForStateOrContext(ctx,StateClosing,nil)`
	`133`	`+state,reasonErr:=rpty.state.waitForStateOrContext(ctx,StateClosing)`
`134`	`134`	`ifstate<StateClosing {`
`135`	`135`	`// If we have not closed yet then the context is what unblocked us (which`
`136`	`136`	`// means the agent is shutting down) so move into the closing phase.`
`@@ -155,7 +155,7 @@ func (rpty *screenReconnectingPTY) Attach(ctx context.Context, _ string, conn ne`
`155`	`155`	`ctx,cancel:=context.WithCancel(ctx)`
`156`	`156`	`defercancel()`
`157`	`157`
`158`		`-state,err:=rpty.state.waitForStateOrContext(ctx,StateReady,nil)`
	`158`	`+state,err:=rpty.state.waitForStateOrContext(ctx,StateReady)`
`159`	`159`	`ifstate!=StateReady {`
`160`	`160`	`returnxerrors.Errorf("reconnecting pty ready wait: %w",err)`
`161`	`161`	`}`

Comments

(0)