mirror of
https://github.com/golang/go.git
synced 2025-12-08 06:10:04 +00:00
syscall: optimise cgo clearenv
For programs with very large environments, calling unsetenv(3) for each
environment variable can be very expensive because of CGo overhead, but
clearenv(3) is much faster. The only thing we have to track is whether
GODEBUG is being unset by the operation, which can be done very quickly
without resorting to doing unsetenv(3) for every variable.
This change makes syscall.Clearenv() >98% faster when run in an
environment with as little as 100 environment variables. (Note that due
to golang/go#27217, it is necessary to modify BenchmarkClearenv to use
t.StopTimer() and -benchtime=100x in order to get these benchmark times
-- otherwise syscall.Setenv() time is included and the benchmarks give a
more pessimistic 50% performance improvement.)
goos: linux
goarch: amd64
pkg: syscall
cpu: AMD Ryzen 7 7840U w/ Radeon 780M Graphics
│ before │ after │
│ sec/op │ sec/op vs base │
Clearenv/100-16 22276.5n ± 5% 285.8n ± 3% -98.72% (p=0.000 n=10)
Clearenv/1000-16 1414104.0n ± 1% 783.1n ± 8% -99.94% (p=0.000 n=10)
Clearenv/10000-16 143827.554µ ± 1% 7.591µ ± 5% -99.99% (p=0.000 n=10)
geomean 1.655m 1.193µ -99.93%
The above benchmarks are CGo builds, which require CGo overhead for
every setenv(2). If you run the same benchmarks for a non-CGo package
(i.e., outside of the "syscall" package), you get slightly more modest
performance improvements:
goos: linux
goarch: amd64
pkg: clearenv_nocgo
cpu: AMD Ryzen 7 7840U w/ Radeon 780M Graphics
│ before │ after │
│ sec/op │ sec/op vs base │
Clearenv/100-16 1106.0n ± 3% 230.7n ± 8% -79.14% (p=0.000 n=10)
Clearenv/1000-16 11222.0n ± 1% 305.4n ± 6% -97.28% (p=0.000 n=10)
Clearenv/10000-16 195676.5n ± 6% 759.9n ± 10% -99.61% (p=0.000 n=10)
geomean 13.44µ 376.9n -97.20%
(As above, this requires modifying the benchmarks to use t.StopTimer()
and -benchtime=100x.)
Change-Id: I53b96a75f189e91affbde423c907888b7e0fafcd
GitHub-Last-Rev: f8d7a8140d
GitHub-Pull-Request: golang/go#70672
Reviewed-on: https://go-review.googlesource.com/c/go/+/633515
Reviewed-by: Mark Freeman <markfreeman@google.com>
Reviewed-by: Keith Randall <khr@golang.org>
Reviewed-by: Kirill Kolyshkin <kolyshkin@gmail.com>
LUCI-TryBot-Result: Go LUCI <golang-scoped@luci-project-accounts.iam.gserviceaccount.com>
Reviewed-by: Keith Randall <khr@google.com>
This commit is contained in:
parent
ce39174482
commit
836fa74518
7 changed files with 231 additions and 3 deletions
15
src/runtime/cgo/clearenv.go
Normal file
15
src/runtime/cgo/clearenv.go
Normal file
|
|
@ -0,0 +1,15 @@
|
|||
// Copyright 2025 The Go Authors. All rights reserved.
|
||||
// Use of this source code is governed by a BSD-style
|
||||
// license that can be found in the LICENSE file.
|
||||
|
||||
//go:build linux
|
||||
|
||||
package cgo
|
||||
|
||||
import _ "unsafe" // for go:linkname
|
||||
|
||||
//go:cgo_import_static x_cgo_clearenv
|
||||
//go:linkname x_cgo_clearenv x_cgo_clearenv
|
||||
//go:linkname _cgo_clearenv runtime._cgo_clearenv
|
||||
var x_cgo_clearenv byte
|
||||
var _cgo_clearenv = &x_cgo_clearenv
|
||||
18
src/runtime/cgo/gcc_clearenv.c
Normal file
18
src/runtime/cgo/gcc_clearenv.c
Normal file
|
|
@ -0,0 +1,18 @@
|
|||
// Copyright 2025 The Go Authors. All rights reserved.
|
||||
// Use of this source code is governed by a BSD-style
|
||||
// license that can be found in the LICENSE file.
|
||||
|
||||
//go:build linux
|
||||
|
||||
#include "libcgo.h"
|
||||
|
||||
#include <stdlib.h>
|
||||
|
||||
/* Stub for calling clearenv */
|
||||
void
|
||||
x_cgo_clearenv(void **_unused)
|
||||
{
|
||||
_cgo_tsan_acquire();
|
||||
clearenv();
|
||||
_cgo_tsan_release();
|
||||
}
|
||||
29
src/runtime/runtime_clearenv.go
Normal file
29
src/runtime/runtime_clearenv.go
Normal file
|
|
@ -0,0 +1,29 @@
|
|||
// Copyright 2025 The Go Authors. All rights reserved.
|
||||
// Use of this source code is governed by a BSD-style
|
||||
// license that can be found in the LICENSE file.
|
||||
|
||||
//go:build linux
|
||||
|
||||
package runtime
|
||||
|
||||
import "unsafe"
|
||||
|
||||
var _cgo_clearenv unsafe.Pointer // pointer to C function
|
||||
|
||||
// Clear the C environment if cgo is loaded.
|
||||
func clearenv_c() {
|
||||
if _cgo_clearenv == nil {
|
||||
return
|
||||
}
|
||||
asmcgocall(_cgo_clearenv, nil)
|
||||
}
|
||||
|
||||
//go:linkname syscall_runtimeClearenv syscall.runtimeClearenv
|
||||
func syscall_runtimeClearenv(env map[string]int) {
|
||||
clearenv_c()
|
||||
// Did we just unset GODEBUG?
|
||||
if _, ok := env["GODEBUG"]; ok {
|
||||
godebugEnv.Store(nil)
|
||||
godebugNotify(true)
|
||||
}
|
||||
}
|
||||
18
src/runtime/runtime_noclearenv.go
Normal file
18
src/runtime/runtime_noclearenv.go
Normal file
|
|
@ -0,0 +1,18 @@
|
|||
// Copyright 2025 The Go Authors. All rights reserved.
|
||||
// Use of this source code is governed by a BSD-style
|
||||
// license that can be found in the LICENSE file.
|
||||
|
||||
//go:build !linux
|
||||
|
||||
package runtime
|
||||
|
||||
import _ "unsafe" // for go:linkname
|
||||
|
||||
//go:linkname syscall_runtimeClearenv syscall.runtimeClearenv
|
||||
func syscall_runtimeClearenv(env map[string]int) {
|
||||
// The system doesn't have clearenv(3) so emulate it by unsetting all of
|
||||
// the variables manually.
|
||||
for k := range env {
|
||||
syscall_runtimeUnsetenv(k)
|
||||
}
|
||||
}
|
||||
|
|
@ -126,9 +126,8 @@ func Clearenv() {
|
|||
envLock.Lock()
|
||||
defer envLock.Unlock()
|
||||
|
||||
for k := range env {
|
||||
runtimeUnsetenv(k)
|
||||
}
|
||||
runtimeClearenv(env)
|
||||
|
||||
env = make(map[string]int)
|
||||
envs = []string{}
|
||||
}
|
||||
|
|
|
|||
145
src/syscall/env_unix_test.go
Normal file
145
src/syscall/env_unix_test.go
Normal file
|
|
@ -0,0 +1,145 @@
|
|||
// Copyright 2025 The Go Authors. All rights reserved.
|
||||
// Use of this source code is governed by a BSD-style
|
||||
// license that can be found in the LICENSE file.
|
||||
|
||||
//go:build unix || (js && wasm) || plan9 || wasip1
|
||||
|
||||
package syscall_test
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"strconv"
|
||||
"strings"
|
||||
"syscall"
|
||||
"testing"
|
||||
)
|
||||
|
||||
type env struct {
|
||||
name, val string
|
||||
}
|
||||
|
||||
func genDummyEnv(tb testing.TB, size int) []env {
|
||||
tb.Helper()
|
||||
envList := make([]env, size)
|
||||
for idx := range size {
|
||||
envList[idx] = env{
|
||||
name: fmt.Sprintf("DUMMY_VAR_%d", idx),
|
||||
val: fmt.Sprintf("val-%d", idx*100),
|
||||
}
|
||||
}
|
||||
return envList
|
||||
}
|
||||
|
||||
func setDummyEnv(tb testing.TB, envList []env) {
|
||||
tb.Helper()
|
||||
for _, env := range envList {
|
||||
if err := syscall.Setenv(env.name, env.val); err != nil {
|
||||
tb.Fatalf("setenv %s=%q failed: %v", env.name, env.val, err)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func setupEnvCleanup(tb testing.TB) {
|
||||
tb.Helper()
|
||||
originalEnv := map[string]string{}
|
||||
for _, env := range syscall.Environ() {
|
||||
fields := strings.SplitN(env, "=", 2)
|
||||
name, val := fields[0], fields[1]
|
||||
originalEnv[name] = val
|
||||
}
|
||||
tb.Cleanup(func() {
|
||||
syscall.Clearenv()
|
||||
for name, val := range originalEnv {
|
||||
if err := syscall.Setenv(name, val); err != nil {
|
||||
tb.Fatalf("could not reset env %s=%q: %v", name, val, err)
|
||||
}
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
func TestClearenv(t *testing.T) {
|
||||
setupEnvCleanup(t)
|
||||
|
||||
t.Run("DummyVars-4096", func(t *testing.T) {
|
||||
envList := genDummyEnv(t, 4096)
|
||||
setDummyEnv(t, envList)
|
||||
|
||||
if env := syscall.Environ(); len(env) < 4096 {
|
||||
t.Fatalf("env is missing dummy variables: %v", env)
|
||||
}
|
||||
for idx := range 4096 {
|
||||
name := fmt.Sprintf("DUMMY_VAR_%d", idx)
|
||||
if _, ok := syscall.Getenv(name); !ok {
|
||||
t.Fatalf("env is missing dummy variable %s", name)
|
||||
}
|
||||
}
|
||||
|
||||
syscall.Clearenv()
|
||||
|
||||
if env := syscall.Environ(); len(env) != 0 {
|
||||
t.Fatalf("clearenv should've cleared all variables: %v still set", env)
|
||||
}
|
||||
for idx := range 4096 {
|
||||
name := fmt.Sprintf("DUMMY_VAR_%d", idx)
|
||||
if val, ok := syscall.Getenv(name); ok {
|
||||
t.Fatalf("clearenv should've cleared all variables: %s=%q still set", name, val)
|
||||
}
|
||||
}
|
||||
})
|
||||
|
||||
// Test that GODEBUG getting cleared by Clearenv also resets the behaviour.
|
||||
t.Run("GODEBUG", func(t *testing.T) {
|
||||
envList := genDummyEnv(t, 100)
|
||||
setDummyEnv(t, envList)
|
||||
|
||||
doNilPanic := func() (ret any) {
|
||||
defer func() {
|
||||
ret = recover()
|
||||
}()
|
||||
panic(nil)
|
||||
return "should not return"
|
||||
}
|
||||
|
||||
// Allow panic(nil).
|
||||
if err := syscall.Setenv("GODEBUG", "panicnil=1"); err != nil {
|
||||
t.Fatalf("setenv GODEBUG=panicnil=1 failed: %v", err)
|
||||
}
|
||||
|
||||
got := doNilPanic()
|
||||
if got != nil {
|
||||
t.Fatalf("GODEBUG=panicnil=1 did not allow for nil panic: got %#v", got)
|
||||
}
|
||||
|
||||
// Disallow panic(nil).
|
||||
syscall.Clearenv()
|
||||
|
||||
if env := syscall.Environ(); len(env) != 0 {
|
||||
t.Fatalf("clearenv should've cleared all variables: %v still set", env)
|
||||
}
|
||||
|
||||
got = doNilPanic()
|
||||
if got == nil {
|
||||
t.Fatalf("GODEBUG=panicnil=1 being unset didn't reset panicnil behaviour")
|
||||
}
|
||||
if godebug, ok := syscall.Getenv("GODEBUG"); ok {
|
||||
t.Fatalf("GODEBUG still exists in environment despite being unset: GODEBUG=%q", godebug)
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
func BenchmarkClearenv(b *testing.B) {
|
||||
setupEnvCleanup(b)
|
||||
b.ResetTimer()
|
||||
for _, size := range []int{100, 1000, 10000} {
|
||||
b.Run(strconv.Itoa(size), func(b *testing.B) {
|
||||
envList := genDummyEnv(b, size)
|
||||
for b.Loop() {
|
||||
// Ideally we would use b.StopTimer() for the setDummyEnv
|
||||
// portion, but this causes the benchmark time to get confused
|
||||
// and take forever. See <https://go.dev/issue/27217>.
|
||||
setDummyEnv(b, envList)
|
||||
syscall.Clearenv()
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
|
@ -104,3 +104,7 @@ func Exit(code int)
|
|||
// runtimeSetenv and runtimeUnsetenv are provided by the runtime.
|
||||
func runtimeSetenv(k, v string)
|
||||
func runtimeUnsetenv(k string)
|
||||
|
||||
// runtimeClearenv is provided by the runtime (on platforms without
|
||||
// clearenv(3), it is just a wrapper around runtimeUnsetenv).
|
||||
func runtimeClearenv(env map[string]int)
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue