Home
last modified time | relevance | path

Searched refs:worker_interface (Results 1 – 12 of 12) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-currentthread.hpp28 std::shared_ptr<worker_interface> w;
51 static const std::shared_ptr<worker_interface>& get_worker_interface() { in get_worker_interface()
92 static std::shared_ptr<worker_interface> ensure(std::shared_ptr<worker_interface> w) { in ensure()
101 static std::unique_ptr<current_thread_queue_type> create(std::shared_ptr<worker_interface> w) { in create()
139 struct derecurser : public worker_interface
165 struct current_worker : public worker_interface
Drx-runloop.hpp50 struct run_loop_worker : public worker_interface
113 std::shared_ptr<worker_interface> create_worker_interface() const { in create_worker_interface()
Drx-immediate.hpp20 struct immediate_worker : public worker_interface
Drx-eventloop.hpp20 struct loop_worker : public worker_interface
Drx-newthread.hpp22 struct new_worker : public worker_interface
Drx-test.hpp61 struct test_type_worker : public worker_interface
416 : worker(cs, std::static_pointer_cast<worker_interface>(t)) in test_worker()
/external/tensorflow/tensorflow/core/distributed_runtime/
DBUILD41 ":worker_interface",
98 ":worker_interface",
178 name = "worker_interface",
180 "worker_interface.h",
203 ":worker_interface",
265 ":worker_interface",
287 ":worker_interface",
317 ":worker_interface",
339 ":worker_interface",
395 ":worker_interface",
[all …]
/external/webp/src/enc/
Danalysis_enc.c497 const WebPWorkerInterface* const worker_interface = in VP8EncAnalyze() local
508 ok &= worker_interface->Reset(&side_job.worker); in VP8EncAnalyze()
511 worker_interface->Launch(&side_job.worker); in VP8EncAnalyze()
512 worker_interface->Execute(&main_job.worker); in VP8EncAnalyze()
513 ok &= worker_interface->Sync(&side_job.worker); in VP8EncAnalyze()
514 ok &= worker_interface->Sync(&main_job.worker); in VP8EncAnalyze()
516 worker_interface->End(&side_job.worker); in VP8EncAnalyze()
521 worker_interface->Execute(&main_job.worker); in VP8EncAnalyze()
522 ok &= worker_interface->Sync(&main_job.worker); in VP8EncAnalyze()
524 worker_interface->End(&main_job.worker); in VP8EncAnalyze()
Dvp8l_enc.c1693 const WebPWorkerInterface* const worker_interface = WebPGetWorkerInterface(); in VP8LEncodeStream() local
1760 worker_interface->Init(worker); in VP8LEncodeStream()
1769 if (!worker_interface->Reset(&worker_side)) { in VP8LEncodeStream()
1782 worker_interface->Launch(&worker_side); in VP8LEncodeStream()
1785 worker_interface->Execute(&worker_main); in VP8LEncodeStream()
1786 ok_main = worker_interface->Sync(&worker_main); in VP8LEncodeStream()
1787 worker_interface->End(&worker_main); in VP8LEncodeStream()
1790 const int ok_side = worker_interface->Sync(&worker_side); in VP8LEncodeStream()
1791 worker_interface->End(&worker_side); in VP8LEncodeStream()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-scheduler.hpp14 class worker_interface;
22 typedef std::shared_ptr<worker_interface> worker_interface_ptr;
23 typedef std::shared_ptr<const worker_interface> const_worker_interface_ptr;
25 typedef std::weak_ptr<worker_interface> worker_interface_weak_ptr;
26 typedef std::weak_ptr<const worker_interface> const_worker_interface_weak_ptr;
163 class worker_interface class
164 : public std::enable_shared_from_this<worker_interface>
166 typedef worker_interface this_type;
171 virtual ~worker_interface() {} in ~worker_interface()
215 : inner(std::const_pointer_cast<worker_interface>(i)) in worker()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
DBUILD95 "//tensorflow/core/distributed_runtime:worker_interface",
159 "//tensorflow/core/distributed_runtime:worker_interface",
271 "//tensorflow/core/distributed_runtime:worker_interface",
/external/tensorflow/tensorflow/contrib/gdr/
DBUILD93 "//tensorflow/core/distributed_runtime:worker_interface",