1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
// Author: arnej
package startcbinary
import (
"os"
"strings"
"github.com/vespa-engine/vespa/client/go/trace"
)
type ProgSpec struct {
Program string
Args []string
BaseName string
Env map[string]string
numaSocket int
shouldUseCallgrind bool
shouldUseValgrind bool
shouldUseNumaCtl bool
shouldUseVespaMalloc bool
vespaMallocPreload string
}
func (p *ProgSpec) setup() {
p.BaseName = baseNameOf(p.Program)
p.Env = make(map[string]string)
p.numaSocket = -1
}
func baseNameOf(s string) string {
idx := strings.LastIndex(s, "/")
idx++
return s[idx:]
}
func (p *ProgSpec) setenv(k, v string) {
p.Env[k] = v
}
func (p *ProgSpec) getenv(k string) string {
if v, ok := p.Env[k]; ok {
return v
}
return os.Getenv(k)
}
func (p *ProgSpec) prependPath(dirName string) {
pathList := []string{dirName}
oldPath := p.getenv(ENV_PATH)
if oldPath == "" {
oldPath = "/usr/bin"
}
for _, part := range strings.Split(oldPath, ":") {
if part != dirName {
pathList = append(pathList, part)
}
}
newPath := strings.Join(pathList, ":")
p.setenv(ENV_PATH, newPath)
os.Setenv(ENV_PATH, newPath)
}
func (p *ProgSpec) matchesListEnv(envVarName string) bool {
return p.matchesListString(p.getenv(envVarName))
}
func (p *ProgSpec) matchesListString(env string) bool {
if env == "all" {
trace.Debug(p.Program, "always matching in:", env)
return true
}
parts := strings.Fields(env)
for _, part := range parts {
if p.BaseName == part {
trace.Debug(p.Program, "has basename matching in:", env)
return true
}
trace.Debug("checking matching:", p.BaseName, "!=", part)
}
return false
}
func (p *ProgSpec) valueFromListEnv(envVarName string) string {
return p.valueFromListString(p.getenv(envVarName))
}
func (p *ProgSpec) valueFromListString(env string) string {
parts := strings.Fields(env)
for _, part := range parts {
idx := strings.Index(part, "=")
if idx <= 0 {
trace.Trace("expected key=value, but got:", part)
continue
}
partName := part[:idx]
idx++
partValue := part[idx:]
if p.BaseName == partName || partName == "all" {
trace.Debug(p.Program, "has basename matching in:", env)
return partValue
}
trace.Debug("checking matching:", p.BaseName, "!=", part)
}
return ""
}
func (spec *ProgSpec) effectiveEnv() []string {
env := make(map[string]string)
for _, entry := range os.Environ() {
addInMap := func(kv string) bool {
for idx, elem := range kv {
if elem == '=' {
k := kv[:idx]
env[k] = kv
return true
}
}
return false
}
if !addInMap(entry) {
env[entry] = ""
}
}
for k, v := range spec.Env {
trace.Trace("add to environment:", k, "=", v)
env[k] = k + "=" + v
}
envv := make([]string, 0, len(env))
for _, v := range env {
envv = append(envv, v)
}
return envv
}
|
