unseless for loop

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)
-			err = binary.Read(conn, binary.LittleEndian, &packet)
+		if err != nil {
-			if err != nil {
+			if err == io.EOF {
-				if err == io.EOF {
-					break
-				}
-				fmt.Println("Error in connection:", err)
-			}
-			if packet.Version != 2 {
-				fmt.Printf("Unknown version %d", packet.Version)
 				break
 			}
+			fmt.Println("Error in connection:", err)
+		}
+		if packet.Version != 2 {
+			fmt.Printf("Unknown version %d", packet.Version)
+			break
+		}
 
-			switch packet.MessageType {
+		switch packet.MessageType {
-			case RemoteHandleMessage:
+		case RemoteHandleMessage:
-				var msg Message
+			var msg Message
-				err = ReadMessage(conn, &msg)
+			err = ReadMessage(conn, &msg)
-				if err != nil {
+			if err != nil {
-					fmt.Println("Error reading message:", err)
+				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)
 			}
 
+			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)
 		}
 
 	}
+
 }