| 432 | } |
| 433 | |
| 434 | func bootHarnessReentryBridge(ctx context.Context, state *bootState) (*harnessReentryBridge, error) { |
| 435 | reentrySessions, ok := state.sessions.(harnessReentrySessionManager) |
| 436 | if !ok { |
| 437 | if state != nil && state.logger != nil { |
| 438 | state.logger.Warn( |
| 439 | "daemon: synthetic reentry bridge disabled because session manager support is unavailable", |
| 440 | ) |
| 441 | } |
| 442 | return nil, nil |
| 443 | } |
| 444 | reentryStore, ok := state.registry.(harnessReentryStore) |
| 445 | if !ok { |
| 446 | if state != nil && state.logger != nil { |
| 447 | state.logger.Warn("daemon: synthetic reentry bridge disabled because registry support is unavailable") |
| 448 | } |
| 449 | return nil, nil |
| 450 | } |
| 451 | return newHarnessReentryBridge( |
| 452 | ctx, |
| 453 | state.harnessResolver, |
| 454 | state.harnessRecorder, |
| 455 | reentryStore, |
| 456 | reentrySessions, |
| 457 | state.logger, |
| 458 | withHarnessHeartbeatWake(state.registry, reentrySessions, state.cfg.Agents.Heartbeat), |
| 459 | ) |
| 460 | } |
| 461 | |
| 462 | func (d *Daemon) bootSpawnReaper(ctx context.Context, state *bootState, cleanup *bootCleanup) error { |
| 463 | if state == nil || state.sessions == nil || state.tasks == nil || state.tasks.manager == nil { |