/external/webp/src/utils/ |
H A D | thread.c | 8 // Multi-threaded worker 139 WebPWorker* const worker = (WebPWorker*)ptr; local 142 pthread_mutex_lock(&worker->mutex_); 143 while (worker->status_ == OK) { // wait in idling mode 144 pthread_cond_wait(&worker->condition_, &worker->mutex_); 146 if (worker->status_ == WORK) { 147 if (worker->hook) { 148 worker->had_error |= !worker 162 WebPWorkerChangeState(WebPWorker* const worker, WebPWorkerStatus new_status) argument 184 WebPWorkerInit(WebPWorker* const worker) argument 189 WebPWorkerSync(WebPWorker* const worker) argument 197 WebPWorkerReset(WebPWorker* const worker) argument 220 WebPWorkerLaunch(WebPWorker* const worker) argument 229 WebPWorkerEnd(WebPWorker* const worker) argument [all...] |
H A D | thread.h | 8 // Multi-threaded worker 39 // State of the worker thread object 46 // Function to be called by the worker thread. Takes two opaque pointers as 50 // Synchronize object used to launch job in the worker thread 65 void WebPWorkerInit(WebPWorker* const worker); 68 int WebPWorkerReset(WebPWorker* const worker); 69 // Make sure the previous work is finished. Returns true if worker->had_error 71 int WebPWorkerSync(WebPWorker* const worker); 75 void WebPWorkerLaunch(WebPWorker* const worker); 78 void WebPWorkerEnd(WebPWorker* const worker); [all...] |
/external/webkit/Source/WebCore/workers/ |
H A D | SharedWorker.cpp | 54 RefPtr<SharedWorker> worker = adoptRef(new SharedWorker(context)); local 57 worker->m_port = channel->port1(); 61 KURL scriptURL = worker->resolveURL(url, ec); 65 SharedWorkerRepository::connect(worker.get(), remotePort.release(), scriptURL, name, ec); 67 InspectorInstrumentation::didCreateWorker(context, worker->asID(), scriptURL.string(), true); 69 return worker.release();
|
H A D | Worker.cpp | 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)); 68 worker->m_scriptLoader->loadAsynchronously(context, scriptURL, DenyCrossOriginRequests, worker.get()); 70 // The worker context does not exist while loading, so we must ensure that the worker object is not collected, nor are its event listeners. 71 worker->setPendingActivity(worker.get()); 73 InspectorInstrumentation::didCreateWorker(context, worker [all...] |
/external/apache-xml/src/main/java/org/apache/xml/utils/ |
H A D | ThreadControllerWrapper.java | 38 public static void waitThread(Thread worker, Runnable task) argument 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) argument 92 worker.join();
|
/external/chromium/chrome/browser/sync/engine/ |
H A D | 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/ |
H A D | arrow-operator.cpp | 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'?}}
|
/external/chromium/chrome/browser/printing/ |
H A D | 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/ |
H A D | notification_object_proxy.cc | 14 int notification_id, bool worker) 18 worker_(worker) { 13 NotificationObjectProxy(int process_id, int route_id, int notification_id, bool worker) argument
|
H A D | notification_object_proxy.h | 21 // attached JS listeners will be invoked in the renderer or worker process. 27 int notification_id, bool worker);
|
/external/webkit/Source/WebCore/bindings/js/ |
H A D | JSWorkerCustom.cpp | 62 RefPtr<Worker> worker = Worker::create(ustringToString(scriptURL), window->document(), ec); local 68 return JSValue::encode(asObject(toJS(exec, jsConstructor->globalObject(), worker.release())));
|
H A D | JSSharedWorkerCustom.cpp | 69 // FIXME: We need to use both the dynamic scope and the lexical scope (dynamic scope for resolving the worker URL) 72 RefPtr<SharedWorker> worker = SharedWorker::create(ustringToString(scriptURL), ustringToString(name), window->document(), ec); local 78 return JSValue::encode(asObject(toJS(exec, jsConstructor->globalObject(), worker.release())));
|
/external/apache-harmony/luni/src/test/api/unix/org/apache/harmony/luni/tests/java/net/ |
H A D | UnixSocketTest.java | 46 Socket worker = pingServer.accept(); 52 InputStream in = worker.getInputStream(); 55 OutputStream out = worker.getOutputStream(); 57 worker.close();
|
/external/webkit/Tools/Scripts/webkitpy/layout_tests/layout_package/ |
H A D | manager_worker_broker_unittest.py | 51 # to have to pass extra arguments to the worker in the start_worker() call. 113 options, args = parser.parse_args(args=['--worker-model', worker_model]) 174 worker = self._broker.start_worker(0) 175 worker.cancel() 177 worker.join(0.5) 178 self.assertFalse(worker.is_alive()) 182 worker = self._broker.start_worker(0) 186 worker.join(0.5) 187 self.assertFalse(worker.is_alive()) 199 worker [all...] |
H A D | worker_mixin.py | 161 worker = self 163 driver = worker._port.create_driver(worker._worker_number) 168 self.result = worker._run_single_test(driver, test_input)
|
/external/webkit/Source/WebCore/inspector/front-end/ |
H A D | 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);
|
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/net/ |
H A D | SocketTest.java | 194 Socket worker = server.accept(); 198 worker.getRemoteSocketAddress()); 200 worker.close(); 813 Socket worker = sinkServer.accept(); 815 InputStream in = worker.getInputStream(); 818 worker.close(); 1008 Socket worker = server.accept(); 1012 worker.close(); 1025 worker = server.accept(); 1028 worker [all...] |
/external/webkit/Source/WebCore/inspector/ |
H A D | InspectorAgent.cpp | 251 InspectorWorkerResource* worker = it->second.get(); local 252 m_frontend->inspector()->didCreateWorker(worker->id(), worker->url(), worker->isSharedWorker()); 320 static PassOwnPtr<PostWorkerNotificationToFrontendTask> create(PassRefPtr<InspectorWorkerResource> worker, InspectorAgent::WorkerAction action) argument 322 return new PostWorkerNotificationToFrontendTask(worker, action); 326 PostWorkerNotificationToFrontendTask(PassRefPtr<InspectorWorkerResource> worker, InspectorAgent::WorkerAction action) argument 327 : m_worker(worker) 345 void InspectorAgent::postWorkerNotificationToFrontend(const InspectorWorkerResource& worker, InspectorAgent::WorkerAction action) argument 352 m_frontend->inspector()->didCreateWorker(worker [all...] |
/external/valgrind/unittest/ |
H A D | thread_wrappers_win.h | 197 MyThread(worker_t worker, void *arg = NULL, const char *name = NULL) argument 198 :w_(worker), arg_(arg), name_(name), t_(NULL) {} 199 MyThread(void (*worker)(void), void *arg = NULL, const char *name = NULL) argument 200 :w_(reinterpret_cast<worker_t>(worker)), arg_(arg), name_(name), t_(NULL) {} 201 MyThread(void (*worker)(void *), void *arg = NULL, const char *name = NULL) 202 :w_(reinterpret_cast<worker_t>(worker)), arg_(arg), name_(name), t_(NULL) {}
|
/external/webkit/Source/WebKit/chromium/src/ |
H A D | SharedWorkerRepository.cpp | 64 // Callback class that keeps the SharedWorker and WebSharedWorker objects alive while loads are potentially happening, and also translates load errors into error events on the worker. 67 SharedWorkerScriptLoader(PassRefPtr<SharedWorker> worker, const KURL& url, const String& name, PassOwnPtr<MessagePortChannel> port, PassOwnPtr<WebSharedWorker> webWorker) argument 68 : m_worker(worker) 133 // If the shared worker is not yet running, load the script resource for it, otherwise just send it a connect event. 138 // Keep the worker + JS wrapper alive until the resource load is complete in case we need to dispatch an error event. 147 // Extract the WebMessagePortChannel to send to the worker. 166 // Pass the script off to the worker, then send a connect event. 196 void SharedWorkerRepository::connect(PassRefPtr<SharedWorker> worker, PassOwnPtr<MessagePortChannel> port, const KURL& url, const String& name, ExceptionCode& ec) argument 203 ASSERT(worker->scriptExecutionContext()->isDocument()); 204 Document* document = static_cast<Document*>(worker [all...] |
/external/chromium/chrome/browser/sync/glue/ |
H A D | database_model_worker_unittest.cc | 30 DatabaseModelWorker* worker() { return worker_.get(); } function in class:__anon2314::DatabaseModelWorkerTest 43 worker()->DoWorkAndWaitUntilDone(c.get());
|
H A D | ui_model_worker_unittest.cc | 41 // A faux-syncer that only interacts with its model safe worker. 44 explicit Syncer(UIModelWorker* worker) : worker_(worker) {} argument 77 UIModelWorker* worker, 80 : syncer_thread_(syncer_thread), worker_(worker), jobs_(jobs), 76 FakeSyncapiShutdownTask(base::Thread* syncer_thread, UIModelWorker* worker, base::WaitableEvent** jobs, size_t job_count) argument
|
/external/chromium/third_party/libjingle/source/talk/base/ |
H A D | asynchttprequest.cc | 71 // worker is already quitting, no need to explicitly quit 90 worker()->Quit(); 101 worker()->Quit();
|
/external/stressapptest/ |
H A D | Android.mk | 18 src/worker.cc
|
/external/webkit/Source/WebCore/bindings/v8/custom/ |
H A D | V8WorkerCustom.cpp | 73 // Create the worker object. 93 Worker* worker = V8Worker::toNative(args.Holder()); local 104 worker->postMessage(message.release(), &portArray, ec);
|