| /external/chromium/chrome/browser/sync/engine/ |
| model_changing_syncer_command.cc | 20 for (size_t i = 0; i < session->workers().size(); ++i) {
21 ModelSafeWorker* worker = session->workers()[i];
|
| syncer_thread.cc | 244 s->delegate(), s->source(), s->routing_info(), s->workers()));
287 old->source(), old->routing_info(), old->workers()));
395 s->source(), s->routing_info(), s->workers()));
405 // Helper to extract the routing info and workers corresponding to types in
409 std::vector<ModelSafeWorker*>* workers) {
427 iter it2 = std::find_if(workers->begin(), workers->end(),
429 if (it2 == workers->end())
430 workers->push_back(*it);
444 workers->push_back(*it)
458 std::vector<ModelSafeWorker*> workers; local
796 std::vector<ModelSafeWorker*> workers; local
[all...] |
| verify_updates_command_unittest.cc | 31 workers()->clear();
33 workers()->push_back(make_scoped_refptr(new MockDBModelWorker()));
34 workers()->push_back(make_scoped_refptr(new MockUIModelWorker()));
|
| download_updates_command_unittest.cc | 25 workers()->clear();
28 workers()->push_back(make_scoped_refptr(new ModelSafeWorker()));
|
| process_commit_response_command_unittest.cc | 42 workers()->clear();
46 workers()->push_back(make_scoped_refptr(new ModelSafeWorker()));
48 workers()->push_back(make_scoped_refptr(new MockUIModelWorker()));
63 using SyncerCommandTestWithParam<T>::workers;
|
| syncer_thread.h | 254 const std::vector<ModelSafeWorker*>& workers,
|
| apply_updates_command_unittest.cc | 43 workers()->clear();
46 workers()->push_back(make_scoped_refptr(new ModelSafeWorker()));
|
| /external/apache-harmony/security/src/test/impl/java/org/apache/harmony/security/tests/x509/ |
| PolicyQualifierInfoTest.java | 151 Thread[] workers = new Thread[workersNumber]; local
153 workers[i] = new TestWorker1(i);
156 workers[i].start();
159 workers[i].join();
169 Thread[] workers = new Thread[workersNumber]; local
171 workers[i] = new TestWorker2(i);
174 workers[i].start();
177 workers[i].join();
|
| /external/apache-harmony/security/src/test/impl/java/org/apache/harmony/security/tests/asn1/der/ |
| DerUTCTimeEDTest.java | 120 Thread[] workers = new Thread[workersNumber]; local
122 workers[i] = new TestWorker();
125 workers[i].start();
128 workers[i].join();
|
| /external/chromium/chrome/browser/sync/sessions/ |
| sync_session.h | 87 const std::vector<ModelSafeWorker*>& workers);
125 const std::vector<ModelSafeWorker*>& workers() const { return workers_; } function in class:browser_sync::sessions::SyncSession
158 // datatypes should be synced and which workers should be used when working
|
| sync_session.cc | 15 const std::vector<ModelSafeWorker*>& workers)
20 workers_(workers),
|
| sync_session_unittest.cc | 296 std::find(one.workers().begin(), one.workers().end(), db_worker);
298 std::find(one.workers().begin(), one.workers().end(), ui_worker);
299 EXPECT_NE(it_db, one.workers().end());
300 EXPECT_NE(it_ui, one.workers().end());
|
| /external/chromium/chrome/browser/sync/glue/ |
| sync_backend_host.cc | 83 DCHECK(registrar_.workers.empty());
105 registrar_.workers[GROUP_DB] = new DatabaseModelWorker();
106 registrar_.workers[GROUP_UI] = new UIModelWorker();
107 registrar_.workers[GROUP_PASSIVE] = new ModelSafeWorker();
113 registrar_.workers[GROUP_HISTORY] =
129 registrar_.workers[GROUP_PASSWORD] =
277 registrar_.workers[GROUP_DB] = NULL;
278 registrar_.workers[GROUP_HISTORY] = NULL;
279 registrar_.workers[GROUP_UI] = NULL;
280 registrar_.workers[GROUP_PASSIVE] = NULL
[all...] |
| sync_backend_host.h | 604 // We maintain ownership of all workers. In some cases, we need to ensure
605 // shutdown occurs in an expected sequence by Stop()ing certain workers.
613 WorkerMap workers; member in struct:browser_sync::SyncBackendHost::__anon3878
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ThreadPoolExecutor.java | 299 * The workerCount is the number of workers that have been
305 * reported as the current size of the workers set.
413 * Lock held on access to workers set and related bookkeeping.
422 * ensuring workers set is stable while separately checking
431 private final HashSet<Worker> workers = new HashSet<Worker>(); field in class:ThreadPoolExecutor
492 * Core pool size is the minimum number of workers to keep alive
685 for (Worker w : workers)
701 for (Worker w : workers) {
721 * enabled but there are still other workers. In this case, at
725 * workers since shutdown began will also eventually exit
[all...] |
| ForkJoinPool.java | 136 * into a submission queue. Workers take these tasks and typically
137 * split them into subtasks that may be stolen by other workers.
144 * decentralized control -- workers mostly take tasks from
165 * Recording Workers. Workers are recorded in the "workers" array
168 * structure to support index-based random steals by workers.
169 * Updates to the array recording new workers and unrecording
172 * and accessed directly by workers. To simplify index-based
176 * workers (which is unlikely to need further resizing durin
416 ForkJoinWorkerThread[] workers; field in class:ForkJoinPool
[all...] |
| ForkJoinWorkerThread.java | 104 * in that: (1) We only maintain dependency links across workers
106 * require a linear scan of workers array to locate stealers, but
205 * its workers array.
647 if (t != null || (ws = pool.workers) == null)
748 ForkJoinWorkerThread[] ws = pool.workers;
805 * some workers queue, steals and executes it.
812 ForkJoinWorkerThread[] ws = pool.workers;
842 * number of idle workers.
[all...] |
| /external/libpcap/packaging/ |
| pcap.spec | 18 Please send inquiries/comments/reports to tcpdump-workers@tcpdump.org
|
| /external/webkit/Tools/Scripts/ |
| run-qtwebkit-tests | 238 """ Executes given files by using a pool of workers. """
239 workers = self._Pool(processes=self._options.parallel_level)
241 self.debug("Using %s the workers pool, number of workers %i", repr(workers), self._options.parallel_level)
243 self.debug("Generated packages for workers: %s", repr(package))
244 results = workers.map(run_test, package) # Collects results.
|
| /external/webkit/Source/WebCore/ |
| Android.mk | [all...] |
| /frameworks/base/tests/CoreTests/android/core/ |
| TestWebServer.java | 51 int workers = 5; field in class:TestWebServer
409 if (pool.size() >= workers) {
|
| /external/chromium/chrome/browser/sync/ |
| profile_sync_service_autofill_unittest.cc | 587 std::vector<browser_sync::ModelSafeWorker*> workers; local
588 service_->GetBackendForTest()->GetWorkers(&workers);
602 std::vector<browser_sync::ModelSafeWorker*> workers; local
603 service_->GetBackendForTest()->GetWorkers(&workers);
[all...] |
| /external/webkit/Tools/DumpRenderTree/win/ |
| LayoutTestControllerWin.cpp | 264 COMPtr<IWebWorkersPrivate> workers; local
265 if (FAILED(WebKitCreateInstance(CLSID_WebWorkersPrivate, 0, __uuidof(workers), reinterpret_cast<void**>(&workers))))
268 if (FAILED(workers->workerThreadCount(&count)))
[all...] |
| /external/webkit/ |
| Android.mk | 165 $(WEBCORE_PATH)/workers \
|
| /external/webkit/Source/WebCore/inspector/front-end/ |
| ScriptsPanel.js | 143 this.sidebarPanes.workers = new WebInspector.WorkersSidebarPane();
488 this.sidebarPanes.workers.reset();
[all...] |
