/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/deploy/ |
H A D | StandaloneDynamicAllocationSuite.scala | 101 assert(apps.head.executors.size === 0) 106 assert(apps.head.executors.size === 1) 111 assert(apps.head.executors.size === 2) 116 assert(apps.head.executors.size === 2) 121 assert(apps.head.executors.size === 1) 368 val executors = getExecutorIds(sc) constant 369 assert(executors.size === 2) 391 val executors = getExecutorIds(sc) constant 393 assert(executors.size === 2) 432 val executors = getExecutorIds(sc) constant [all …]
|
/dports/emulators/mess/mame-mame0226/3rdparty/asio/src/examples/cpp14/ |
H A D | Makefile.am | 19 executors/actor \ 20 executors/async_1 \ 21 executors/async_2 \ 22 executors/bank_account_1 \ 23 executors/bank_account_2 \ 24 executors/fork_join \ 25 executors/pipeline \ 26 executors/priority_scheduler \ 37 executors_actor_SOURCES = executors/actor.cpp 38 executors_async_1_SOURCES = executors/async_1.cpp [all …]
|
/dports/emulators/mame/mame-mame0226/3rdparty/asio/src/examples/cpp14/ |
H A D | Makefile.am | 19 executors/actor \ 20 executors/async_1 \ 21 executors/async_2 \ 22 executors/bank_account_1 \ 23 executors/bank_account_2 \ 24 executors/fork_join \ 25 executors/pipeline \ 26 executors/priority_scheduler \ 37 executors_actor_SOURCES = executors/actor.cpp 38 executors_async_1_SOURCES = executors/async_1.cpp [all …]
|
/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/modules/asio-standalone/asio/src/examples/cpp14/ |
H A D | Makefile.am | 19 executors/actor \ 20 executors/async_1 \ 21 executors/async_2 \ 22 executors/bank_account_1 \ 23 executors/bank_account_2 \ 24 executors/fork_join \ 25 executors/pipeline \ 26 executors/priority_scheduler \ 37 executors_actor_SOURCES = executors/actor.cpp 38 executors_async_1_SOURCES = executors/async_1.cpp [all …]
|
/dports/multimedia/obs-websocket/obs-websocket-4.8.0/deps/asio/asio/src/examples/cpp14/ |
H A D | Makefile.am | 19 executors/actor \ 20 executors/async_1 \ 21 executors/async_2 \ 22 executors/bank_account_1 \ 23 executors/bank_account_2 \ 24 executors/fork_join \ 25 executors/pipeline \ 26 executors/priority_scheduler \ 37 executors_actor_SOURCES = executors/actor.cpp 38 executors_async_1_SOURCES = executors/async_1.cpp [all …]
|
/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/scheduler/ |
H A D | ReceiverSchedulingPolicySuite.scala | 40 0, Some("host1"), receiverTrackingInfoMap, executors) 50 1, None, receiverTrackingInfoMap, executors) 51 assert(scheduledLocations.toSet === executors.tail.toSet) 55 val executors = Seq( constant 76 4, None, receiverTrackingInfoMap, executors) 88 val executors = (0 until 3).map(executorId => constant 104 val executors = (0 until 6).map(executorId => constant 122 val executors = (0 until 3).map(executorId => constant 130 assert(executors.size == 1) 131 executors.foreach { l => [all …]
|
/dports/www/restbed/restbed-4.8/dependency/asio/asio/src/examples/cpp14/ |
H A D | Makefile.am | 19 executors/actor \ 20 executors/async_1 \ 21 executors/async_2 \ 22 executors/bank_account_1 \ 23 executors/bank_account_2 \ 24 executors/fork_join \ 25 executors/pipeline \ 26 executors/priority_scheduler \ 45 executors_actor_SOURCES = executors/actor.cpp 46 executors_async_1_SOURCES = executors/async_1.cpp [all …]
|
/dports/net/asio/asio-1.16.0/src/examples/cpp14/ |
H A D | Makefile.am | 19 executors/actor \ 20 executors/async_1 \ 21 executors/async_2 \ 22 executors/bank_account_1 \ 23 executors/bank_account_2 \ 24 executors/fork_join \ 25 executors/pipeline \ 26 executors/priority_scheduler \ 45 executors_actor_SOURCES = executors/actor.cpp 46 executors_async_1_SOURCES = executors/async_1.cpp [all …]
|
H A D | Makefile.in | 99 executors/actor$(EXEEXT) executors/async_1$(EXEEXT) \ 100 executors/async_2$(EXEEXT) executors/bank_account_1$(EXEEXT) \ 101 executors/bank_account_2$(EXEEXT) executors/fork_join$(EXEEXT) \ 288 executors/$(DEPDIR)/actor.Po executors/$(DEPDIR)/async_1.Po \ 622 executors/actor.$(OBJEXT): executors/$(am__dirstamp) \ 628 executors/async_1.$(OBJEXT): executors/$(am__dirstamp) \ 634 executors/async_2.$(OBJEXT): executors/$(am__dirstamp) \ 640 executors/bank_account_1.$(OBJEXT): executors/$(am__dirstamp) \ 646 executors/bank_account_2.$(OBJEXT): executors/$(am__dirstamp) \ 652 executors/fork_join.$(OBJEXT): executors/$(am__dirstamp) \ [all …]
|
/dports/databases/pymongo/pymongo-3.12.0/test/ |
H A D | test_monitor.py | 38 executors = [] 40 executors.append(server._monitor._executor) 41 executors.append(server._monitor._rtt_monitor._executor) 42 executors.append(client._kill_cursors_executor) 44 return [e for e in executors if e is not None] 57 executors = get_executors(client) 58 self.assertEqual(len(executors), 4) 64 del executors 74 executors = get_executors(client) 75 self.assertEqual(len(executors), 4) [all …]
|
/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/modules/asio-standalone/asio/src/examples/cpp11/ |
H A D | Makefile.am | 23 executors/actor \ 24 executors/bank_account_1 \ 25 executors/bank_account_2 \ 26 executors/fork_join \ 27 executors/pipeline \ 28 executors/priority_scheduler \ 54 executors_actor_SOURCES = executors/actor.cpp 55 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp 56 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp 57 executors_fork_join_SOURCES = executors/fork_join.cpp [all …]
|
/dports/emulators/mess/mame-mame0226/3rdparty/asio/src/examples/cpp11/ |
H A D | Makefile.am | 23 executors/actor \ 24 executors/bank_account_1 \ 25 executors/bank_account_2 \ 26 executors/fork_join \ 27 executors/pipeline \ 28 executors/priority_scheduler \ 54 executors_actor_SOURCES = executors/actor.cpp 55 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp 56 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp 57 executors_fork_join_SOURCES = executors/fork_join.cpp [all …]
|
/dports/emulators/mame/mame-mame0226/3rdparty/asio/src/examples/cpp11/ |
H A D | Makefile.am | 23 executors/actor \ 24 executors/bank_account_1 \ 25 executors/bank_account_2 \ 26 executors/fork_join \ 27 executors/pipeline \ 28 executors/priority_scheduler \ 54 executors_actor_SOURCES = executors/actor.cpp 55 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp 56 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp 57 executors_fork_join_SOURCES = executors/fork_join.cpp [all …]
|
/dports/devel/grpc130/grpc-1.30.2/src/core/lib/iomgr/ |
H A D | executor.cc | 61 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short() 66 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long() 71 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short() 76 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long() 395 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll() 397 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll() 400 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll() 401 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll() 437 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll() 438 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll() [all …]
|
/dports/devel/grpc/grpc-1.42.0/src/core/lib/iomgr/ |
H A D | executor.cc | 60 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short() 65 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long() 70 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short() 75 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long() 381 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll() 383 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll() 386 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll() 387 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll() 423 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll() 424 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll() [all …]
|
/dports/devel/grpc134/grpc-1.34.1/src/core/lib/iomgr/ |
H A D | executor.cc | 61 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short() 66 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long() 71 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short() 76 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long() 395 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll() 397 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll() 400 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll() 401 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll() 437 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll() 438 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll() [all …]
|
/dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/iomgr/ |
H A D | executor.cc | 60 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short() 65 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long() 70 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short() 75 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long() 381 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll() 383 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll() 386 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll() 387 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll() 423 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll() 424 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll() [all …]
|
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/lib/iomgr/ |
H A D | executor.cc | 60 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short() 65 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long() 70 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short() 75 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long() 378 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll() 380 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll() 383 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll() 384 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Init(); in InitAll() 420 delete executors[static_cast<size_t>(ExecutorType::DEFAULT)]; in ShutdownAll() 421 delete executors[static_cast<size_t>(ExecutorType::RESOLVER)]; in ShutdownAll() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ |
H A D | RamDiskAsyncLazyPersistService.java | 55 private Map<File, ThreadPoolExecutor> executors field in RamDiskAsyncLazyPersistService 88 executors.put(volume, executor); in addExecutorForVolume() 96 if (executors == null) { in addVolume() 99 ThreadPoolExecutor executor = executors.get(volume); in addVolume() 111 if (executors == null) { in removeVolume() 120 executors.remove(volume); in removeVolume() 131 if (executors == null) { in queryVolume() 142 if (executors == null) { in execute() 145 ThreadPoolExecutor executor = executors.get(root); in execute() 159 if (executors == null) { in shutdown() [all …]
|
H A D | FsDatasetAsyncDiskService.java | 72 private Map<File, ThreadPoolExecutor> executors field in FsDatasetAsyncDiskService 116 executors.put(volume, executor); in addExecutorForVolume() 124 if (executors == null) { in addVolume() 127 ThreadPoolExecutor executor = executors.get(volume); in addVolume() 139 if (executors == null) { in removeVolume() 142 ThreadPoolExecutor executor = executors.get(volume); in removeVolume() 148 executors.remove(volume); in removeVolume() 164 if (executors == null) { in execute() 167 ThreadPoolExecutor executor = executors.get(root); in execute() 181 if (executors == null) { in shutdown() [all …]
|
/dports/multimedia/obs-websocket/obs-websocket-4.8.0/deps/asio/asio/src/examples/cpp11/ |
H A D | Makefile.am | 23 executors/actor \ 24 executors/bank_account_1 \ 25 executors/bank_account_2 \ 26 executors/fork_join \ 27 executors/pipeline \ 28 executors/priority_scheduler \ 68 executors_actor_SOURCES = executors/actor.cpp 69 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp 70 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp 71 executors_fork_join_SOURCES = executors/fork_join.cpp [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/iomgr/ |
H A D | executor.cc | 58 Executor* executors[static_cast<size_t>(ExecutorType::NUM_EXECUTORS)]; variable 61 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short() 66 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long() 71 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short() 76 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long() 410 executors[static_cast<size_t>(ExecutorType::DEFAULT)] = in InitAll() 412 executors[static_cast<size_t>(ExecutorType::RESOLVER)] = in InitAll() 415 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Init(); in InitAll() 457 executors[static_cast<size_t>(ExecutorType::DEFAULT)]); in ShutdownAll() 459 executors[static_cast<size_t>(ExecutorType::RESOLVER)]); in ShutdownAll() [all …]
|
/dports/www/restbed/restbed-4.8/dependency/asio/asio/src/examples/cpp11/ |
H A D | Makefile.am | 23 executors/actor \ 24 executors/bank_account_1 \ 25 executors/bank_account_2 \ 26 executors/fork_join \ 27 executors/pipeline \ 28 executors/priority_scheduler \ 91 executors_actor_SOURCES = executors/actor.cpp 92 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp 93 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp 94 executors_fork_join_SOURCES = executors/fork_join.cpp [all …]
|
/dports/net/asio/asio-1.16.0/src/examples/cpp11/ |
H A D | Makefile.am | 23 executors/actor \ 24 executors/bank_account_1 \ 25 executors/bank_account_2 \ 26 executors/fork_join \ 27 executors/pipeline \ 28 executors/priority_scheduler \ 90 executors_actor_SOURCES = executors/actor.cpp 91 executors_bank_account_1_SOURCES = executors/bank_account_1.cpp 92 executors_bank_account_2_SOURCES = executors/bank_account_2.cpp 93 executors_fork_join_SOURCES = executors/fork_join.cpp [all …]
|
/dports/devel/hpx/hpx-1.2.1/hpx/parallel/executors/ |
H A D | service_executors.hpp | 27 using service_executor = threads::executors::service_executor; 36 using io_pool_executor = threads::executors::io_pool_executor; 45 using parcel_pool_executor = threads::executors::parcel_pool_executor; 54 using timer_pool_executor = threads::executors::timer_pool_executor; 63 using main_pool_executor = threads::executors::main_pool_executor;
|