Searched refs:barrier (Results 1 – 11 of 11) sorted by relevance
60 const std::shared_ptr<Barrier>& barrier) { in cacheAsync() argument63 std::lock_guard<std::mutex> lock(barrier->mutex); in cacheAsync()64 barrier->isOpen = true; in cacheAsync()65 barrier->result = BAD_VALUE; in cacheAsync()67 barrier->condition.notify_one(); in cacheAsync()71 QueueEntry entry = {QueueEntry::Operation::Insert, buffer, buffer->getId(), barrier}; in cacheAsync()77 auto barrier = std::make_shared<Barrier>(); in cache() local78 cacheAsync(buffer, barrier); in cache()79 std::lock_guard<std::mutex> lock(barrier->mutex); in cache()80 barrier->condition.wait(barrier->mutex, in cache()[all …]
46 void cacheAsync(const sp<GraphicBuffer>& buffer, const std::shared_ptr<Barrier>& barrier)49 void releaseAsync(uint64_t bufferId, const std::shared_ptr<Barrier>& barrier) EXCLUDES(mMutex);58 std::shared_ptr<Barrier> barrier = nullptr; member
699 auto barrier = std::make_shared<ImageManager::Barrier>(); in cacheExternalTextureBufferForTesting() local700 mImageManager->cacheAsync(buffer, barrier); in cacheExternalTextureBufferForTesting()701 return barrier; in cacheExternalTextureBufferForTesting()749 auto barrier = std::make_shared<ImageManager::Barrier>(); in unbindExternalTextureBufferForTesting() local750 mImageManager->releaseAsync(bufferId, barrier); in unbindExternalTextureBufferForTesting()751 return barrier; in unbindExternalTextureBufferForTesting()
1234 std::shared_ptr<renderengine::gl::ImageManager::Barrier> barrier = in TEST_F() local1236 std::lock_guard<std::mutex> lock(barrier->mutex); in TEST_F()1237 ASSERT_TRUE(barrier->condition.wait_for(barrier->mutex, std::chrono::seconds(5), in TEST_F()1238 [&]() REQUIRES(barrier->mutex) { in TEST_F()1239 return barrier->isOpen; in TEST_F()1242 EXPECT_EQ(NO_ERROR, barrier->result); in TEST_F()1259 std::shared_ptr<renderengine::gl::ImageManager::Barrier> barrier = in TEST_F() local1261 std::lock_guard<std::mutex> lock(barrier->mutex); in TEST_F()1262 ASSERT_TRUE(barrier->condition.wait_for(barrier->mutex, std::chrono::seconds(5), in TEST_F()1263 [&]() REQUIRES(barrier->mutex) { in TEST_F()[all …]
120 final CyclicBarrier barrier = new CyclicBarrier(2); in binderDied_iBinderArg() local133 barrier.await(); in binderDied_iBinderArg()147 barrier.await(10, TimeUnit.SECONDS); in binderDied_iBinderArg()153 barrier.reset(); in binderDied_iBinderArg()156 barrier.await(10, TimeUnit.SECONDS); in binderDied_iBinderArg()
42 connect(R.id.date, ConstraintSet.END, R.id.barrier, ConstraintSet.START) in emptyCutoutConstraints()44 R.id.barrier, in emptyCutoutConstraints()
193 final CyclicBarrier barrier = new CyclicBarrier(numThreads); in testKeyValue_ReadRemoveConcurrency() local207 barrier.await(); in testKeyValue_ReadRemoveConcurrency()213 barrier.await(); in testKeyValue_ReadRemoveConcurrency()219 barrier.await(); in testKeyValue_ReadRemoveConcurrency()
44 optional int32 barrier = 8; field
179 assertThat(getConstraint(R.id.date).layout.endToStart).isEqualTo(R.id.barrier) in <lambda>()183 assertThat(getConstraint(R.id.barrier).layout.mReferenceIds).asList().containsExactly( in <lambda>()187 assertThat(getConstraint(R.id.barrier).layout.mBarrierDirection).isEqualTo(START) in <lambda>()
104 Now that we have no barrier, that could create issues, because at the time we change configuration …131 To solve these issues, we use a scheme involving "barrier transactions". We show how148 are tagged with a barrier, referring to the frame number of the last150 by stalling transactions in the queue until barriers are fulfilled. This barrier
META-INF/ META-INF/MANIFEST.MF org/ org/clearsilver/ org/ ...