From 800af0f8c2dfc1ac8582cb18a021dddf75199adf Mon Sep 17 00:00:00 2001 From: Sergey Matveev Date: Thu, 23 Mar 2023 13:03:20 +0300 Subject: [PATCH] Missed error checks --- src/pipe.go | 2 +- src/tx_test.go | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/pipe.go b/src/pipe.go index cb9460a..e9295d4 100644 --- a/src/pipe.go +++ b/src/pipe.go @@ -65,7 +65,7 @@ func (c PipeConn) SetWriteDeadline(t time.Time) error { } func (c PipeConn) Close() (err error) { - err = c.r.Close() + c.r.Close() err = c.w.Close() go c.cmd.Wait() time.AfterFunc(time.Duration(10*time.Second), func() { diff --git a/src/tx_test.go b/src/tx_test.go index 6c0aa78..ffe0ede 100644 --- a/src/tx_test.go +++ b/src/tx_test.go @@ -86,6 +86,9 @@ func TestTx(t *testing.T) { nodeTgt.Via = append(nodeTgt.Via, node.Id) } pkt, err := NewPkt(PktTypeExec, replyNice, []byte(pathSrc)) + if err != nil { + panic(err) + } src := bytes.NewReader(data) dstNode, _, _, err := ctx.Tx( nodeTgt, -- 2.44.0