]> Cypherpunks repositories - gostls13.git/commitdiff
net: rename netFD.proto to netFD.net on Plan 9
authorMikio Hara <mikioh.mikioh@gmail.com>
Thu, 16 Apr 2015 07:24:45 +0000 (16:24 +0900)
committerMikio Hara <mikioh.mikioh@gmail.com>
Fri, 17 Apr 2015 00:09:13 +0000 (00:09 +0000)
In followup changes, we'll move OpError around from the netFD layer to
the Conn layer for fixing #4856. Before doing that, this change makes
netFD of Plan 9 match netFD for POSIX platforms to avoid conflict.

Change-Id: Iea7632716d48722a1758e52effefec964a3a9442
Reviewed-on: https://go-review.googlesource.com/8990
Reviewed-by: David du Colombier <0intro@gmail.com>
Reviewed-by: Brad Fitzpatrick <bradfitz@golang.org>
src/net/fd_plan9.go
src/net/ipsock_plan9.go

index 38355e24580fa8656a93fd212a534017cf9f9d2e..29ec8012788a367cbff92962e22f65a7ae20a2be 100644 (file)
@@ -17,7 +17,7 @@ type netFD struct {
        fdmu fdMutex
 
        // immutable until Close
-       proto        string
+       net          string
        n            string
        dir          string
        ctl, data    *os.File
@@ -38,8 +38,8 @@ func dial(net string, ra Addr, dialer func(time.Time) (Conn, error), deadline ti
        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 {
@@ -55,7 +55,7 @@ func (fd *netFD) name() string {
        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 }
@@ -132,7 +132,7 @@ func (fd *netFD) Read(b []byte) (n int, err error) {
        }
        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
        }
index 94ceea31b0350c645f524ed626f4f42d1f46ee74..1c2932d1c1be8a887a89a5821e9d41c9dbcd72f3 100644 (file)
@@ -193,7 +193,7 @@ func listenPlan9(net string, laddr Addr) (fd *netFD, err error) {
 }
 
 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) {
@@ -213,16 +213,16 @@ 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)
 }