Skip to content
Snippets Groups Projects
  • Florian Fischer's avatar
    1aadf7fe
    [PipeSleepStrategy] implement notifySpecific · 1aadf7fe
    Florian Fischer authored
    Implement notifySpecific by using a worker exclusive thread local
    sleepState and pipe.
    The sleepState previously waitInflight is no longer a member of IoContext
    a thread_local PipeSleepStrategy::SleepState is used instead.
    It is safe to use a thread_local object because onNewWorkNotification
    is only called by the Owner of the sleepState.
    Since others (ANYWHERE, EMPER) must not reap newWorkNotifications from
    a workers CQ.
    
    Update the algorithm documentation and other code comments.
    1aadf7fe
    History
    [PipeSleepStrategy] implement notifySpecific
    Florian Fischer authored
    Implement notifySpecific by using a worker exclusive thread local
    sleepState and pipe.
    The sleepState previously waitInflight is no longer a member of IoContext
    a thread_local PipeSleepStrategy::SleepState is used instead.
    It is safe to use a thread_local object because onNewWorkNotification
    is only called by the Owner of the sleepState.
    Since others (ANYWHERE, EMPER) must not reap newWorkNotifications from
    a workers CQ.
    
    Update the algorithm documentation and other code comments.