pl.edu.agh.age.services.worker.internal

Class ComputationService

java.lang.Object

pl.edu.agh.age.services.worker.internal.ComputationService

final class ComputationService
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ComputationService.Event
private static class	ComputationService.ExceptionHandler
private class	ComputationService.ExecutionListener
static class	ComputationService.State

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Set<CommunicationFacility>	communicationFacilities
private @Nullable ComputationContext	computationContext
private HazelcastDistributionUtilities	computeDistributionUtilities
private java.util.Map<HazelcastObjectNames.ConfigurationKey,java.lang.Object>	configurationMap
private EventBus	eventBus
private ListeningScheduledExecutorService	executorService
private static org.slf4j.Logger	logger
private IMap<java.lang.String,ComputationState>	nodeComputationState
private java.lang.String	nodeId
private StateMachineService<ComputationService.State,ComputationService.Event>	service
private TopologyService	topologyService

Constructor Summary

Constructors

Constructor and Description
ComputationService(java.util.Map<HazelcastObjectNames.ConfigurationKey,java.lang.Object> configurationMap, EventBus eventBus, IMap<java.lang.String,ComputationState> nodeComputationState, HazelcastDistributionUtilities computeDistributionUtilities, java.lang.String nodeId, java.util.Set<CommunicationFacility> communicationFacilities, TopologyService topologyService)

Method Summary

Modifier and Type	Method and Description
private void	changeErrorIfMaster(@Nullable java.lang.Throwable error)
private void	changeGlobalComputationStateIfMaster(ComputationState state)
private void	cleanUpAfterTask(FSM<ComputationService.State,ComputationService.Event> fsm)
private <T> java.util.Optional<T>	configurationValue(HazelcastObjectNames.ConfigurationKey key, java.lang.Class<T> klass)
private void	configure(FSM<ComputationService.State,ComputationService.Event> fsm)
private ComputationState	globalComputationState()
private ComputationState	nodeComputationState()
private void	setNodeComputationState(ComputationState state)
private void	startTask(FSM<ComputationService.State,ComputationService.Event> fsm)
private void	taskFailed(FSM<ComputationService.State,ComputationService.Event> fsm)
private void	taskFinished(FSM<ComputationService.State,ComputationService.Event> fsm)
private void	terminate(FSM<ComputationService.State,ComputationService.Event> fsm)
void	triggerCancel()
void	triggerClear()
void	triggerConfigurationLoad()
void	triggerStart()
void	triggerTermination()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

private static final org.slf4j.Logger logger

service

private final StateMachineService<ComputationService.State,ComputationService.Event> service

configurationMap

private final java.util.Map<HazelcastObjectNames.ConfigurationKey,java.lang.Object> configurationMap

executorService

private final ListeningScheduledExecutorService executorService

eventBus

private final EventBus eventBus

nodeComputationState

private final IMap<java.lang.String,ComputationState> nodeComputationState

computeDistributionUtilities

private final HazelcastDistributionUtilities computeDistributionUtilities

nodeId

private final java.lang.String nodeId

communicationFacilities

private final java.util.Set<CommunicationFacility> communicationFacilities

topologyService

private final TopologyService topologyService

computationContext

private @Nullable ComputationContext computationContext

Constructor Detail

ComputationService

ComputationService(java.util.Map<HazelcastObjectNames.ConfigurationKey,java.lang.Object> configurationMap,
                   EventBus eventBus,
                   IMap<java.lang.String,ComputationState> nodeComputationState,
                   HazelcastDistributionUtilities computeDistributionUtilities,
                   java.lang.String nodeId,
                   java.util.Set<CommunicationFacility> communicationFacilities,
                   TopologyService topologyService)

Method Detail

triggerConfigurationLoad

public void triggerConfigurationLoad()

triggerStart

public void triggerStart()

triggerCancel

public void triggerCancel()

triggerClear

public void triggerClear()

triggerTermination

public void triggerTermination()

configure

private void configure(FSM<ComputationService.State,ComputationService.Event> fsm)

startTask

private void startTask(FSM<ComputationService.State,ComputationService.Event> fsm)

taskFinished

private void taskFinished(FSM<ComputationService.State,ComputationService.Event> fsm)

taskFailed

private void taskFailed(FSM<ComputationService.State,ComputationService.Event> fsm)

cleanUpAfterTask

private void cleanUpAfterTask(FSM<ComputationService.State,ComputationService.Event> fsm)

terminate

private void terminate(FSM<ComputationService.State,ComputationService.Event> fsm)

configurationValue

private <T> java.util.Optional<T> configurationValue(HazelcastObjectNames.ConfigurationKey key,
                                                     java.lang.Class<T> klass)

globalComputationState

private ComputationState globalComputationState()

nodeComputationState

private ComputationState nodeComputationState()

setNodeComputationState

private void setNodeComputationState(ComputationState state)

changeGlobalComputationStateIfMaster

private void changeGlobalComputationStateIfMaster(ComputationState state)

changeErrorIfMaster

private void changeErrorIfMaster(@Nullable java.lang.Throwable error)