All checks were successful
Test / Create distribution (push) Successful in 1m19s
Test / Sandbox (push) Successful in 3m20s
Test / Hakurei (push) Successful in 4m26s
Test / ShareFS (push) Successful in 4m28s
Test / Sandbox (race detector) (push) Successful in 5m42s
Test / Hakurei (race detector) (push) Successful in 6m57s
Test / Flake checks (push) Successful in 1m27s
This does not make sense as part of the public API, so make it internal. Signed-off-by: Ophestra <cat@gensokyo.uk>
43 lines
1.0 KiB
Go
43 lines
1.0 KiB
Go
// Package params provides helpers for receiving setup payload from parent.
|
|
package params
|
|
|
|
import (
|
|
"encoding/gob"
|
|
"errors"
|
|
"os"
|
|
"strconv"
|
|
"syscall"
|
|
)
|
|
|
|
// ErrReceiveEnv is returned by [Receive] if setup fd is not present in environment.
|
|
var ErrReceiveEnv = errors.New("environment variable not set")
|
|
|
|
// Receive retrieves setup fd from the environment and receives params.
|
|
//
|
|
// The file descriptor written to the value pointed to by fdp must not be passed
|
|
// to any system calls. It is made available for ordering file descriptor only.
|
|
func Receive(key string, v any, fdp *int) (func() error, error) {
|
|
var setup *os.File
|
|
|
|
if s, ok := os.LookupEnv(key); !ok {
|
|
return nil, ErrReceiveEnv
|
|
} else {
|
|
if fd, err := strconv.Atoi(s); err != nil {
|
|
if _err := errors.Unwrap(err); _err != nil {
|
|
err = _err
|
|
}
|
|
return nil, err
|
|
} else {
|
|
setup = os.NewFile(uintptr(fd), "setup")
|
|
if setup == nil {
|
|
return nil, syscall.EDOM
|
|
}
|
|
if fdp != nil {
|
|
*fdp = fd
|
|
}
|
|
}
|
|
}
|
|
|
|
return setup.Close, gob.NewDecoder(setup).Decode(v)
|
|
}
|