(ctx context.Context)
| 229 | } |
| 230 | |
| 231 | func (y *yamuxPingerCloser) Ping(ctx context.Context) error { |
| 232 | errCh := make(chan error, 1) |
| 233 | go func() { |
| 234 | _, err := y.mux.Ping() |
| 235 | errCh <- err |
| 236 | }() |
| 237 | select { |
| 238 | case <-ctx.Done(): |
| 239 | return ctx.Err() |
| 240 | case err := <-errCh: |
| 241 | return err |
| 242 | } |
| 243 | } |
| 244 | |
| 245 | func (api *API) startAgentYamuxMonitor(ctx context.Context, |
| 246 | workspace database.Workspace, |