- call() - Method in class io.parallec.core.actor.PingWorker.PingTask
-
- call() - Method in class io.parallec.core.actor.SshWorker.SshTask
-
- cancel() - Method in class io.parallec.core.actor.OperationWorker
-
Cancel.
- cancel(boolean) - Method in class io.parallec.core.ParallelTask
-
Cancel.
- cancelCancellable() - Method in class io.parallec.core.actor.HttpWorker
-
Cancel cancellable.
- cancelCancellable() - Method in class io.parallec.core.actor.OperationWorker
-
Cancel cancellable.
- cancelCancellable() - Method in class io.parallec.core.actor.PingWorker
-
Cancel cancellable.
- cancelCancellable() - Method in class io.parallec.core.actor.SshWorker
-
Cancel cancellable.
- cancelCancellable() - Method in class io.parallec.core.actor.TcpWorker
-
Cancel cancellable.
- cancelCancellable() - Method in class io.parallec.core.actor.UdpWorker
-
Cancel cancellable.
- cancelExistingIfAnyAndScheduleTimeoutCall() - Method in class io.parallec.core.actor.OperationWorker
-
201412: now consider the poller.
- cancelOnTargetHosts(List<String>) - Method in class io.parallec.core.ParallelTask
-
Cancel on target hosts.
- cancelRequestAndWorkerOnHost(List<String>) - Method in class io.parallec.core.actor.ExecutionManager
-
Cancel request and worker on host.
- cancelRequestAndWorkers() - Method in class io.parallec.core.actor.ExecutionManager
-
Cancel request and workers.
- CancelTaskOnHostRequest - Class in io.parallec.core.actor.message
-
The Class CancelTaskOnHostRequestToManager.
- CancelTaskOnHostRequest(List<String>) - Constructor for class io.parallec.core.actor.message.CancelTaskOnHostRequest
-
- CapacityAwareTaskScheduler - Class in io.parallec.core.task
-
A task scheduler runnable to check if there are capacity to run a task
from the waitQ.
- CapacityAwareTaskScheduler() - Constructor for class io.parallec.core.task.CapacityAwareTaskScheduler
-
- capacityUsed() - Method in class io.parallec.core.ParallelTask
-
Capacity used.
- cause - Variable in class io.parallec.core.actor.HttpWorker
-
The cause.
- cause - Variable in class io.parallec.core.actor.PingWorker
-
The cause.
- cause - Variable in class io.parallec.core.actor.SshWorker
-
The cause.
- cause - Variable in class io.parallec.core.actor.TcpWorker
-
The cause.
- cause - Variable in class io.parallec.core.actor.UdpWorker
-
The cause.
- channel - Variable in class io.parallec.core.actor.TcpWorker
-
The channel.
- channel - Variable in class io.parallec.core.actor.UdpWorker
-
The channel.
- channel - Variable in class io.parallec.core.commander.workflow.ssh.SshProvider
-
The channel.
- channelDisconnected(ChannelHandlerContext, ChannelStateEvent) - Method in class io.parallec.core.actor.TcpWorker.TcpChannelHandler
-
Why not use channelClosed: if fail to establish a channel
(e.g.
- channelFactory - Variable in class io.parallec.core.bean.tcp.TcpMeta
-
- channelFactory - Variable in class io.parallec.core.bean.udp.UdpMeta
-
- channelFactory - Variable in class io.parallec.core.resources.TcpUdpSshPingResourceStore
-
- channelIdle(ChannelHandlerContext, IdleStateEvent) - Method in class io.parallec.core.actor.TcpWorker.MyIdleHandler
-
- channelIdle(ChannelHandlerContext, IdleStateEvent) - Method in class io.parallec.core.actor.UdpWorker.MyIdleHandler
-
this case is like a read timeout where did not get anything from the
server for a long time.
- checkClientTrusted(X509Certificate[], String) - Method in class io.parallec.core.resources.AsyncHttpClientFactoryEmbed.CustomTrustManager
-
Check client trusted.
- checkServerTrusted(X509Certificate[], String) - Method in class io.parallec.core.resources.AsyncHttpClientFactoryEmbed.CustomTrustManager
-
Check server trusted.
- cleanInprogressJobMap() - Method in class io.parallec.core.ParallelClient
-
Clean inprogress job map.
- cleanInprogressJobMap() - Method in class io.parallec.core.task.ParallelTaskManager
-
also clean the waitQ.
- cleanWaitTaskQueue() - Method in class io.parallec.core.ParallelClient
-
Clean wait task queue.
- cleanWaitTaskQueue() - Method in class io.parallec.core.task.ParallelTaskManager
-
Clean wait task queue.
- client - Variable in class io.parallec.core.actor.HttpWorker
-
The client.
- client - Variable in class io.parallec.core.actor.OperationWorker
-
The client.
- command - Variable in class io.parallec.core.bean.tcp.TcpMeta
-
The command
- command - Variable in class io.parallec.core.bean.udp.UdpMeta
-
The command
- COMMAND_VAR_DEFAULT_REQUEST_CONTENT - Static variable in class io.parallec.core.util.PcConstants
-
The Constant COMMAND_VAR_DEFAULT_REQUEST_CONTENT.
- commandLine - Variable in class io.parallec.core.bean.ssh.SshMeta
-
The command line.
- commandMeta - Variable in class io.parallec.core.task.ParallelTaskBean
-
The command meta.
- concurrency - Variable in class io.parallec.core.ParallelTask
-
The concurrency.
- concurrency - Variable in class io.parallec.core.ParallelTaskBuilder
-
The concurrency.
- concurrencyDefault - Static variable in class io.parallec.core.config.ParallecGlobalConfig
-
The concurrency for each task.
- concurrencySshLimit - Static variable in class io.parallec.core.config.ParallecGlobalConfig
-
The max concurrency for SSH task.
- conf - Static variable in class io.parallec.core.actor.ActorConfig
-
The conf.
- config - Variable in class io.parallec.core.ParallelTask
-
The config.
- config - Variable in class io.parallec.core.ParallelTaskBuilder
-
The config using default values.
- ContinueToSendToBatchSenderAsstManager - Class in io.parallec.core.actor.message
-
The Class ContinueToSendToBatchSenderAsstManager.
- ContinueToSendToBatchSenderAsstManager(int) - Constructor for class io.parallec.core.actor.message.ContinueToSendToBatchSenderAsstManager
-
Instantiates a new continue to send to batch sender asst manager.
- copy(ParallelTask, ParallelTaskBean) - Static method in class io.parallec.core.util.BeanMapper
-
- count - Variable in class io.parallec.core.bean.SetAndCount
-
The count.
- cpuTimeInNanoSeconds - Variable in class io.parallec.core.monitor.MonitorProvider.ThreadData
-
The cpu time in nano seconds.
- createAndGetActorSystem() - Static method in class io.parallec.core.actor.ActorConfig
-
Create and get actor system.
- createRequest() - Method in class io.parallec.core.actor.HttpWorker
-
Creates the request.
- currentJvmPerformUsage - Variable in class io.parallec.core.monitor.MonitorProvider
-
The current jvm perform usage.
- currentProgress - Variable in class io.parallec.core.actor.poll.PollerData
-
The current progress.
- CustomTrustManager() - Constructor for class io.parallec.core.resources.AsyncHttpClientFactoryEmbed.CustomTrustManager
-