Server.PauseAccept() / Server.ResumeAccept() — accept control

[FumingPower3925]

Problem

The overload middleware's most aggressive stage needs to temporarily stop accepting new connections. The engine.AcceptController interface exists and is implemented by epoll/io_uring engines, but it's not exposed through the public Server API.

Unblocks

• Overload Management middleware (fix: io_uring send queue corruption under concurrent writes #34) — stage 5 (connection shedding)

Change

// server.go
func (s *Server) PauseAccept() error {
    ac, ok := s.engine.(engine.AcceptController)
    if !ok {
        return ErrAcceptControlNotSupported
    }
    return ac.PauseAccept()
}

func (s *Server) ResumeAccept() error {
    ac, ok := s.engine.(engine.AcceptController)
    if !ok {
        return ErrAcceptControlNotSupported
    }
    return ac.ResumeAccept()
}

// errors.go
var ErrAcceptControlNotSupported = errors.New("celeris: engine does not support accept control")

Performance

Pure method forwarding with type assertion. Only called during overload events. Zero cost on hot path.

Files

• server.go
• errors.go