| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| worker.h | 38 // A worker is an object that performs some specific long-lived task in an
44 // each other, and it is an error to call them while the worker is running on
46 // The destructor may not be called if the worker is currently running
49 class Worker : private MessageHandler {
51 Worker();
53 // Destroys this Worker, but it must have already been stopped via StopWork().
54 virtual ~Worker();
56 // Attaches the worker to the current thread and begins processing work if not
69 // Called on the worker thread to start working.
71 // Called on the worker thread when work has been signalled via HaveWork()
[all...] |
| worker.cc | 28 #include "talk/base/worker.h"
40 Worker::Worker() : worker_thread_(NULL) {}
42 Worker::~Worker() {
49 bool Worker::StartWork() {
66 bool Worker::StopWork() {
81 void Worker::HaveWork() {
86 void Worker::OnMessage(talk_base::Message *msg) {
|
| signalthread.h | 40 // SignalThread - Base class for worker threads. The main thread should call
43 // Cancellation: Call Release(true), to abort the worker thread.
62 // Context: Main Thread. Call before Start to change the worker's name.
65 // Context: Main Thread. Call before Start to change the worker's priority.
68 // Context: Main Thread. Call to begin the worker thread.
71 // Context: Main Thread. If the worker thread is not running, deletes the
72 // object immediately. Otherwise, asks the worker thread to abort processing,
73 // and schedules the object to be deleted once the worker exits.
78 // Context: Main Thread. If the worker thread is complete, deletes the
80 // the worker thread completes. SignalWorkDone will be signalled
91 Thread* worker() { return &worker_; } function in class:talk_base::SignalThread
[all...] |
| /external/chromium_org/content/test/data/workers/ |
| messageport_worker.js | 3 port.postMessage("Worker connected.");
5 port.postMessage("Worker got a port.");
9 anotherport.postMessage("Worker got a message via the passed port.");
|
| /external/chromium_org/third_party/WebKit/Source/core/workers/ |
| Worker.cpp | 29 #include "core/workers/Worker.h"
46 inline Worker::Worker(ExecutionContext* context)
53 PassRefPtr<Worker> Worker::create(ExecutionContext* context, const String& url, ExceptionState& exceptionState)
62 RefPtr<Worker> worker = adoptRef(new Worker(context)); local
64 worker->suspendIfNeeded();
66 KURL scriptURL = worker->resolveURL(url, exceptionState)
[all...] |
| Worker.h | 49 class Worker : public AbstractWorker, public ScriptWrappable, private WorkerScriptLoaderClient {
51 static PassRefPtr<Worker> create(ExecutionContext*, const String& url, ExceptionState&);
52 virtual ~Worker();
66 explicit Worker(ExecutionContext*);
73 WorkerGlobalScopeProxy* m_contextProxy; // The proxy outlives the worker to perform thread shutdown.
|
| Worker.idl | 33 ] interface Worker : EventTarget {
41 Worker implements AbstractWorker;
|
| WorkerGlobalScopeProxyProvider.h | 43 class Worker;
51 virtual WorkerGlobalScopeProxy* createWorkerGlobalScopeProxy(Worker*) = 0;
|
| WorkerGlobalScopeProxy.h | 42 class Worker;
44 // A proxy to talk to the worker global scope.
|
| WorkerMessagingProxy.h | 45 class Worker;
51 WorkerMessagingProxy(Worker*, PassOwnPtr<WorkerClients>);
54 // (Only use these methods in the worker object thread.)
64 // These methods come from worker context thread via WorkerObjectProxy
65 // and are called on the worker object thread (e.g. main thread).
91 Worker* m_workerObject;
95 unsigned m_unconfirmedMessageCount; // Unconfirmed messages from worker object to worker thread.
96 bool m_workerThreadHadPendingActivity; // The latest confirmation from worker thread reported that it was still active.
|
| /external/chromium_org/media/audio/ |
| fake_audio_consumer.h | 37 // Stop executing the ReadCB provided to Start(). Blocks until the worker
44 // cancellation of posted tasks must happen on the worker thread some time
46 class Worker;
47 const scoped_refptr<Worker> worker_;
|
| fake_audio_consumer.cc | 22 class FakeAudioConsumer::Worker
23 : public base::RefCountedThreadSafe<FakeAudioConsumer::Worker> {
25 Worker(const scoped_refptr<base::MessageLoopProxy>& worker_loop,
33 friend class base::RefCountedThreadSafe<Worker>;
34 ~Worker();
36 // Initialize and start regular calls to DoRead() on the worker thread.
39 // Cancel any delayed callbacks to DoRead() in the worker loop's queue.
44 // the worker loop.
55 // Used to cancel any delayed tasks still inside the worker loop's queue.
60 DISALLOW_COPY_AND_ASSIGN(Worker);
[all...] |
| /external/chromium_org/third_party/WebKit/Source/web/ |
| WorkerGlobalScopeProxyProviderImpl.h | 39 class Worker;
54 virtual WebCore::WorkerGlobalScopeProxy* createWorkerGlobalScopeProxy(WebCore::Worker*) OVERRIDE;
|
| /external/valgrind/unittest/ |
| atomicity_tests.cc | 70 void Worker() {
82 MyThreadArray t(Worker, Worker);
129 void Worker() {
138 MyThreadArray t(Worker, Worker, Worker);
|
| racecheck_unittest.cc | 397 // Parent: Worker:
399 // 2. Start(Worker) ------------>
401 // 3. Join(Worker) <------------
403 void Worker() {
408 MyThread t(Worker);
696 void Worker() {
714 MyThreadArray t(Worker, Worker);
730 void Worker() {
747 MyThreadArray t(Worker, Worker, Worker)
[all...] |
| /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>'}}
63 worker.Chuck(); // expected-error {{no member named 'Chuck' in 'arrow_suggest::wrapped_ptr<arrow_suggest::Worker>'; did you mean 'Check'?}
[all...] |
| /external/chromium_org/ppapi/native_client/tests/nacl_browser/manifest_file/ |
| pm_manifest_file_test.cc | 73 // A Worker object is associated with a single worker thread and a
74 // plugin instance (which may be associated with multiple Worker
77 // reference will be immediately handed off to its associated worker
82 // handler thread should no longer use the Worker*).
83 class Worker {
85 explicit Worker(MyInstance *instance);
87 // RunToCompletion should be invoked in the worker thread. It
89 // automatically unref the Worker object, so the worker threa
162 Worker *worker() { return worker_; } function in class:MyInstance
608 Worker *worker = reinterpret_cast<Worker *>(arg); local
[all...] |
| /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_org/ipc/ |
| ipc_sync_channel_unittest.cc | 34 class Worker : public Listener, public Sender {
37 Worker(Channel::Mode mode, const std::string& thread_name)
49 Worker(const std::string& channel_name, Channel::Mode mode)
61 virtual ~Worker() {
79 FROM_HERE, base::Bind(&Worker::OnStart, this));
83 // ~Worker(), since that'll reset the vtable pointer (to Worker's), which
87 FROM_HERE, base::Bind(&Worker::OnListenerThreadShutdown1, this,
189 FROM_HERE, base::Bind(&Worker::OnIPCThreadShutdown, this,
199 FROM_HERE, base::Bind(&Worker::OnListenerThreadShutdown2, this
705 Worker* worker; local
807 Worker* worker; local
1882 Worker* worker; local
[all...] |
| /libcore/luni/src/test/java/libcore/java/lang/ |
| OldAndroidMonitorTest.java | 312 private class Worker extends Thread {
316 Worker(int id, Object lock) {
317 super("Worker(" + id + ")");
340 Worker w[] = new Worker[NUM_WORKERS];
344 w[i] = new Worker(i * 2 - 1, new Object());
386 Worker w1 = new Worker(0, 1);
387 Worker w2 = new Worker(2, 3)
[all...] |
| /external/chromium/third_party/libjingle/source/talk/base/ |
| signalthread.h | 39 // SignalThread - Base class for worker threads. The main thread should call
42 // Cancellation: Call Release(true), to abort the worker thread.
59 // Context: Main Thread. Call before Start to change the worker's name.
62 // Context: Main Thread. Call before Start to change the worker's priority.
65 // Context: Main Thread. Call to begin the worker thread.
68 // Context: Main Thread. If the worker thread is not running, deletes the
69 // object immediately. Otherwise, asks the worker thread to abort processing,
70 // and schedules the object to be deleted once the worker exits.
75 // Context: Main Thread. If the worker thread is complete, deletes the
77 // the worker thread completes. SignalWorkDone will be signalled
88 Thread* worker() { return &worker_; } function in class:talk_base::SignalThread
[all...] |
| /external/chromium_org/chrome/browser/media/ |
| native_desktop_media_list.h | 43 class Worker;
44 friend class Worker;
46 // Struct used to represent sources list the model gets from the Worker.
91 scoped_ptr<Worker> worker_;
|
| native_desktop_media_list.cc | 86 class NativeDesktopMediaList::Worker
89 Worker(base::WeakPtr<NativeDesktopMediaList> media_list,
92 virtual ~Worker();
113 DISALLOW_COPY_AND_ASSIGN(Worker);
116 NativeDesktopMediaList::Worker::Worker(
129 NativeDesktopMediaList::Worker::~Worker() {}
131 void NativeDesktopMediaList::Worker::Refresh(
215 webrtc::SharedMemory* NativeDesktopMediaList::Worker::CreateSharedMemory
[all...] |
| /external/valgrind/main/drd/tests/ |
| tsan_unittest.cpp | 331 void Worker() {
336 MyThread t(Worker);
639 // Parent: Worker:
641 // 2. Start(Worker) ------------>
643 // 3. Join(Worker) <------------
645 void Worker() {
650 MyThread t(Worker);
745 void Worker() {
758 MyThreadArray t(Worker, Worker);
[all...] |
