HomeSort by relevance Sort by last modified time
    Searched refs:workers (Results 1 - 25 of 86) sorted by null

1 2 3 4

  /external/chromium_org/sync/sessions/
sync_session_context.cc 19 const std::vector<ModelSafeWorker*>& workers,
39 for (size_t i = 0u; i < workers.size(); ++i)
40 workers_.push_back(workers[i]);
sync_session_context.h 52 const std::vector<ModelSafeWorker*>& workers,
78 const std::vector<scoped_refptr<ModelSafeWorker> >& workers() const { function in class:syncer::sessions::SyncSessionContext
sync_session_unittest.cc 55 std::vector<ModelSafeWorker*> workers; local
56 GetWorkers(&workers);
62 workers,
  /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()));
  /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/engine/
model_changing_syncer_command.cc 22 for (size_t i = 0; i < session->context()->workers().size(); ++i) {
23 ModelSafeWorker* worker = session->context()->workers()[i].get();
25 // Skip workers whose group isn't active.
download_unittest.cc 22 workers()->clear();
24 workers()->push_back(
26 workers()->push_back(
model_changing_syncer_command_unittest.cc 63 workers()->push_back(
65 workers()->push_back(
  /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/test/engine/
syncer_command_test.cc 23 workers()->push_back(
syncer_command_test.h 83 std::vector<ModelSafeWorker*> workers; local
86 workers.push_back(it->get());
87 return workers;
139 std::vector<scoped_refptr<ModelSafeWorker> >* workers() { function in class:syncer::SyncerCommandTestBase
  /external/chromium_org/sync/internal_api/
internal_components_factory_impl.cc 39 const std::vector<ModelSafeWorker*>& workers,
47 connection_manager, directory, workers, extensions_activity,
  /external/chromium_org/sync/internal_api/test/
test_internal_components_factory.cc 33 const std::vector<ModelSafeWorker*>& workers,
44 connection_manager, directory, workers, monitor,
  /external/chromium_org/sync/internal_api/public/
internal_components_factory_impl.h 29 const std::vector<ModelSafeWorker*>& workers,
  /external/chromium_org/sync/internal_api/public/test/
test_internal_components_factory.h 35 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),
  /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.

Completed in 335 milliseconds

1 2 3 4