]> git.sesse.net Git - pistorm/blob - platforms/amiga/piscsi/piscsi.c
Add license information to source
[pistorm] / platforms / amiga / piscsi / piscsi.c
1 // SPDX-License-Identifier: MIT
2
3 #include <stdio.h>
4 #include <stdint.h>
5 #include <stdlib.h>
6 #include <string.h>
7 #include <fcntl.h>
8 #include <unistd.h>
9 #include <endian.h>
10
11 #include "config_file/config_file.h"
12 #include "gpio/ps_protocol.h"
13 #include "piscsi-enums.h"
14 #include "piscsi.h"
15 #include "platforms/amiga/hunk-reloc.h"
16
17 #define BE(val) be32toh(val)
18 #define BE16(val) be16toh(val)
19
20 // Uncomment the line below to enable debug output
21 //#define PISCSI_DEBUG
22
23 #ifdef PISCSI_DEBUG
24 #define DEBUG printf
25 //#define DEBUG_TRIVIAL printf
26 #define DEBUG_TRVIAL(...)
27
28 extern void stop_cpu_emulation(uint8_t disasm_cur);
29
30 static const char *op_type_names[4] = {
31     "BYTE",
32     "WORD",
33     "LONGWORD",
34     "MEM",
35 };
36 #else
37 #define DEBUG(...)
38 #define DEBUG_TRIVIAL(...)
39 #define stop_cpu_emulation(...)
40 #endif
41
42 #ifdef FAKESTORM
43 #define lseek64 lseek
44 #endif
45
46 extern struct emulator_config *cfg;
47
48 struct piscsi_dev devs[8];
49 struct piscsi_fs filesystems[NUM_FILESYSTEMS];
50
51 uint8_t piscsi_num_fs = 0;
52
53 uint8_t piscsi_cur_drive = 0;
54 uint32_t piscsi_u32[4];
55 uint32_t piscsi_dbg[8];
56 uint32_t piscsi_rom_size = 0;
57 uint8_t *piscsi_rom_ptr;
58
59 uint32_t rom_partitions[128];
60 uint32_t rom_partition_prio[128];
61 uint32_t rom_partition_dostype[128];
62 uint32_t rom_cur_partition = 0, rom_cur_fs = 0;
63
64 extern unsigned char ac_piscsi_rom[];
65
66 //static const char *partition_marker = "PART";
67
68 struct hunk_info piscsi_hinfo;
69 struct hunk_reloc piscsi_hreloc[256];
70
71 void piscsi_init() {
72     for (int i = 0; i < 8; i++) {
73         devs[i].fd = -1;
74         devs[i].lba = 0;
75         devs[i].c = devs[i].h = devs[i].s = 0;
76     }
77
78     FILE *in = fopen("./platforms/amiga/piscsi/piscsi.rom", "rb");
79     if (in == NULL) {
80         printf("[PISCSI] Could not open PISCSI Boot ROM file for reading!\n");
81         // Zero out the boot ROM offset from the autoconfig ROM.
82         ac_piscsi_rom[20] = 0;
83         ac_piscsi_rom[21] = 0;
84         ac_piscsi_rom[22] = 0;
85         ac_piscsi_rom[23] = 0;
86         return;
87     }
88     fseek(in, 0, SEEK_END);
89     piscsi_rom_size = ftell(in);
90     fseek(in, 0, SEEK_SET);
91     piscsi_rom_ptr = malloc(piscsi_rom_size);
92     fread(piscsi_rom_ptr, piscsi_rom_size, 1, in);
93
94     fseek(in, PISCSI_DRIVER_OFFSET, SEEK_SET);
95     process_hunks(in, &piscsi_hinfo, piscsi_hreloc, PISCSI_DRIVER_OFFSET);
96
97     fclose(in);
98     printf("[PISCSI] Loaded Boot ROM.\n");
99 }
100
101 void piscsi_find_partitions(struct piscsi_dev *d) {
102     int fd = d->fd;
103     int cur_partition = 0;
104     uint8_t tmp;
105
106     for (int i = 0; i < 16; i++) {
107         if (d->pb[i]) {
108             free(d->pb[i]);
109             d->pb[i] = NULL;
110         }
111     }
112
113     if (!d->rdb || d->rdb->rdb_PartitionList == 0) {
114         DEBUG("[PISCSI] No partitions on disk.\n");
115         return;
116     }
117
118     char *block = malloc(512);
119
120     lseek(fd, BE(d->rdb->rdb_PartitionList) * 512, SEEK_SET);
121 next_partition:;
122     read(fd, block, 512);
123
124     uint32_t first = be32toh(*((uint32_t *)&block[0]));
125     if (first != PART_IDENTIFIER) {
126         DEBUG("Entry at block %d is not a valid partition. Aborting.\n", BE(d->rdb->rdb_PartitionList));
127         return;
128     }
129
130     struct PartitionBlock *pb = (struct PartitionBlock *)block;
131     tmp = pb->pb_DriveName[0];
132     pb->pb_DriveName[tmp + 1] = 0x00;
133     DEBUG("[PISCSI] Partition %d: %s\n", cur_partition, pb->pb_DriveName + 1);
134     DEBUG("Checksum: %.8X HostID: %d\n", BE(pb->pb_ChkSum), BE(pb->pb_HostID));
135     DEBUG("Flags: %d (%.8X) Devflags: %d (%.8X)\n", BE(pb->pb_Flags), BE(pb->pb_Flags), BE(pb->pb_DevFlags), BE(pb->pb_DevFlags));
136     d->pb[cur_partition] = pb;
137
138     if (d->pb[cur_partition]->pb_Next != 0xFFFFFFFF) {
139         uint64_t next = be32toh(pb->pb_Next);
140         block = malloc(512);
141         lseek64(fd, next * 512, SEEK_SET);
142         cur_partition++;
143         DEBUG("[PISCSI] Next partition at block %d.\n", be32toh(pb->pb_Next));
144         goto next_partition;
145     }
146     DEBUG("[PISCSI] No more partitions on disk.\n");
147     d->num_partitions = cur_partition + 1;
148     d->fshd_offs = lseek64(fd, 0, SEEK_CUR);
149
150     return;
151 }
152
153 int piscsi_parse_rdb(struct piscsi_dev *d) {
154     int fd = d->fd;
155     int i = 0;
156     uint8_t *block = malloc(512);
157
158     lseek(fd, 0, SEEK_SET);
159     for (i = 0; i < RDB_BLOCK_LIMIT; i++) {
160         read(fd, block, 512);
161         uint32_t first = be32toh(*((uint32_t *)&block[0]));
162         if (first == RDB_IDENTIFIER)
163             goto rdb_found;
164     }
165     goto no_rdb_found;
166 rdb_found:;
167     struct RigidDiskBlock *rdb = (struct RigidDiskBlock *)block;
168     DEBUG("[PISCSI] RDB found at block %d.\n", i);
169     d->c = be32toh(rdb->rdb_Cylinders);
170     d->h = be32toh(rdb->rdb_Heads);
171     d->s = be32toh(rdb->rdb_Sectors);
172     d->num_partitions = 0;
173     DEBUG("[PISCSI] RDB - first partition at block %d.\n", be32toh(rdb->rdb_PartitionList));
174     if (d->rdb)
175         free(d->rdb);
176     d->rdb = rdb;
177     sprintf(d->rdb->rdb_DriveInitName, "pi-scsi.device");
178     return 0;
179
180 no_rdb_found:;
181     if (block)
182         free(block);
183
184     return -1;
185 }
186
187 void piscsi_refresh_drives() {
188     piscsi_num_fs = 0;
189
190     for (int i = 0; i < NUM_FILESYSTEMS; i++) {
191         if (filesystems[i].binary_data) {
192             free(filesystems[i].binary_data);
193             filesystems[i].binary_data = NULL;
194         }
195         if (filesystems[i].fhb) {
196             free(filesystems[i].fhb);
197             filesystems[i].fhb = NULL;
198         }
199         filesystems[i].h_info.current_hunk = 0;
200         filesystems[i].h_info.reloc_hunks = 0;
201         filesystems[i].FS_ID = 0;
202         filesystems[i].handler = 0;
203     }
204
205     rom_cur_fs = 0;
206
207     for (int i = 0; i < NUM_UNITS; i++) {
208         if (devs[i].fd != -1) {
209             piscsi_parse_rdb(&devs[i]);
210             piscsi_find_partitions(&devs[i]);
211             piscsi_find_filesystems(&devs[i]);
212         }
213     }
214 }
215
216 void piscsi_find_filesystems(struct piscsi_dev *d) {
217     if (!d->num_partitions)
218         return;
219
220     uint8_t fs_found = 0;
221
222     uint8_t *fhb_block = malloc(512);
223
224     lseek64(d->fd, d->fshd_offs, SEEK_SET);
225
226     struct FileSysHeaderBlock *fhb = (struct FileSysHeaderBlock *)fhb_block;
227     read(d->fd, fhb_block, 512);
228
229     while (BE(fhb->fhb_ID) == FS_IDENTIFIER) {
230         char *dosID = (char *)&fhb->fhb_DosType;
231 #ifdef PISCSI_DEBUG
232         uint16_t *fsVer = (uint16_t *)&fhb->fhb_Version;
233
234         DEBUG("[FSHD] FSHD Block found.\n");
235         DEBUG("[FSHD] HostID: %d Next: %d Size: %d\n", BE(fhb->fhb_HostID), BE(fhb->fhb_Next), BE(fhb->fhb_SummedLongs));
236         DEBUG("[FSHD] Flags: %.8X DOSType: %c%c%c/%d\n", BE(fhb->fhb_Flags), dosID[0], dosID[1], dosID[2], dosID[3]);
237         DEBUG("[FSHD] Version: %d.%d\n", BE16(fsVer[0]), BE16(fsVer[1]));
238         DEBUG("[FSHD] Patchflags: %d Type: %d\n", BE(fhb->fhb_PatchFlags), BE(fhb->fhb_Type));
239         DEBUG("[FSHD] Task: %d Lock: %d\n", BE(fhb->fhb_Task), BE(fhb->fhb_Lock));
240         DEBUG("[FSHD] Handler: %d StackSize: %d\n", BE(fhb->fhb_Handler), BE(fhb->fhb_StackSize));
241         DEBUG("[FSHD] Prio: %d Startup: %d\n", BE(fhb->fhb_Priority), BE(fhb->fhb_Startup));
242         DEBUG("[FSHD] SegListBlocks: %d GlobalVec: %d\n", BE(fhb->fhb_Priority), BE(fhb->fhb_Startup));
243         DEBUG("[FSHD] FileSysName: %s\n", fhb->fhb_FileSysName + 1);
244 #endif
245
246         for (int i = 0; i < NUM_FILESYSTEMS; i++) {
247             if (filesystems[i].FS_ID == fhb->fhb_DosType) {
248                 DEBUG("[FSHD] File system %c%c%c/%d already loaded. Skipping.\n", dosID[0], dosID[1], dosID[2], dosID[3]);
249                 if (BE(fhb->fhb_Next) == 0xFFFFFFFF)
250                     goto fs_done;
251
252                 goto skip_fs_load_lseg;
253             }
254         }
255
256         if (load_lseg(d->fd, &filesystems[piscsi_num_fs].binary_data, &filesystems[piscsi_num_fs].h_info, filesystems[piscsi_num_fs].relocs) != -1) {
257             filesystems[piscsi_num_fs].FS_ID = fhb->fhb_DosType;
258             filesystems[piscsi_num_fs].fhb = fhb;
259             printf("[FSHD] Loaded and set up file system %d: %c%c%c/%d\n", piscsi_num_fs + 1, dosID[0], dosID[1], dosID[2], dosID[3]);
260             piscsi_num_fs++;
261         }
262
263 skip_fs_load_lseg:;
264         fs_found++;
265         lseek64(d->fd, BE(fhb->fhb_Next) * 512, SEEK_SET);
266         fhb_block = malloc(512);
267         fhb = (struct FileSysHeaderBlock *)fhb_block;
268         read(d->fd, fhb_block, 512);
269     }
270
271     if (!fs_found) {
272         DEBUG("[!!!FSHD] No file systems found on hard drive!\n");
273     }
274
275 fs_done:;
276     if (fhb_block)
277         free(fhb_block);
278 }
279
280 void piscsi_map_drive(char *filename, uint8_t index) {
281     if (index > 7) {
282         printf("[PISCSI] Drive index %d out of range.\nUnable to map file %s to drive.\n", index, filename);
283         return;
284     }
285
286     int32_t tmp_fd = open(filename, O_RDWR);
287     if (tmp_fd == -1) {
288         printf("[PISCSI] Failed to open file %s, could not map drive %d.\n", filename, index);
289         return;
290     }
291
292     struct piscsi_dev *d = &devs[index];
293
294     uint64_t file_size = lseek(tmp_fd, 0, SEEK_END);
295     d->fs = file_size;
296     d->fd = tmp_fd;
297     lseek(tmp_fd, 0, SEEK_SET);
298     printf("[PISCSI] Map %d: [%s] - %llu bytes.\n", index, filename, file_size);
299
300     if (piscsi_parse_rdb(d) == -1) {
301         DEBUG("[PISCSI] No RDB found on disk, making up some CHS values.\n");
302         d->h = 16;
303         d->s = 63;
304         d->c = (file_size / 512) / (d->s * d->h);
305     }
306     printf("[PISCSI] CHS: %d %d %d\n", d->c, d->h, d->s);
307
308     piscsi_find_partitions(d);
309     piscsi_find_filesystems(d);
310 }
311
312 void piscsi_unmap_drive(uint8_t index) {
313     if (devs[index].fd != -1) {
314         DEBUG("[PISCSI] Unmapped drive %d.\n", index);
315         close (devs[index].fd);
316         devs[index].fd = -1;
317     }
318 }
319
320 char *io_cmd_name(int index) {
321     switch (index) {
322         case CMD_INVALID: return "INVALID";
323         case CMD_RESET: return "RESET";
324         case CMD_READ: return "READ";
325         case CMD_WRITE: return "WRITE";
326         case CMD_UPDATE: return "UPDATE";
327         case CMD_CLEAR: return "CLEAR";
328         case CMD_STOP: return "STOP";
329         case CMD_START: return "START";
330         case CMD_FLUSH: return "FLUSH";
331         case TD_MOTOR: return "TD_MOTOR";
332         case TD_SEEK: return "SEEK";
333         case TD_FORMAT: return "FORMAT";
334         case TD_REMOVE: return "REMOVE";
335         case TD_CHANGENUM: return "CHANGENUM";
336         case TD_CHANGESTATE: return "CHANGESTATE";
337         case TD_PROTSTATUS: return "PROTSTATUS";
338         case TD_RAWREAD: return "RAWREAD";
339         case TD_RAWWRITE: return "RAWWRITE";
340         case TD_GETDRIVETYPE: return "GETDRIVETYPE";
341         case TD_GETNUMTRACKS: return "GETNUMTRACKS";
342         case TD_ADDCHANGEINT: return "ADDCHANGEINT";
343         case TD_REMCHANGEINT: return "REMCHANGEINT";
344         case TD_GETGEOMETRY: return "GETGEOMETRY";
345         case TD_EJECT: return "EJECT";
346         case TD_LASTCOMM: return "LASTCOMM/READ64";
347         case TD_WRITE64: return "WRITE64";
348         case HD_SCSICMD: return "HD_SCSICMD";
349         case NSCMD_DEVICEQUERY: return "NSCMD_DEVICEQUERY";
350         case NSCMD_TD_READ64: return "NSCMD_TD_READ64";
351         case NSCMD_TD_WRITE64: return "NSCMD_TD_WRITE64";
352         case NSCMD_TD_FORMAT64: return "NSCMD_TD_FORMAT64";
353
354         default:
355             return "[!!!PISCSI] Unhandled IO command";
356     }
357 }
358
359 #define GETSCSINAME(a) case a: return ""#a"";
360 #define SCSIUNHANDLED(a) return "[!!!PISCSI] Unhandled SCSI command "#a"";
361
362 char *scsi_cmd_name(int index) {
363     switch(index) {
364         GETSCSINAME(SCSICMD_TEST_UNIT_READY);
365         GETSCSINAME(SCSICMD_INQUIRY);
366         GETSCSINAME(SCSICMD_READ_6);
367         GETSCSINAME(SCSICMD_WRITE_6);
368         GETSCSINAME(SCSICMD_READ_10);
369         GETSCSINAME(SCSICMD_WRITE_10);
370         GETSCSINAME(SCSICMD_READ_CAPACITY_10);
371         GETSCSINAME(SCSICMD_MODE_SENSE_6);
372         GETSCSINAME(SCSICMD_READ_DEFECT_DATA_10);
373         default:
374             return "[!!!PISCSI] Unhandled SCSI command";
375     }
376 }
377
378 void print_piscsi_debug_message(int index) {
379     int32_t r = 0;
380
381     switch (index) {
382         case DBG_INIT:
383             DEBUG("[PISCSI] Initializing devices.\n");
384             break;
385         case DBG_OPENDEV:
386             if (piscsi_dbg[0] != 255) {
387                 DEBUG("[PISCSI] Opening device %d (%d). Flags: %d (%.2X)\n", piscsi_dbg[0], piscsi_dbg[2], piscsi_dbg[1], piscsi_dbg[1]);
388             }
389             break;
390         case DBG_CLEANUP:
391             DEBUG("[PISCSI] Cleaning up.\n");
392             break;
393         case DBG_CHS:
394             DEBUG("[PISCSI] C/H/S: %d / %d / %d\n", piscsi_dbg[0], piscsi_dbg[1], piscsi_dbg[2]);
395             break;
396         case DBG_BEGINIO:
397             DEBUG("[PISCSI] BeginIO: io_Command: %d (%s) - io_Flags = %d - quick: %d\n", piscsi_dbg[0], io_cmd_name(piscsi_dbg[0]), piscsi_dbg[1], piscsi_dbg[2]);
398             break;
399         case DBG_ABORTIO:
400             DEBUG("[PISCSI] AbortIO!\n");
401             break;
402         case DBG_SCSICMD:
403             DEBUG("[PISCSI] SCSI Command %d (%s)\n", piscsi_dbg[1], scsi_cmd_name(piscsi_dbg[1]));
404             DEBUG("Len: %d - %.2X %.2X %.2X - Command Length: %d\n", piscsi_dbg[0], piscsi_dbg[1], piscsi_dbg[2], piscsi_dbg[3], piscsi_dbg[4]);
405             break;
406         case DBG_SCSI_UNKNOWN_MODESENSE:
407             DEBUG("[!!!PISCSI] SCSI: Unknown modesense %.4X\n", piscsi_dbg[0]);
408             break;
409         case DBG_SCSI_UNKNOWN_COMMAND:
410             DEBUG("[!!!PISCSI] SCSI: Unknown command %.4X\n", piscsi_dbg[0]);
411             break;
412         case DBG_SCSIERR:
413             DEBUG("[!!!PISCSI] SCSI: An error occured: %.4X\n", piscsi_dbg[0]);
414             break;
415         case DBG_IOCMD:
416             DEBUG_TRIVIAL("[PISCSI] IO Command %d (%s)\n", piscsi_dbg[0], io_cmd_name(piscsi_dbg[0]));
417             break;
418         case DBG_IOCMD_UNHANDLED:
419             DEBUG("[!!!PISCSI] WARN: IO command %.4X (%s) is unhandled by driver.\n", piscsi_dbg[0], io_cmd_name(piscsi_dbg[0]));
420             break;
421         case DBG_SCSI_FORMATDEVICE:
422             DEBUG("[PISCSI] Get SCSI FormatDevice MODE SENSE.\n");
423             break;
424         case DBG_SCSI_RDG:
425             DEBUG("[PISCSI] Get SCSI RDG MODE SENSE.\n");
426             break;
427         case DBG_SCSICMD_RW10:
428 #ifdef PISCSI_DEBUG
429             r = get_mapped_item_by_address(cfg, piscsi_dbg[0]);
430             struct SCSICmd_RW10 *rwdat = NULL;
431             char data[10];
432             if (r != -1) {
433                 uint32_t addr = piscsi_dbg[0] - cfg->map_offset[r];
434                 rwdat = (struct SCSICmd_RW10 *)(&cfg->map_data[r][addr]);
435             }
436             else {
437                 DEBUG_TRIVIAL("[RW10] scsiData: %.8X\n", piscsi_dbg[0]);
438                 for (int i = 0; i < 10; i++) {
439                     data[i] = read8(piscsi_dbg[0] + i);
440                 }
441                 rwdat = data;
442             }
443             if (rwdat) {
444                 DEBUG_TRIVIAL("[RW10] CMD: %.2X\n", rwdat->opcode);
445                 DEBUG_TRIVIAL("[RW10] RDP: %.2X\n", rwdat->rdprotect_flags);
446                 DEBUG_TRIVIAL("[RW10] Block: %d (%d)\n", rwdat->block, BE(rwdat->block));
447                 DEBUG_TRIVIAL("[RW10] Res_Group: %.2X\n", rwdat->res_groupnum);
448                 DEBUG_TRIVIAL("[RW10] Len: %d (%d)\n", rwdat->len, BE16(rwdat->len));
449             }
450 #endif
451             break;
452         case DBG_SCSI_DEBUG_MODESENSE_6:
453             DEBUG_TRIVIAL("[PISCSI] SCSI ModeSense debug. Data: %.8X\n", piscsi_dbg[0]);
454             r = get_mapped_item_by_address(cfg, piscsi_dbg[0]);
455             if (r != -1) {
456 #ifdef PISCSI_DEBUG
457                 uint32_t addr = piscsi_dbg[0] - cfg->map_offset[r];
458                 struct SCSICmd_ModeSense6 *sense = (struct SCSICmd_ModeSense6 *)(&cfg->map_data[r][addr]);
459                 DEBUG_TRIVIAL("[SenseData] CMD: %.2X\n", sense->opcode);
460                 DEBUG_TRIVIAL("[SenseData] DBD: %d\n", sense->reserved_dbd & 0x04);
461                 DEBUG_TRIVIAL("[SenseData] PC: %d\n", (sense->pc_pagecode & 0xC0 >> 6));
462                 DEBUG_TRIVIAL("[SenseData] PageCodes: %.2X %.2X\n", (sense->pc_pagecode & 0x3F), sense->subpage_code);
463                 DEBUG_TRIVIAL("[SenseData] AllocLen: %d\n", sense->alloc_len);
464                 DEBUG_TRIVIAL("[SenseData] Control: %.2X (%d)\n", sense->control, sense->control);
465 #endif
466             }
467             else {
468                 DEBUG("[!!!PISCSI] ModeSense data not immediately available.\n");
469             }
470             break;
471         default:
472             DEBUG("[!!!PISCSI] No debug message available for index %d.\n", index);
473             break;
474     }
475 }
476
477 #define DEBUGME_SIMPLE(i, s) case i: DEBUG(s); break;
478
479 void piscsi_debugme(uint32_t index) {
480     switch (index) {
481         DEBUGME_SIMPLE(1, "[PISCSI-DEBUGME] Arrived at DiagEntry.\n");
482         DEBUGME_SIMPLE(3, "[PISCSI-DEBUGME] Init: Interrupt disable.\n");
483         DEBUGME_SIMPLE(4, "[PISCSI-DEBUGME] Init: Copy/reloc driver.\n");
484         DEBUGME_SIMPLE(5, "[PISCSI-DEBUGME] Init: InitResident.\n");
485         DEBUGME_SIMPLE(7, "[PISCSI-DEBUGME] Init: Begin partition loop.\n");
486         DEBUGME_SIMPLE(8, "[PISCSI-DEBUGME] Init: Partition loop done. Cleaning up and returning to Exec.\n");
487         DEBUGME_SIMPLE(9, "[PISCSI-DEBUGME] Init: Load file systems.\n");
488         DEBUGME_SIMPLE(10, "[PISCSI-DEBUGME] Init: AllocMem for resident.\n");
489         DEBUGME_SIMPLE(11, "[PISCSI-DEBUGME] Init: Checking if resident is loaded.\n");
490         DEBUGME_SIMPLE(22, "[PISCSI-DEBUGME] Arrived at BootEntry.\n");
491         DEBUGME_SIMPLE(30, "[PISCSI-DEBUGME] LoadFileSystems: Opening FileSystem.resource.\n");
492         DEBUGME_SIMPLE(33, "[PISCSI-DEBUGME] FileSystem.resource not available, creating.\n");
493         case 31:
494             DEBUG("[PISCSI-DEBUGME] OpenResource result: %d\n", piscsi_u32[0]);
495             break;
496         case 32:
497             DEBUG("AAAAHH!\n");
498             break;
499         default:
500             DEBUG("[!!!PISCSI-DEBUGME] No debugme message for index %d!\n", index);
501             break;
502     }
503
504     if (index == 8) {
505         stop_cpu_emulation(1);
506     }
507 }
508
509 void handle_piscsi_write(uint32_t addr, uint32_t val, uint8_t type) {
510     int32_t r;
511 #ifndef PISCSI_DEBUG
512     if (type) {}
513 #endif
514
515     struct piscsi_dev *d = &devs[piscsi_cur_drive];
516
517     uint16_t cmd = (addr & 0xFFFF);
518
519     switch (cmd) {
520         case PISCSI_CMD_READ64:
521         case PISCSI_CMD_READ:
522             d = &devs[val];
523             if (d->fd == -1) {
524                 DEBUG("[!!!PISCSI] BUG: Attempted read from unmapped drive %d.\n", val);
525                 break;
526             }
527
528             if (cmd == PISCSI_CMD_READ) {
529                 DEBUG("[PISCSI-%d] %d byte READ from block %d to address %.8X\n", val, piscsi_u32[1], piscsi_u32[0], piscsi_u32[2]);
530                 d->lba = piscsi_u32[0];
531                 lseek(d->fd, (piscsi_u32[0] * 512), SEEK_SET);
532             }
533             else {
534                 uint64_t src = piscsi_u32[3];
535                 src = (src << 32) | piscsi_u32[0];
536                 DEBUG("[PISCSI-%d] %d byte READ64 from block %lld to address %.8X\n", val, piscsi_u32[1], (src / 512), piscsi_u32[2]);
537                 d->lba = (src / 512);
538                 lseek64(d->fd, src, SEEK_SET);
539             }
540
541             r = get_mapped_item_by_address(cfg, piscsi_u32[2]);
542             if (r != -1 && cfg->map_type[r] == MAPTYPE_RAM) {
543                 DEBUG_TRIVIAL("[PISCSI-%d] \"DMA\" Read goes to mapped range %d.\n", val, r);
544                 read(d->fd, cfg->map_data[r] + piscsi_u32[2] - cfg->map_offset[r], piscsi_u32[1]);
545             }
546             else {
547                 DEBUG_TRIVIAL("[PISCSI-%d] No mapped range found for read.\n", val);
548                 uint8_t c = 0;
549                 for (uint32_t i = 0; i < piscsi_u32[1]; i++) {
550                     read(d->fd, &c, 1);
551                     write8(piscsi_u32[2] + i, (uint32_t)c);
552                 }
553             }
554             break;
555         case PISCSI_CMD_WRITE64:
556         case PISCSI_CMD_WRITE:
557             d = &devs[val];
558             if (d->fd == -1) {
559                 DEBUG ("[PISCSI] BUG: Attempted write to unmapped drive %d.\n", val);
560                 break;
561             }
562
563             if (cmd == PISCSI_CMD_WRITE) {
564                 DEBUG("[PISCSI-%d] %d byte WRITE to block %d from address %.8X\n", val, piscsi_u32[1], piscsi_u32[0], piscsi_u32[2]);
565                 d->lba = piscsi_u32[0];
566                 lseek(d->fd, (piscsi_u32[0] * 512), SEEK_SET);
567             }
568             else {
569                 uint64_t src = piscsi_u32[3];
570                 src = (src << 32) | piscsi_u32[0];
571                 DEBUG("[PISCSI-%d] %d byte WRITE64 to block %lld from address %.8X\n", val, piscsi_u32[1], (src / 512), piscsi_u32[2]);
572                 d->lba = (src / 512);
573                 lseek64(d->fd, src, SEEK_SET);
574             }
575
576             r = get_mapped_item_by_address(cfg, piscsi_u32[2]);
577             if (r != -1) {
578                 DEBUG_TRIVIAL("[PISCSI-%d] \"DMA\" Write comes from mapped range %d.\n", val, r);
579                 write(d->fd, cfg->map_data[r] + piscsi_u32[2] - cfg->map_offset[r], piscsi_u32[1]);
580             }
581             else {
582                 DEBUG_TRIVIAL("[PISCSI-%d] No mapped range found for write.\n", val);
583                 uint8_t c = 0;
584                 for (uint32_t i = 0; i < piscsi_u32[1]; i++) {
585                     c = read8(piscsi_u32[2] + i);
586                     write(d->fd, &c, 1);
587                 }
588             }
589             break;
590         case PISCSI_CMD_ADDR1: case PISCSI_CMD_ADDR2: case PISCSI_CMD_ADDR3: case PISCSI_CMD_ADDR4: {
591             int i = ((addr & 0xFFFF) - PISCSI_CMD_ADDR1) / 4;
592             piscsi_u32[i] = val;
593             break;
594         }
595         case PISCSI_CMD_DRVNUM:
596             //printf("%d ", val);
597             if (val % 10 != 0)
598                 piscsi_cur_drive = 255;
599             else
600                 piscsi_cur_drive = val / 10;
601             if (piscsi_cur_drive > NUM_UNITS)
602                 piscsi_cur_drive = 255;
603
604             if (piscsi_cur_drive != 255) {
605                 DEBUG("[PISCSI] (%s) Drive number set to %d (%d)\n", op_type_names[type], piscsi_cur_drive, val);
606             }
607             break;
608         case PISCSI_CMD_DEBUGME:
609             piscsi_debugme(val);
610             break;
611         case PISCSI_CMD_DRIVER: {
612             DEBUG("[PISCSI] Driver copy/patch called, destination address %.8X.\n", val);
613             int r = get_mapped_item_by_address(cfg, val);
614             if (r != -1) {
615                 uint32_t addr = val - cfg->map_offset[r];
616                 uint8_t *dst_data = cfg->map_data[r];
617                 uint8_t cur_partition = 0;
618                 memcpy(dst_data + addr, piscsi_rom_ptr + PISCSI_DRIVER_OFFSET, 0x4000 - PISCSI_DRIVER_OFFSET);
619
620                 piscsi_hinfo.base_offset = val;
621
622                 reloc_hunks(piscsi_hreloc, dst_data + addr, &piscsi_hinfo);
623
624                 #define PUTNODELONG(val) *(uint32_t *)&dst_data[p_offs] = htobe32(val); p_offs += 4;
625                 #define PUTNODELONGBE(val) *(uint32_t *)&dst_data[p_offs] = val; p_offs += 4;
626
627                 for (int i = 0; i < 128; i++) {
628                     rom_partitions[i] = 0;
629                     rom_partition_prio[i] = 0;
630                     rom_partition_dostype[i] = 0;
631                 }
632                 rom_cur_partition = 0;
633
634                 uint32_t data_addr = addr + 0x3F00;
635                 sprintf((char *)dst_data + data_addr, "pi-scsi.device");
636                 uint32_t addr2 = addr + 0x4000;
637                 for (int i = 0; i < NUM_UNITS; i++) {
638                     if (devs[i].fd != -1)
639                         piscsi_find_partitions(&devs[i]);
640                     else
641                         goto skip_disk;
642
643                     if (devs[i].num_partitions) {
644                         uint32_t p_offs = addr2;
645                         DEBUG("[PISCSI] Adding %d partitions for unit %d\n", devs[i].num_partitions, i);
646                         for (uint32_t j = 0; j < devs[i].num_partitions; j++) {
647                             DEBUG("Partition %d: %s\n", j, devs[i].pb[j]->pb_DriveName + 1);
648                             sprintf((char *)dst_data + p_offs, "%s", devs[i].pb[j]->pb_DriveName + 1);
649                             p_offs += 0x20;
650                             PUTNODELONG(addr2 + cfg->map_offset[r]);
651                             PUTNODELONG(data_addr + cfg->map_offset[r]);
652                             PUTNODELONG((i * 10));
653                             PUTNODELONG(0);
654                             uint32_t nodesize = (be32toh(devs[i].pb[j]->pb_Environment[0]) + 1) * 4;
655                             memcpy(dst_data + p_offs, devs[i].pb[j]->pb_Environment, nodesize);
656
657                             struct pihd_dosnode_data *dat = (struct pihd_dosnode_data *)(&dst_data[addr2+0x20]);
658
659                             if (BE(devs[i].pb[j]->pb_Flags) & 0x01) {
660                                 DEBUG("Partition is bootable.\n");
661                                 rom_partition_prio[cur_partition] = 0;
662                                 dat->priority = 0;
663                             }
664                             else {
665                                 DEBUG("Partition is not bootable.\n");
666                                 rom_partition_prio[cur_partition] = -128;
667                                 dat->priority = htobe32(-128);
668                             }
669
670                             DEBUG("DOSNode Data:\n");
671                             DEBUG("Name: %s Device: %s\n", dst_data + addr2, dst_data + data_addr);
672                             DEBUG("Unit: %d Flags: %d Pad1: %d\n", BE(dat->unit), BE(dat->flags), BE(dat->pad1));
673                             DEBUG("Node len: %d Block len: %d\n", BE(dat->node_len) * 4, BE(dat->block_len) * 4);
674                             DEBUG("H: %d SPB: %d BPS: %d\n", BE(dat->surf), BE(dat->secs_per_block), BE(dat->blocks_per_track));
675                             DEBUG("Reserved: %d Prealloc: %d\n", BE(dat->reserved_blocks), BE(dat->pad2));
676                             DEBUG("Interleaved: %d Buffers: %d Memtype: %d\n", BE(dat->interleave), BE(dat->buffers), BE(dat->mem_type));
677                             DEBUG("Lowcyl: %d Highcyl: %d Prio: %d\n", BE(dat->lowcyl), BE(dat->highcyl), BE(dat->priority));
678                             DEBUG("Maxtransfer: %.8X Mask: %.8X\n", BE(dat->maxtransfer), BE(dat->transfer_mask));
679                             DEBUG("DOSType: %.8X\n", BE(dat->dostype));
680
681                             rom_partitions[cur_partition] = addr2 + 0x20 + cfg->map_offset[r];
682                             rom_partition_dostype[cur_partition] = dat->dostype;
683                             cur_partition++;
684                             addr2 += 0x100;
685                             p_offs = addr2;
686                         }
687                     }
688 skip_disk:;
689                 }
690             }
691
692             break;
693         }
694         case PISCSI_CMD_NEXTPART:
695             DEBUG("[PISCSI] Switch partition %d -> %d\n", rom_cur_partition, rom_cur_partition + 1);
696             rom_cur_partition++;
697             break;
698         case PISCSI_CMD_NEXTFS:
699             DEBUG("[PISCSI] Switch file file system %d -> %d\n", rom_cur_fs, rom_cur_fs + 1);
700             rom_cur_fs++;
701             break;
702         case PISCSI_CMD_COPYFS:
703             DEBUG("[PISCSI] Copy file system %d to %.8X and reloc.\n", rom_cur_fs, piscsi_u32[2]);
704             r = get_mapped_item_by_address(cfg, piscsi_u32[2]);
705             if (r != -1) {
706                 uint32_t addr = piscsi_u32[2] - cfg->map_offset[r];
707                 memset(cfg->map_data[r] + addr, 0x00, filesystems[rom_cur_fs].h_info.alloc_size);
708                 memcpy(cfg->map_data[r] + addr, filesystems[rom_cur_fs].binary_data, filesystems[rom_cur_fs].h_info.byte_size);
709                 filesystems[rom_cur_fs].h_info.base_offset = piscsi_u32[2];
710                 reloc_hunks(filesystems[rom_cur_fs].relocs, cfg->map_data[r] + addr, &filesystems[rom_cur_fs].h_info);
711                 filesystems[rom_cur_fs].handler = piscsi_u32[2];
712             }
713             break;
714         case PISCSI_CMD_SETFSH: {
715             int i = 0;
716             DEBUG("[PISCSI] Set handler for partition %d (DeviceNode: %.8X)\n", rom_cur_partition, val);
717             r = get_mapped_item_by_address(cfg, val);
718             if (r != -1) {
719                 uint32_t addr = val - cfg->map_offset[r];
720                 struct DeviceNode *node = (struct DeviceNode *)(cfg->map_data[r] + addr);
721 #ifdef PISCSI_DEBUG
722                 char *dosID = (char *)&rom_partition_dostype[rom_cur_partition];
723 #endif
724                 DEBUG("[PISCSI] Partition DOSType is %c%c%c/%d\n", dosID[0], dosID[1], dosID[2], dosID[3]);
725                 for (i = 0; i < piscsi_num_fs; i++) {
726                     if (rom_partition_dostype[rom_cur_partition] == filesystems[i].FS_ID) {
727                         node->dn_SegList = htobe32((filesystems[i].handler >> 2));
728                         node->dn_GlobalVec = 0xFFFFFFFF;
729                         goto fs_found;
730                     }
731                 }
732                 DEBUG("[!!!PISCSI] Found no handler for file system!\n");
733 fs_found:;
734                 DEBUG("[FS-HANDLER] Next: %d Type: %.8X\n", BE(node->dn_Next), BE(node->dn_Type));
735                 DEBUG("[FS-HANDLER] Task: %d Lock: %d\n", BE(node->dn_Task), BE(node->dn_Lock));
736                 DEBUG("[FS-HANDLER] Handler: %d Stacksize: %d\n", BE((uint32_t)node->dn_Handler), BE(node->dn_StackSize));
737                 DEBUG("[FS-HANDLER] Priority: %d Startup: %d\n", BE((uint32_t)node->dn_Priority), BE(node->dn_Startup));
738                 DEBUG("[FS-HANDLER] SegList: %.8X GlobalVec: %d\n", BE((uint32_t)node->dn_SegList), BE(node->dn_GlobalVec));
739                 DEBUG("[PISCSI] Handler for partition %.8X set to %.8X (%.8X).\n", BE((uint32_t)node->dn_Name), filesystems[i].FS_ID, filesystems[i].handler);
740             }
741             break;
742         }
743         case PISCSI_DBG_VAL1: case PISCSI_DBG_VAL2: case PISCSI_DBG_VAL3: case PISCSI_DBG_VAL4:
744         case PISCSI_DBG_VAL5: case PISCSI_DBG_VAL6: case PISCSI_DBG_VAL7: case PISCSI_DBG_VAL8: {
745             int i = ((addr & 0xFFFF) - PISCSI_DBG_VAL1) / 4;
746             piscsi_dbg[i] = val;
747             break;
748         }
749         case PISCSI_DBG_MSG:
750             print_piscsi_debug_message(val);
751             break;
752         default:
753             DEBUG("[!!!PISCSI] WARN: Unhandled %s register write to %.8X: %d\n", op_type_names[type], addr, val);
754             break;
755     }
756 }
757
758 #define PIB 0x00
759
760 uint32_t handle_piscsi_read(uint32_t addr, uint8_t type) {
761     if (type) {}
762
763     if ((addr & 0xFFFF) >= PISCSI_CMD_ROM) {
764         uint32_t romoffs = (addr & 0xFFFF) - PISCSI_CMD_ROM;
765         if (romoffs < (piscsi_rom_size + PIB)) {
766             //DEBUG("[PISCSI] %s read from Boot ROM @$%.4X (%.8X): ", op_type_names[type], romoffs, addr);
767             uint32_t v = 0;
768             switch (type) {
769                 case OP_TYPE_BYTE:
770                     v = piscsi_rom_ptr[romoffs - PIB];
771                     //DEBUG("%.2X\n", v);
772                     break;
773                 case OP_TYPE_WORD:
774                     v = be16toh(*((uint16_t *)&piscsi_rom_ptr[romoffs - PIB]));
775                     //DEBUG("%.4X\n", v);
776                     break;
777                 case OP_TYPE_LONGWORD:
778                     v = be32toh(*((uint32_t *)&piscsi_rom_ptr[romoffs - PIB]));
779                     //DEBUG("%.8X\n", v);
780                     break;
781             }
782             return v;
783         }
784         return 0;
785     }
786
787     switch (addr & 0xFFFF) {
788         case PISCSI_CMD_ADDR1: case PISCSI_CMD_ADDR2: case PISCSI_CMD_ADDR3: case PISCSI_CMD_ADDR4: {
789             int i = ((addr & 0xFFFF) - PISCSI_CMD_ADDR1) / 4;
790             return piscsi_u32[i];
791             break;
792         }
793         case PISCSI_CMD_DRVTYPE:
794             if (devs[piscsi_cur_drive].fd == -1) {
795                 DEBUG("[PISCSI] %s Read from DRVTYPE %d, drive not attached.\n", op_type_names[type], piscsi_cur_drive);
796                 return 0;
797             }
798             DEBUG("[PISCSI] %s Read from DRVTYPE %d, drive attached.\n", op_type_names[type], piscsi_cur_drive);
799             return 1;
800             break;
801         case PISCSI_CMD_DRVNUM:
802             return piscsi_cur_drive;
803             break;
804         case PISCSI_CMD_CYLS:
805             DEBUG("[PISCSI] %s Read from CYLS %d: %d\n", op_type_names[type], piscsi_cur_drive, devs[piscsi_cur_drive].c);
806             return devs[piscsi_cur_drive].c;
807             break;
808         case PISCSI_CMD_HEADS:
809             DEBUG("[PISCSI] %s Read from HEADS %d: %d\n", op_type_names[type], piscsi_cur_drive, devs[piscsi_cur_drive].h);
810             return devs[piscsi_cur_drive].h;
811             break;
812         case PISCSI_CMD_SECS:
813             DEBUG("[PISCSI] %s Read from SECS %d: %d\n", op_type_names[type], piscsi_cur_drive, devs[piscsi_cur_drive].s);
814             return devs[piscsi_cur_drive].s;
815             break;
816         case PISCSI_CMD_BLOCKS: {
817             uint32_t blox = devs[piscsi_cur_drive].fs / 512;
818             DEBUG("[PISCSI] %s Read from BLOCKS %d: %d\n", op_type_names[type], piscsi_cur_drive, (uint32_t)(devs[piscsi_cur_drive].fs / 512));
819             DEBUG("fs: %lld (%d)\n", devs[piscsi_cur_drive].fs, blox);
820             return blox;
821             break;
822         }
823         case PISCSI_CMD_GETPART: {
824             DEBUG("[PISCSI] Get ROM partition %d offset: %.8X\n", rom_cur_partition, rom_partitions[rom_cur_partition]);
825             return rom_partitions[rom_cur_partition];
826             break;
827         }
828         case PISCSI_CMD_GETPRIO:
829             DEBUG("[PISCSI] Get partition %d boot priority: %d\n", rom_cur_partition, rom_partition_prio[rom_cur_partition]);
830             return rom_partition_prio[rom_cur_partition];
831             break;
832         case PISCSI_CMD_CHECKFS:
833             DEBUG("[PISCSI] Get current loaded file system: %.8X\n", filesystems[rom_cur_fs].FS_ID);
834             return filesystems[rom_cur_fs].FS_ID;
835         case PISCSI_CMD_FSSIZE:
836             DEBUG("[PISCSI] Get alloc size of loaded file system: %d\n", filesystems[rom_cur_fs].h_info.alloc_size);
837             return filesystems[rom_cur_fs].h_info.alloc_size;
838         default:
839             DEBUG("[!!!PISCSI] WARN: Unhandled %s register read from %.8X\n", op_type_names[type], addr);
840             break;
841     }
842
843     return 0;
844 }