+++ /dev/null
-// Copyright (C) The Arvados Authors. All rights reserved.
-//
-// SPDX-License-Identifier: AGPL-3.0
-
-package main
-
-import (
- "encoding/json"
- "flag"
- "fmt"
- "git.curoverse.com/arvados.git/sdk/go/config"
- "io"
- "io/ioutil"
- "log"
- "net"
- "net/http"
- "os"
- "os/exec"
- "os/signal"
- "regexp"
- "strings"
- "syscall"
- "time"
-)
-
-var listener net.Listener
-
-type report struct {
- Type string
- Msg string
-}
-
-type bundle struct {
- sourceDir string
- name string
- packageType string
- versionType string
- versionPrefix string
-}
-
-type result struct {
- RequestHash string
- GitHash string
- Versions map[string]map[string]string
- Cached bool
- Elapsed string
-}
-
-type about struct {
- Name string
- Version string
- URL string
-}
-
-type help struct {
- Usage string
-}
-
-// Config structure
-type Config struct {
- DirPath string
- CacheDirPath string
- GitExecutablePath string
- ListenPort string
- ShortHashLength string
-
- Packages []bundle
-}
-
-var theConfig Config
-
-const defaultConfigPath = "/etc/arvados/version-server/version-server.yml"
-
-func loadPackages() (packages []bundle) {
- packages = []bundle{
- {
- sourceDir: ".",
- name: "arvados-src",
- packageType: "distribution",
- versionType: "git",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "apps/workbench",
- name: "arvados-workbench",
- packageType: "distribution",
- versionType: "git",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "sdk/cwl",
- name: "python-arvados-cwl-runner",
- packageType: "distribution",
- versionType: "python",
- versionPrefix: "1.0",
- },
- {
- sourceDir: "sdk/cwl",
- name: "arvados-cwl-runner",
- packageType: "python",
- versionType: "python",
- versionPrefix: "1.0",
- },
- {
- sourceDir: "sdk/cwl",
- name: "arvados/jobs",
- packageType: "docker",
- versionType: "docker",
- versionPrefix: "",
- },
- {
- sourceDir: "sdk/go/crunchrunner",
- name: "crunchrunner",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "sdk/pam",
- name: "libpam-arvados",
- packageType: "distribution",
- versionType: "python",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "sdk/pam",
- name: "arvados-pam",
- packageType: "python",
- versionType: "python",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "sdk/python",
- name: "python-arvados-python-client",
- packageType: "distribution",
- versionType: "python",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "sdk/python",
- name: "arvados-python-client",
- packageType: "python",
- versionType: "python",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/api",
- name: "arvados-api-server",
- packageType: "distribution",
- versionType: "git",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/arv-git-httpd",
- name: "arvados-git-httpd",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/crunch-dispatch-local",
- name: "crunch-dispatch-local",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/crunch-dispatch-slurm",
- name: "crunch-dispatch-slurm",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/crunch-run",
- name: "crunch-run",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/crunchstat",
- name: "crunchstat",
- packageType: "distribution",
- versionType: "git",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/dockercleaner",
- name: "arvados-docker-cleaner",
- packageType: "distribution",
- versionType: "python",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/fuse",
- name: "python-arvados-fuse",
- packageType: "distribution",
- versionType: "python",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/fuse",
- name: "arvados_fuse",
- packageType: "python",
- versionType: "python",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/keep-balance",
- name: "keep-balance",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/keepproxy",
- name: "keepproxy",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/keepstore",
- name: "keepstore",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/keep-web",
- name: "keep-web",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/nodemanager",
- name: "arvados-node-manager",
- packageType: "distribution",
- versionType: "python",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/nodemanager",
- name: "arvados-node-manager",
- packageType: "python",
- versionType: "python",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/ws",
- name: "arvados-ws",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "tools/crunchstat-summary",
- name: "crunchstat-summary",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "tools/keep-block-check",
- name: "keep-block-check",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "tools/keep-exercise",
- name: "keep-exercise",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "tools/keep-rsync",
- name: "keep-rsync",
- packageType: "distribution",
- versionType: "go",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "sdk/ruby",
- name: "arvados",
- packageType: "gem",
- versionType: "ruby",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "sdk/cli",
- name: "arvados-cli",
- packageType: "gem",
- versionType: "ruby",
- versionPrefix: "0.1",
- },
- {
- sourceDir: "services/login-sync",
- name: "arvados-login-sync",
- packageType: "gem",
- versionType: "ruby",
- versionPrefix: "0.1",
- },
- }
- return
-}
-
-func lookupInCache(hash string) (result, error) {
- statData, err := os.Stat(theConfig.CacheDirPath)
- if os.IsNotExist(err) {
- err = os.MkdirAll(theConfig.CacheDirPath, 0700)
- if err != nil {
- logError([]string{"Error creating directory", theConfig.CacheDirPath, ":", err.Error()})
- }
- } else {
- if !statData.IsDir() {
- logError([]string{"The path", theConfig.CacheDirPath, "is not a directory"})
- return result{}, fmt.Errorf("The path %s is not a directory", theConfig.CacheDirPath)
- }
- }
- file, e := ioutil.ReadFile(theConfig.CacheDirPath + "/" + hash)
- if e != nil {
- return result{}, fmt.Errorf("File error: %v\n", e)
- }
- var m result
- err = json.Unmarshal(file, &m)
- return m, err
-}
-
-func writeToCache(hash string, data result) (err error) {
- statData, err := os.Stat(theConfig.CacheDirPath)
- if os.IsNotExist(err) {
- err = os.MkdirAll(theConfig.CacheDirPath, 0700)
- if err != nil {
- logError([]string{"Error creating directory", theConfig.CacheDirPath, ":", err.Error()})
- }
- } else {
- if !statData.IsDir() {
- logError([]string{"The path", theConfig.CacheDirPath, "is not a directory"})
- return fmt.Errorf("The path %s is not a directory", theConfig.CacheDirPath)
- }
- }
-
- jsonData, err := json.Marshal(data)
- if err != nil {
- return
- }
- err = ioutil.WriteFile(theConfig.CacheDirPath+"/"+hash, jsonData, 0644)
- return
-}
-
-func prepareGitPath(hash string) error {
- statData, err := os.Stat(theConfig.DirPath)
- if os.IsNotExist(err) {
- err = os.MkdirAll(theConfig.DirPath, 0700)
- if err != nil {
- logError([]string{"Error creating directory", theConfig.DirPath, ":", err.Error()})
- return fmt.Errorf("Error creating directory %s", theConfig.DirPath)
- }
- cmdArgs := []string{"clone", "https://github.com/curoverse/arvados.git", theConfig.DirPath}
- if _, err = exec.Command(theConfig.GitExecutablePath, cmdArgs...).Output(); err != nil {
- logError([]string{"There was an error running the command ", theConfig.GitExecutablePath, strings.Join(cmdArgs, " "), err.Error()})
- return fmt.Errorf("There was an error cloning the repository")
- }
- } else {
- if !statData.IsDir() {
- logError([]string{"The path", theConfig.DirPath, "is not a directory"})
- return fmt.Errorf("The path %s is not a directory", theConfig.DirPath)
- }
- }
- return nil
-}
-
-func prepareGitCheckout(hash string) (string, error) {
- err := prepareGitPath(hash)
- if err != nil {
- return "", err
- }
- err = os.Chdir(theConfig.DirPath)
- if err != nil {
- logError([]string{"Error changing directory to", theConfig.DirPath})
- return "", fmt.Errorf("Error changing directory to %s", theConfig.DirPath)
- }
- cmdArgs := []string{"fetch", "--all"}
- if _, err := exec.Command(theConfig.GitExecutablePath, cmdArgs...).Output(); err != nil {
- logError([]string{"There was an error running the command ", theConfig.GitExecutablePath, strings.Join(cmdArgs, " "), err.Error()})
- return "", fmt.Errorf("There was an error fetching all remotes")
- }
- if hash == "" {
- hash = "master"
- }
- cmdArgs = []string{"checkout", hash}
- if _, err := exec.Command(theConfig.GitExecutablePath, cmdArgs...).Output(); err != nil {
- logError([]string{"There was an error running the command ", theConfig.GitExecutablePath, strings.Join(cmdArgs, " "), err.Error()})
- return "", fmt.Errorf("There was an error checking out the requested revision")
- }
- if hash == "master" {
- cmdArgs := []string{"reset", "--hard", "origin/master"}
- if _, err := exec.Command(theConfig.GitExecutablePath, cmdArgs...).Output(); err != nil {
- logError([]string{"There was an error running the command ", theConfig.GitExecutablePath, strings.Join(cmdArgs, " "), err.Error()})
- return "", fmt.Errorf("There was an error fetching all remotes")
- }
- }
- return "", nil
-}
-
-// Generates the hash for the latest git commit for the current working directory
-func gitHashFull() (string, error) {
- cmdArgs := []string{"log", "-n1", "--first-parent", "--max-count=1", "--format=format:%H", "."}
- cmdOut, err := exec.Command(theConfig.GitExecutablePath, cmdArgs...).Output()
- if err != nil {
- logError([]string{"There was an error running the command ", theConfig.GitExecutablePath, strings.Join(cmdArgs, " "), err.Error()})
- return "", fmt.Errorf("There was an error getting the git hash for this revision")
- }
- return string(cmdOut), nil
-}
-
-// Generates a version number from the git log for the current working directory
-func versionFromGit(prefix string) (string, error) {
- gitTs, err := getGitTs()
- if err != nil {
- return "", err
- }
- cmdArgs := []string{"log", "-n1", "--first-parent", "--max-count=1", "--format=format:%h", "--abbrev=" + theConfig.ShortHashLength, "."}
- gitHash, err := exec.Command(theConfig.GitExecutablePath, cmdArgs...).Output()
- if err != nil {
- logError([]string{"There was an error running the command ", theConfig.GitExecutablePath, strings.Join(cmdArgs, " "), err.Error()})
- return "", fmt.Errorf("There was an error getting the git hash for this revision")
- }
- cmdName := "/bin/date"
- cmdArgs = []string{"-ud", "@" + string(gitTs), "+%Y%m%d%H%M%S"}
- date, err := exec.Command(cmdName, cmdArgs...).Output()
- if err != nil {
- logError([]string{"There was an error running the command ", cmdName, strings.Join(cmdArgs, " "), err.Error()})
- return "", fmt.Errorf("There was an error converting the datestamp for this revision")
- }
-
- return fmt.Sprintf("%s.%s.%s", strings.TrimSpace(prefix), strings.TrimSpace(string(date)), strings.TrimSpace(string(gitHash))), nil
-}
-
-// Generates a python package version number from the git log for the current working directory
-func rubyVersionFromGit(prefix string) (string, error) {
- gitTs, err := getGitTs()
- if err != nil {
- return "", err
- }
- cmdName := "/bin/date"
- cmdArgs := []string{"-ud", "@" + string(gitTs), "+%Y%m%d%H%M%S"}
- date, err := exec.Command(cmdName, cmdArgs...).Output()
- if err != nil {
- logError([]string{"There was an error running the command ", cmdName, strings.Join(cmdArgs, " "), err.Error()})
- return "", fmt.Errorf("There was an error converting the datestamp for this revision")
- }
-
- return fmt.Sprintf("%s.%s", strings.TrimSpace(prefix), strings.TrimSpace(string(date))), nil
-}
-
-// Generates a python package version number from the git log for the current working directory
-func pythonVersionFromGit(prefix string) (string, error) {
- rv, err := rubyVersionFromGit(prefix)
- if err != nil {
- return "", err
- }
- return rv, nil
-}
-
-// Generates a docker image version number from the git log for the current working directory
-func dockerVersionFromGit() (string, error) {
- rv, err := gitHashFull()
- if err != nil {
- return "", err
- }
- return rv, nil
-}
-
-func getGitTs() (gitTs []byte, err error) {
- cmdArgs := []string{"log", "-n1", "--first-parent", "--max-count=1", "--format=format:%ct", "."}
- gitTs, err = exec.Command(theConfig.GitExecutablePath, cmdArgs...).Output()
- if err != nil {
- logError([]string{"There was an error running the command ", theConfig.GitExecutablePath, strings.Join(cmdArgs, " "), err.Error()})
- return nil, fmt.Errorf("There was an error getting the git hash for this revision")
- }
- return
-}
-
-// Generates a timestamp from the git log for the current working directory
-func timestampFromGit() (string, error) {
- gitTs, err := getGitTs()
- if err != nil {
- return "", err
- }
- return fmt.Sprintf("%s", strings.TrimSpace(string(gitTs))), nil
-}
-
-func normalizeRequestedHash(hash string) (string, error) {
- _, err := prepareGitCheckout(hash)
- if err != nil {
- return "", err
- }
-
- // Get the git hash for the tree
- var gitHash string
- gitHash, err = gitHashFull()
- if err != nil {
- return "", err
- }
-
- return gitHash, nil
-}
-
-func getPackageVersionsWorker(hash string) (gitHash string, goSDKTimestamp string, goSDKVersionWithoutPrefix string, pythonSDKTimestamp string, err error) {
- gitHash = ""
- goSDKTimestamp = ""
- goSDKVersionWithoutPrefix = ""
- pythonSDKTimestamp = ""
-
- _, err = prepareGitCheckout(hash)
- if err != nil {
- return
- }
-
- // Get the git hash for the tree
- gitHash, err = gitHashFull()
- if err != nil {
- return
- }
-
- // Get the git timestamp and version string for the sdk/go directory
- err = os.Chdir(theConfig.DirPath + "/sdk/go")
- if err != nil {
- err = nil
- } else {
- goSDKTimestamp, err = timestampFromGit()
- if err != nil {
- return
- }
- goSDKVersionWithoutPrefix, err = versionFromGit("")
- if err != nil {
- return
- }
- }
-
- // Get the git timestamp and version string for the sdk/python directory
- err = os.Chdir(theConfig.DirPath + "/sdk/python")
- if err != nil {
- err = nil
- } else {
- pythonSDKTimestamp, err = timestampFromGit()
- if err != nil {
- return
- }
- }
-
- return
-}
-
-func pythonSDKVersionCheck(pythonSDKTimestamp string) (err error) {
- var packageTimestamp string
- packageTimestamp, err = timestampFromGit()
- if err != nil {
- return
- }
-
- if pythonSDKTimestamp > packageTimestamp {
- err = os.Chdir(theConfig.DirPath + "/sdk/python")
- if err != nil {
- return
- }
- }
- return
-}
-
-func getPackageVersions(hash string) (versions map[string]map[string]string, gitHash string, err error) {
- versions = make(map[string]map[string]string)
-
- gitHash, goSDKTimestamp, goSDKVersionWithoutPrefix, pythonSDKTimestamp, err := getPackageVersionsWorker(hash)
- if err != nil {
- return nil, "", err
- }
-
- for _, p := range theConfig.Packages {
- err = os.Chdir(theConfig.DirPath + "/" + p.sourceDir)
- if err != nil {
- // Skip those packages for which the source directory doesn't exist
- // in this revision of the source tree.
- err = nil
- continue
- }
- name := p.name
-
- var packageVersion string
-
- if (p.versionType == "git") || (p.versionType == "go") {
- packageVersion, err = versionFromGit(p.versionPrefix)
- if err != nil {
- return nil, "", err
- }
- }
- if p.versionType == "go" {
- var packageTimestamp string
- packageTimestamp, err = timestampFromGit()
- if err != nil {
- return nil, "", err
- }
-
- if goSDKTimestamp > packageTimestamp {
- packageVersion = p.versionPrefix + goSDKVersionWithoutPrefix
- }
- } else if p.versionType == "python" {
- // Not all of our packages that use our python sdk are automatically
- // getting rebuilt when sdk/python changes. Yet.
- if p.name == "python-arvados-cwl-runner" {
- err = pythonSDKVersionCheck(pythonSDKTimestamp)
- if err != nil {
- return nil, "", err
- }
- }
-
- packageVersion, err = pythonVersionFromGit(p.versionPrefix)
- if err != nil {
- return nil, "", err
- }
- } else if p.versionType == "ruby" {
- packageVersion, err = rubyVersionFromGit(p.versionPrefix)
- if err != nil {
- return nil, "", err
- }
- } else if p.versionType == "docker" {
- // the arvados/jobs image version is always the latest of the
- // sdk/python and the sdk/cwl version
- if p.name == "arvados/jobs" {
- err = pythonSDKVersionCheck(pythonSDKTimestamp)
- if err != nil {
- return nil, "", err
- }
- }
- packageVersion, err = dockerVersionFromGit()
- if err != nil {
- return nil, "", err
- }
- }
-
- if versions[strings.Title(p.packageType)] == nil {
- versions[strings.Title(p.packageType)] = make(map[string]string)
- }
- versions[strings.Title(p.packageType)][name] = packageVersion
- }
-
- return
-}
-
-func logError(m []string) {
- log.Printf(string(marshal(report{"Error", strings.Join(m, " ")})))
-}
-
-func logNotice(m []string) {
- log.Printf(string(marshal(report{"Notice", strings.Join(m, " ")})))
-}
-
-func marshal(message interface{}) (encoded []byte) {
- encoded, err := json.Marshal(message)
- if err != nil {
- // do not call logError here because that would create an infinite loop
- fmt.Fprintln(os.Stderr, "{\"Error\": \"Unable to marshal message into json:", message, "\"}")
- return nil
- }
- return
-}
-
-func marshalAndWrite(w io.Writer, message interface{}) {
- b := marshal(message)
- if b == nil {
- errorMessage := "{\n\"Error\": \"Unspecified error\"\n}"
- _, err := io.WriteString(w, errorMessage)
- if err != nil {
- // do not call logError (it calls marshal and that function has already failed at this point)
- fmt.Fprintln(os.Stderr, "{\"Error\": \"Unable to write message to client\"}")
- }
- } else {
- _, err := w.Write(b)
- if err != nil {
- logError([]string{"Unable to write message to client:", string(b)})
- }
- }
-}
-
-func packageVersionHandler(w http.ResponseWriter, r *http.Request) {
- start := time.Now()
- w.Header().Set("Content-Type", "application/json; charset=utf-8")
-
- var packageVersions map[string]map[string]string
- var cached bool
-
- // Sanity check the input RequestHash
- match, err := regexp.MatchString("^([a-z0-9]+|)$", r.URL.Path[11:])
- if err != nil {
- m := report{"Error", "Error matching RequestHash"}
- marshalAndWrite(w, m)
- return
- }
- if !match {
- m := report{"Error", "Invalid RequestHash"}
- marshalAndWrite(w, m)
- return
- }
-
- hash := r.URL.Path[11:]
-
- // Empty hash or non-standard hash length? Normalize it.
- if string(len(hash)) != theConfig.ShortHashLength && len(hash) != 40 {
- hash, err = normalizeRequestedHash(hash)
- if err != nil {
- m := report{"Error", err.Error()}
- marshalAndWrite(w, m)
- return
- }
- }
-
- var gitHash string
- rs, err := lookupInCache(hash)
- if err == nil {
- packageVersions = rs.Versions
- gitHash = rs.GitHash
- cached = true
- } else {
- packageVersions, gitHash, err = getPackageVersions(hash)
- if err != nil {
- m := report{"Error", err.Error()}
- marshalAndWrite(w, m)
- return
- }
- m := result{"", gitHash, packageVersions, true, ""}
- err = writeToCache(hash, m)
- if err != nil {
- logError([]string{"Unable to save entry in cache directory", theConfig.CacheDirPath})
- }
- cached = false
- }
-
- m := result{hash, gitHash, packageVersions, cached, fmt.Sprintf("%v", time.Since(start))}
- marshalAndWrite(w, m)
-}
-
-func aboutHandler(w http.ResponseWriter, r *http.Request) {
- w.Header().Set("Content-Type", "application/json; charset=utf-8")
- m := about{"Arvados Version Server", "0.1", "https://arvados.org"}
- marshalAndWrite(w, m)
-}
-
-func helpHandler(w http.ResponseWriter, r *http.Request) {
- w.Header().Set("Content-Type", "application/json; charset=utf-8")
- m := help{"GET /v1/commit/ or GET /v1/commit/git-commit or GET /v1/about or GET /v1/help"}
- marshalAndWrite(w, m)
-}
-
-func parseFlags() (configPath *string) {
-
- flags := flag.NewFlagSet("arvados-version-server", flag.ExitOnError)
- flags.Usage = func() { usage(flags) }
-
- configPath = flags.String(
- "config",
- defaultConfigPath,
- "`path` to YAML configuration file")
-
- // Parse args; omit the first arg which is the command name
- err := flags.Parse(os.Args[1:])
- if err != nil {
- logError([]string{"Unable to parse command line arguments:", err.Error()})
- os.Exit(1)
- }
-
- return
-}
-
-func main() {
- err := os.Setenv("TZ", "UTC")
- if err != nil {
- logError([]string{"Error setting environment variable:", err.Error()})
- os.Exit(1)
- }
-
- configPath := parseFlags()
-
- err = readConfig(&theConfig, *configPath, defaultConfigPath)
- if err != nil {
- logError([]string{"Unable to start Arvados Version Server:", err.Error()})
- os.Exit(1)
- }
-
- theConfig.Packages = loadPackages()
-
- if theConfig.DirPath == "" {
- theConfig.DirPath = "/tmp/arvados-version-server-checkout"
- }
-
- if theConfig.CacheDirPath == "" {
- theConfig.CacheDirPath = "/tmp/arvados-version-server-cache"
- }
-
- if theConfig.GitExecutablePath == "" {
- theConfig.GitExecutablePath = "/usr/bin/git"
- }
-
- if theConfig.ListenPort == "" {
- theConfig.ListenPort = "80"
- }
-
- if theConfig.ShortHashLength == "" {
- theConfig.ShortHashLength = "7"
- }
-
- http.HandleFunc("/v1/commit/", packageVersionHandler)
- http.HandleFunc("/v1/about", aboutHandler)
- http.HandleFunc("/v1/help", helpHandler)
- http.HandleFunc("/v1", helpHandler)
- http.HandleFunc("/", helpHandler)
- logNotice([]string{"Arvados Version Server listening on port", theConfig.ListenPort})
-
- listener, err = net.Listen("tcp", ":"+theConfig.ListenPort)
-
- if err != nil {
- logError([]string{"Unable to start Arvados Version Server:", err.Error()})
- os.Exit(1)
- }
-
- // Shut down the server gracefully (by closing the listener)
- // if SIGTERM is received.
- term := make(chan os.Signal, 1)
- go func(sig <-chan os.Signal) {
- <-sig
- logError([]string{"caught signal"})
- _ = listener.Close()
- }(term)
- signal.Notify(term, syscall.SIGTERM)
- signal.Notify(term, syscall.SIGINT)
-
- // Start serving requests.
- _ = http.Serve(listener, nil)
- // http.Serve returns an error when it gets the term or int signal
-
- logNotice([]string{"Arvados Version Server shutting down"})
-
-}
-
-func readConfig(cfg interface{}, path string, defaultConfigPath string) error {
- err := config.LoadFile(cfg, path)
- if err != nil && os.IsNotExist(err) && path == defaultConfigPath {
- logNotice([]string{"Config not specified. Continue with default configuration."})
- err = nil
- }
- return err
-}
projects / arvados-dev.git / blobdiff