Home
last modified time | relevance | path

Searched refs:work_queue_ (Results 1 – 25 of 40) sorted by relevance

12

/external/cronet/stable/base/task/sequence_manager/
Dwork_queue_unittest.cc58 work_queue_ = in SetUp()
63 work_queue_sets_->AddQueue(work_queue_.get(), 0); in SetUp()
67 work_queue_sets_->RemoveQueue(work_queue_.get()); in TearDown()
120 std::unique_ptr<WorkQueue> work_queue_; member in base::sequence_manager::internal::WorkQueueTest
134 EXPECT_TRUE(work_queue_->Empty()); in TEST_F()
135 work_queue_->Push(FakeTaskWithEnqueueOrder(1)); in TEST_F()
136 EXPECT_FALSE(work_queue_->Empty()); in TEST_F()
140 work_queue_->Push(FakeTaskWithEnqueueOrder(1)); in TEST_F()
141 work_queue_->InsertFence(Fence::BlockingFence()); in TEST_F()
142 EXPECT_FALSE(work_queue_->Empty()); in TEST_F()
[all …]
Dwork_queue.cc98 : work_queue_(work_queue), was_empty_(work_queue->Empty()) {} in TaskPusher()
101 : work_queue_(other.work_queue_), was_empty_(other.was_empty_) { in TaskPusher()
102 other.work_queue_ = nullptr; in TaskPusher()
106 DCHECK(work_queue_); in Push()
113 DCHECK(work_queue_->tasks_.empty() || in Push()
114 work_queue_->tasks_.back().task_order() < task.task_order()); in Push()
117 DCHECK(work_queue_->tasks_.empty() || in Push()
118 work_queue_->tasks_.back().enqueue_order() < task.enqueue_order() || in Push()
119 (work_queue_->queue_type_ == QueueType::kDelayed && in Push()
120 work_queue_->tasks_.back().enqueue_order() == task.enqueue_order())); in Push()
[all …]
/external/cronet/tot/base/task/sequence_manager/
Dwork_queue_unittest.cc58 work_queue_ = in SetUp()
63 work_queue_sets_->AddQueue(work_queue_.get(), 0); in SetUp()
67 work_queue_sets_->RemoveQueue(work_queue_.get()); in TearDown()
120 std::unique_ptr<WorkQueue> work_queue_; member in base::sequence_manager::internal::WorkQueueTest
134 EXPECT_TRUE(work_queue_->Empty()); in TEST_F()
135 work_queue_->Push(FakeTaskWithEnqueueOrder(1)); in TEST_F()
136 EXPECT_FALSE(work_queue_->Empty()); in TEST_F()
140 work_queue_->Push(FakeTaskWithEnqueueOrder(1)); in TEST_F()
141 work_queue_->InsertFence(Fence::BlockingFence()); in TEST_F()
142 EXPECT_FALSE(work_queue_->Empty()); in TEST_F()
[all …]
Dwork_queue.cc98 : work_queue_(work_queue), was_empty_(work_queue->Empty()) {} in TaskPusher()
101 : work_queue_(other.work_queue_), was_empty_(other.was_empty_) { in TaskPusher()
102 other.work_queue_ = nullptr; in TaskPusher()
106 DCHECK(work_queue_); in Push()
113 DCHECK(work_queue_->tasks_.empty() || in Push()
114 work_queue_->tasks_.back().task_order() < task.task_order()); in Push()
117 DCHECK(work_queue_->tasks_.empty() || in Push()
118 work_queue_->tasks_.back().enqueue_order() < task.enqueue_order() || in Push()
119 (work_queue_->queue_type_ == QueueType::kDelayed && in Push()
120 work_queue_->tasks_.back().enqueue_order() == task.enqueue_order())); in Push()
[all …]
/external/libchrome/base/task/sequence_manager/
Dwork_queue_unittest.cc41 work_queue_.reset(new WorkQueue(task_queue_.get(), "test", in SetUp()
44 work_queue_sets_->AddQueue(work_queue_.get(), 0); in SetUp()
47 void TearDown() override { work_queue_sets_->RemoveQueue(work_queue_.get()); } in TearDown()
78 std::unique_ptr<WorkQueue> work_queue_; member in base::sequence_manager::internal::WorkQueueTest
84 EXPECT_TRUE(work_queue_->Empty()); in TEST_F()
85 work_queue_->Push(FakeTaskWithEnqueueOrder(1)); in TEST_F()
86 EXPECT_FALSE(work_queue_->Empty()); in TEST_F()
90 work_queue_->Push(FakeTaskWithEnqueueOrder(1)); in TEST_F()
91 work_queue_->InsertFence(EnqueueOrder::blocking_fence()); in TEST_F()
92 EXPECT_FALSE(work_queue_->Empty()); in TEST_F()
[all …]
/external/tensorflow/tensorflow/core/tfrt/runtime/
Dwork_queue_interface.cc29 : id_(id), work_queue_(work_queue) {} in DefaultWorkQueueWrapperBase()
34 std::string name() const override { return work_queue_->name(); } in name()
37 work_queue_->AddTask(WrapWork(id_, "inter", std::move(work))); in AddTask()
42 return work_queue_->AddBlockingTask( in AddBlockingTask()
48 work_queue_->Await(values); in Await()
51 void Quiesce() override { work_queue_->Quiesce(); } in Quiesce()
54 return work_queue_->GetParallelismLevel(); in GetParallelismLevel()
58 return work_queue_->IsInWorkerThread(); in IsInWorkerThread()
63 tfrt::ConcurrentWorkQueue* work_queue_ = nullptr; member in tensorflow::tfrt_stub::__anon577898500111::DefaultWorkQueueWrapperBase
71 work_queue_(std::move(work_queue)) {} in DefaultWorkQueueWrapper()
[all …]
Druntime.h64 WorkQueueInterface* work_queue() const { return work_queue_; } in work_queue()
96 WorkQueueInterface* work_queue_ = nullptr; variable
Druntime.cc160 : core_runtime_(std::move(core_runtime)), work_queue_(work_queue) { in Runtime()
161 DCHECK(work_queue_); in Runtime()
/external/grpc-grpc/test/core/event_engine/work_queue/
Dbasic_work_queue_fuzzer.cc46 work_queue_.Add(CreateClosure(action.add().key())); in Run()
49 work_queue_.Add(CreateInvocable(action.add().key())); in Run()
55 auto* wq_c = work_queue_.PopMostRecent(); in Run()
57 if (!work_queue_.Empty() || !deque_.empty()) abort(); in Run()
67 auto* wq_c = work_queue_.PopOldest(); in Run()
69 if (!work_queue_.Empty() || !deque_.empty()) abort(); in Run()
78 if (work_queue_.Empty() != deque_.empty()) abort(); in Run()
115 while (auto* wq_c = work_queue_.PopOldest()) { in CheckEqual()
124 BasicWorkQueue work_queue_; member in grpc_event_engine::experimental::WorkQueueFuzzer
/external/tensorflow/tensorflow/tsl/platform/default/
Dunbounded_work_queue.cc36 if (!work_queue_.empty()) { in ~UnboundedWorkQueue()
59 work_queue_.push_back(std::move(fn)); in Schedule()
63 if (work_queue_.size() > num_idle_threads_) { in Schedule()
86 while (!cancelled_ && work_queue_.empty()) { in PooledThreadFunc()
94 fn = std::move(work_queue_.front()); in PooledThreadFunc()
95 work_queue_.pop_front(); in PooledThreadFunc()
/external/tensorflow/tensorflow/compiler/xla/pjrt/
Dworker_thread.cc27 work_queue_.push(nullptr); in ~WorkerThread()
33 work_queue_.push(std::move(fn)); in Schedule()
36 bool WorkerThread::WorkAvailable() { return !work_queue_.empty(); } in WorkAvailable()
44 fn = std::move(work_queue_.front()); in WorkLoop()
45 work_queue_.pop(); in WorkLoop()
Dworker_thread.h47 std::queue<std::function<void()>> work_queue_ ABSL_GUARDED_BY(mu_);
/external/tensorflow/tensorflow/core/kernels/batching_util/
Dbounded_executor.cc59 work_queue_.push_back(nullptr); in ~BoundedExecutor()
72 work_queue_.push_back(std::move(func)); in Schedule()
87 while (work_queue_.empty()) { in Run()
91 func = std::move(work_queue_.front()); in Run()
92 work_queue_.pop_front(); in Run()
/external/tensorflow/tensorflow/core/platform/
Dunbounded_work_queue_test.cc29 : work_queue_( in UnboundedWorkQueueTest()
36 work_queue_->Schedule([this, fn]() { in RunMultipleCopiesOfClosure()
52 void ResetQueue() { work_queue_.reset(); } in ResetQueue()
63 std::unique_ptr<UnboundedWorkQueue> work_queue_; member in tensorflow::__anone0e5d6d40111::UnboundedWorkQueueTest
/external/tensorflow/tensorflow/compiler/xla/stream_executor/host/
Dhost_stream.cc45 work_queue_.push(nullptr); in ~HostStream()
61 work_queue_.push(std::move(task)); in EnqueueTaskWithStatus()
65 bool HostStream::WorkAvailable() { return !work_queue_.empty(); } in WorkAvailable()
78 std::swap(queue, work_queue_); in WorkLoop()
/external/pigweed/pw_rpc_transport/public/pw_rpc_transport/
Dtest_loopback_service_registry.h30 Thread(work_queue::test::WorkQueueThreadOptions(), work_queue_); in TestLoopbackTransport()
34 work_queue_.RequestStop(); in ~TestLoopbackTransport()
53 return work_queue_.PushWork([this]() { in Send()
66 work_queue::WorkQueueWithBuffer<1> work_queue_; variable
/external/tensorflow/tensorflow/core/common_runtime/
Dbase_collective_executor.h106 work_queue_(std::move(work_queue)) {} in BaseCollectiveExecutor()
124 work_queue_->Schedule(std::move(closure)); in RunClosure()
143 std::shared_ptr<UnboundedWorkQueue> work_queue_; variable
Dcollective_executor_mgr.cc40 work_queue_(std::make_shared<UnboundedWorkQueue>(Env::Default(), in CollectiveExecutorMgr()
68 return new BaseCollectiveExecutor(this, rma, step_id, dev_mgr_, work_queue_); in Create()
/external/tensorflow/tensorflow/core/distributed_runtime/
Dcollective_rma_distributed.h35 work_queue_(std::move(work_queue)), in CollectiveRemoteAccessDistributed()
58 std::shared_ptr<UnboundedWorkQueue> work_queue_; variable
/external/pigweed/pw_rpc/raw/
Dsynchronous_call_test.cc46 Thread(work_queue::test::WorkQueueThreadOptions(), work_queue_); in SetUp()
50 work_queue_.RequestStop(); in TearDown()
67 EXPECT_TRUE(work_queue_.PushWork([this]() { SendResponse(); }).ok()); in OnSend()
105 work_queue::WorkQueueWithBuffer<1> work_queue_; member in pw::rpc::test::__anon76b04ce70111::RawSynchronousCallTest
/external/pigweed/pw_rpc/nanopb/
Dsynchronous_call_test.cc46 Thread(work_queue::test::WorkQueueThreadOptions(), work_queue_); in SetUp()
50 work_queue_.RequestStop(); in TearDown()
65 EXPECT_TRUE(work_queue_.PushWork([this]() { SendResponse(); }).ok()); in OnSend()
104 work_queue::WorkQueueWithBuffer<1> work_queue_; member in pw::rpc::test::__anonc798101b0111::SynchronousCallTest
/external/pigweed/pw_software_update/public/pw_software_update/
Dbundled_update_service.h44 work_queue_(work_queue),
101 work_queue::WorkQueue& work_queue_ PW_GUARDED_BY(mutex_);
Dbundled_update_service_pwpb.h44 work_queue_(work_queue),
99 work_queue::WorkQueue& work_queue_ PW_GUARDED_BY(mutex_);
/external/pigweed/pw_rpc/pwpb/
Dsynchronous_call_test.cc74 Thread(work_queue::test::WorkQueueThreadOptions(), work_queue_); in SetUp()
78 work_queue_.RequestStop(); in TearDown()
97 EXPECT_TRUE(work_queue_.PushWork([this]() { SendResponse(); }).ok()); in OnSend()
136 work_queue::WorkQueueWithBuffer<1> work_queue_; member in pw::rpc::test::__anon7f104bf60111::SynchronousCallTest
/external/tensorflow/tensorflow/core/nccl/
Dnccl_manager_test.cc76 work_queue_ = new UnboundedWorkQueue(Env::Default(), "nccl_manager_test"); in SetUpTestSuite()
81 ASSERT_NE(work_queue_, nullptr); in SetUp()
101 delete work_queue_; in TearDownTestSuite()
354 this->work_queue_->Schedule(node_fn); in RunMultiNodeAllReduceTest()
413 this->work_queue_->Schedule(std::move(rank_fn)); in RunMultiNodeBroadcastTest()
432 static UnboundedWorkQueue* work_queue_; member in tensorflow::NcclManagerTest
460 UnboundedWorkQueue* NcclManagerTest<Scalar>::work_queue_ = nullptr; member in tensorflow::NcclManagerTest<Scalar>
559 this->work_queue_->Schedule(fn); in TYPED_TEST()
905 this->work_queue_->Schedule( in TYPED_TEST()
945 this->work_queue_->Schedule( in TYPED_TEST()

12