/** # Copyright (c) NVIDIA CORPORATION. All rights reserved. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. **/ package runtime import ( "errors" "fmt" "strings" "github.com/opencontainers/runtime-spec/specs-go" "github.com/NVIDIA/nvidia-container-toolkit/internal/config" "github.com/NVIDIA/nvidia-container-toolkit/internal/info" "github.com/NVIDIA/nvidia-container-toolkit/internal/logger" "github.com/NVIDIA/nvidia-container-toolkit/internal/lookup/root" ) // Run is an entry point that allows for idiomatic handling of errors // when calling from the main function. func (r rt) Run(argv []string) (rerr error) { defer func() { if rerr != nil { r.logger.Errorf("%v", rerr) } }() printVersion := hasVersionFlag(argv) if printVersion { fmt.Printf("%v version %v\n", "NVIDIA Container Runtime", info.GetVersionString(fmt.Sprintf("spec: %v", specs.Version))) } cfg, err := config.GetConfig() if err != nil { return fmt.Errorf("error loading config: %v", err) } r.logger.Update( cfg.NVIDIAContainerRuntimeConfig.DebugFilePath, cfg.NVIDIAContainerRuntimeConfig.LogLevel, argv, ) defer func() { if rerr != nil { r.logger.Errorf("%v", rerr) } if err := r.logger.Reset(); err != nil { rerr = errors.Join(rerr, fmt.Errorf("failed to reset logger: %v", err)) } }() // We apply some config updates here to ensure that the config is valid in // all cases. if r.modeOverride != "" { cfg.NVIDIAContainerRuntimeConfig.Mode = r.modeOverride } //nolint:staticcheck // TODO(elezar): We should swith the nvidia-container-runtime from using nvidia-ctk to using nvidia-cdi-hook. cfg.NVIDIACTKConfig.Path = config.ResolveNVIDIACTKPath(&logger.NullLogger{}, cfg.NVIDIACTKConfig.Path) cfg.NVIDIAContainerRuntimeHookConfig.Path = config.ResolveNVIDIAContainerRuntimeHookPath(&logger.NullLogger{}, cfg.NVIDIAContainerRuntimeHookConfig.Path) // Log the config at Trace to allow for debugging if required. r.logger.Tracef("Running with config: %+v", cfg) driver := root.New( root.WithLogger(r.logger), root.WithDriverRoot(cfg.NVIDIAContainerCLIConfig.Root), ) r.logger.Tracef("Command line arguments: %v", argv) runtime, err := newNVIDIAContainerRuntime(r.logger, cfg, argv, driver) if err != nil { return fmt.Errorf("failed to create NVIDIA Container Runtime: %v", err) } if printVersion { fmt.Print("\n") } return runtime.Exec(argv) } func (r rt) Errorf(format string, args ...interface{}) { r.logger.Errorf(format, args...) } // TODO: This should be refactored / combined with parseArgs in logger. func hasVersionFlag(args []string) bool { for i := 0; i < len(args); i++ { param := args[i] parts := strings.SplitN(param, "=", 2) trimmed := strings.TrimLeft(parts[0], "-") // If this is not a flag we continue if parts[0] == trimmed { continue } // Check the version flag if trimmed == "version" { return true } } return false }