Method waitEventT

pkg/sentry/socket/plugin/stack/socket.go:837–849

waitEventT implements blocking wait on given events until one of the events have been reported or timeout based on given deadline.

(ctx context.Context, event waiter.EventMask, deadline ktime.Time)

// waitEventT implements blocking wait on given events
// until one of the events have been reported or timeout based on given deadline.
func (s *socketOperations) waitEventT(ctx context.Context, event waiter.EventMask, deadline ktime.Time) error {
	var err error
	t := ctx.(*kernel.Task)
	e, ch := waiter.NewChannelEntry(event | waiter.EventErr | waiter.EventHUp)
	s.EventRegister(&e)

	if s.Readiness(event|waiter.EventErr|waiter.EventHUp) == 0 {
		err = t.BlockWithDeadline(ch, true, deadline)
	}

	s.EventUnregister(&e)
	return err
}