Method blockWithDeadlineFromSampledClock

pkg/sentry/kernel/task_block.go:121–140

(C <-chan struct{}, clock ktime.SampledClock, deadline ktime.Time)

}

func (t *Task) blockWithDeadlineFromSampledClock(C <-chan struct{}, clock ktime.SampledClock, deadline ktime.Time) error {
	// Start the timeout timer.
	t.blockingTimer.SetClock(clock, ktime.Setting{
		Enabled: true,
		Next:    deadline,
	})

	err := t.block(C, t.blockingTimerChan)

	// Stop the timeout timer and drain the channel. If s.Enabled is true, the
	// timer didn't fire yet, so t.blockingTimerChan must be empty.
	if _, s := t.blockingTimer.Set(ktime.Setting{}, nil); !s.Enabled {
		select {
		case <-t.blockingTimerChan:
		default:
		}
	}

	return err
}

// Block implements context.Context.Block
//