fix

diff --git a/io/io.go b/io/io.go
index f1e2af5f8f3eb4a2ef1d4b787baa26fb9e06d95e..ec8de7d7c46b14d4d2f058e0f0ff7c6390ac9e14 100644 (file)
--- 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 b48adf80ab69416790e84e4ed7917d721fd07689..da4ef88e7e607322f74801d6ead737d91f7a9e63 100644 (file)
--- 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()
                }()