Method waitForProcessExit

internal/daemon/orphan.go:57–85

(ctx context.Context, pid int)

}

func (d *Daemon) waitForProcessExit(ctx context.Context, pid int) bool {
	if pid <= 0 {
		return true
	}
	if !d.processAlive(pid) {
		return true
	}
	if d.orphanGraceWait <= 0 || d.orphanPollWait <= 0 {
		return !d.processAlive(pid)
	}

	timer := time.NewTimer(d.orphanGraceWait)
	ticker := time.NewTicker(d.orphanPollWait)
	defer timer.Stop()
	defer ticker.Stop()

	for {
		select {
		case <-ctx.Done():
			return !d.processAlive(pid)
		case <-ticker.C:
			if !d.processAlive(pid) {
				return true
			}
		case <-timer.C:
			return !d.processAlive(pid)
		}
	}
}

func removeStaleSocket(path string) error {
	cleanPath := strings.TrimSpace(path)