| /external/libxcam/xcore/ |
| D | worker.cpp | 25 Worker::Worker (const char *name, const SmartPtr<Callback> &cb) in Worker() function in XCam::Worker
33 Worker::~Worker () in ~Worker()
39 Worker::set_name (const char *name) in set_name()
54 Worker::set_callback (const SmartPtr<Worker::Callback> &callback) in set_callback()
66 Worker::status_check (const SmartPtr<Worker::Arguments> &args, const XCamReturn error) in status_check()
74 Worker::set_func_obj (const SmartPtr<FuncObj> &obj) in set_func_obj()
84 Worker::work (const SmartPtr<Worker::Arguments> &args) in work()
96 struct UTArguments : Worker::Arguments {
101 class UnitTestWorker: public Worker {
103 UnitTestWorker () : Worker("UnitTestWorker") {} in UnitTestWorker()
[all …]
|
| D | worker.h | 29 class CbClass : public ::XCam::Worker::Callback { \
33 const ::XCam::SmartPtr<::XCam::Worker> &worker, \
34 const ::XCam::SmartPtr<::XCam::Worker::Arguments> &args, \
41 class Worker
59 … const SmartPtr<Worker> &worker, const SmartPtr<Arguments> &args, const XCamReturn error) = 0;
77 explicit Worker (const char *name, const SmartPtr<Callback> &cb = NULL);
80 virtual ~Worker ();
97 XCAM_DEAD_COPY (Worker);
|
| /external/libchrome/ipc/ |
| D | ipc_sync_channel_unittest.cc | 42 class Worker : public Listener, public Sender { class
45 Worker(Channel::Mode mode, in Worker() function in IPC::__anon60820dc30111::Worker
64 Worker(mojo::ScopedMessagePipeHandle channel_handle, Channel::Mode mode) in Worker() function in IPC::__anon60820dc30111::Worker
80 ~Worker() override { in ~Worker()
93 FROM_HERE, base::Bind(&Worker::OnStart, base::Unretained(this))); in Start()
106 base::Bind(&Worker::OnListenerThreadShutdown1, base::Unretained(this), in Shutdown()
210 base::Bind(&Worker::OnIPCThreadShutdown, base::Unretained(this), in OnListenerThreadShutdown1()
220 FROM_HERE, base::Bind(&Worker::OnListenerThreadShutdown2, in OnIPCThreadShutdown()
230 IPC_BEGIN_MESSAGE_MAP(Worker, message) in OnMessageReceived()
259 DISALLOW_COPY_AND_ASSIGN(Worker);
[all …]
|
| /external/caliper/caliper/src/main/java/com/google/caliper/worker/ |
| D | WorkerModule.java | 46 private final Class<? extends Worker> workerClass;
52 this.workerClass = workerSpec.workerClass.asSubclass(Worker.class); in WorkerModule()
65 Worker provideWorker(Map<Class<? extends Worker>, Provider<Worker>> availableWorkers) { in provideWorker() argument
66 Provider<Worker> workerProvider = availableWorkers.get(workerClass); in provideWorker()
80 Class<? extends Worker> value(); in value()
85 static Worker provideArbitraryMeasurementWorker(ArbitraryMeasurementWorker impl) { in provideArbitraryMeasurementWorker()
91 static Worker provideMicrobenchmarkAllocationWorker(MicrobenchmarkAllocationWorker impl) { in provideMicrobenchmarkAllocationWorker()
97 static Worker provideMacrobenchmarkWorker(MacrobenchmarkWorker impl) { in provideMacrobenchmarkWorker()
103 static Worker provideMacrobenchmarkAllocationWorker(MacrobenchmarkAllocationWorker impl) { in provideMacrobenchmarkAllocationWorker()
109 static Worker provideRuntimeWorkerMicro(RuntimeWorker.Micro impl) { in provideRuntimeWorkerMicro()
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | worker.cc | 23 Worker::Worker() : worker_thread_(NULL) {} in Worker() function in rtc::Worker
25 Worker::~Worker() { in ~Worker()
32 bool Worker::StartWork() { in StartWork()
49 bool Worker::StopWork() { in StopWork()
64 void Worker::HaveWork() { in HaveWork()
69 void Worker::OnMessage(rtc::Message *msg) { in OnMessage()
|
| D | worker.h | 32 class Worker : private MessageHandler {
34 Worker();
37 ~Worker() override;
67 RTC_DISALLOW_COPY_AND_ASSIGN(Worker);
|
| D | signalthread.h | 103 class Worker : public Thread {
105 explicit Worker(SignalThread* parent) : parent_(parent) {} in Worker() function
106 ~Worker() override;
112 RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(Worker);
142 Worker worker_;
|
| D | signalthread.cc | 127 SignalThread::Worker::~Worker() { in ~Worker()
131 void SignalThread::Worker::Run() { in Run()
|
| /external/drm_hwcomposer/ |
| D | worker.cpp | 24 Worker::Worker(const char *name, int priority) in Worker() function in android::Worker
28 Worker::~Worker() { in ~Worker()
32 int Worker::InitWorker() { in InitWorker()
38 new std::thread(&Worker::InternalRoutine, this)); in InitWorker()
45 void Worker::Exit() { in Exit()
56 int Worker::WaitForSignalOrExitLocked(int64_t max_nanoseconds) { in WaitForSignalOrExitLocked()
79 void Worker::InternalRoutine() { in InternalRoutine()
|
| D | worker.h | 30 class Worker {
49 Worker(const char *name, int priority);
50 virtual ~Worker();
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker.cc | 31 Worker::Worker(WorkerEnv* env) : env_(env) {} in Worker() function in tensorflow::Worker
33 void Worker::GetStatusAsync(const GetStatusRequest* request, in GetStatusAsync()
45 void Worker::CreateWorkerSessionAsync(const CreateWorkerSessionRequest* request, in CreateWorkerSessionAsync()
54 void Worker::DeleteWorkerSessionAsync(CallOptions* opts, in DeleteWorkerSessionAsync()
62 void Worker::RegisterGraphAsync(const RegisterGraphRequest* request, in RegisterGraphAsync()
83 void Worker::DeregisterGraphAsync(const DeregisterGraphRequest* request, in DeregisterGraphAsync()
101 void Worker::AbortStep(int64 step_id) { in AbortStep()
113 Status Worker::PrepareRunGraph(RunGraphRequestWrapper* req, in PrepareRunGraph()
130 void Worker::RunGraphAsync(CallOptions* opts, RunGraphRequestWrapper* request, in RunGraphAsync()
146 MutableRunGraphRequestWrapper* Worker::CreateRunGraphRequest() { in CreateRunGraphRequest()
[all …]
|
| D | worker.h | 42 class Worker : public WorkerInterface {
44 Worker(WorkerEnv* env);
45 virtual ~Worker() {} in ~Worker()
135 TF_DISALLOW_COPY_AND_ASSIGN(Worker);
|
| /external/libxcam/modules/soft/ |
| D | soft_blender.h | 70 … const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &args, const XCamReturn error);
72 … const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &args, const XCamReturn error);
74 … const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &args, const XCamReturn error);
76 … const SmartPtr<Worker> &worker, const SmartPtr<Worker::Arguments> &args, const XCamReturn error);
|
| D | soft_blender_tasks_priv.h | 48 …explicit GaussScaleGray (const char *name = "GaussScaleGray", const SmartPtr<Worker::Callback> &cb…
109 explicit GaussDownScale (const SmartPtr<Worker::Callback> &cb) in GaussDownScale()
147 explicit BlendTask (const SmartPtr<Worker::Callback> &cb) in BlendTask()
181 explicit LaplaceTask (const SmartPtr<Worker::Callback> &cb) in LaplaceTask()
218 explicit ReconstructTask (const SmartPtr<Worker::Callback> &cb) in ReconstructTask()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-trace.hpp | 44 template<class Worker, class Schedulable>
45 inline void schedule_enter(const Worker&, const Schedulable&) {} in schedule_enter()
46 template<class Worker>
47 inline void schedule_return(const Worker&) {} in schedule_return()
48 template<class Worker, class When, class Schedulable>
49 inline void schedule_when_enter(const Worker&, const When&, const Schedulable&) {} in schedule_when_enter()
50 template<class Worker>
51 inline void schedule_when_return(const Worker&) {} in schedule_when_return()
|
| /external/perfetto/ui/src/common/ |
| D | wasm_engine_proxy.ts | 24 const activeWorkers = new Map<string, Worker>();
25 let warmWorker: null|Worker = null;
27 function createWorker(): Worker {
28 return new Worker('engine_bundle.js');
33 export function createWasmEngine(id: string): Worker {
74 private readonly worker: Worker;
80 constructor(args: {id: string, worker: Worker}) {
|
| /external/icu/icu4j/main/tests/translit/src/com/ibm/icu/dev/test/translit/ |
| D | ThreadTest.java | 25 private ArrayList<Worker> threads = new ArrayList<Worker>();
36 Worker thread = new Worker(); in TestThreads()
41 for (Worker thread: threads) { in TestThreads()
59 private class Worker extends Thread { class in ThreadTest
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/translit/ |
| D | ThreadTest.java | 28 private ArrayList<Worker> threads = new ArrayList<Worker>();
39 Worker thread = new Worker(); in TestThreads()
44 for (Worker thread: threads) { in TestThreads()
62 private class Worker extends Thread { class in ThreadTest
|
| /external/clang/test/Sema/ |
| D | attr-capabilities.c | 27 ThreadRole GUI, Worker; variable
29 void Func2(void) __attribute__((requires_shared_capability(Worker))) {} in Func2()
61 void Func28(void) __attribute__((requires_capability(GUI && Worker)));
62 void Func29(void) __attribute__((requires_capability(GUI || Worker)));
63 void Func30(void) __attribute__((requires_capability((Worker || Worker) && !GUI)));
|
| /external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/trace/export/ |
| D | SpanExporterImpl.java | 39 private final Worker worker;
54 Worker worker = new Worker(bufferSize, scheduleDelay); in create()
86 private SpanExporterImpl(Worker worker) { in SpanExporterImpl()
107 private static final class Worker implements Runnable { class in SpanExporterImpl
154 private Worker(int bufferSize, Duration scheduleDelay) { in Worker() method in SpanExporterImpl.Worker
|
| /external/snakeyaml/src/test/java/org/yaml/snakeyaml/stress/ |
| D | ParallelTest.java | 34 Worker worker = new Worker(i, doc); in testPerfomance()
47 private class Worker implements Runnable { class in ParallelTest
51 public Worker(int id, String doc) { in Worker() method in ParallelTest.Worker
|
| /external/clang/test/SemaCXX/ |
| D | arrow-operator.cpp | 53 class Worker { class
60 wrapped_ptr<Worker> worker(new Worker); in test()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/pythagorian/ |
| D | main.cpp | 21 template<class Worker>
22 inline void schedule_return(const Worker&) { in schedule_return()
26 template<class Worker>
27 inline void schedule_when_return(const Worker&) { in schedule_when_return()
|
| /external/drm_hwcomposer/tests/ |
| D | worker_test.cpp | 8 using android::Worker;
10 struct TestWorker : public Worker {
12 : Worker("test-worker", HAL_PRIORITY_URGENT_DISPLAY), in TestWorker()
|
| /external/desugar/test/java/com/google/devtools/build/android/desugar/runtime/ |
| D | ConcurrentWeakIdentityHashMapTest.java | 129 List<Worker> workers = in testFunctionalCorrectnessForMultiThreadedUse()
131 .mapToObj(i -> new Worker("worker-" + i, map)) in testFunctionalCorrectnessForMultiThreadedUse()
135 Iterator<Worker> workIterator = workers.iterator(); in testFunctionalCorrectnessForMultiThreadedUse()
229 private class Worker implements Runnable { class in ConcurrentWeakIdentityHashMapTest
234 private Worker(String name, ConcurrentWeakIdentityHashMap map) { in Worker() method in ConcurrentWeakIdentityHashMapTest.Worker
|