lib9p

commit 4188c62878f3bc0a90430cd3aa6bbdf1788f0323
parent 68e8eade06e28eb3c8c180aff30d81b8e61c778b
Author: Matsuda Kenji <info@mtkn.jp>
Date:   Mon, 25 Dec 2023 12:43:24 +0900

delete rVersion

Diffstat:
M
server.go
 | 
22
----------------------

1 file changed, 0 insertions(+), 22 deletions(-)
diff --git a/server.go b/server.go
@@ -204,9 +204,6 @@ func (s *Server)getReq(ctx context.Context) *Req {
 // TODO: abort all outstanding I/O on the same connection before
 // serving new Tversion.
 func sVersion(ctx context.Context, s *Server, c <-chan *Req) {
-	rc := make(chan *Req)
-	defer close(rc)
-	go rVersion(ctx, rc)
 	for {
 		select {
 		case <-ctx.Done():
@@ -230,25 +227,6 @@ func sVersion(ctx context.Context, s *Server, c <-chan *Req) {
 				Msize:   msize,
 				Version: version,
 			}
-			rc <- r
-		}
-	}
-}
-
-// rVersion confirms that err is nil, and sets the server's msize to the
-// appropreate one.
-func rVersion(ctx context.Context, c <-chan *Req) {
-	for {
-		select {
-		case <-ctx.Done():
-			return
-		case r, ok := <-c:
-			if !ok {
-				return
-			}
-			if r.err != nil {
-				panic(fmt.Errorf("rVersion err: %w", r.err))
-			}
 			r.Srv.setMSize(r.Ofcall.(*RVersion).Msize)
 			r.Srv.respChan <- r
 		}