Commit2f8cb85

committed

fixup! drain connection async

1 parent149bfb6 commit2f8cb85Copy full SHA for 2f8cb85

File tree

-3

lines changed

-3

lines changed

Lines changed: 0 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -116,17 +116,14 @@ func (r *Runner) Run(ctx context.Context, _ string, logs io.Writer) error {`
`116`	`116`	`ifwErr:=<-wch;wErr!=nil {`
`117`	`117`	`returnxerrors.Errorf("write to pty: %w",wErr)`
`118`	`118`	`}`
`119`		`-drainStart:=time.Now()`
`120`	`119`	`ifrErr:=<-rch;rErr!=nil {`
`121`	`120`	`returnxerrors.Errorf("read from pty: %w",rErr)`
`122`	`121`	`}`
`123`	`122`
`124`	`123`	`duration:=time.Since(start)`
`125`		`-drainDuration:=time.Since(drainStart)`
`126`	`124`
`127`	`125`	`logger.Info(ctx,"results",`
`128`	`126`	`slog.F("duration",duration),`
`129`		`-slog.F("drain",drainDuration),`
`130`	`127`	`slog.F("sent",crw.BytesWritten()),`
`131`	`128`	`slog.F("rcvd",crw.BytesRead()),`
`132`	`129`	`)`

Comments

(0)