/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/third_party/WebKit/Source/core/workers/ |
Worker.cpp | 29 #include "core/workers/Worker.h" 49 inline Worker::Worker(ScriptExecutionContext* context) 56 PassRefPtr<Worker> Worker::create(ScriptExecutionContext* context, const String& url, ExceptionState& es) 61 RefPtr<Worker> worker = adoptRef(new Worker(context)); local 63 worker->suspendIfNeeded(); 65 KURL scriptURL = worker->resolveURL(url, es) [all...] |
Worker.idl | 33 ] interface Worker : EventTarget { 41 Worker implements AbstractWorker;
|
WorkerGlobalScopeProxy.h | 42 class Worker; 44 // A proxy to talk to the worker global scope. 47 typedef WorkerGlobalScopeProxy* CreateDelegate(Worker*); 51 static WorkerGlobalScopeProxy* create(Worker* worker) { return s_createDelegate(worker); }
|
Worker.h | 49 class Worker : public AbstractWorker, public ScriptWrappable, private WorkerScriptLoaderClient { 51 static PassRefPtr<Worker> create(ScriptExecutionContext*, const String& url, ExceptionState&); 52 virtual ~Worker(); 67 explicit Worker(ScriptExecutionContext*); 77 WorkerGlobalScopeProxy* m_contextProxy; // The proxy outlives the worker to perform thread shutdown.
|
WorkerMessagingProxy.h | 45 class Worker; 51 WorkerMessagingProxy(Worker*, PassOwnPtr<WorkerClients>); 54 // (Only use these methods in the worker object thread.) 65 // (Only use these methods in the worker context thread.) 84 // Only use this method on the worker object thread. 100 Worker* workerObject() const { return m_workerObject; } 103 Worker* m_workerObject; 107 unsigned m_unconfirmedMessageCount; // Unconfirmed messages from worker object to worker thread. 108 bool m_workerThreadHadPendingActivity; // The latest confirmation from worker thread reported that it was still active [all...] |
/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/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_org/third_party/WebKit/Source/web/ |
WebWorkerClientImpl.h | 67 static WebCore::WorkerGlobalScopeProxy* createWorkerGlobalScopeProxy(WebCore::Worker*); 70 // These are called on the thread that created the worker. In the renderer 90 WebWorkerClientImpl(WebCore::Worker*, WebFrameImpl*, PassOwnPtr<WebCore::WorkerClients>);
|
/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/ |
desktop_media_picker_model.h | 84 class Worker; 85 friend class Worker; 87 // Struct used to represent sources list the model gets from the Worker. 132 scoped_ptr<Worker> worker_;
|
desktop_media_picker_model.cc | 90 class DesktopMediaPickerModel::Worker 93 Worker(base::WeakPtr<DesktopMediaPickerModel> model, 96 virtual ~Worker(); 116 DISALLOW_COPY_AND_ASSIGN(Worker); 119 DesktopMediaPickerModel::Worker::Worker( 132 DesktopMediaPickerModel::Worker::~Worker() {} 134 void DesktopMediaPickerModel::Worker::Refresh(const gfx::Size& thumbnail_size) { 212 webrtc::SharedMemory* DesktopMediaPickerModel::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...] |
/external/chromium_org/content/browser/devtools/ |
devtools_protocol_constants.cc | 46 namespace Worker { 48 const char kName[] = "Worker.disconnectedFromWorker"; 50 } // Worker
|
devtools_protocol_constants.h | 77 namespace Worker { 81 } // Worker
|