func (r *RH) loop() {
	// lmtr := limiter.New(r.qmax)
	// defer lmtr.Wait()
	rr := newReadRequestChan(r.conn)
	//
	rootFID, err := r.ssn.Walk(nil)
	if err != nil {
		panic("u")
	}
	if rootNID, _ := r.node.Add(rootFID); rootNID != 1 { // Insert root into node table with node ID 1
		panic("u")
	}
	for {
		select {
		case q := <-rr:
			if err, ok := q.(error); ok && err != nil {
				r.eof.Close(err)
				return
			}
			go func() {
				r.serve(q.(fuse.Request))
			}()
		case err := <-r.fuseEOF.Chan():
			r.eof.Close(err)
			return
		}
	}
}
// loop listens for FUSE requests until the connection is closed.
loop listens for FUSE requests until the connection is closed.
// loop listens for FUSE requests until the connection is closed .
func (r *RH) loop() {
	rr := newReadRequestChan(r.conn)
	rootFID, err := r.ssn.Walk(nil)
	if err != nil {
		panic("u")
	}
	if rootNID, _ := r.node.Add(rootFID); rootNID != 1 {  Insert root into node table with node ID 1
		panic("u")
	}
	for {
		select {
		case q := <-rr:
			if err, ok := q.(error); ok && err != nil {
				r.eof.Close(err)
				return
			}
			go func() {
				r.serve(q.(fuse.Request))
			}()
		case err := <-r.fuseEOF.Chan():
			r.eof.Close(err)
			return
		}
	}
}
func ( r * RH ) loop ( ) { rr := newReadRequestChan ( r . conn ) rootFID , err := r . ssn . Walk ( nil ) if err != nil { panic ( " " ) } if rootNID , _ := r . node . Add ( rootFID ) ; rootNID != 1 { panic ( " " ) } for { select { case q := <- rr : if err , ok := q . ( error ) ; ok && err != nil { r . eof . Close ( err ) return } go func ( ) { r . serve ( q . ( fuse . Request ) ) } ( ) case err := <- r . fuseEOF . Chan ( ) : r . eof . Close ( err ) return } } }
loop listens for FUSE requests until the connection is closed.
loop listens for FUSE requests until the connection is closed .
// lmtr := limiter.New(r.qmax) // defer lmtr.Wait() // // Insert root into node table with node ID 1