Searched refs:worker (Results 1 - 25 of 68) sorted by relevance

123

/external/webp/src/utils/
H A Dthread.c8 // 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 Dthread.h8 // 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 DSharedWorker.cpp54 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 DWorker.cpp61 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 DThreadControllerWrapper.java38 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 Dmodel_changing_syncer_command.cc21 ModelSafeWorker* worker = session->workers()[i]; local
22 ModelSafeGroup group = worker->GetModelSafeGroup();
28 worker->DoWorkAndWaitUntilDone(c.get());
/external/clang/test/SemaCXX/
H A Darrow-operator.cpp60 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 Dprint_job_unittest.cc43 // 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 Dnotification_object_proxy.cc14 int notification_id, bool worker)
18 worker_(worker) {
13 NotificationObjectProxy(int process_id, int route_id, int notification_id, bool worker) argument
H A Dnotification_object_proxy.h21 // 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 DJSWorkerCustom.cpp62 RefPtr<Worker> worker = Worker::create(ustringToString(scriptURL), window->document(), ec); local
68 return JSValue::encode(asObject(toJS(exec, jsConstructor->globalObject(), worker.release())));
H A DJSSharedWorkerCustom.cpp69 // 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 DUnixSocketTest.java46 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 Dmanager_worker_broker_unittest.py51 # 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 Dworker_mixin.py161 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 DWorkersSidebarPane.js58 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 DSocketTest.java194 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 DInspectorAgent.cpp251 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 Dthread_wrappers_win.h197 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 DSharedWorkerRepository.cpp64 // 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 Ddatabase_model_worker_unittest.cc30 DatabaseModelWorker* worker() { return worker_.get(); } function in class:__anon2314::DatabaseModelWorkerTest
43 worker()->DoWorkAndWaitUntilDone(c.get());
H A Dui_model_worker_unittest.cc41 // 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 Dasynchttprequest.cc71 // worker is already quitting, no need to explicitly quit
90 worker()->Quit();
101 worker()->Quit();
/external/stressapptest/
H A DAndroid.mk18 src/worker.cc
/external/webkit/Source/WebCore/bindings/v8/custom/
H A DV8WorkerCustom.cpp73 // Create the worker object.
93 Worker* worker = V8Worker::toNative(args.Holder()); local
104 worker->postMessage(message.release(), &portArray, ec);

Completed in 767 milliseconds

123