diff options
Diffstat (limited to 'internal/server/tcpserver.go')
| -rw-r--r-- | internal/server/tcpserver.go | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/internal/server/tcpserver.go b/internal/server/tcpserver.go index 3853cdc..47d47ca 100644 --- a/internal/server/tcpserver.go +++ b/internal/server/tcpserver.go @@ -15,26 +15,26 @@ type handlerCb func(message string) string func tcpServerRun(ctx context.Context, conf config.Config, cb handlerCb) error { listener, err := net.Listen("tcp", conf.Address) if err != nil { - return fmt.Errorf("Error starting TCP server: %s", err.Error()) + return fmt.Errorf("error starting TCP server: %s", err.Error()) } defer listener.Close() - log.Printf("TCP server started on %s\n", conf.Address) + log.Println("server: lisetning on", conf.Address) for { conn, err := listener.Accept() if err != nil { - log.Printf("Error accepting connection: %s\n", err.Error()) + log.Println("server: error accepting connection:", err) continue } if !conf.IsNodeWithLookup(conn.RemoteAddr().String(), net.LookupIP) { - log.Printf("Denying connection, peer not a node: %v\n", conn.RemoteAddr().String()) + log.Println("server: denying connection, peer not a node:", conn.RemoteAddr().String()) conn.Close() continue } - log.Printf("Client connected: %s\n", conn.RemoteAddr().String()) + log.Println("server: client connected:", conn.RemoteAddr().String()) go handleConnection(ctx, conn, cb) } } @@ -50,16 +50,16 @@ func handleConnection(ctx context.Context, conn net.Conn, cb handlerCb) { for { select { case <-ctx.Done(): - log.Printf("Server context done, disconnecting client %s\n", remoteAddr) + log.Println("server: context done, disconnecting client:", remoteAddr) return default: message, err := reader.ReadString('\n') if err != nil { - log.Printf("Client %s disconnected: %s\n", remoteAddr, err.Error()) + log.Println("server: client disconnected:", remoteAddr, err) return } - log.Printf("Received message from %s: %s", remoteAddr, message) + log.Println("server: received message", remoteAddr, message) response := cb(message) conn.Write([]byte(response)) } |