(sessionID string)
| 3963 | } |
| 3964 | |
| 3965 | func (d *integrationDriver) releaseBlocked(sessionID string) { |
| 3966 | d.mu.Lock() |
| 3967 | release := d.blocked[sessionID] |
| 3968 | d.mu.Unlock() |
| 3969 | if release == nil { |
| 3970 | return |
| 3971 | } |
| 3972 | select { |
| 3973 | case <-release: |
| 3974 | default: |
| 3975 | close(release) |
| 3976 | } |
| 3977 | } |
| 3978 | |
| 3979 | func (d *integrationDriver) waitForBlocked(sessionID string, timeout time.Duration) bool { |
| 3980 | deadline := time.Now().Add(timeout) |
no outgoing calls
no test coverage detected