76c379571e538424d41754c46d479655fb62331b
[lunaix-os.git] / lunaix-os / hal / ahci / atapi.c
1 #include <hal/ahci/hba.h>
2 #include <hal/ahci/sata.h>
3 #include <hal/ahci/scsi.h>
4 #include <hal/ahci/utils.h>
5
6 #include <klibc/string.h>
7 #include <lunaix/mm/valloc.h>
8 #include <lunaix/mm/vmm.h>
9 #include <lunaix/spike.h>
10 #include <lunaix/syslog.h>
11
12 void
13 scsi_create_packet12(struct scsi_cdb12* cdb,
14                      uint8_t opcode,
15                      uint32_t lba,
16                      uint32_t alloc_size)
17 {
18     memset(cdb, 0, sizeof(*cdb));
19     cdb->opcode = opcode;
20     cdb->lba_be = SCSI_FLIP(lba);
21     cdb->length = SCSI_FLIP(alloc_size);
22 }
23
24 void
25 scsi_create_packet16(struct scsi_cdb16* cdb,
26                      uint8_t opcode,
27                      uint64_t lba,
28                      uint32_t alloc_size)
29 {
30     memset(cdb, 0, sizeof(*cdb));
31     cdb->opcode = opcode;
32     cdb->lba_be_hi = SCSI_FLIP((uint32_t)(lba >> 32));
33     cdb->lba_be_lo = SCSI_FLIP((uint32_t)lba);
34     cdb->length = SCSI_FLIP(alloc_size);
35 }
36
37 void
38 scsi_parse_capacity(struct hba_device* device, uint32_t* parameter)
39 {
40     if (device->cbd_size == SCSI_CDB16) {
41         device->max_lba =
42           SCSI_FLIP(*(parameter + 1)) | (SCSI_FLIP(*parameter) << 32);
43         device->block_size = SCSI_FLIP(*(parameter + 2));
44     } else {
45         // for READ_CAPACITY(10)
46         device->max_lba = SCSI_FLIP(*(parameter));
47         device->block_size = SCSI_FLIP(*(parameter + 1));
48     }
49 }
50
51 int
52 __scsi_buffer_io(struct hba_device* dev,
53                  uint64_t lba,
54                  void* buffer,
55                  uint32_t size,
56                  int write)
57 {
58     assert_msg(((uintptr_t)buffer & 0x3) == 0, "HBA: Bad buffer alignment");
59
60     struct hba_port* port = dev->port;
61     struct hba_cmdh* header;
62     struct hba_cmdt* table;
63     int slot = hba_prepare_cmd(port, &table, &header, buffer, size);
64     int bitmask = 1 << slot;
65
66     // 确保端口是空闲的
67     wait_until(!(port->regs[HBA_RPxTFD] & (HBA_PxTFD_BSY | HBA_PxTFD_DRQ)));
68
69     port->regs[HBA_RPxIS] = 0;
70
71     header->options |= (HBA_CMDH_WRITE * (write == 1)) | HBA_CMDH_ATAPI;
72
73     uint32_t count = ICEIL(size, port->device->block_size);
74
75     struct sata_reg_fis* fis = (struct sata_reg_fis*)table->command_fis;
76     void* cdb = table->atapi_cmd;
77     sata_create_fis(fis, ATA_PACKET, (size << 8), 0);
78     fis->feature = 1 | ((!write) << 2);
79
80     if (port->device->cbd_size == 16) {
81         scsi_create_packet16((struct scsi_cdb16*)cdb,
82                              write ? SCSI_WRITE_BLOCKS_16 : SCSI_READ_BLOCKS_16,
83                              lba,
84                              count);
85     } else {
86         scsi_create_packet12((struct scsi_cdb12*)cdb,
87                              write ? SCSI_WRITE_BLOCKS_12 : SCSI_READ_BLOCKS_12,
88                              lba,
89                              count);
90     }
91
92     // field: cdb->misc1
93     *((uint8_t*)cdb + 1) = 3 << 5; // RPROTECT=011b 禁用保护检查
94
95     int retries = 0;
96
97     while (retries < MAX_RETRY) {
98         port->regs[HBA_RPxCI] = bitmask;
99
100         wait_until_expire(!(port->regs[HBA_RPxCI] & bitmask), 1000000);
101
102         if ((port->regs[HBA_RPxTFD] & HBA_PxTFD_ERR)) {
103             // 有错误
104             sata_read_error(port);
105             retries++;
106         } else {
107             vfree_dma(table);
108             return 1;
109         }
110     }
111
112 fail:
113     vfree_dma(table);
114     return 0;
115 }
116
117 int
118 scsi_read_buffer(struct hba_device* dev,
119                  uint64_t lba,
120                  void* buffer,
121                  uint32_t size)
122 {
123     return __scsi_buffer_io(dev, lba, buffer, size, 0);
124 }
125
126 int
127 scsi_write_buffer(struct hba_device* dev,
128                   uint64_t lba,
129                   void* buffer,
130                   uint32_t size)
131 {
132     return __scsi_buffer_io(dev, lba, buffer, size, 1);
133 }