fdmu fdMutex
// immutable until Close
- proto string
+ net string
n string
dir string
ctl, data *os.File
return dialChannel(net, ra, dialer, deadline)
}
-func newFD(proto, name string, ctl, data *os.File, laddr, raddr Addr) (*netFD, error) {
- return &netFD{proto: proto, n: name, dir: netdir + "/" + proto + "/" + name, ctl: ctl, data: data, laddr: laddr, raddr: raddr}, nil
+func newFD(net, name string, ctl, data *os.File, laddr, raddr Addr) (*netFD, error) {
+ return &netFD{net: net, n: name, dir: netdir + "/" + net + "/" + name, ctl: ctl, data: data, laddr: laddr, raddr: raddr}, nil
}
func (fd *netFD) init() error {
if fd.raddr != nil {
rs = fd.raddr.String()
}
- return fd.proto + ":" + ls + "->" + rs
+ return fd.net + ":" + ls + "->" + rs
}
func (fd *netFD) ok() bool { return fd != nil && fd.ctl != nil }
}
defer fd.readUnlock()
n, err = fd.data.Read(b)
- if fd.proto == "udp" && err == io.EOF {
+ if fd.net == "udp" && err == io.EOF {
n = 0
err = nil
}
}
func (l *netFD) netFD() (*netFD, error) {
- return newFD(l.proto, l.n, l.ctl, l.data, l.laddr, l.raddr)
+ return newFD(l.net, l.n, l.ctl, l.data, l.laddr, l.raddr)
}
func (l *netFD) acceptPlan9() (fd *netFD, err error) {
return nil, &OpError{"accept", l.dir + "/listen", l.laddr, err}
}
name := string(buf[:n])
- data, err := os.OpenFile(netdir+"/"+l.proto+"/"+name+"/data", os.O_RDWR, 0)
+ data, err := os.OpenFile(netdir+"/"+l.net+"/"+name+"/data", os.O_RDWR, 0)
if err != nil {
f.Close()
- return nil, &OpError{"accept", l.proto, l.laddr, err}
+ return nil, &OpError{"accept", l.net, l.laddr, err}
}
- raddr, err := readPlan9Addr(l.proto, netdir+"/"+l.proto+"/"+name+"/remote")
+ raddr, err := readPlan9Addr(l.net, netdir+"/"+l.net+"/"+name+"/remote")
if err != nil {
data.Close()
f.Close()
- return nil, &OpError{"accept", l.proto, l.laddr, err}
+ return nil, &OpError{"accept", l.net, l.laddr, err}
}
- return newFD(l.proto, name, f, data, l.laddr, raddr)
+ return newFD(l.net, name, f, data, l.laddr, raddr)
}