diff options
| author | Ophestra <cat@gensokyo.uk> | 2025-10-31 22:34:38 +0900 |
|---|---|---|
| committer | Ophestra <cat@gensokyo.uk> | 2025-10-31 22:39:02 +0900 |
| commit | 68ff0a2ba624fc9c87a6feb331a01f64cdef4209 (patch) | |
| tree | 6ba673174995b8c4c3d35460625cc90af4b2d85d /container/params_test.go | |
| parent | 6a0ecced9021482f1f2f05d6ec63c1e4cd33c8a0 (diff) | |
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 <cat@gensokyo.uk>
Diffstat (limited to 'container/params_test.go')
| -rw-r--r-- | container/params_test.go | 9 |
1 files changed, 7 insertions, 2 deletions
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 { |