()
| 1775 | } |
| 1776 | |
| 1777 | func (r *basePoolManager) Wait() error { |
| 1778 | done := make(chan struct{}) |
| 1779 | timer := time.NewTimer(60 * time.Second) |
| 1780 | go func() { |
| 1781 | r.wg.Wait() |
| 1782 | timer.Stop() |
| 1783 | close(done) |
| 1784 | }() |
| 1785 | select { |
| 1786 | case <-done: |
| 1787 | case <-timer.C: |
| 1788 | return runnerErrors.NewTimeoutError("waiting for pool to stop") |
| 1789 | } |
| 1790 | return nil |
| 1791 | } |
| 1792 | |
| 1793 | func (r *basePoolManager) runnerCleanup() (err error) { |
| 1794 | slog.DebugContext( |