| /external/webkit/Source/WebCore/workers/ |
| Worker.cpp | 32 #include "Worker.h"
53 inline Worker::Worker(ScriptExecutionContext* context)
59 PassRefPtr<Worker> Worker::create(const String& url, ScriptExecutionContext* context, ExceptionCode& ec)
61 RefPtr<Worker> worker = adoptRef(new Worker(context)); local
63 KURL scriptURL = worker->resolveURL(url, ec);
67 worker->m_scriptLoader = adoptPtr(new WorkerScriptLoader(ResourceRequestBase::TargetIsWorker))
[all...] |
| Worker.h | 54 class Worker : public AbstractWorker, private WorkerScriptLoaderClient {
56 static PassRefPtr<Worker> create(const String& url, ScriptExecutionContext*, ExceptionCode&);
57 virtual ~Worker();
59 virtual Worker* toWorker() { return this; }
75 Worker(ScriptExecutionContext*);
83 WorkerContextProxy* m_contextProxy; // The proxy outlives the worker to perform thread shutdown.
|
| /external/valgrind/unittest/ |
| atomicity_tests.cc | 70 void Worker() {
82 MyThreadArray t(Worker, Worker);
129 void Worker() {
138 MyThreadArray t(Worker, Worker, Worker);
|
| posix_tests.cc | 73 void Worker() {
86 MyThreadArray t(Worker, Worker);
265 void Worker() {
318 MyThreadArray t(Worker, Worker, Worker);
356 void Worker() {
392 MyThreadArray t(Worker, Worker, Worker)
[all...] |
| thread_wrappers.h | 237 MyThread *thread = new MyThread(&ThreadPool::Worker, this);
270 static void *Worker(void *p) {
|
| windows_tests.cc | 492 void Worker() {
498 MyThreadArray mta(Worker, Worker);
|
| demo_tests.cc | 76 void Worker() {
104 MyThread t1(Worker), t2(Worker);
474 void Worker() { Func19(); }
477 MyThreadArray t(Worker, Worker, Worker);
488 // Worker(N) will do 2^N increments of GLOB, each increment in a separate thread
489 void Worker(int depth) {
494 pool.Add(NewCallback(Worker, depth-1))
[all...] |
| /external/webkit/Tools/Scripts/webkitpy/layout_tests/layout_package/ |
| worker.py | 44 class Worker(manager_worker_broker.AbstractWorker, worker_mixin.WorkerMixin):
49 self._name = 'worker/%d' % worker_number
76 raise AssertionError("%s: ran out of messages in worker queue."
|
| /external/webkit/Source/WebCore/inspector/front-end/ |
| InjectedFakeWorker.js | 34 Worker = function(url)
59 function FakeWorker(worker, url)
63 this._worker = worker;
236 console.error("Failed to load worker: " + url + "[" + xhr.status + "]");
237 text = ""; // We've got error message, not worker code.
|
| WorkersSidebarPane.js | 58 var worker = new WebInspector.Worker(id, url, isShared);
59 this._workers[id] = worker;
61 var title = WebInspector.linkifyURL(url, WebInspector.displayNameForURL(url), "worker-item", true, url);
62 var treeElement = new TreeElement(null, worker, false);
97 WebInspector.Worker = function(id, url, shared)
|
| /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...] |
| /hardware/ril/mock-ril/src/cpp/ |
| worker.cpp | 19 #include "worker.h"
37 void * v = t->Worker(t->workerParam_);
115 // Wait until worker is running
137 void * Worker(void *param) {
138 DBG("WorkerQueueThread::Worker E");
155 DBG("WorkerQueueThread::Worker move p=%p time=%lldms",
167 DBG("WorkerQueueThread::Worker wait"
189 DBG("WorkerQueueThread::Worker X");
315 void * Worker(void *param)
317 LOGD("TesterThread::Worker E param=%p", param)
[all...] |
| ctrl_server.cpp | 32 #include "worker.h"
322 virtual void * Worker(void *param) {
323 DBG("CtrlServerThread::Worker E param=%p stopper_fd_=%d",
334 DBG("CtrlServerThread::Worker wait on server for a client");
342 DBG("CtrlServerThread::Worker accepted server_to_client_socket_=%d isRunning()=%d",
349 DBG("CtrlServerThread::Worker wait on client for message");
359 LOGD("CtrlServerThread::Worker echo");
363 DBG("CtrlServerThread::Worker sendToCtrlServer");
384 DBG("CtrlServerThread::Worker X param=%p", param);
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| SingleThreadNamedTaskExecutor.java | 38 mWorker = threadFactory.newThread(new Worker());
63 private class Worker implements Runnable {
68 if (!mClosed) Log.w(TAG, "Worker exited before close");
|
| /external/mesa3d/src/pixelflinger2/ |
| pixelflinger2.h | 106 mutable struct Worker {
111 bool assignedWork; // only used by main; worker uses assignCond & quit
115 pthread_mutex_t assignLock; // held by worker execpt for during cond_wait assign
120 Worker() : assignedWork(false), quit(false), thread(0)
129 ~Worker()
146 } worker; member in struct:GGLContext
|
| /packages/apps/Gallery2/src/com/android/gallery3d/util/ |
| ThreadPool.java | 91 Worker<T> w = new Worker<T>(job, listener);
100 private class Worker<T> implements Runnable, Future<T>, JobContext {
101 private static final String TAG = "Worker";
111 public Worker(Job<T> job, FutureListener<T> listener) {
|
| /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...] |
| /packages/apps/Phone/src/com/android/phone/ |
| Ringer.java | 62 private Worker mRingThread;
248 private class Worker implements Runnable {
252 Worker(String name) {
296 mRingThread = new Worker("ringer");
|
| /external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/io/ |
| PipedInputStreamTest.java | 355 static class Worker extends Thread {
358 Worker(PipedOutputStream pos) {
376 Thread worker = new Worker(out); local
377 worker.start();
380 worker.join();
|
| /frameworks/base/core/tests/coretests/src/android/webkit/ |
| AccessibilityInjectorTest.java | 91 /** Worker thread with a handler to perform non test thread processing. */
92 private Worker mWorker;
110 mWorker = new Worker();
[all...] |
| /libcore/support/src/test/java/tests/support/ |
| Support_TestWebServer.java | 244 * The AcceptThread is responsible for initiating worker threads
275 new Thread(new Worker(s), "additional worker").start();
332 * The worker thread handles all interactions with a current open
337 class Worker implements Support_HttpConstants, Runnable {
366 /* Create a new worker thread */
367 Worker(Socket s) {
|
| /external/valgrind/main/drd/tests/ |
| tsan_thread_wrappers_pthread.h | 346 MyThread(worker_t worker, void *arg = NULL, const char *name = NULL)
347 :w_(worker), arg_(arg), name_(name) {}
348 MyThread(void (*worker)(void), void *arg = NULL, const char *name = NULL)
349 :w_(reinterpret_cast<worker_t>(worker)), arg_(arg), name_(name) {}
350 MyThread(void (*worker)(void *), void *arg = NULL, const char *name = NULL)
351 :w_(reinterpret_cast<worker_t>(worker)), arg_(arg), name_(name) {}
507 MyThread *thread = new MyThread(&ThreadPool::Worker, this);
540 static void *Worker(void *p) {
|
| /frameworks/base/tests/CoreTests/android/core/ |
| TestWebServer.java | 41 /* Where worker threads stand idle */
44 /* List of all active worker threads */
50 /* max # worker threads */
216 * The AcceptThread is responsible for initiating worker threads
263 Worker w = null;
266 Worker ws = new Worker();
269 (new Thread(ws, "additional worker")).start();
271 w = (Worker) threads.elementAt(0);
298 // Stop worker threads from continuin
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ThreadPoolExecutor.java | 49 * handle the request, even if other worker threads are idle. If
210 * <p>If hook or callback methods throw exceptions, internal worker
396 * The queue used for holding tasks and handing off to worker
424 * Set containing all worker threads in pool. Accessed only when
427 private final HashSet<Worker> workers = new HashSet<Worker>();
442 * worker threads. Accessed only under mainLock.
509 * have permission to actually interrupt threads in the worker set
530 * Class Worker mainly maintains interrupt control state for
535 * intended to wake up a worker thread waiting for a task fro
[all...] |
| /packages/apps/Music/src/com/android/music/ |
| MediaPlaybackActivity.java | 85 private Worker mAlbumArtWorker;
102 mAlbumArtWorker = new Worker("album art worker");
[all...] |
