class
Obsctl::Server::ReconnectSignal
- Obsctl::Server::ReconnectSignal
- Reference
- Object
Overview
Internal synchronization primitive for supervisor reconnect sleeps.
Defined in:
obsctl/server/reconnect_signal.crConstructors
Instance Method Summary
- #cancel : Nil
- #latest_request_epoch : UInt64
-
#on_waiter_registered : Proc(Nil) | Nil
Test-only hook invoked while
@lockis held, immediately after a waiter is appended. -
#on_waiter_registered=(on_waiter_registered : Proc(Nil) | Nil)
Test-only hook invoked while
@lockis held, immediately after a waiter is appended. - #request : UInt64
- #wait(delay : Time::Span, handled_request_epoch : UInt64) : WaitResult
- #wake : Nil
Constructor Detail
Instance Method Detail
def on_waiter_registered : Proc(Nil) | Nil
#
Test-only hook invoked while @lock is held, immediately after a waiter
is appended. Callbacks must not block and must not send on an unbuffered
channel because that can deadlock waiter registration.
def on_waiter_registered=(on_waiter_registered : Proc(Nil) | Nil)
#
Test-only hook invoked while @lock is held, immediately after a waiter
is appended. Callbacks must not block and must not send on an unbuffered
channel because that can deadlock waiter registration.