public class NodeManager extends CompositeService implements EventHandler<NodeManagerEvent>
Modifier and Type | Class and Description |
---|---|
static class |
NodeManager.NMContext |
CompositeService.CompositeServiceShutdownHook
Service.STATE
Modifier and Type | Field and Description |
---|---|
protected NodeManagerMetrics |
metrics |
static int |
SHUTDOWN_HOOK_PRIORITY
Priority of the NodeManager shutdown hook.
|
STOP_ONLY_STARTED_SERVICES
Constructor and Description |
---|
NodeManager() |
addIfService, addService, getServices, removeService
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public static final int SHUTDOWN_HOOK_PRIORITY
protected final NodeManagerMetrics metrics
protected NodeStatusUpdater createNodeStatusUpdater(Context context, Dispatcher dispatcher, NodeHealthCheckerService healthChecker)
protected NodeResourceMonitor createNodeResourceMonitor()
protected ContainerManagerImpl createContainerManager(Context context, ContainerExecutor exec, DeletionService del, NodeStatusUpdater nodeStatusUpdater, ApplicationACLsManager aclsManager, LocalDirsHandlerService dirsHandler)
protected WebServer createWebServer(Context nmContext, ResourceView resourceView, ApplicationACLsManager aclsManager, LocalDirsHandlerService dirsHandler)
protected DeletionService createDeletionService(ContainerExecutor exec)
protected NodeManager.NMContext createNMContext(NMContainerTokenSecretManager containerTokenSecretManager, NMTokenSecretManagerInNM nmTokenSecretManager)
protected void doSecureLogin() throws IOException
IOException
protected void serviceInit(Configuration conf) throws Exception
AbstractService
AbstractService.init(Configuration)
prevents re-entrancy.
The base implementation checks to see if the subclass has created
a new configuration instance, and if so, updates the base class valueserviceInit
in class CompositeService
conf
- configurationException
- on a failure -these will be caught,
possibly wrapped, and wil; trigger a service stopprotected void serviceStart() throws Exception
AbstractService
AbstractService.start()
prevents re-entrancy.serviceStart
in class CompositeService
Exception
- if needed -these will be caught,
wrapped, and trigger a service stopprotected void serviceStop() throws Exception
AbstractService
AbstractService.stop()
prevents re-entrancy.
Implementations MUST write this to be robust against failures, including
checks for null references -and for the first failure to not stop other
attempts to shut down parts of the service.serviceStop
in class CompositeService
Exception
- if needed -these will be caught and logged.public String getName()
Service
getName
in interface Service
getName
in class AbstractService
protected void shutDown()
protected void resyncWithRM()
public NodeHealthCheckerService getNodeHealthChecker()
public void handle(NodeManagerEvent event)
handle
in interface EventHandler<NodeManagerEvent>
public Context getNMContext()
public static void main(String[] args)
@InterfaceAudience.Private public NodeStatusUpdater getNodeStatusUpdater()
Copyright © 2013 Apache Software Foundation. All rights reserved.