Searched refs:SafeBlockingQueue (Results 1 – 3 of 3) sorted by relevance
377 SafeBlockingQueue* pBlockingQueue = reinterpret_cast<SafeBlockingQueue*>(this_); in nnosSafeBlockingQueueInitialize()378 new (pBlockingQueue) SafeBlockingQueue(); in nnosSafeBlockingQueueInitialize()384 SafeBlockingQueue* pBlockingQueue = reinterpret_cast<SafeBlockingQueue*>(this_); in nnosSafeBlockingQueueTryInitialize()385 new (pBlockingQueue) SafeBlockingQueue(); in nnosSafeBlockingQueueTryInitialize()392 SafeBlockingQueue* pBlockingQueue = reinterpret_cast<SafeBlockingQueue*>(this_); in nnosSafeBlockingQueueFinalize()394 pBlockingQueue->~SafeBlockingQueue(); in nnosSafeBlockingQueueFinalize()399 SafeBlockingQueue* pBlockingQueue = reinterpret_cast<SafeBlockingQueue*>(this_); in nnosSafeBlockingQueueTryEnqueue()405 SafeBlockingQueue* pBlockingQueue = reinterpret_cast<SafeBlockingQueue*>(this_); in nnosSafeBlockingQueueEnqueue()411 SafeBlockingQueue* pBlockingQueue = reinterpret_cast<SafeBlockingQueue*>(this_); in nnosSafeBlockingQueueTryJam()417 SafeBlockingQueue* pBlockingQueue = reinterpret_cast<SafeBlockingQueue*>(this_); in nnosSafeBlockingQueueJam()[all …]
26 typedef SafeBlockingQueue InterCoreSafeBlockingQueue;
313 class SafeBlockingQueue : private os::detail::BlockingQueueBase<nn::os::Mutex>324 SafeBlockingQueue() {} in SafeBlockingQueue() function334 SafeBlockingQueue(uptr buffer[], size_t size) : Base(buffer, size) {} in SafeBlockingQueue() function341 ~SafeBlockingQueue() {} in ~SafeBlockingQueue()600 NN_UTIL_DETAIL_CLIBIMPL_DEFINE_BUFFER_CLASS(nnosSafeBlockingQueue, nn::os::SafeBlockingQueue, 44, u…