| /external/webrtc/webrtc/base/ |
| worker.h | 21 // A worker is an object that performs some specific long-lived task in an
27 // each other, and it is an error to call them while the worker is running on
29 // The destructor may not be called if the worker is currently running
32 class Worker : private MessageHandler {
34 Worker();
36 // Destroys this Worker, but it must have already been stopped via StopWork().
37 ~Worker() override;
39 // Attaches the worker to the current thread and begins processing work if not
52 // Called on the worker thread to start working.
54 // Called on the worker thread when work has been signalled via HaveWork()
[all...] |
| worker.cc | 11 #include "webrtc/base/worker.h"
23 Worker::Worker() : worker_thread_(NULL) {}
25 Worker::~Worker() {
32 bool Worker::StartWork() {
49 bool Worker::StopWork() {
64 void Worker::HaveWork() {
69 void Worker::OnMessage(rtc::Message *msg) {
|
| signalthread.h | 23 // SignalThread - Base class for worker threads. The main thread should call
26 // Cancellation: Call Release(true), to abort the worker thread.
45 // Context: Main Thread. Call before Start to change the worker's name.
48 // Context: Main Thread. Call to begin the worker thread.
51 // Context: Main Thread. If the worker thread is not running, deletes the
52 // object immediately. Otherwise, asks the worker thread to abort processing,
53 // and schedules the object to be deleted once the worker exits.
58 // Context: Main Thread. If the worker thread is complete, deletes the
60 // the worker thread completes. SignalWorkDone will be signalled.
71 Thread* worker() { return &worker_; function in class:rtc::SignalThread
[all...] |
| /external/v8/test/mjsunit/regress/ |
| regress-crbug-518747.js | 5 if (this.Worker) {
6 Worker.prototype = 12;
7 var __v_6 = new Worker('');
|
| regress-crbug-511880.js | 5 if (this.Worker) {
7 `var __v_9 = new Worker('postMessage(42)');
11 var __v_9 = new Worker(__v_8);
|
| regress-crbug-503578.js | 5 if (this.Worker) {
11 var __v_6 = new Worker('onmessage = function() {}');
|
| regress-crbug-503968.js | 5 if (this.Worker) {
11 var __v_9 = new Worker('');
|
| regress-crbug-504729.js | 5 if (this.Worker) {
8 assertThrows(function() { var __v_5 = new Worker(__f_7.toString()); });
|
| /external/drm_hwcomposer/ |
| worker.h | 26 class Worker {
40 Worker(const char *name, int priority);
41 virtual ~Worker();
58 static void *InternalRoutine(void *worker);
|
| worker.cpp | 17 #define LOG_TAG "hwc-drm-worker"
19 #include "worker.h"
34 Worker::Worker(const char *name, int priority)
38 Worker::~Worker() {
47 int Worker::InitWorker() {
75 bool Worker::initialized() const {
79 int Worker::Lock() {
83 int Worker::Unlock()
165 Worker *worker = (Worker *)arg; local
[all...] |
| drmcompositorworker.h | 20 #include "worker.h"
26 class DrmCompositorWorker : public Worker {
|
| /external/caliper/caliper/src/main/java/com/google/caliper/worker/ |
| WorkerModule.java | 17 package com.google.caliper.worker;
37 * Binds classes necessary for the worker. Also manages the injection of {@link Param parameters}
40 * <p>TODO(gak): Ensure that each worker only has bindings for the objects it needs and not the
41 * objects required by different workers. (i.e. don't bind a Ticker if the worker is an allocation
42 * worker).
46 private final Class<? extends Worker> workerClass;
52 this.workerClass = workerSpec.workerClass.asSubclass(Worker.class);
65 Worker provideWorker(Map<Class<? extends Worker>, Provider<Worker>> availableWorkers)
[all...] |
| WorkerComponent.java | 17 package com.google.caliper.worker;
26 * Creates {@link Worker} for an {@link com.google.caliper.runner.Experiment}.
36 Worker getWorker();
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/translit/ |
| ThreadTest.java | 25 private ArrayList<Worker> threads = new ArrayList<Worker>();
35 Worker thread = new Worker();
40 for (Worker thread: threads) {
58 private class Worker extends Thread {
|
| /external/icu/icu4j/main/tests/translit/src/com/ibm/icu/dev/test/translit/ |
| ThreadTest.java | 21 private ArrayList<Worker> threads = new ArrayList<Worker>();
31 Worker thread = new Worker();
36 for (Worker thread: threads) {
54 private class Worker extends Thread {
|
| /external/clang/test/SemaCXX/ |
| arrow-operator.cpp | 53 class Worker {
60 wrapped_ptr<Worker> worker(new Worker);
61 worker.DoSomething(); // expected-error {{no member named 'DoSomething' in 'arrow_suggest::wrapped_ptr<arrow_suggest::Worker>'; did you mean to use '->' instead of '.'?}}
62 worker.DoSamething(); // expected-error {{no member named 'DoSamething' in 'arrow_suggest::wrapped_ptr<arrow_suggest::Worker>'; did you mean to use '->' instead of '.'?}} \
63 // expected-error {{no member named 'DoSamething' in 'arrow_suggest::Worker'; did you mean 'DoSomething'?}}
64 worker.Chuck(); // expected-error {{no member named 'Chuck' in 'arrow_suggest::wrapped_ptr<arrow_suggest: (…)
[all...] |
| /external/clang/test/Sema/ |
| attr-capabilities.c | 27 ThreadRole GUI, Worker;
29 void Func2(void) __attribute__((requires_shared_capability(Worker))) {}
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)));
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| threaded_import_hangers.py | 21 class Worker(threading.Thread):
38 t = Worker(func, args)
|
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| threaded_import_hangers.py | 21 class Worker(threading.Thread):
38 t = Worker(func, args)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| threaded_import_hangers.py | 21 class Worker(threading.Thread):
38 t = Worker(func, args)
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| threaded_import_hangers.py | 21 class Worker(threading.Thread):
38 t = Worker(func, args)
|
| /external/chromium-trace/catapult/tracing/third_party/gl-matrix/spec/gl-matrix/ |
| worker-spec.js | 1 /* spec tests gl-matrix when embedded into a Web Worker */
4 if (typeof(Worker) !== 'undefined') {
30 var worker = new Worker(URL.createObjectURL(blob));
31 worker.onmessage = function(e) {
|
| /external/snakeyaml/src/test/java/org/yaml/snakeyaml/stress/ |
| ParallelTest.java | 34 Worker worker = new Worker(i, doc); local
35 Thread thread = new Thread(worker);
47 private class Worker implements Runnable {
51 public Worker(int id, String doc) {
|
| /external/vulkan-validation-layers/demos/smoke/ |
| Smoke.h | 58 class Worker {
60 Worker(Smoke &smoke, int index, int object_begin, int object_end);
88 static void thread_loop(Worker *worker) { worker->update_loop(); }
128 std::vector<std::unique_ptr<Worker>> workers_;
190 void update_simulation(const Worker &worker);
192 void draw_objects(Worker &worker);
[all...] |
| /external/compiler-rt/test/tsan/ |
| mmap_stress.cc | 28 void *Worker(void *arg) {
41 pthread_create(&th[i], 0, Worker, 0);
|
