MCPcopy Create free account
hub / github.com/Snapchat/KeyDB / waitMany

Method waitMany

deps/concurrentqueue/lightweightsemaphore.h:377–384  ·  view source on GitHub ↗

Acquires at least one, and (greedily) at most max

Source from the content-addressed store, hash-verified

375
376 // Acquires at least one, and (greedily) at most max
377 ssize_t waitMany(ssize_t max, std::int64_t timeout_usecs)
378 {
379 assert(max >= 0);
380 ssize_t result = tryWaitMany(max);
381 if (result == 0 && max > 0)
382 result = waitManyWithPartialSpinning(max, timeout_usecs);
383 return result;
384 }
385
386 ssize_t waitMany(ssize_t max)
387 {

Callers 2

wait_dequeue_bulkMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected