(sessionID string, timeout time.Duration)
| 3977 | } |
| 3978 | |
| 3979 | func (d *integrationDriver) waitForBlocked(sessionID string, timeout time.Duration) bool { |
| 3980 | deadline := time.Now().Add(timeout) |
| 3981 | for time.Now().Before(deadline) { |
| 3982 | d.mu.Lock() |
| 3983 | _, ok := d.blocked[sessionID] |
| 3984 | d.mu.Unlock() |
| 3985 | if ok { |
| 3986 | return true |
| 3987 | } |
| 3988 | time.Sleep(10 * time.Millisecond) |
| 3989 | } |
| 3990 | return false |
| 3991 | } |
| 3992 | |
| 3993 | func (d *integrationDriver) Cancel(context.Context, *session.AgentProcess) error { |
| 3994 | return nil |
no test coverage detected