From 68ff0a2ba624fc9c87a6feb331a01f64cdef4209 Mon Sep 17 00:00:00 2001 From: Ophestra Date: Fri, 31 Oct 2025 22:34:38 +0900 Subject: container/params: expose pipe This increases flexibility of how caller wants to handle the I/O. Also makes it no longer rely on finalizer. Signed-off-by: Ophestra --- container/params_test.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) (limited to 'container/params_test.go') diff --git a/container/params_test.go b/container/params_test.go index a65f686a..f74abf1c 100644 --- a/container/params_test.go +++ b/container/params_test.go @@ -1,6 +1,7 @@ package container_test import ( + "encoding/gob" "errors" "os" "slices" @@ -59,12 +60,16 @@ func TestSetupReceive(t *testing.T) { encoderDone := make(chan error, 1) extraFiles := make([]*os.File, 0, 1) - if fd, encoder, err := container.Setup(&extraFiles); err != nil { + deadline, _ := t.Deadline() + if fd, f, err := container.Setup(&extraFiles); err != nil { t.Fatalf("Setup: error = %v", err) } else if fd != 3 { t.Fatalf("Setup: fd = %d, want 3", fd) } else { - go func() { encoderDone <- encoder.Encode(payload) }() + if err = f.SetDeadline(deadline); err != nil { + t.Fatal(err.Error()) + } + go func() { encoderDone <- gob.NewEncoder(f).Encode(payload) }() } if len(extraFiles) != 1 { -- cgit v1.3.1