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