/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::__anon4430
|
/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/compiler-rt/lib/asan/tests/ |
asan_mac_test.cc | 176 pthread_t workers[kNumWorkers], forker; local 178 PTHREAD_CREATE(&workers[i], 0, MallocIntrospectionLockWorker, 0); 182 PTHREAD_JOIN(workers[i], 0);
|
/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 | 178 $(WEBCORE_PATH)/workers \
|