lib9p

commit edf77a3c3815a962d7f3801063ba10d3d48f8f7b
parent 7cee1a932b36f9b36a9fe7c7de272535d1ac9f74
Author: Matsuda Kenji <info@mtkn.jp>
Date:   Fri, 22 Dec 2023 13:01:05 +0900

not return when Req.Done is closed

Diffstat:
M
server.go
 | 
6
+++---

1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/server.go b/server.go
@@ -853,10 +853,10 @@ func sRead(ctx context.Context, s *Server, c <-chan *Req) {
 				if err != nil {
 					r.err = err
 					rc <- r
-				continue
+					continue
 				}
 			case <-r.Done:
-				return
+				continue
 			}
 			r.Ofcall = &RRead{
 				Count: uint32(n),
@@ -946,7 +946,7 @@ func sWrite(ctx context.Context, s *Server, c <-chan *Req) {
 				continue
 				}
 			case <-r.Done:
-				return
+				continue
 			}
 			r.Ofcall = ofcall
 			rc <- r