From e14923ae530dda0601c204fe17ac1956f54a45b0 Mon Sep 17 00:00:00 2001 From: Ophestra Date: Sat, 8 Feb 2025 13:03:45 +0900 Subject: helper/proc: move package out of internal Signed-off-by: Ophestra --- internal/proc/fd.go | 45 --------------------------------------------- 1 file changed, 45 deletions(-) delete mode 100644 internal/proc/fd.go (limited to 'internal/proc/fd.go') diff --git a/internal/proc/fd.go b/internal/proc/fd.go deleted file mode 100644 index e99abb38..00000000 --- a/internal/proc/fd.go +++ /dev/null @@ -1,45 +0,0 @@ -package proc - -import ( - "encoding/gob" - "errors" - "os" - "strconv" -) - -var ( - ErrNotSet = errors.New("environment variable not set") - ErrInvalid = errors.New("bad file descriptor") -) - -// Setup appends the read end of a pipe for payload transmission and returns its fd. -func Setup(extraFiles *[]*os.File) (int, *gob.Encoder, error) { - if r, w, err := os.Pipe(); err != nil { - return -1, nil, err - } else { - fd := 3 + len(*extraFiles) - *extraFiles = append(*extraFiles, r) - return fd, gob.NewEncoder(w), nil - } -} - -// Receive retrieves payload pipe fd from the environment, -// receives its payload and returns the Close method of the pipe. -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) -} -- cgit v1.3.1