| /sdk/hierarchyviewer/src/com/android/hierarchyviewer/ui/action/ |
| BackgroundAction.java | 23 protected void executeBackgroundTask(SwingWorker<?, ?> worker) {
24 if (worker != null) {
25 worker.execute();
|
| /external/chromium_org/third_party/libwebp/utils/ |
| thread.c | 10 // Multi-threaded worker
137 WebPWorker* const worker = (WebPWorker*)ptr; local
140 pthread_mutex_lock(&worker->mutex_);
141 while (worker->status_ == OK) { // wait in idling mode
142 pthread_cond_wait(&worker->condition_, &worker->mutex_);
144 if (worker->status_ == WORK) {
145 if (worker->hook) {
146 worker->had_error |= !worker->hook(worker->data1, worker->data2)
[all...] |
| thread.h | 10 // Multi-threaded worker
45 // State of the worker thread object
52 // Function to be called by the worker thread. Takes two opaque pointers as
56 // Synchronize object used to launch job in the worker thread
71 void WebPWorkerInit(WebPWorker* const worker);
74 int WebPWorkerReset(WebPWorker* const worker);
75 // Makes sure the previous work is finished. Returns true if worker->had_error
77 int WebPWorkerSync(WebPWorker* const worker);
81 void WebPWorkerLaunch(WebPWorker* const worker);
84 void WebPWorkerEnd(WebPWorker* const worker);
[all...] |
| /external/webp/src/utils/ |
| thread.c | 10 // Multi-threaded worker
137 WebPWorker* const worker = (WebPWorker*)ptr; local
140 pthread_mutex_lock(&worker->mutex_);
141 while (worker->status_ == OK) { // wait in idling mode
142 pthread_cond_wait(&worker->condition_, &worker->mutex_);
144 if (worker->status_ == WORK) {
145 if (worker->hook) {
146 worker->had_error |= !worker->hook(worker->data1, worker->data2)
[all...] |
| thread.h | 10 // Multi-threaded worker
45 // State of the worker thread object
52 // Function to be called by the worker thread. Takes two opaque pointers as
56 // Synchronize object used to launch job in the worker thread
71 void WebPWorkerInit(WebPWorker* const worker);
74 int WebPWorkerReset(WebPWorker* const worker);
75 // Makes sure the previous work is finished. Returns true if worker->had_error
77 int WebPWorkerSync(WebPWorker* const worker);
81 void WebPWorkerLaunch(WebPWorker* const worker);
84 void WebPWorkerEnd(WebPWorker* const worker);
[all...] |
| /external/libvpx/libvpx/vp9/decoder/ |
| vp9_thread.c | 10 // Multi-threaded worker
140 VP9Worker* const worker = (VP9Worker*)ptr; local
143 pthread_mutex_lock(&worker->mutex_);
144 while (worker->status_ == OK) { // wait in idling mode
145 pthread_cond_wait(&worker->condition_, &worker->mutex_);
147 if (worker->status_ == WORK) {
148 vp9_worker_execute(worker);
149 worker->status_ = OK;
150 } else if (worker->status_ == NOT_OK) { // finish the worke
[all...] |
| vp9_thread.h | 10 // Multi-threaded worker
46 // State of the worker thread object
53 // Function to be called by the worker thread. Takes two opaque pointers as
57 // Synchronize object used to launch job in the worker thread
72 void vp9_worker_init(VP9Worker* const worker);
75 int vp9_worker_reset(VP9Worker* const worker);
76 // Makes sure the previous work is finished. Returns true if worker->had_error
78 int vp9_worker_sync(VP9Worker* const worker);
82 void vp9_worker_launch(VP9Worker* const worker);
87 void vp9_worker_execute(VP9Worker* const worker);
[all...] |
| /external/chromium_org/third_party/WebKit/Source/modules/filesystem/ |
| WorkerGlobalScopeFileSystem.cpp | 50 void WorkerGlobalScopeFileSystem::webkitRequestFileSystem(WorkerGlobalScope* worker, int type, long long size, PassRefPtr<FileSystemCallback> successCallback, PassRefPtr<ErrorCallback> errorCallback)
52 ScriptExecutionContext* secureContext = worker->scriptExecutionContext();
54 DOMFileSystem::scheduleCallback(worker, errorCallback, FileError::create(FileError::SECURITY_ERR));
60 DOMFileSystem::scheduleCallback(worker, errorCallback, FileError::create(FileError::INVALID_MODIFICATION_ERR));
64 WorkerLocalFileSystem::from(worker)->requestFileSystem(worker, fileSystemType, size, FileSystemCallbacks::create(successCallback, errorCallback, worker, fileSystemType), AsynchronousFileSystem);
67 PassRefPtr<DOMFileSystemSync> WorkerGlobalScopeFileSystem::webkitRequestFileSystemSync(WorkerGlobalScope* worker, int type, long long size, ExceptionState& es)
69 ScriptExecutionContext* secureContext = worker->scriptExecutionContext();
82 OwnPtr<FileSystemCallbacks> callbacks = FileSystemCallbacks::create(helper.successCallback(), helper.errorCallback(), worker, fileSystemType)
[all...] |
| /external/chromium_org/content/test/data/workers/ |
| worker_utils.js | 4 // Create either a dedicated or shared worker, depending on flags
7 // Make a shared worker that looks like a worker
8 var worker = new SharedWorker(worker_url, "name" + ++shared_worker_count);
9 worker.port.onmessage = function(evt) {
10 worker.onmessage(evt);
12 worker.postMessage = function(msg, port) {
13 worker.port.postMessage(msg, port);
15 return worker;
17 return new Worker(worker_url)
[all...] |
| worker_common.js | 1 // Track the number of clients for this worker - tests can use this to ensure
6 // This is a shared worker - mimic dedicated worker APIs
|
| /external/apache-xml/src/main/java/org/apache/xml/utils/ |
| ThreadControllerWrapper.java | 38 public static void waitThread(Thread worker, Runnable task)
41 m_tpool.waitThread(worker, task);
79 * Wait until the task is completed on the worker
82 * NEEDSDOC @param worker
87 public void waitThread(Thread worker, Runnable task)
92 worker.join();
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/ |
| print-test-ordering | 39 parser.description = "Prints out lists of tests run on each worker as per the stats.json file."
54 worker = "worker/" + str(data["results"][0])
55 if worker not in stats_by_worker:
56 stats_by_worker[worker] = []
58 stats_by_worker[worker].append({
63 for worker in sorted(stats_by_worker.keys()):
64 print worker + ':'
65 for test in sorted(stats_by_worker[worker], key=lambda test:test["number"]):
|
| /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...] |
| SharedWorker.cpp | 59 RefPtr<SharedWorker> worker = adoptRef(new SharedWorker(context)); local
62 worker->m_port = channel->port1();
66 worker->suspendIfNeeded();
68 KURL scriptURL = worker->resolveURL(url, es);
80 SharedWorkerRepository::connect(worker.get(), remotePort.release(), scriptURL, name, es);
82 return worker.release();
|
| 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); }
|
| /external/chromium/chrome/browser/sync/engine/ |
| model_changing_syncer_command.cc | 21 ModelSafeWorker* worker = session->workers()[i]; local
22 ModelSafeGroup group = worker->GetModelSafeGroup();
28 worker->DoWorkAndWaitUntilDone(c.get());
|
| /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/sync/engine/ |
| model_changing_syncer_command.cc | 23 ModelSafeWorker* worker = session->context()->workers()[i].get(); local
24 ModelSafeGroup group = worker->GetModelSafeGroup();
27 DVLOG(2) << "Skipping worker for group "
41 SyncerError this_worker_result = worker->DoWorkAndWaitUntilDone(c);
|
| /external/chromium_org/third_party/WebKit/Source/web/ |
| WebWorkerClientImpl.cpp | 49 #include "core/workers/Worker.h"
75 WorkerGlobalScopeProxy* WebWorkerClientImpl::createWorkerGlobalScopeProxy(Worker* worker)
77 if (worker->scriptExecutionContext()->isDocument()) {
78 Document* document = toDocument(worker->scriptExecutionContext());
82 WebWorkerClientImpl* proxy = new WebWorkerClientImpl(worker, webFrame, workerClients.release());
147 WebWorkerClientImpl::WebWorkerClientImpl(Worker* worker, WebFrameImpl* webFrame, PassOwnPtr<WorkerClients> workerClients)
148 : WebCore::WorkerMessagingProxy(worker, workerClients)
|
| /external/chromium_org/third_party/WebKit/Source/bindings/v8/custom/ |
| V8WorkerCustom.cpp | 39 #include "core/workers/Worker.h"
47 Worker* worker = V8Worker::toNative(args.Holder()); local
64 worker->postMessage(message.release(), &ports, es);
|
| /external/chromium/chrome/browser/printing/ |
| print_job_unittest.cc | 43 // We're screwing up here since we're calling worker from the main thread.
45 TestPrintJobWorker* worker(new TestPrintJobWorker(new_owner));
46 EXPECT_TRUE(worker->Start());
47 worker->printing_context()->UseDefaultSettings();
48 settings_ = worker->printing_context()->settings();
49 return worker;
|
| /external/chromium/chrome/browser/notifications/ |
| notification_object_proxy.cc | 14 int notification_id, bool worker)
18 worker_(worker) {
47 // TODO(johnnyg): http://crbug.com/23065 Worker support coming soon.
|
| notification_object_proxy.h | 21 // attached JS listeners will be invoked in the renderer or worker process.
27 int notification_id, bool worker);
|
| /external/chromium_org/net/data/websocket/ |
| websocket_worker_simple.js | 6 // This is a shared worker - mimic dedicated worker APIs
19 // This test is compatible with shared-worker-simple.html layout test.
44 postMessage("FAIL: worker: Unexpected exception: " + e);
|
| /external/apache-harmony/luni/src/test/api/unix/org/apache/harmony/luni/tests/java/net/ |
| UnixSocketTest.java | 46 Socket worker = pingServer.accept(); local
52 InputStream in = worker.getInputStream();
55 OutputStream out = worker.getOutputStream();
57 worker.close();
|
