| /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()));
|
| /external/chromium_org/ipc/ |
| ipc_sync_channel_unittest.cc | 242 // Starts the test with the given workers. This function deletes the workers
244 void RunTest(std::vector<Worker*> workers) {
245 // First we create the workers that are channel servers, or else the other
246 // workers' channel initialization might fail because the pipe isn't created..
247 for (size_t i = 0; i < workers.size(); ++i) {
248 if (workers[i]->mode() & Channel::MODE_SERVER_FLAG) {
249 workers[i]->Start();
250 workers[i]->WaitForChannelCreation();
255 for (size_t i = 0; i < workers.size(); ++i)
301 std::vector<Worker*> workers; local
361 std::vector<Worker*> workers; local
390 std::vector<Worker*> workers; local
443 std::vector<Worker*> workers; local
505 std::vector<Worker*> workers; local
582 std::vector<Worker*> workers; local
605 std::vector<Worker*> workers; local
693 std::vector<Worker*> workers; local
798 std::vector<Worker*> workers; local
866 std::vector<Worker*> workers; local
934 std::vector<Worker*> workers; local
945 std::vector<Worker*> workers; local
956 std::vector<Worker*> workers; local
1027 std::vector<Worker*> workers; local
1125 std::vector<Worker*> workers; local
1335 std::vector<Worker*> workers; local
1553 std::vector<Worker*> workers; local
1686 std::vector<Worker*> workers; local
1808 std::vector<Worker*> workers; local
1872 std::vector<Worker*> workers; local
[all...] |
| /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/chromium_org/sync/sessions/ |
| sync_session_context.cc | 16 const std::vector<ModelSafeWorker*>& workers,
38 for (size_t i = 0u; i < workers.size(); ++i) {
40 std::make_pair(workers[i]->GetModelSafeGroup(), workers[i]));
|
| sync_session_unittest.cc | 54 std::vector<ModelSafeWorker*> workers; local
55 GetWorkers(&workers);
61 workers,
|
| /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_org/sync/internal_api/ |
| internal_components_factory_impl.cc | 44 const std::vector<ModelSafeWorker*>& workers,
52 connection_manager, directory, workers, extensions_activity,
|
| /external/chromium_org/sync/internal_api/test/ |
| test_internal_components_factory.cc | 35 const std::vector<ModelSafeWorker*>& workers,
46 connection_manager, directory, workers, monitor,
|
| /external/chromium_org/sync/internal_api/public/ |
| internal_components_factory_impl.h | 30 const std::vector<ModelSafeWorker*>& workers,
|
| internal_components_factory.h | 85 const std::vector<ModelSafeWorker*>& workers,
|
| /external/chromium_org/sync/internal_api/public/test/ |
| test_internal_components_factory.h | 36 const std::vector<ModelSafeWorker*>& workers,
|
| /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());
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ThreadPoolExecutor.java | 303 * The workerCount is the number of workers that have been
309 * reported as the current size of the workers set.
417 * Lock held on access to workers set and related bookkeeping.
426 * ensuring workers set is stable while separately checking
435 private final HashSet<Worker> workers = new HashSet<Worker>(); field in class:ThreadPoolExecutor
501 * Core pool size is the minimum number of workers to keep alive
709 for (Worker w : workers)
725 for (Worker w : workers)
741 * enabled but there are still other workers. In this case, at
745 * workers since shutdown began will also eventually exit
[all...] |
| /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...] |
| /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/chromium_org/chrome/browser/sync/glue/ |
| sync_backend_registrar_unittest.cc | 125 std::vector<syncer::ModelSafeWorker*> workers; local
126 registrar_->GetWorkers(&workers);
127 EXPECT_EQ(4u, workers.size());
138 std::vector<syncer::ModelSafeWorker*> workers; local
139 registrar_->GetWorkers(&workers);
140 EXPECT_EQ(4u, workers.size());
|
| /external/chromium_org/content/test/data/workers/ |
| worker_common.js | 2 // that shared workers are actually shared, not distinct.
|
| /external/chromium_org/build/android/pylib/base/ |
| test_dispatcher.py | 253 workers = reraiser_thread.ReraiserThreadGroup(threads)
254 workers.StartAll()
258 workers.JoinAll(watcher)
|
| /external/chromium_org/third_party/WebKit/Source/devtools/front_end/ |
| sourcesPanel.css | 144 #shared-workers-list {
149 #pause-workers-checkbox > input {
188 .workers-list > li {
|
| /external/chromium_org/sync/tools/ |
| sync_client.cc | 322 std::vector<ModelSafeWorker*> workers; local
323 workers.push_back(passive_model_safe_worker.get());
364 workers,
|
