Home
last modified time | relevance | path

Searched refs:worker_interface (Results 1 – 13 of 13) 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/webp/src/enc/
Danalysis_enc.c437 const WebPWorkerInterface* const worker_interface = in VP8EncAnalyze() local
448 ok &= worker_interface->Reset(&side_job.worker); in VP8EncAnalyze()
451 worker_interface->Launch(&side_job.worker); in VP8EncAnalyze()
452 worker_interface->Execute(&main_job.worker); in VP8EncAnalyze()
453 ok &= worker_interface->Sync(&side_job.worker); in VP8EncAnalyze()
454 ok &= worker_interface->Sync(&main_job.worker); in VP8EncAnalyze()
456 worker_interface->End(&side_job.worker); in VP8EncAnalyze()
461 worker_interface->Execute(&main_job.worker); in VP8EncAnalyze()
462 ok &= worker_interface->Sync(&main_job.worker); in VP8EncAnalyze()
464 worker_interface->End(&main_job.worker); in VP8EncAnalyze()
Dvp8l_enc.c1706 const WebPWorkerInterface* const worker_interface = WebPGetWorkerInterface(); in VP8LEncodeStream() local
1773 worker_interface->Init(worker); in VP8LEncodeStream()
1782 if (!worker_interface->Reset(&worker_side)) { in VP8LEncodeStream()
1795 worker_interface->Launch(&worker_side); in VP8LEncodeStream()
1798 worker_interface->Execute(&worker_main); in VP8LEncodeStream()
1799 ok_main = worker_interface->Sync(&worker_main); in VP8LEncodeStream()
1800 worker_interface->End(&worker_main); in VP8LEncodeStream()
1803 const int ok_side = worker_interface->Sync(&worker_side); in VP8LEncodeStream()
1804 worker_interface->End(&worker_side); in VP8LEncodeStream()
/external/tensorflow/tensorflow/core/distributed_runtime/
DBUILD45 ":worker_interface",
101 ":worker_interface",
189 name = "worker_interface",
191 "worker_interface.h",
215 ":worker_interface",
278 ":worker_interface",
297 ":worker_interface",
328 ":worker_interface",
351 ":worker_interface",
407 ":worker_interface",
[all …]
/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/
DBUILD100 "//tensorflow/core/distributed_runtime:worker_interface",
168 "//tensorflow/core/distributed_runtime:worker_interface",
304 "//tensorflow/core/distributed_runtime:worker_interface",
/external/tensorflow/tensorflow/core/common_runtime/eager/
DBUILD214 "//tensorflow/core/distributed_runtime:worker_interface",
/external/tensorflow/tensorflow/c/eager/
DBUILD105 "//tensorflow/core/distributed_runtime:worker_interface",