From eec76611f9da99911414f562655e5920da955949 Mon Sep 17 00:00:00 2001 From: qydysky Date: Mon, 17 Jul 2023 03:19:26 +0800 Subject: [PATCH] fix --- io/io.go | 4 ++-- reqf/Reqf_test.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/io/io.go b/io/io.go index f1e2af5..ec8de7d 100644 --- a/io/io.go +++ b/io/io.go @@ -78,7 +78,7 @@ func WithCtxTO(ctx context.Context, callTree string, to time.Duration, w io.Writ case <-ctx.Done(): if old := chanw.Load(); old == -1 { return - } else if now := time.Now(); old > 0 && now.Unix()-old >= int64(to.Seconds()) { + } else if now := time.Now(); old > 0 && now.Unix()-old > int64(to.Seconds()) { if old != 0 { panicf[0](fmt.Sprintf("rw blocking while close %vs > %v, goruntime leak \n%v", now.Unix()-old, to, callTree)) } @@ -86,7 +86,7 @@ func WithCtxTO(ctx context.Context, callTree string, to time.Duration, w io.Writ time.AfterFunc(to, func() { if old := chanw.Load(); old == -1 { return - } else if now := time.Now(); old > 0 && now.Unix()-old >= int64(to.Seconds()) { + } else if now := time.Now(); old > 0 && now.Unix()-old > int64(to.Seconds()) { panicf[0](fmt.Sprintf("rw blocking after close %vs > %v, goruntime leak \n%v", now.Unix()-old, to, callTree)) } }) diff --git a/reqf/Reqf_test.go b/reqf/Reqf_test.go index b48adf8..da4ef88 100644 --- a/reqf/Reqf_test.go +++ b/reqf/Reqf_test.go @@ -268,7 +268,7 @@ func Test_req8(t *testing.T) { rc, wc := io.Pipe() go func() { var buf []byte = make([]byte, 1<<16) - rc.Read(buf) + _, _ = rc.Read(buf) time.Sleep(time.Millisecond * 500) r.Cancel() }() -- 2.39.2