From 2831e627b8a61a8c2108ccdbbbf25aab6954ecf1 Mon Sep 17 00:00:00 2001 From: matst80 Date: Sun, 10 Nov 2024 00:26:35 +0100 Subject: [PATCH] unseless for loop --- rpc-server.go | 61 +++++++++++++++++++++++++-------------------------- 1 file changed, 30 insertions(+), 31 deletions(-) diff --git a/rpc-server.go b/rpc-server.go index 5ea341c..e667f3a 100644 --- a/rpc-server.go +++ b/rpc-server.go @@ -44,47 +44,46 @@ func (h *GrainHandler) Serve() { func (h *GrainHandler) handleClient(conn net.Conn) { var err error - fmt.Println("Handling client connection") + defer conn.Close() var packet CartPacket + for { - for { - err = binary.Read(conn, binary.LittleEndian, &packet) - if err != nil { - if err == io.EOF { - break - } - fmt.Println("Error in connection:", err) - } - if packet.Version != 2 { - fmt.Printf("Unknown version %d", packet.Version) + err = binary.Read(conn, binary.LittleEndian, &packet) + if err != nil { + if err == io.EOF { break } + fmt.Println("Error in connection:", err) + } + if packet.Version != 2 { + fmt.Printf("Unknown version %d", packet.Version) + break + } - switch packet.MessageType { - case RemoteHandleMessage: - var msg Message - err = ReadMessage(conn, &msg) - if err != nil { - fmt.Println("Error reading message:", err) - } - - data, err := h.pool.Process(packet.Id, msg) - if err != nil { - fmt.Println("Error handling message:", err) - } - SendRawResponse(conn, data) - - case RemoteGetState: - data, err := h.pool.Get(packet.Id) - if err != nil { - fmt.Println("Error getting grain:", err) - } - SendRawResponse(conn, data) + switch packet.MessageType { + case RemoteHandleMessage: + var msg Message + err = ReadMessage(conn, &msg) + if err != nil { + fmt.Println("Error reading message:", err) } + data, err := h.pool.Process(packet.Id, msg) + if err != nil { + fmt.Println("Error handling message:", err) + } + SendRawResponse(conn, data) + + case RemoteGetState: + data, err := h.pool.Get(packet.Id) + if err != nil { + fmt.Println("Error getting grain:", err) + } + SendRawResponse(conn, data) } } + }