This repository was archived by the owner on Sep 26, 2023. It is now read-only.
This repository was archived by the owner on Sep 26, 2023. It is now read-only.
FlowController.reserve - deadlock on acquireUninterruptibly() #268
Description
The FlowController:: reserve doesn't take the initial size of the semaphore into account when blocking.
Background: trying to provide limits to the pub/sub subscriber - wanted one-at-a-time. With the size of the semaphore set to 1, pub/sub subscriber code will usually pull back more than one message (could be as many as 1000 if I'm reading the code correctly). Each thread that processes pub/sub messages gets stuck on this call [and will never unblock].