diff options
Diffstat (limited to 'src/pkg/websocket/websocket.go')
| -rw-r--r-- | src/pkg/websocket/websocket.go | 74 |
1 files changed, 37 insertions, 37 deletions
diff --git a/src/pkg/websocket/websocket.go b/src/pkg/websocket/websocket.go index 373961d57..efcb228b3 100644 --- a/src/pkg/websocket/websocket.go +++ b/src/pkg/websocket/websocket.go @@ -12,52 +12,52 @@ package websocket // better logging. import ( - "bufio"; - "io"; - "net"; - "os"; + "bufio" + "io" + "net" + "os" ) type WebSocketAddr string -func (addr WebSocketAddr) Network() string { return "websocket" } +func (addr WebSocketAddr) Network() string { return "websocket" } -func (addr WebSocketAddr) String() string { return string(addr) } +func (addr WebSocketAddr) String() string { return string(addr) } // Conn is an channels to communicate over Web Socket. type Conn struct { // An origin URI of the Web Socket. - Origin string; + Origin string // A location URI of the Web Socket. - Location string; + Location string // A subprotocol of the Web Socket. - Protocol string; + Protocol string - buf *bufio.ReadWriter; - rwc io.ReadWriteCloser; + buf *bufio.ReadWriter + rwc io.ReadWriteCloser } // newConn creates a new Web Socket. func newConn(origin, location, protocol string, buf *bufio.ReadWriter, rwc io.ReadWriteCloser) *Conn { if buf == nil { - br := bufio.NewReader(rwc); - bw := bufio.NewWriter(rwc); - buf = bufio.NewReadWriter(br, bw); + br := bufio.NewReader(rwc) + bw := bufio.NewWriter(rwc) + buf = bufio.NewReadWriter(br, bw) } - ws := &Conn{origin, location, protocol, buf, rwc}; - return ws; + ws := &Conn{origin, location, protocol, buf, rwc} + return ws } func (ws *Conn) Read(msg []byte) (n int, err os.Error) { for { - frameByte, err := ws.buf.ReadByte(); + frameByte, err := ws.buf.ReadByte() if err != nil { return n, err } if (frameByte & 0x80) == 0x80 { - length := 0; + length := 0 for { - c, err := ws.buf.ReadByte(); + c, err := ws.buf.ReadByte() if err != nil { return n, err } @@ -68,15 +68,15 @@ func (ws *Conn) Read(msg []byte) (n int, err os.Error) { } } for length > 0 { - _, err := ws.buf.ReadByte(); + _, err := ws.buf.ReadByte() if err != nil { return n, err } - length--; + length-- } } else { for { - c, err := ws.buf.ReadByte(); + c, err := ws.buf.ReadByte() if err != nil { return n, err } @@ -87,8 +87,8 @@ func (ws *Conn) Read(msg []byte) (n int, err os.Error) { if n+1 <= cap(msg) { msg = msg[0 : n+1] } - msg[n] = c; - n++; + msg[n] = c + n++ } if n >= cap(msg) { return n, os.E2BIG @@ -97,42 +97,42 @@ func (ws *Conn) Read(msg []byte) (n int, err os.Error) { } } - panic("unreachable"); + panic("unreachable") } func (ws *Conn) Write(msg []byte) (n int, err os.Error) { - ws.buf.WriteByte(0); - ws.buf.Write(msg); - ws.buf.WriteByte(0xff); - err = ws.buf.Flush(); - return len(msg), err; + ws.buf.WriteByte(0) + ws.buf.Write(msg) + ws.buf.WriteByte(0xff) + err = ws.buf.Flush() + return len(msg), err } -func (ws *Conn) Close() os.Error { return ws.rwc.Close() } +func (ws *Conn) Close() os.Error { return ws.rwc.Close() } -func (ws *Conn) LocalAddr() net.Addr { return WebSocketAddr(ws.Origin) } +func (ws *Conn) LocalAddr() net.Addr { return WebSocketAddr(ws.Origin) } -func (ws *Conn) RemoteAddr() net.Addr { return WebSocketAddr(ws.Location) } +func (ws *Conn) RemoteAddr() net.Addr { return WebSocketAddr(ws.Location) } func (ws *Conn) SetTimeout(nsec int64) os.Error { if conn, ok := ws.rwc.(net.Conn); ok { return conn.SetTimeout(nsec) } - return os.EINVAL; + return os.EINVAL } func (ws *Conn) SetReadTimeout(nsec int64) os.Error { if conn, ok := ws.rwc.(net.Conn); ok { return conn.SetReadTimeout(nsec) } - return os.EINVAL; + return os.EINVAL } func (ws *Conn) SetWriteTimeout(nsec int64) os.Error { if conn, ok := ws.rwc.(net.Conn); ok { return conn.SetWriteTimeout(nsec) } - return os.EINVAL; + return os.EINVAL } -var _ net.Conn = (*Conn)(nil) // compile-time check that *Conn implements net.Conn. +var _ net.Conn = (*Conn)(nil) // compile-time check that *Conn implements net.Conn. |
