Function StartRpcServer

user/rpc/rpc.go:108–143

(stopper chan os.Signal, rpcPath string)

}

func StartRpcServer(stopper chan os.Signal, rpcPath string) {
	addr, err := net.ResolveTCPAddr("tcp4", rpcPath)
	if err != nil {
		Logger.Println("Error ResolveTCPAddr:", err)
		return
	}

	l, err := net.ListenTCP("tcp4", addr)
	if err != nil {
		Logger.Println("Error ListenTCP:", err)
		return
	}

	defer l.Close()

	go func() {
		<-stopper
		Logger.Println("\nReceived Ctrl+C, shutting down...")
		_ = l.Close()
		os.Exit(0)
	}()

	Logger.Println("Server waiting for client...")

	for {
		conn, err := l.Accept()
		if err != nil {
			Logger.Println("Error accepting:", err)
			return
		}

		Logger.Println("Client connected.")

		go handleConnection(conn)
	}
}

func handleConnection(conn net.Conn) {
	defer conn.Close()