docker-runner/dev.ust.zinc.grader.virtualization.docker/EngineTrackedDaemonHost

EngineTrackedDaemonHost

internal data class EngineTrackedDaemonHost(val daemon: DockerDaemon, val isMainHost: Boolean) : DaemonHost

Constructors

constructor(daemon: DockerDaemon, isMainHost: Boolean)

Types

Companion

object Companion

TrackedRunner

data class TrackedRunner(val runner: Runner, val allocTime: Instant) : DaemonHost.TrackedRunner

Properties

_gpuDevices

private var _gpuDevices: Option<MutableSet<GpuDevice>>

_managedRunners

private val _managedRunners: MutableList<Runner>

cpuFree

open override val cpuFree: Double

The current amount of unallocated CPU.

cpuOvercommitRatio

protected val cpuOvercommitRatio: Double

daemon

open override val daemon: DockerDaemon

Encapsulated Docker daemon.

engineInfo

private val engineInfo: Info

gpuAllocation

open override val gpuAllocation: Map<GpuDevice, Boolean>

Mapping of all GPUs on the host system to its occupancy status.

gpuCapabilities

open override val gpuCapabilities: Map<GpuDevice, Runner?>

Mapping of all GPUs on the host system to the allocated Runner.

hostReservedCpu

protected val hostReservedCpu: Double

hostReservedMem

protected val hostReservedMem: Long

isConnected

val isConnected: Boolean

Whether this daemon is connected to the Docker Engine.

isDispatchable

open val isDispatchable: Boolean

Whether this daemon can be used for dispatched.

isInitialized

open override val isInitialized: Boolean

Whether this daemon is initialized.

isMainHost

open override val isMainHost: Boolean

Whether to treat this daemon host as a main host, i.e. reserve more resources for the host OS and its services.

managedRunners

open val managedRunners: List<Runner>

A List of all runners managed by this DaemonHost.

maxCpuAlloc

open override val maxCpuAlloc: Double

The maximum amount of allocatable CPU by runners.

maxMemAlloc

open override val maxMemAlloc: Long

The maximum amount of allocatable memory by runners.

memFree

open override val memFree: Long

The current amount of unallocated memory.

memOvercommitRatio

protected val memOvercommitRatio: Double

reservationContainers

private val reservationContainers: List<Container>

trackedRunners

open override val trackedRunners: List<DaemonHost.TrackedRunner>

A List of all runners tracked by this DaemonHost, stored as instances of TrackedRunner.

Functions

addRunnerInstance

open override fun addRunnerInstance(runner: Runner)

Binds runner to this Docker daemon.

canSatisfyCpuLimit

fun canSatisfyCpuLimit(context: DockerContext): Boolean

canSatisfyGpuRequest

fun canSatisfyGpuRequest(context: DockerContext): Boolean

canSatisfyMemLimit

fun canSatisfyMemLimit(context: DockerContext): Boolean

canSatisfyWithMaxResource

fun canSatisfyWithMaxResource(context: DockerContext): Boolean

containsRunner

fun containsRunner(runner: Runner): Boolean

findReservationForRunner

private fun findReservationForRunner(runner: Runner): Container?

getAllocatedGpu

open override fun getAllocatedGpu(runner: Runner): GpuDevice?

getOutputFromContainer

private fun getOutputFromContainer(cmd: String, timeout: Duration, containerConfig: CreateContainerCmd.() -> Unit = {}): String

Wrapper for getting the stdout output from a container using the given cmd.

queryGpuCapabilities

protected fun queryGpuCapabilities(): List<GpuDevice>

Queries the list of GPUs present on this daemon host.

removeRunnerInstance

open override fun removeRunnerInstance(runner: Runner)

Unbinds runner to this Docker daemon.

updateEngineInfo

open override fun updateEngineInfo()

Tries to update the information of the engine from the daemon.