proc: setup payload receive
Generic implementation of setup payload receiver adapted from finit. Signed-off-by: Ophestra Umiker <cat@ophivana.moe>
This commit is contained in:
parent
2f676c9d6e
commit
ef8fd37e9d
32
internal/proc/fd.go
Normal file
32
internal/proc/fd.go
Normal file
@ -0,0 +1,32 @@
|
|||||||
|
package proc
|
||||||
|
|
||||||
|
import (
|
||||||
|
"encoding/gob"
|
||||||
|
"errors"
|
||||||
|
"os"
|
||||||
|
"strconv"
|
||||||
|
)
|
||||||
|
|
||||||
|
var (
|
||||||
|
ErrNotSet = errors.New("environment variable not set")
|
||||||
|
ErrInvalid = errors.New("bad file descriptor")
|
||||||
|
)
|
||||||
|
|
||||||
|
func Receive(key string, e any) (func() error, error) {
|
||||||
|
var setup *os.File
|
||||||
|
|
||||||
|
if s, ok := os.LookupEnv(key); !ok {
|
||||||
|
return nil, ErrNotSet
|
||||||
|
} else {
|
||||||
|
if fd, err := strconv.Atoi(s); err != nil {
|
||||||
|
return nil, err
|
||||||
|
} else {
|
||||||
|
setup = os.NewFile(uintptr(fd), "setup")
|
||||||
|
if setup == nil {
|
||||||
|
return nil, ErrInvalid
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return func() error { return setup.Close() }, gob.NewDecoder(setup).Decode(e)
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user