| /external/webp/src/utils/ |
| D | thread.c | 135 WebPWorker* const worker = (WebPWorker*)ptr; in WebPWorkerThreadLoop() local
138 pthread_mutex_lock(&worker->mutex_); in WebPWorkerThreadLoop()
139 while (worker->status_ == OK) { // wait in idling mode in WebPWorkerThreadLoop()
140 pthread_cond_wait(&worker->condition_, &worker->mutex_); in WebPWorkerThreadLoop()
142 if (worker->status_ == WORK) { in WebPWorkerThreadLoop()
143 if (worker->hook) { in WebPWorkerThreadLoop()
144 worker->had_error |= !worker->hook(worker->data1, worker->data2); in WebPWorkerThreadLoop()
146 worker->status_ = OK; in WebPWorkerThreadLoop()
147 } else if (worker->status_ == NOT_OK) { // finish the worker in WebPWorkerThreadLoop()
151 pthread_cond_signal(&worker->condition_); in WebPWorkerThreadLoop()
[all …]
|
| D | thread.h | 69 void WebPWorkerInit(WebPWorker* const worker);
72 int WebPWorkerReset(WebPWorker* const worker);
75 int WebPWorkerSync(WebPWorker* const worker);
79 void WebPWorkerLaunch(WebPWorker* const worker);
82 void WebPWorkerEnd(WebPWorker* const worker);
|
| /external/webkit/Source/WebCore/workers/ |
| D | Worker.cpp | 61 RefPtr<Worker> worker = adoptRef(new Worker(context)); in create() local
63 KURL scriptURL = worker->resolveURL(url, ec); in create()
67 worker->m_scriptLoader = adoptPtr(new WorkerScriptLoader(ResourceRequestBase::TargetIsWorker)); in create()
68 …worker->m_scriptLoader->loadAsynchronously(context, scriptURL, DenyCrossOriginRequests, worker.get… in create()
71 worker->setPendingActivity(worker.get()); in create()
73 InspectorInstrumentation::didCreateWorker(context, worker->asID(), scriptURL.string(), false); in create()
75 return worker.release(); in create()
|
| D | SharedWorker.cpp | 54 RefPtr<SharedWorker> worker = adoptRef(new SharedWorker(context)); in create() local
57 worker->m_port = channel->port1(); in create()
61 KURL scriptURL = worker->resolveURL(url, ec); in create()
65 SharedWorkerRepository::connect(worker.get(), remotePort.release(), scriptURL, name, ec); in create()
67 InspectorInstrumentation::didCreateWorker(context, worker->asID(), scriptURL.string(), true); in create()
69 return worker.release(); in create()
|
| D | DefaultSharedWorkerRepository.cpp | 268 SharedWorkerScriptLoader::SharedWorkerScriptLoader(PassRefPtr<SharedWorker> worker, PassOwnPtr<Mess… in SharedWorkerScriptLoader() argument
269 : m_worker(worker) in SharedWorkerScriptLoader()
329 void SharedWorkerRepository::connect(PassRefPtr<SharedWorker> worker, PassOwnPtr<MessagePortChannel… in connect() argument
331 DefaultSharedWorkerRepository::instance().connectToWorker(worker, port, url, name, ec); in connect()
372 void DefaultSharedWorkerRepository::connectToWorker(PassRefPtr<SharedWorker> worker, PassOwnPtr<Mes… in connectToWorker() argument
375 …ASSERT(worker->scriptExecutionContext()->securityOrigin()->canAccess(SecurityOrigin::create(url).g… in connectToWorker()
378 proxy->addToWorkerDocuments(worker->scriptExecutionContext()); in connectToWorker()
388 …RefPtr<SharedWorkerScriptLoader> loader = adoptRef(new SharedWorkerScriptLoader(worker, port, prox… in connectToWorker()
|
| /external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/net/ |
| D | SocketTest.java | 194 Socket worker = server.accept(); in test_bindLjava_net_SocketAddress() local
198 worker.getRemoteSocketAddress()); in test_bindLjava_net_SocketAddress()
200 worker.close(); in test_bindLjava_net_SocketAddress()
813 Socket worker = sinkServer.accept(); in test_getOutputStream()
815 InputStream in = worker.getInputStream(); in test_getOutputStream()
818 worker.close(); in test_getOutputStream()
1008 Socket worker = server.accept(); in test_isBound() local
1012 worker.close(); in test_isBound()
1025 worker = server.accept(); in test_isBound()
1028 worker.close(); in test_isBound()
[all …]
|
| /external/webkit/Tools/Scripts/webkitpy/layout_tests/layout_package/ |
| D | manager_worker_broker_unittest.py | 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 = self._broker.start_worker(0)
201 worker.log_wedged_worker('test_name')
205 worker.join(0.5)
[all …]
|
| 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/webp/src/enc/ |
| D | alpha.c | 317 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncInitAlpha() local
318 WebPWorkerInit(worker); in VP8EncInitAlpha()
319 worker->data1 = enc; in VP8EncInitAlpha()
320 worker->data2 = NULL; in VP8EncInitAlpha()
321 worker->hook = (WebPWorkerHook)CompressAlphaJob; in VP8EncInitAlpha()
328 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncStartAlpha() local
329 if (!WebPWorkerReset(worker)) { // Makes sure worker is good to go. in VP8EncStartAlpha()
332 WebPWorkerLaunch(worker); in VP8EncStartAlpha()
344 WebPWorker* const worker = &enc->alpha_worker_; in VP8EncFinishAlpha() local
345 if (!WebPWorkerSync(worker)) return 0; // error in VP8EncFinishAlpha()
[all …]
|
| /external/webkit/Source/WebCore/inspector/ |
| D | InspectorAgent.cpp | 251 InspectorWorkerResource* worker = it->second.get(); in setFrontend() local
252 … m_frontend->inspector()->didCreateWorker(worker->id(), worker->url(), worker->isSharedWorker()); in setFrontend()
320 …erNotificationToFrontendTask> create(PassRefPtr<InspectorWorkerResource> worker, InspectorAgent::W… in create() argument
322 return new PostWorkerNotificationToFrontendTask(worker, action); in create()
326 …PostWorkerNotificationToFrontendTask(PassRefPtr<InspectorWorkerResource> worker, InspectorAgent::W… in PostWorkerNotificationToFrontendTask() argument
327 : m_worker(worker) in PostWorkerNotificationToFrontendTask()
345 void InspectorAgent::postWorkerNotificationToFrontend(const InspectorWorkerResource& worker, Inspec… in postWorkerNotificationToFrontend() argument
352 … m_frontend->inspector()->didCreateWorker(worker.id(), worker.url(), worker.isSharedWorker()); in postWorkerNotificationToFrontend()
355 m_frontend->inspector()->didDestroyWorker(worker.id()); in postWorkerNotificationToFrontend()
|
| /external/apache-xml/src/main/java/org/apache/xml/utils/ |
| D | ThreadControllerWrapper.java | 38 public static void waitThread(Thread worker, Runnable task) in waitThread() argument
41 m_tpool.waitThread(worker, task); in waitThread()
87 public void waitThread(Thread worker, Runnable task) in waitThread() argument
92 worker.join(); in waitThread()
|
| /external/clang/test/SemaCXX/ |
| D | arrow-operator.cpp | 60 wrapped_ptr<Worker> worker(new Worker); in test() local
61 …worker.DoSomething(); // expected-error {{no member named 'DoSomething' in 'arrow_suggest::wrapped… in test()
62 …worker.DoSamething(); // expected-error {{no member named 'DoSamething' in 'arrow_suggest::wrapped… in test()
63 …worker.Chuck(); // expected-error {{no member named 'Chuck' in 'arrow_suggest::wrapped_ptr<arrow_s… in test()
|
| /external/chromium/chrome/browser/printing/ |
| D | print_job_unittest.cc | 45 TestPrintJobWorker* worker(new TestPrintJobWorker(new_owner)); in DetachWorker() local
46 EXPECT_TRUE(worker->Start()); in DetachWorker()
47 worker->printing_context()->UseDefaultSettings(); in DetachWorker()
48 settings_ = worker->printing_context()->settings(); in DetachWorker()
49 return worker; in DetachWorker()
|
| /external/webkit/Source/WebKit/chromium/src/ |
| D | SharedWorkerRepository.cpp | 67 …SharedWorkerScriptLoader(PassRefPtr<SharedWorker> worker, const KURL& url, const String& name, Pas… in SharedWorkerScriptLoader() argument
68 : m_worker(worker) in SharedWorkerScriptLoader()
196 void SharedWorkerRepository::connect(PassRefPtr<SharedWorker> worker, PassOwnPtr<MessagePortChannel… in connect() argument
203 ASSERT(worker->scriptExecutionContext()->isDocument()); in connect()
204 Document* document = static_cast<Document*>(worker->scriptExecutionContext()); in connect()
220 …SharedWorkerScriptLoader* loader = new SharedWorkerScriptLoader(worker, url, name, port, webWorker… in connect()
|
| D | WebWorkerClientImpl.cpp | 83 WorkerContextProxy* WebWorkerClientImpl::createWorkerContextProxy(Worker* worker) in createWorkerContextProxy() argument
91 WebWorkerClientImpl* proxy = new WebWorkerClientImpl(worker); in createWorkerContextProxy()
93 if (worker->scriptExecutionContext()->isDocument()) { in createWorkerContextProxy()
95 worker->scriptExecutionContext()); in createWorkerContextProxy()
115 WebWorkerClientImpl::WebWorkerClientImpl(Worker* worker) in WebWorkerClientImpl() argument
116 : m_scriptExecutionContext(worker->scriptExecutionContext()) in WebWorkerClientImpl()
117 , m_worker(worker) in WebWorkerClientImpl()
|
| /external/valgrind/unittest/ |
| D | thread_wrappers_win.h | 197 MyThread(worker_t worker, void *arg = NULL, const char *name = NULL)
198 :w_(worker), arg_(arg), name_(name), t_(NULL) {} in w_() argument
199 MyThread(void (*worker)(void), void *arg = NULL, const char *name = NULL)
200 :w_(reinterpret_cast<worker_t>(worker)), arg_(arg), name_(name), t_(NULL) {} in w_() argument
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) {} in w_() argument
|
| D | thread_wrappers_pthread.h | 338 MyThread(worker_t worker, void *arg = NULL, const char *name = NULL)
339 :w_(worker), arg_(arg), name_(name) {} in w_() argument
340 MyThread(void (*worker)(void), void *arg = NULL, const char *name = NULL)
341 :w_(reinterpret_cast<worker_t>(worker)), arg_(arg), name_(name) {} in w_() argument
342 MyThread(void (*worker)(void *), void *arg = NULL, const char *name = NULL)
343 :w_(reinterpret_cast<worker_t>(worker)), arg_(arg), name_(name) {} in w_() argument
|
| /external/chromium/chrome/browser/sync/engine/ |
| D | model_changing_syncer_command.cc | 21 ModelSafeWorker* worker = session->workers()[i]; in ExecuteImpl() local
22 ModelSafeGroup group = worker->GetModelSafeGroup(); in ExecuteImpl()
28 worker->DoWorkAndWaitUntilDone(c.get()); in ExecuteImpl()
|
| /external/apache-harmony/luni/src/test/api/unix/org/apache/harmony/luni/tests/java/net/ |
| D | UnixSocketTest.java | 46 Socket worker = pingServer.accept(); in test_getInputStream() local
52 InputStream in = worker.getInputStream(); in test_getInputStream()
55 OutputStream out = worker.getOutputStream(); in test_getInputStream()
57 worker.close(); in test_getInputStream()
|
| /external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/ |
| D | ShadowAsyncTask.java | 23 private final BackgroundWorker worker; field in ShadowAsyncTask
27 worker = new BackgroundWorker(); in ShadowAsyncTask()
28 future = new FutureTask<Result>(worker) { in ShadowAsyncTask()
80 worker.params = params; in execute()
|
| /external/webkit/Source/WebCore/inspector/front-end/ |
| D | WorkersSidebarPane.js | 58 var worker = new WebInspector.Worker(id, url, isShared);
59 this._workers[id] = worker;
62 var treeElement = new TreeElement(null, worker, false);
|
| /external/chromium/chrome/browser/sync/glue/ |
| D | ui_model_worker_unittest.cc | 44 explicit Syncer(UIModelWorker* worker) : worker_(worker) {} in Syncer() argument
77 UIModelWorker* worker, in FakeSyncapiShutdownTask() argument
80 : syncer_thread_(syncer_thread), worker_(worker), jobs_(jobs), in FakeSyncapiShutdownTask()
|
| /external/chromium/net/base/ |
| D | cert_verifier.cc | 237 explicit CertVerifierJob(CertVerifierWorker* worker) : worker_(worker) { in CertVerifierJob() argument
347 CertVerifierWorker* worker = new CertVerifierWorker(cert, hostname, flags, in Verify() local
349 job = new CertVerifierJob(worker); in Verify()
350 if (!worker->Start()) { in Verify()
352 delete worker; in Verify()
|
| /external/chromium/chrome/browser/notifications/ |
| D | notification_object_proxy.cc | 14 int notification_id, bool worker) in NotificationObjectProxy() argument
18 worker_(worker) { in NotificationObjectProxy()
|
| /external/freetype/src/smooth/ |
| D | ftgrays.c | 242 #define RAS_ARG gray_PWorker worker
243 #define RAS_ARG_ gray_PWorker worker,
245 #define RAS_VAR worker
246 #define RAS_VAR_ worker,
380 #define ras (*worker)
392 gray_PWorker worker; member
1123 gray_PWorker worker ) in gray_move_to() argument
1137 worker->x = x; in gray_move_to()
1138 worker->y = y; in gray_move_to()
1145 gray_PWorker worker ) in gray_line_to() argument
[all …]
|