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