Package org.apache.storm.container.oci
Class RuncLibContainerManager
java.lang.Object
org.apache.storm.container.oci.OciContainerManager
org.apache.storm.container.oci.RuncLibContainerManager
- All Implemented Interfaces:
ResourceIsolationInterface
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.storm.container.oci.OciContainerManager
OciContainerManager.CmdType
-
Field Summary
Fields inherited from class org.apache.storm.container.oci.OciContainerManager
cgroupParent, cgroupRootPath, conf, memoryCgroupRootPath, memoryCoreAtRoot, nscdPath, readonlyBindmounts, readwriteBindmounts, seccompJsonFile, stormHome, TMP_DIR, validatedNumaMap, workerToCores, workerToCpu, workerToMemoryMb, workerToMemoryZone
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
areAllProcessesDead
(String user, String workerId) The container terminates if any process inside the container dies.void
This function will be called when the worker needs to shutdown.void
Kill the given worker forcefully.long
getMemoryUsage
(String user, String workerId, int port) Get the current memory usage of the a given worker.boolean
Return true if resources are being managed.void
Kill the given worker.void
launchWorkerProcess
(String user, String topologyId, Map<String, Object> topoConf, int port, String workerId, List<String> command, Map<String, String> env, String logPrefix, ExitCodeCallback processExitCallback, File targetDir) After reserving resources for the worker (i.e. calling reserveResourcesForWorker), this function can be used to launch worker process.void
Called when starting up.boolean
runProfilingCommand
(String user, String workerId, List<String> command, Map<String, String> env, String logPrefix, File targetDir) Run profiling command in the container.Methods inherited from class org.apache.storm.container.oci.OciContainerManager
commandFilePath, getImageName, getSystemFreeMemoryMb, reserveResourcesForWorker, writeToCommandFile
-
Constructor Details
-
RuncLibContainerManager
public RuncLibContainerManager()
-
-
Method Details
-
prepare
Description copied from interface:ResourceIsolationInterface
Called when starting up.- Specified by:
prepare
in interfaceResourceIsolationInterface
- Overrides:
prepare
in classOciContainerManager
- Parameters:
conf
- the cluster config- Throws:
IOException
- on any error.
-
launchWorkerProcess
public void launchWorkerProcess(String user, String topologyId, Map<String, Object> topoConf, int port, String workerId, List<String> command, Map<String, throws IOExceptionString> env, String logPrefix, ExitCodeCallback processExitCallback, File targetDir) Description copied from interface:ResourceIsolationInterface
After reserving resources for the worker (i.e. calling reserveResourcesForWorker), this function can be used to launch worker process.- Parameters:
user
- the user who runs the command astopologyId
- the Id of the topologytopoConf
- the topology configurationport
- the port where the worker is onworkerId
- the Id of the workercommand
- the command to runenv
- the environment to run the commandlogPrefix
- the prefix to include in the logsprocessExitCallback
- a callback for when the process exitstargetDir
- the working directory to run the command in- Throws:
IOException
- on I/O exception
-
getMemoryUsage
Description copied from interface:ResourceIsolationInterface
Get the current memory usage of the a given worker.- Parameters:
user
- the user that the worker is running asworkerId
- the id of the workerport
- the port of the worker- Returns:
- the amount of memory the worker is using in bytes or -1 if not supported
- Throws:
IOException
- on I/O exception
-
kill
Description copied from interface:ResourceIsolationInterface
Kill the given worker.- Parameters:
user
- the user that the worker is running asworkerId
- the id of the worker to kill- Throws:
IOException
- on I/O exception
-
forceKill
Description copied from interface:ResourceIsolationInterface
Kill the given worker forcefully.- Parameters:
user
- the user that the worker is running asworkerId
- the id of the worker to kill- Throws:
IOException
- on I/O exception
-
areAllProcessesDead
The container terminates if any process inside the container dies. So we only need to check if the initial process is alive or not.- Parameters:
user
- the user that the processes are running asworkerId
- the id of the worker to kill- Returns:
- true if all processes are dead; false otherwise
- Throws:
IOException
- on I/O exception
-
cleanup
Description copied from interface:ResourceIsolationInterface
This function will be called when the worker needs to shutdown. This function should include logic to clean up after a worker is shutdown.- Specified by:
cleanup
in interfaceResourceIsolationInterface
- Overrides:
cleanup
in classOciContainerManager
- Parameters:
user
- the user of the workerworkerId
- worker id to shutdown and clean up afterport
- the port of the worker- Throws:
IOException
-
runProfilingCommand
public boolean runProfilingCommand(String user, String workerId, List<String> command, Map<String, String> env, String logPrefix, File targetDir) throws IOException, InterruptedExceptionRun profiling command in the container.- Parameters:
user
- the user that the worker is running asworkerId
- the id of the workercommand
- the command to run. The profiler to be used is configured in worker-launcher.cfg.env
- the environment to run the commandlogPrefix
- the prefix to include in the logstargetDir
- the working directory to run the command in- Returns:
- true if the command succeeds, false otherwise.
- Throws:
IOException
- on I/O exceptionInterruptedException
- if interrupted
-
isResourceManaged
public boolean isResourceManaged()Description copied from interface:ResourceIsolationInterface
Return true if resources are being managed. TheDefaultResourceIsolationManager
will have it return false since it doesn't really manage resources.- Returns:
- true if resources are being managed.
-