mirror of
https://github.com/unknwon/the-way-to-go_ZH_CN.git
synced 2025-11-13 09:16:10 +08:00
@@ -23,10 +23,10 @@ func main() {
|
|||||||
go connectionHandler(conn)
|
go connectionHandler(conn)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
func initServer(hostAndPort string) *net.TCPListener {
|
func initServer(hostAndPort string) net.Listener {
|
||||||
serverAddr, err := net.ResolveTCPAddr("tcp", hostAndPort)
|
serverAddr, err := net.ResolveTCPAddr("tcp", hostAndPort)
|
||||||
checkError(err, "Resolving address:port failed: '"+hostAndPort+"'")
|
checkError(err, "Resolving address:port failed: '"+hostAndPort+"'")
|
||||||
listener, err := net.Listen("tcp", serverAddr)
|
listener, err := net.Listen("tcp", serverAddr.String())
|
||||||
checkError(err, "ListenTCP: ")
|
checkError(err, "ListenTCP: ")
|
||||||
println("Listening to: ", listener.Addr().String())
|
println("Listening to: ", listener.Addr().String())
|
||||||
return listener
|
return listener
|
||||||
@@ -42,7 +42,7 @@ func connectionHandler(conn net.Conn) {
|
|||||||
switch err {
|
switch err {
|
||||||
case nil:
|
case nil:
|
||||||
handleMsg(length, err, ibuf)
|
handleMsg(length, err, ibuf)
|
||||||
case syscall.Errno(0xb): // try again
|
case syscall.EAGAIN: // try again
|
||||||
continue
|
continue
|
||||||
default:
|
default:
|
||||||
goto DISCONNECT
|
goto DISCONNECT
|
||||||
|
|||||||
Reference in New Issue
Block a user