Consolidate logic for building nvidiaConfig into a single function

Signed-off-by: Kevin Klues <kklues@nvidia.com>
This commit is contained in:
Kevin Klues 2020-07-23 11:04:03 +00:00
parent 430dda41e9
commit cc0a22a6d9

View File

@ -198,21 +198,44 @@ func isLegacyCUDAImage(env map[string]string) bool {
return len(legacyCudaVersion) > 0 && len(cudaRequire) == 0 return len(legacyCudaVersion) > 0 && len(cudaRequire) == 0
} }
func getDevices(env map[string]string) *string { func getDevices(env map[string]string, legacyImage bool) *string {
gpuVars := []string{envNVVisibleDevices} // Build a list of envvars to consider.
envVars := []string{envNVVisibleDevices}
if envSwarmGPU != nil { if envSwarmGPU != nil {
// The Swarm resource has higher precedence. // The Swarm envvar has higher precedence.
gpuVars = append([]string{*envSwarmGPU}, gpuVars...) envVars = append([]string{*envSwarmGPU}, envVars...)
} }
for _, gpuVar := range gpuVars { // Grab a reference to devices from the first envvar
if devices, ok := env[gpuVar]; ok { // in the list that actually exists in the environment.
return &devices var devices *string
for _, envVar := range envVars {
if devs, ok := env[envVar]; ok {
devices = &devs
} }
} }
// Environment variable unset with legacy image: default to "all".
if devices == nil && legacyImage {
all := "all"
return &all
}
// Environment variable unset or empty or "void": return nil
if devices == nil || len(*devices) == 0 || *devices == "void" {
return nil return nil
} }
// Environment variable set to "none": reset to "".
if *devices == "none" {
empty := ""
return &empty
}
// Any other value.
return devices
}
func getMigConfigDevices(env map[string]string) *string { func getMigConfigDevices(env map[string]string) *string {
if devices, ok := env[envNVMigConfigDevices]; ok { if devices, ok := env[envNVMigConfigDevices]; ok {
return &devices return &devices
@ -227,14 +250,37 @@ func getMigMonitorDevices(env map[string]string) *string {
return nil return nil
} }
func getDriverCapabilities(env map[string]string) *string { func getDriverCapabilities(env map[string]string, legacyImage bool) *string {
if capabilities, ok := env[envNVDriverCapabilities]; ok { // Grab a reference to the capabilities from the envvar
return &capabilities // if it actually exists in the environment.
} var capabilities *string
return nil if caps, ok := env[envNVDriverCapabilities]; ok {
capabilities = &caps
} }
func getRequirements(env map[string]string) []string { // Environment variable unset with legacy image: set all capabilities.
if capabilities == nil && legacyImage {
allCaps := allDriverCapabilities
return &allCaps
}
// Environment variable unset or set but empty: set default capabilities.
if capabilities == nil || len(*capabilities) == 0 {
defaultCaps := defaultDriverCapabilities
return &defaultCaps
}
// Environment variable set to "all": set all capabilities.
if *capabilities == "all" {
allCaps := allDriverCapabilities
return &allCaps
}
// Any other value
return capabilities
}
func getRequirements(env map[string]string, legacyImage bool) []string {
// All variables with the "NVIDIA_REQUIRE_" prefix are passed to nvidia-container-cli // All variables with the "NVIDIA_REQUIRE_" prefix are passed to nvidia-container-cli
var requirements []string var requirements []string
for name, value := range env { for name, value := range env {
@ -242,22 +288,23 @@ func getRequirements(env map[string]string) []string {
requirements = append(requirements, value) requirements = append(requirements, value)
} }
} }
if legacyImage {
vmaj, vmin, _ := parseCudaVersion(env[envCUDAVersion])
cudaRequire := fmt.Sprintf("cuda>=%d.%d", vmaj, vmin)
requirements = append(requirements, cudaRequire)
}
return requirements return requirements
} }
func getNvidiaConfig(env map[string]string, privileged bool) *nvidiaConfig { func getNvidiaConfig(env map[string]string, privileged bool) *nvidiaConfig {
legacyImage := isLegacyCUDAImage(env)
var devices string var devices string
d := getDevices(env) if d := getDevices(env, legacyImage); d != nil {
if d == nil || len(*d) == 0 || *d == "void" {
// Environment variable unset or empty or "void": not a GPU container.
return nil
}
// Environment variable non-empty and not "void".
devices = *d devices = *d
} else {
if devices == "none" { // 'nil' devices means this is not a GPU container.
devices = "" return nil
} }
var migConfigDevices string var migConfigDevices string
@ -277,18 +324,11 @@ func getNvidiaConfig(env map[string]string, privileged bool) *nvidiaConfig {
} }
var driverCapabilities string var driverCapabilities string
if c := getDriverCapabilities(env); c == nil || len(*c) == 0 { if c := getDriverCapabilities(env, legacyImage); c != nil {
// Environment variable unset or set but empty: use default capability.
driverCapabilities = defaultDriverCapabilities
} else {
// Environment variable set and non-empty.
driverCapabilities = *c driverCapabilities = *c
} }
if driverCapabilities == "all" {
driverCapabilities = allDriverCapabilities
}
requirements := getRequirements(env) requirements := getRequirements(env, legacyImage)
// Don't fail on invalid values. // Don't fail on invalid values.
disableRequire, _ := strconv.ParseBool(env[envNVDisableRequire]) disableRequire, _ := strconv.ParseBool(env[envNVDisableRequire])