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. | 
