commit 88a3b15213543dd45f568ca2dd0babd4709a1b7d
Author: David Fifield <david(a)bamsoftware.com>
Date: Thu Aug 15 14:05:38 2013 -0700
No need to export these local functions.
---
.../src/websocket-server/websocket-server.go | 22 ++++++++++----------
1 file changed, 11 insertions(+), 11 deletions(-)
diff --git a/websocket-transport/src/websocket-server/websocket-server.go b/websocket-transport/src/websocket-server/websocket-server.go
index c951c60..b280862 100644
--- a/websocket-transport/src/websocket-server/websocket-server.go
+++ b/websocket-transport/src/websocket-server/websocket-server.go
@@ -48,7 +48,7 @@ func usage() {
var logMutex sync.Mutex
-func Log(format string, v ...interface{}) {
+func log(format string, v ...interface{}) {
dateStr := time.Now().Format("2006-01-02 15:04:05")
logMutex.Lock()
defer logMutex.Unlock()
@@ -129,7 +129,7 @@ func (conn *webSocketConn) Close() error {
}
// Create a new webSocketConn.
-func NewWebSocketConn(ws *websocket.WebSocket) webSocketConn {
+func newWebSocketConn(ws *websocket.WebSocket) webSocketConn {
var conn webSocketConn
conn.Ws = ws
conn.Base64 = (ws.Subprotocol == "base64")
@@ -145,7 +145,7 @@ func proxy(local *net.TCPConn, conn *webSocketConn) {
go func() {
_, err := io.Copy(conn, local)
if err != nil {
- Log("error copying ORPort to WebSocket")
+ log("error copying ORPort to WebSocket")
}
local.CloseRead()
conn.Close()
@@ -155,7 +155,7 @@ func proxy(local *net.TCPConn, conn *webSocketConn) {
go func() {
_, err := io.Copy(local, conn)
if err != nil {
- Log("error copying WebSocket to ORPort")
+ log("error copying WebSocket to ORPort")
}
local.CloseWrite()
conn.Close()
@@ -168,7 +168,7 @@ func proxy(local *net.TCPConn, conn *webSocketConn) {
func webSocketHandler(ws *websocket.WebSocket) {
// Undo timeouts on HTTP request handling.
ws.Conn.SetDeadline(time.Time{})
- conn := NewWebSocketConn(ws)
+ conn := newWebSocketConn(ws)
handlerChan <- 1
defer func() {
@@ -177,7 +177,7 @@ func webSocketHandler(ws *websocket.WebSocket) {
s, err := pt.ConnectOr(&ptInfo, ws.Conn, ptMethodName)
if err != nil {
- Log("Failed to connect to ORPort: " + err.Error())
+ log("Failed to connect to ORPort: " + err.Error())
return
}
@@ -199,7 +199,7 @@ func startListener(addr *net.TCPAddr) (*net.TCPListener, error) {
}
err = s.Serve(ln)
if err != nil {
- Log("http.Serve: " + err.Error())
+ log("http.Serve: " + err.Error())
}
}()
return ln, nil
@@ -223,7 +223,7 @@ func main() {
logFile = f
}
- Log("starting")
+ log("starting")
ptInfo = pt.ServerSetup([]string{ptMethodName})
listeners := make([]*net.TCPListener, 0)
@@ -241,7 +241,7 @@ func main() {
continue
}
pt.Smethod(bindAddr.MethodName, ln.Addr())
- Log("listening on %s", ln.Addr().String())
+ log("listening on %s", ln.Addr().String())
listeners = append(listeners, ln)
}
pt.SmethodsDone()
@@ -256,7 +256,7 @@ func main() {
case n := <-handlerChan:
numHandlers += n
case <-signalChan:
- Log("SIGINT")
+ log("SIGINT")
sigint = true
}
}
@@ -271,7 +271,7 @@ func main() {
case n := <-handlerChan:
numHandlers += n
case <-signalChan:
- Log("SIGINT")
+ log("SIGINT")
sigint = true
}
}