public class ContainersMonitorImpl extends AbstractService implements ContainersMonitor
Service.STATE
Constructor and Description |
---|
ContainersMonitorImpl(ContainerExecutor exec,
AsyncDispatcher dispatcher,
Context context) |
Modifier and Type | Method and Description |
---|---|
long |
getPmemAllocatedForContainers() |
long |
getVmemAllocatedForContainers() |
void |
handle(ContainersMonitorEvent monitoringEvent) |
boolean |
isPmemCheckEnabled()
Is the total physical memory check enabled?
|
boolean |
isVmemCheckEnabled()
Is the total virtual memory check enabled?
|
protected void |
serviceInit(Configuration conf)
All initialization code needed by a service.
|
protected void |
serviceStart()
Actions called during the INITED to STARTED transition.
|
protected void |
serviceStop()
Actions called during the transition to the STOPPED state.
|
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, registerServiceListener, start, stop, unregisterServiceListener, waitForServiceToStop
public ContainersMonitorImpl(ContainerExecutor exec, AsyncDispatcher dispatcher, Context context)
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 AbstractService
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 AbstractService
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 AbstractService
Exception
- if needed -these will be caught and logged.public long getVmemAllocatedForContainers()
getVmemAllocatedForContainers
in interface ResourceView
public boolean isPmemCheckEnabled()
isPmemCheckEnabled
in interface ResourceView
public long getPmemAllocatedForContainers()
getPmemAllocatedForContainers
in interface ResourceView
public boolean isVmemCheckEnabled()
isVmemCheckEnabled
in interface ResourceView
public void handle(ContainersMonitorEvent monitoringEvent)
handle
in interface EventHandler<ContainersMonitorEvent>
Copyright © 2013 Apache Software Foundation. All rights reserved.