Function handleConnection

user/rpc/rpc.go:145–185

(conn net.Conn)

}

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

	for {
		var size uint32 = 0
		err := binary.Read(conn, binary.LittleEndian, &size)
		if err != nil {
			return
		}

		buffer := make([]byte, size)
		err = binary.Read(conn, binary.LittleEndian, &buffer)
		if err != nil {
			return
		}

		msg := RespMsg{}

		brk_options, err := ParseMsg(buffer)
		if err != nil {
			msg.Status = "error"
			msg.Msg = fmt.Sprintf("ParseMsg failed, err:%v", err)
		} else {
			Logger.Println("Received message:", string(buffer))
			BrkIt(brk_options)
			msg.Status = "ok"
			msg.Msg = "register breakpoint success"
		}

		resp, err := json.Marshal(msg)
		err = binary.Write(conn, binary.LittleEndian, uint32(len(resp)))
		if err != nil {
			return
		}
		err = binary.Write(conn, binary.LittleEndian, resp)
		if err != nil {
			return
		}
		Logger.Println("resp ->", string(resp))
	}
}