Explorar el Código

listening 写完一半

skyfffire hace 2 años
padre
commit
5341c09e63
Se han modificado 1 ficheros con 9 adiciones y 1 borrados
  1. 9 1
      p2p/server.go

+ 9 - 1
p2p/server.go

@@ -26,7 +26,7 @@ type Server struct {
 	lock    sync.Mutex // protects running
 	lock    sync.Mutex // protects running
 	running bool
 	running bool
 
 
-	//listener net.Listener
+	listener     net.Listener
 	ourHandshake *protoHandshake
 	ourHandshake *protoHandshake
 	//loopWG sync.WaitGroup // loop, listenLoop
 	//loopWG sync.WaitGroup // loop, listenLoop
 	//peerFeed event.Feed
 	//peerFeed event.Feed
@@ -88,6 +88,14 @@ func (server *Server) setupLocalNode() (err error) {
 
 
 // 监听器
 // 监听器
 func (server *Server) setupListening() (err error) {
 func (server *Server) setupListening() (err error) {
+	listener, err := net.Listen("tcp", server.ListenAddr)
+	if err != nil {
+		return err
+	}
+
+	server.listener = listener
+	server.ListenAddr = listener.Addr().String()
+
 	return nil
 	return nil
 }
 }