(sessionID string)
| 4020 | } |
| 4021 | |
| 4022 | func (d *integrationDaemon) releaseBlocked(sessionID string) { |
| 4023 | d.mu.Lock() |
| 4024 | driver := d.driver |
| 4025 | manager := d.manager |
| 4026 | d.mu.Unlock() |
| 4027 | if driver == nil { |
| 4028 | return |
| 4029 | } |
| 4030 | target := sessionID |
| 4031 | if manager != nil { |
| 4032 | if info, err := manager.Status( |
| 4033 | context.Background(), |
| 4034 | sessionID, |
| 4035 | ); err == nil && |
| 4036 | strings.TrimSpace(info.ACPSessionID) != "" { |
| 4037 | target = info.ACPSessionID |
| 4038 | } |
| 4039 | } |
| 4040 | driver.releaseBlocked(target) |
| 4041 | } |
| 4042 | |
| 4043 | func (d *integrationDaemon) waitForBlocked(sessionID string, timeout time.Duration) bool { |
| 4044 | d.mu.Lock() |
nothing calls this directly
no test coverage detected