Palacios Public Git Repository

To checkout Palacios execute

  git clone http://v3vee.org/palacios/palacios.web/palacios.git
This will give you the master branch. You probably want the devel branch or one of the release branches. To switch to the devel branch, simply execute
  cd palacios
  git checkout --track -b devel origin/devel
The other branches are similar.


Merge branch 'devel' into ide
[palacios.git] / palacios / src / devices / ramdisk.c
index 9455798..04602f7 100644 (file)
-/*
- * Zheng Cui
- * cuizheng@cs.unm.edu
- * July 2008
+/* 
+ *
+ *   Copyright (C) 2002  MandrakeSoft S.A.
+ *
+ *     MandrakeSoft S.A.
+ *     43, rue d'Aboukir
+ *     75002 Paris - France
+ *     http://www.linux-mandrake.com/
+ *     http://www.mandrakesoft.com/
+ *
+ *   This library is free software; you can redistribute it and/or
+ *   modify it under the terms of the GNU Lesser General Public
+ *   License as published by the Free Software Foundation; either
+ *   version 2 of the License, or (at your option) any later version.
+ *
+ *   This library is distributed in the hope that it will be useful,
+ *   but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ *   Lesser General Public License for more details.
+ *
+ *  You should have received a copy of the GNU Lesser General Public
+ *  License along with this library; if not, write to the Free Software
+ *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
+ *
+ * Major modifications made for the V3VEE project
+ * 
+ * The V3VEE Project is a joint project between Northwestern University
+ * and the University of New Mexico.  You can find out more at 
+ * http://www.v3vee.org
+ * 
+ * Copyright (c) 2008, Zheng Cui <cuizheng@cs.unm.edu>
+ * Copyright (c) 2008, Jack Lange <jarusl@cs.northwestern.edu>
+ * Copyright (c) 2008, The V3VEE Project <http://www.v3vee.org> 
+ * All rights reserved for original changes
+ * 
  */
 
+
 #include <devices/ramdisk.h>
 #include <palacios/vmm.h>
-#include <string.h>
+#include <devices/cdrom.h>
+#include <devices/ide.h>
+#include <devices/pci.h>
 
-#ifdef DEBUG_RAMDISK
-#define Ramdisk_Print(_f, _a...) PrintTrace("\nramdisk.c(%d) " _f, __LINE__, ## _a)
-#else 
-#define Ramdisk_Print(_f, _a...)
+#ifndef TRACE_RAMDISK
+#undef PrintTrace
+#define PrintTrace(fmt, args...)
 #endif
 
-#define RD_PANIC(_f, _a...)     \
-  do {                       \
-    PrintDebug("ramdisk.c(%d) " _f, __LINE__, ## _a);  \
-      while(1);              \
-    }                        \
-   while(0)                                                            
-    
-#define RD_ERROR(_f, _a...) PrintTrace("\nramdisk.c(%d) " _f, __LINE__, ## _a)
+
+#ifndef DEBUG_RAMDISK
+#undef PrintDebug
+#define PrintDebug(fmt, args...)
+#endif
+
+
+
+
 
 /*
- * Debug facilities
+ * Data type definitions
+ *
  */
+#define INDEX_PULSE_CYCLE 10
 
-#define ATA_DETECT                     0xf0 //0X3E8
-#define ATA_RESET                      0xf1 //0X3E9
-#define ATA_CMD_DATA_IN                0xf2 //0X3EA
-#define ATA_CMD_DATA_OUT               0xf3 //0X3EB
-#define ATA_CMD_PACKET                 0xf4 //0X3EC
-#define ATAPI_GET_SENSE                0xf5 //0X3ED
-#define ATAPI_IS_READY                 0xf6 //0X3EE
-#define ATAPI_IS_CDROM                 0xf7 //0X3EF
 
-#define CDEMU_INIT                     0xf8 //0X2E8
-#define CDEMU_ISACTIVE                 0xf9 //0X2E9
-#define CDEMU_EMULATED_DRIVE           0xfa //0X2EA
-#define CDROM_BOOT                     0xfb //0X2EB
 
 
-#define HARD_DRIVE_POST                0xfc //0X2EC
+#define INTR_REASON_BIT_ERR           0x01
+#define UNABLE_FIND_TAT_CHANNEL_ERR   0x02
+#define DRQ_ERR                       0x03
+#define READ_BUF_GT_512               0x04
 
 
-#define ATA_DEVICE_NO                  0xfd //0X2ED
-#define ATA_DEVICE_TYPE                0xfe //0X2ED
 
-#define INT13_HARDDISK                 0xff //0x2ef
-#define INT13_CDROM                    0xe0 //0x2f8
-#define INT13_CDEMU                    0xe1 //0x2f9
-#define INT13_ELTORITO                 0xe2 //0x2fa
-#define INT13_DISKETTE_FUNCTION        0xe3 //0x2fb
+#define PRI_DATA_PORT         0x1f0
+#define PRI_FEATURES_PORT     0x1f1
+#define PRI_SECT_CNT_PORT     0x1f2
+#define PRI_SECT_ADDR1_PORT   0x1f3
+#define PRI_SECT_ADDR2_PORT   0x1f4
+#define PRI_SECT_ADDR3_PORT   0x1f5
+#define PRI_DRV_SEL_PORT      0x1f6
+#define PRI_CMD_PORT          0x1f7
+#define PRI_CTRL_PORT         0x3f6
+#define PRI_ADDR_REG_PORT     0x3f7
 
-// some packet handling macros
-#define EXTRACT_FIELD(arr,byte,start,num_bits) (((arr)[(byte)] >> (start)) & ((1 << (num_bits)) - 1))
-#define get_packet_field(c,b,s,n) (EXTRACT_FIELD((SELECTED_CONTROLLER((c)).buffer),(b),(s),(n)))
-#define get_packet_byte(c,b) (SELECTED_CONTROLLER((c)).buffer[(b)])
-#define get_packet_word(c,b) (((uint16)SELECTED_CONTROLLER((c)).buffer[(b)] << 8) | SELECTED_CONTROLLER((c)).buffer[(b)+1])
+#define SEC_DATA_PORT         0x170
+#define SEC_FEATURES_PORT     0x171
+#define SEC_SECT_CNT_PORT     0x172
+#define SEC_SECT_ADDR1_PORT   0x173
+#define SEC_SECT_ADDR2_PORT   0x174
+#define SEC_SECT_ADDR3_PORT   0x175
+#define SEC_DRV_SEL_PORT      0x176
+#define SEC_CMD_PORT          0x177
+#define SEC_CTRL_PORT         0x376
+#define SEC_ADDR_REG_PORT     0x377
 
 
-#define CONTROLLER(c,a) (channels[(c)].drives[(a)]).controller
-#define DRIVE(c,a) (channels[(c)].drives[(a)])
-#define SELECTED_CONTROLLER(c) (CONTROLLER((c), channels[(c)].drive_select))
-#define SELECTED_DRIVE(c) (DRIVE((c), channels[(c)].drive_select))
+#define PACKET_SIZE 12
 
 
-#define DRIVE_IS_PRESENT(c,a) (channels[(c)].drives[(a)].device_type != IDE_NONE)
-#define DRIVE_IS_HD(c,a) (channels[(c)].drives[(a)].device_type == IDE_DISK)
-#define DRIVE_IS_CD(c,a) (channels[(c)].drives[(a)].device_type == IDE_CDROM)
-#define SELECTED_MODEL(c) (channels[(c)].drives[channels[(c)].drive_select].model_no)
 
-#define MASTER_SELECTED(c) (!channels[(c)].drive_select)
-#define SLAVE_SELECTED(c)  (channels[(c)].drive_select)
+static const char cdrom_str[] = "CD-ROM";
+static const char harddisk_str[] = "HARDDISK";
+static const char none_str[] = "NONE";
 
-#define SELECTED_IS_PRESENT(c) (DRIVE_IS_PRESENT((c),SLAVE_SELECTED((c))))
-#define SELECTED_IS_HD(c) (DRIVE_IS_HD((c),SLAVE_SELECTED((c))))
-#define SELECTED_IS_CD(c) (DRIVE_IS_CD((c),SLAVE_SELECTED((c))))
 
-#define ANY_IS_PRESENT(c) (DRIVE_IS_PRESENT((c),0) || DRIVE_IS_PRESENT((c),1))
-#define SELECTED_TYPE_STRING(channel) ((SELECTED_IS_CD(channel)) ? "CD-ROM" : "NONE")
+static inline const char * device_type_to_str(device_type_t type) {
+    switch (type) {
+       case IDE_DISK:
+           return harddisk_str;
+       case IDE_CDROM:
+           return cdrom_str;
+       case IDE_NONE:
+           return none_str;
+       default:
+           return NULL;
+    }
+}
+
+
+static inline void write_features(struct channel_t * channel, uchar_t value) {
+    channel->drives[0].controller.features = value;
+    channel->drives[1].controller.features = value;
+}
 
-#define WRITE_FEATURES(c,a) do { uint8 _a = a; CONTROLLER((c),0).features = _a; CONTROLLER((c),1).features = _a; } while(0)
-#define WRITE_SECTOR_COUNT(c,a) do { uint8 _a = a; CONTROLLER((c),0).sector_count = _a; CONTROLLER((c),1).sector_count = _a; } while(0)
-#define WRITE_SECTOR_NUMBER(c,a) do { uint8 _a = a; CONTROLLER((c),0).sector_no = _a; CONTROLLER((c),1).sector_no = _a; } while(0)
-#define WRITE_CYLINDER_LOW(c,a) do { uint8 _a = a; CONTROLLER((c),0).cylinder_no = (CONTROLLER((c),0).cylinder_no & 0xff00) | _a; CONTROLLER((c),1).cylinder_no = (CONTROLLER((c),1).cylinder_no & 0xff00) | _a; } while(0)
-#define WRITE_CYLINDER_HIGH(c,a) do { uint16 _a = a; CONTROLLER((c),0).cylinder_no = (_a << 8) | (CONTROLLER((c),0).cylinder_no & 0xff); CONTROLLER((c),1).cylinder_no = (_a << 8) | (CONTROLLER((c),1).cylinder_no & 0xff); } while(0)
-#define WRITE_HEAD_NO(c,a) do { uint8 _a = a; CONTROLLER((c),0).head_no = _a; CONTROLLER((c),1).head_no = _a; } while(0)
-#define WRITE_LBA_MODE(c,a) do { uint8 _a = a; CONTROLLER((c),0).lba_mode = _a; CONTROLLER((c),1).lba_mode = _a; } while(0)
 
+static inline void write_sector_count(struct channel_t * channel, uchar_t value) {
+    channel->drives[0].controller.sector_count = value;
+    channel->drives[1].controller.sector_count = value;
+}
 
+static inline void write_sector_number(struct channel_t * channel, uchar_t value) {
+    channel->drives[0].controller.sector_no = value;
+    channel->drives[1].controller.sector_no = value;
+}
 
-#define GOTO_RETURN_VALUE  if(io_len==4){\
-                             goto return_value32;\
-                             }\
-                           else if(io_len==2){\
-                             value16=(Bit16u)value32;\
-                             goto return_value16;\
-                             }\
-                           else{\
-                             value8=(Bit8u)value32;\
-                             goto return_value8;\
-                             }
 
-#define UNUSED(x) ((void)x)
+static inline void write_cylinder_low(struct channel_t * channel, uchar_t value) {
+    channel->drives[0].controller.cylinder_no &= 0xff00;
+    channel->drives[0].controller.cylinder_no |= value;
+    channel->drives[1].controller.cylinder_no &= 0xff00;
+    channel->drives[1].controller.cylinder_no |= value;
+}
 
-#define PACKET_SIZE 12
+static inline void write_cylinder_high(struct channel_t * channel, uchar_t value) {
+    ushort_t val2 = value;
+    val2 = val2 << 8;
+    channel->drives[0].controller.cylinder_no &= 0x00ff;
+    channel->drives[0].controller.cylinder_no |= (val2 & 0xff00);
 
-static struct ramdisk_t *ramdisk_state;
+    channel->drives[1].controller.cylinder_no &= 0x00ff;
+    channel->drives[1].controller.cylinder_no |= (val2 & 0xff00);
+}
 
+static inline void write_head_no(struct channel_t * channel, uchar_t value) {
+    channel->drives[0].controller.head_no = value;
+    channel->drives[1].controller.head_no = value;
+}
 
+static inline void write_lba_mode(struct channel_t * channel, uchar_t value) {
+    channel->drives[0].controller.lba_mode = value;
+    channel->drives[1].controller.lba_mode = value;
+}
 
 
+static inline uint_t get_channel_no(struct ramdisk_t * ramdisk, struct channel_t * channel) {
+    return (((uchar_t *)channel - (uchar_t *)(ramdisk->channels)) / sizeof(struct channel_t));
+}
 
+static inline uint_t get_drive_no(struct channel_t * channel, struct drive_t * drive) {
+    return (((uchar_t *)drive - (uchar_t*)(channel->drives)) /  sizeof(struct drive_t));
+}
 
-////////////////////////////////////////////////////////////////////////////
+static inline struct drive_t * get_selected_drive(struct channel_t * channel) {
+    return &(channel->drives[channel->drive_select]);
+}
 
-/*
- * Static routines
- */
 
-static
-uint_t ramdisk_read_port(ushort_t port,
-                        void *src,
-                        uint_t length,
-                        struct vm_device *dev);
+static inline int is_primary_port(struct ramdisk_t * ramdisk, ushort_t port) {
+    switch(port) 
+       {
+           case PRI_DATA_PORT:
+           case PRI_FEATURES_PORT:
+           case PRI_SECT_CNT_PORT:
+           case PRI_SECT_ADDR1_PORT:
+           case PRI_SECT_ADDR2_PORT:
+           case PRI_SECT_ADDR3_PORT:
+           case PRI_DRV_SEL_PORT:
+           case PRI_CMD_PORT:
+           case PRI_CTRL_PORT:
+               return 1;
+           default:
+               return 0;
+       }
+}
+
+
+
+static inline int is_secondary_port(struct ramdisk_t * ramdisk, ushort_t port) {
+    switch(port) 
+       {
+           case SEC_DATA_PORT:
+           case SEC_FEATURES_PORT:
+           case SEC_SECT_CNT_PORT:
+           case SEC_SECT_ADDR1_PORT:
+           case SEC_SECT_ADDR2_PORT:
+           case SEC_SECT_ADDR3_PORT:
+           case SEC_DRV_SEL_PORT:
+           case SEC_CMD_PORT:
+           case SEC_CTRL_PORT:
+               return 1;
+           default:
+               return 0;
+       }
+}
+
+static inline int num_drives_on_channel(struct channel_t * channel) {
+    if ((channel->drives[0].device_type == IDE_NONE) &&
+       (channel->drives[1].device_type == IDE_NONE)) {
+       return 0;
+    } else if ((channel->drives[0].device_type != IDE_NONE) &&
+              (channel->drives[1].device_type != IDE_NONE)) {
+       return 2;
+    } else {
+       return 1;
+    }
+}
+
 
-static
-uint_t ramdisk_write_port(ushort_t port,
-                         void *src,
-                         uint_t length,
-                         struct vm_device *dev);
 
-static
-uint_t ramdisk_read_port_ignore(ushort_t port,
-                               void *src,
-                               uint_t length,
-                               struct vm_device *dev);
+static inline uchar_t extract_bits(uchar_t * buf, uint_t buf_offset, uint_t bit_offset, uint_t num_bits) {
+    uchar_t val = buf[buf_offset];
+    val = val >> bit_offset;
+    val &= ((1 << num_bits) -1);
+    return val;
+}
 
-static
-uint_t ramdisk_write_port_ignore(ushort_t port,
-                                void *src,
-                                uint_t length,
-                                struct vm_device *dev);
 
+static inline uchar_t get_packet_field(struct channel_t * channel, uint_t packet_offset, uint_t bit_offset, uint_t num_bits) {
+    struct drive_t * drive = get_selected_drive(channel);
+    return extract_bits(drive->controller.buffer, packet_offset, bit_offset, num_bits);
+}
 
-static
-Bit32u rd_read_handler(struct channel_t *channels, Bit32u address, unsigned io_len);
 
-static
-void rd_write_handler(struct channel_t *channels, Bit32u address, 
-                     Bit32u value, unsigned io_len);
+static inline uchar_t get_packet_byte(struct channel_t * channel, uint_t offset) {
+    struct drive_t * drive = get_selected_drive(channel);
+    return drive->controller.buffer[offset];
+}
 
+static inline uint16_t get_packet_word(struct channel_t * channel, uint_t offset) {
+    struct drive_t * drive = get_selected_drive(channel);
+    uint16_t val = drive->controller.buffer[offset];
+    val = val << 8;
+    val |= drive->controller.buffer[offset + 1];
+    return val;
+}
+
+
+static inline uint16_t rd_read_16bit(const uint8_t* buf) {
+    return (buf[0] << 8) | buf[1];
+}
+
+
+
+static inline uint32_t rd_read_32bit(const uint8_t* buf) {
+    return (buf[0] << 24) | (buf[1] << 16) | (buf[2] << 8) | buf[3];
+}
+
+////////////////////////////////////////////////////////////////////////////
 
 
 /*
  * ATAPI routines
  */
 
-static 
-void rd_identify_ATAPI_drive(struct channel_t *channels, Bit8u channel);
 
+static void rd_init_mode_sense_single(struct vm_device * dev, struct channel_t * channel, const void * src, int size);
 
-static 
-void rd_init_send_atapi_command(struct channel_t *channels, Bit8u channel, Bit8u command, int req_length, int alloc_length, bool lazy /*= false*/);
+static void rd_command_aborted(struct vm_device * dev, struct channel_t * channel, unsigned value);
 
-static 
-void rd_ready_to_send_atapi(struct channel_t *channels, Bit8u channel);
 
 
-static 
-void rd_atapi_cmd_error(struct channel_t *channels, Bit8u channel, sense_t sense_key, asc_t asc);
 
-static 
-void rd_init_mode_sense_single(struct channel_t *channels, Bit8u channel, const void* src, int size);
+static int handle_atapi_packet_command(struct vm_device * dev, 
+                                      struct channel_t * channel, 
+                                      ushort_t val);
 
-static 
-void rd_atapi_cmd_nop(struct channel_t *channels, Bit8u channel);
+static int rd_init_send_atapi_command(struct vm_device * dev, 
+                                     struct channel_t * channel, 
+                                     Bit8u command, int req_length, 
+                                     int alloc_length, bool lazy);
+
+static void rd_ready_to_send_atapi(struct vm_device * dev, 
+                                  struct channel_t * channel);
+
+static void rd_atapi_cmd_error(struct vm_device * dev, 
+                              struct channel_t * channel, 
+                              sense_t sense_key, asc_t asc);
+
+static void rd_atapi_cmd_nop(struct vm_device * dev, struct channel_t * channel);
+static void rd_identify_ATAPI_drive(struct vm_device * dev, struct channel_t * channel);
 
-static
-void rd_command_aborted(struct channel_t *channels, Bit8u channel, unsigned value);
 
 
 /*
  * Interrupt handling
  */
-
-static 
-void rd_raise_interrupt(struct channel_t *channels, Bit8u channel);
-
-static 
-void rd_lower_irq(struct vm_device *dev, Bit32u irq);
+static void rd_raise_interrupt(struct vm_device * dev, struct channel_t * channel);
+static void rd_lower_irq(struct vm_device *dev, struct channel_t * channel);
 
 
 
@@ -199,1830 +315,2257 @@ void rd_lower_irq(struct vm_device *dev, Bit32u irq);
  * Helper routines
  */
 
-uint16 rd_read_16bit(const uint8* buf) 
-{
-  return (buf[0] << 8) | buf[1];
-}
 
 
+#ifdef DEBUG_RAMDISK
+static void rd_print_state(struct ramdisk_t *ramdisk);
+#endif
 
-uint32 rd_read_32bit(const uint8* buf) 
-{
-  return (buf[0] << 24) | (buf[1] << 16) | (buf[2] << 8) | buf[3];
-}
 
 ////////////////////////////////////////////////////////////////////
 
 
-void rd_print_state(struct ramdisk_t *ramdisk, 
-                        struct vm_device *dev)
-//Bit32u   rd_init_harddrive(struct channel_t *channels)
-{
 
-  uchar_t channel; 
-  uchar_t device;
-  struct channel_t *channels = (struct channel_t *)(&(ramdisk->channels));
 
-  for (channel = 0; channel < MAX_ATA_CHANNEL; channel++)
-    memset((char *)(channels + channel), 0, sizeof(struct channel_t));
 
-  Ramdisk_Print("sizeof(*channels) = %d\n", sizeof((*channels)));
-  Ramdisk_Print("sizeof(channles->drives[0].controller) = %d\n", sizeof((channels->drives[0].controller)));
-  Ramdisk_Print("sizeof(channles->drives[0].cdrom) = %d\n", sizeof((channels->drives[0].cdrom)));
-  Ramdisk_Print("sizeof(channles->drives[0].sense) = %d\n", sizeof((channels->drives[0].sense)));
-  Ramdisk_Print("sizeof(channles->drives[0].atapi) = %d\n", sizeof((channels->drives[0].atapi)));
+int v3_ramdisk_register_cdrom(struct vm_device * dev, uint_t busID, uint_t driveID, struct cdrom_ops* cd, void * private_data) {
+    struct ramdisk_t * ramdisk  = (struct ramdisk_t *)(dev->private_data);
+    struct channel_t * channel = &(ramdisk->channels[busID]);
+    struct drive_t * drive = &(channel->drives[driveID]);
+    struct controller_t * controller = &(drive->controller);
 
 
-  Ramdisk_Print("sizeof(channles->drives[0].controller.status) = %d\n", sizeof((channels->drives[0].controller.status)));
-  Ramdisk_Print("sizeof(channles->drives[0].controller.sector_count) = %d\n", sizeof((channels->drives[0].controller.sector_count)));
-  Ramdisk_Print("sizeof(channles->drives[0].controller.interrupt_reason) = %d\n", sizeof((channels->drives[0].controller.interrupt_reason)));
-
-  Ramdisk_Print("sizeof(channles->drives[0].controller.cylinder_no) = %d\n", sizeof((channels->drives[0].controller.cylinder_no)));
-  Ramdisk_Print("sizeof(channles->drives[0].controller.byte_count) = %d\n", sizeof((channels->drives[0].controller.byte_count)));
+  
+    if (drive->device_type != IDE_NONE) {
+       PrintError("Device already registered at this location\n");
+       return -1;
+    }
 
 
-  Ramdisk_Print("sizeof(channles->drives[0].controller.control) = %d\n", sizeof((channels->drives[0].controller.control)));
+    channel->irq =  15;
 
+    // Make model string
+    strncpy((char*)(drive->model_no), "V3VEE Ramdisk", 40);
 
-  for (channel = 0; channel < MAX_ATA_CHANNEL; channel++){
+    while (strlen((char *)(drive->model_no)) < 40) {
+       strcat ((char*)(drive->model_no), " ");
+    }
   
-    for (device = 0; device < 2; device++){
-                  
-      // Initialize controller state, even if device is not present
-      Ramdisk_Print("channels[%d].drives[%d].controller.status.busy = %d\n",channel, device, channels[channel].drives[device].controller.status.busy);
-      Ramdisk_Print("channels[%d].drives[%d].controller.status.drive_ready = %d\n", channel, device, channels[channel].drives[device].controller.status.drive_ready);
-      Ramdisk_Print("channels[%d].drives[%d].controller.status.write_fault = %d\n", channel, device, channels[channel].drives[device].controller.status.write_fault);
-      Ramdisk_Print("channels[%d].drives[%d].controller.status.seek_complete = %d\n", channel, device, channels[channel].drives[device].controller.status.seek_complete);
-      Ramdisk_Print("channels[%d].drives[%d].controller.status.drq = %d\n", channel, device, channels[channel].drives[device].controller.status.drq);
-      Ramdisk_Print("channels[%d].drives[%d].controller.status.corrected_data = %d\n", channel, device, channels[channel].drives[device].controller.status.corrected_data);
-      Ramdisk_Print("channels[%d].drives[%d].controller.status.index_pulse = %d\n", channel, device, channels[channel].drives[device].controller.status.index_pulse);
-      Ramdisk_Print("channels[%d].drives[%d].controller.status.index_pulse_count = %d\n", channel, device, channels[channel].drives[device].controller.status.index_pulse_count);
-      Ramdisk_Print("channels[%d].drives[%d].controller.status.err = %d\n", channel, device, channels[channel].drives[device].controller.status.err);
+    PrintDebug("CDROM on target %d/%d\n", busID, driveID);
+  
+    drive->device_type = IDE_CDROM;
+    drive->cdrom.locked = 0;
+    drive->sense.sense_key = SENSE_NONE;
+    drive->sense.asc = 0;
+    drive->sense.ascq = 0;
+  
+    drive->private_data = private_data;
 
+    controller->sector_count = 0;
 
-      Ramdisk_Print("channels[%d].drives[%d].controller.error_register = %d\n", channel, device, channels[channel].drives[device].controller.error_register);
-      Ramdisk_Print("channels[%d].drives[%d].controller.head_no = %d\n", channel, device, channels[channel].drives[device].controller.head_no);
-      Ramdisk_Print("channels[%d].drives[%d].controller.sector_count = %d\n", channel, device, channels[channel].drives[device].controller.sector_count);
-      Ramdisk_Print("channels[%d].drives[%d].controller.sector_no = %d\n", channel, device, channels[channel].drives[device].controller.sector_no);
-      Ramdisk_Print("channels[%d].drives[%d].controller.cylinder_no = %d\n", channel, device, channels[channel].drives[device].controller.cylinder_no);
-      Ramdisk_Print("channels[%d].drives[%d].controller.current_command = %02x\n", channel, device, channels[channel].drives[device].controller.current_command);
-      Ramdisk_Print("channels[%d].drives[%d].controller.buffer_index = %d\n", channel, device, channels[channel].drives[device].controller.buffer_index);
+    drive->cdrom.cd = cd;
+  
+    PrintDebug("\t\tCD on ata%d-%d: '%s'\n", 
+              busID, 
+              driveID, "");
+  
+    if(drive->cdrom.cd->insert_cdrom(drive->private_data)) {
+       PrintDebug("\t\tMedia present in CD-ROM drive\n");
+       drive->cdrom.ready = 1;
+       drive->cdrom.capacity = drive->cdrom.cd->capacity(drive->private_data);
+       PrintDebug("\t\tCDROM capacity is %d\n", drive->cdrom.capacity);
+    } else {               
+       PrintDebug("\t\tCould not locate CD-ROM, continuing with media not present\n");
+       drive->cdrom.ready = 0;
+    }
+  
+    return 0;
+}
 
 
-      Ramdisk_Print("channels[%d].drives[%d].controller.control.reset = %d\n", channel, device, channels[channel].drives[device].controller.control.reset);
-      Ramdisk_Print("channels[%d].drives[%d].controller.control.disable_irq = %d\n", channel, device, channels[channel].drives[device].controller.control.disable_irq);
+static Bit32u rd_init_hardware(struct ramdisk_t *ramdisk) {
+    uint_t channel_num; 
+    uint_t device;
+    struct channel_t *channels = (struct channel_t *)(&(ramdisk->channels));
 
+    PrintDebug("[rd_init_harddrive]\n");
 
-      Ramdisk_Print("channels[%d].drives[%d].controller.reset_in_progress = %d\n", channel, device, channels[channel].drives[device].controller.reset_in_progress);
-      Ramdisk_Print("channels[%d].drives[%d].controller.sectors_per_block = %02x\n", channel, device, channels[channel].drives[device].controller.sectors_per_block); 
-      Ramdisk_Print("channels[%d].drives[%d].controller.lba_mode = %d\n", channel, device, channels[channel].drives[device].controller.lba_mode); 
-      Ramdisk_Print("channels[%d].drives[%d].controller.features = %d\n", channel, device, channels[channel].drives[device].controller.features); 
+    for (channel_num = 0; channel_num < MAX_ATA_CHANNEL; channel_num++) {
+       memset((char *)(channels + channel_num), 0, sizeof(struct channel_t));
+    }
 
+    for (channel_num = 0; channel_num < MAX_ATA_CHANNEL; channel_num++){
+       struct channel_t * channel = &(channels[channel_num]);
+
+       channel->ioaddr1 = 0x0;
+       channel->ioaddr2 = 0x0;
+       channel->irq = 0;
+
+       for (device = 0; device < 2; device++){
+           struct drive_t * drive = &(channel->drives[device]);
+           struct controller_t * controller = &(drive->controller);
+
+           controller->status.busy = 0;
+           controller->status.drive_ready = 1;
+           controller->status.write_fault = 0;
+           controller->status.seek_complete = 1;
+           controller->status.drq = 0;
+           controller->status.corrected_data = 0;
+           controller->status.index_pulse = 0;
+           controller->status.index_pulse_count = 0;
+           controller->status.err = 0;
+
+           controller->error_register = 0x01; // diagnostic code: no error
+           controller->head_no = 0;
+           controller->sector_count = 1;
+           controller->sector_no = 1;
+           controller->cylinder_no = 0;
+           controller->current_command = 0x00;
+           controller->buffer_index = 0;
+
+           controller->control.reset = 0;
+           controller->control.disable_irq = 0;
+           controller->reset_in_progress = 0;
+
+           controller->sectors_per_block = 0x80;
+           controller->lba_mode = 0;
+      
+      
+           controller->features = 0;
+       
+           // If not present
+           drive->device_type = IDE_NONE;
 
-      Ramdisk_Print("channels[%d].drives[%d].model_no = %s\n", channel, device, channels[channel].drives[device].model_no); 
-      Ramdisk_Print("channels[%d].drives[%d].device_type = %d\n", channel, device, channels[channel].drives[device].device_type); 
-      Ramdisk_Print("channels[%d].drives[%d].cdrom.locked = %d\n", channel, device, channels[channel].drives[device].cdrom.locked); 
-      Ramdisk_Print("channels[%d].drives[%d].sense.sense_key = %d\n", channel, device, channels[channel].drives[device].sense.sense_key); 
-      Ramdisk_Print("channels[%d].drives[%d].sense.asc = %d\n", channel, device, channels[channel].drives[device].sense.asc); 
-      Ramdisk_Print("channels[%d].drives[%d].sense.ascq = %d\n", channel, device, channels[channel].drives[device].sense.ascq); 
+           // Make model string
+           strncpy((char*)(drive->model_no), "", 40);
+           while(strlen((char *)(drive->model_no)) < 40) {
+               strcat ((char*)(drive->model_no), " ");
+           }
 
+       }
+    }
 
+#ifdef DEBUG_RAMDISK
+    rd_print_state(ramdisk);
+#endif
+    return 0;
+}
 
-      Ramdisk_Print("channels[%d].drives[%d].controller.interrupt_reason.c_d = %02x\n", channel, device, channels[channel].drives[device].controller.interrupt_reason.c_d);
 
-      Ramdisk_Print("channels[%d].drives[%d].controller.interrupt_reason.i_o = %02x\n", channel, device, channels[channel].drives[device].controller.interrupt_reason.i_o);
+/*
+  static void rd_reset_harddrive(struct ramdisk_t *ramdisk, unsigned type) {
+  return;
+  }
 
-      Ramdisk_Print("channels[%d].drives[%d].controller.interrupt_reason.rel = %02x\n", channel, device, channels[channel].drives[device].controller.interrupt_reason.rel);
+*/
+static void rd_close_harddrive(struct ramdisk_t *ramdisk) {
+    return;
+}
 
-      Ramdisk_Print("channels[%d].drives[%d].controller.interrupt_reason.tag = %02x\n", channel, device, channels[channel].drives[device].controller.interrupt_reason.tag);
 
-      Ramdisk_Print("channels[%d].drives[%d].cdrom.ready = %d\n", channel, device, channels[channel].drives[device].cdrom.ready);
-      
-    }//for device
-  }//for channel
-  
-  return;
-}
+////////////////////////////////////////////////////////////////////
 
 
-Bit32u rd_init_harddrive(struct ramdisk_t *ramdisk, 
-                        struct vm_device *dev)
-{
 
-  
-  uchar_t channel; 
-  uchar_t device;
-  struct channel_t *channels = (struct channel_t *)(&(ramdisk->channels));
+static int read_data_port(ushort_t port, void * dst, uint_t length, struct vm_device * dev) {
+    struct ramdisk_t * ramdisk  = (struct ramdisk_t *)(dev->private_data);
+    struct channel_t * channel = NULL;
+    struct drive_t * drive = NULL;
+    struct controller_t * controller = NULL;
 
-  Ramdisk_Print("[rd_init_harddrive]\n");
-  for (channel = 0; channel < MAX_ATA_CHANNEL; channel++)
-    memset((char *)(channels + channel), 0, sizeof(struct channel_t));
 
 
-  for (channel = 0; channel < MAX_ATA_CHANNEL; channel++){
+    if (is_primary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[0]);
+    } else if (is_secondary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[1]);
+    } else {
+       PrintError("Invalid Port: %d\n", port);
+       return -1;
+    }
   
-    channels[channel].ioaddr1 = 0x0;
-    channels[channel].ioaddr2 = 0x0;
-    channels[channel].irq = 0;
-
-    for (device = 0; device < 2; device++){
+    drive = get_selected_drive(channel);
+    controller = &(drive->controller);
+
+
+    PrintTrace("[read_data_handler] IO Read at 0x%x, on drive %d/%d current cmd=0x%x\n", 
+              port, 
+              get_channel_no(ramdisk, channel),
+              get_drive_no(channel, drive), 
+              controller->current_command);
+
+    switch (controller->current_command) {
+       case 0xec:    // IDENTIFY DEVICE
+       case 0xa1:
+           {
+               controller->status.busy = 0;
+               controller->status.drive_ready = 1;
+               controller->status.write_fault = 0;
+               controller->status.seek_complete = 1;
+               controller->status.corrected_data = 0;
+               controller->status.err = 0;
+               
+               /*
+                 value32 = controller->buffer[index];
+                 index++;
+       
+                 if (io_len >= 2) {
+                 value32 |= (controller->buffer[index] << 8);
+                 index++;
+                 }
+       
+                 if (io_len == 4) {
+                 value32 |= (controller->buffer[index] << 16);
+                 value32 |= (controller->buffer[index+1] << 24);
+                 index += 2;
+                 }
+       
+                 controller->buffer_index = index;
+               */
+               /* JRL */
+               memcpy(dst, controller->buffer + controller->buffer_index, length);
+               controller->buffer_index += length;
       
+               if (controller->buffer_index >= 512) {
+                   controller->status.drq = 0;
+               }
+               
+               return length;
+           }
+       case 0xa0: //send packet cmd 
+           {
+               uint_t index = controller->buffer_index;
 
-      CONTROLLER(channel,device).status.busy           = 0;
-      CONTROLLER(channel,device).status.drive_ready    = 1;
-      CONTROLLER(channel,device).status.write_fault    = 0;
-      CONTROLLER(channel,device).status.seek_complete  = 1;
-      CONTROLLER(channel,device).status.drq            = 0;
-      CONTROLLER(channel,device).status.corrected_data = 0;
-      CONTROLLER(channel,device).status.index_pulse    = 0;
-      CONTROLLER(channel,device).status.index_pulse_count = 0;
-      CONTROLLER(channel,device).status.err            = 0;
-
-      CONTROLLER(channel,device).error_register = 0x01; // diagnostic code: no error
-      CONTROLLER(channel,device).head_no        = 0;
-      CONTROLLER(channel,device).sector_count   = 1;
-      CONTROLLER(channel,device).sector_no      = 1;
-      CONTROLLER(channel,device).cylinder_no    = 0;
-      CONTROLLER(channel,device).current_command = 0x00;
-      CONTROLLER(channel,device).buffer_index = 0;
-
-      CONTROLLER(channel,device).control.reset       = 0;
-      CONTROLLER(channel,device).control.disable_irq = 0;
-      CONTROLLER(channel,device).reset_in_progress   = 0;
-
-      CONTROLLER(channel,device).sectors_per_block   = 0x80;
-      CONTROLLER(channel,device).lba_mode            = 0;
       
-      CONTROLLER(channel,device).features            = 0;
+               PrintTrace("\t\tatapi.command(%02x), index(%d), cdrom.remaining_blocks(%d)\n", 
+                          drive->atapi.command, 
+                          index, 
+                          drive->cdrom.remaining_blocks);
+      
+               // Load block if necessary
+               if (index >= 2048) {
        
-         // If not present
-      channels[channel].drives[device].device_type           = IDE_NONE;
-
-      // Make model string
-      strncpy((char*)channels[channel].drives[device].model_no, 
-             "", 40);
-      while(strlen((char *)channels[channel].drives[device].model_no) < 40) {
-        strcat ((char*)channels[channel].drives[device].model_no, " ");
-      }
-
-//      Ramdisk_Print("channels[%d].drives[%d].controller.current_command = %02x\n", channel, device, channels[channel].drives[device].controller.current_command);
-//      Ramdisk_Print("channels[%d].drives[%d].controller.interrupt_reason.c_d = %02x\n", channel, device, channels[channel].drives[device].controller.interrupt_reason.c_d);
-
-//      Ramdisk_Print("channels[%d].drives[%d].controller.interrupt_reason.i_o = %02x\n", channel, device, channels[channel].drives[device].controller.interrupt_reason.i_o);
-
-//      Ramdisk_Print("channels[%d].drives[%d].controller.interrupt_reason.rel = %02x\n", channel, device, channels[channel].drives[device].controller.interrupt_reason.rel);
+                   if (index > 2048) {
+                       PrintError("\t\tindex > 2048 : 0x%x\n", index);
+                       return -1;
+                   }
+       
+                   switch (drive->atapi.command) {
+                       case 0x28: // read (10)
+                       case 0xa8: // read (12)
+                           {
+    
+                               if (!(drive->cdrom.ready)) {
+                                   PrintError("\t\tRead with CDROM not ready\n");
+                                   return -1;
+                               } 
+           
+                               drive->cdrom.cd->read_block(drive->private_data, controller->buffer,
+                                                           drive->cdrom.next_lba);
+                               drive->cdrom.next_lba++;
+                               drive->cdrom.remaining_blocks--;
+           
+           
+                               if (!(drive->cdrom.remaining_blocks)) {
+                                   PrintDebug("\t\tLast READ block loaded {CDROM}\n");
+                               } else {
+                                   PrintDebug("\t\tREAD block loaded (%d remaining) {CDROM}\n",
+                                              drive->cdrom.remaining_blocks);
+                               }
+           
+                               // one block transfered, start at beginning
+                               index = 0;
+                               break;
+                           }
+                       default: // no need to load a new block
+                           break;
+                   }
+               }
+    
 
-//      Ramdisk_Print("channels[%d].drives[%d].controller.interrupt_reason.tag = %02x\n", channel, device, channels[channel].drives[device].controller.interrupt_reason.tag);
-      
-//      Ramdisk_Print("channels[%d].drives[%d].controller.control.disable_irq = %d\n", channel, device, channels[channel].drives[device].controller.control.disable_irq);
-      
+               /*
+                 increment = 0;
+                 value32 = controller->buffer[index + increment];
+                 increment++;
+       
+                 if (io_len >= 2) {
+                 value32 |= (controller->buffer[index + increment] << 8);
+                 increment++;
+                 }
+       
+                 if (io_len == 4) {
+                 value32 |= (controller->buffer[index + increment] << 16);
+                 value32 |= (controller->buffer[index + increment + 1] << 24);
+                 increment += 2;
+                 }
+
+                 controller->buffer_index = index + increment;
+                 controller->drq_index += increment;
+
+               */
+               /* JRL: CHECK THAT there is enough data in the buffer to copy.... */
+               {      
+                   memcpy(dst, controller->buffer + index, length);
+       
+                   controller->buffer_index  = index + length;
+                   controller->drq_index += length;
+               }
       
+               /* *** */
       
-      if (channel == 1) {
-
-       channels[channel].ioaddr1 = 0x170;
-       channels[channel].ioaddr2 = 0x370;
-       channels[channel].irq =  15;
-       channels[channel].drive_select = 0;
-       
-       if (device == 0) {
-         // Make model string
-         strncpy((char*)channels[channel].drives[device].model_no, 
-                 "Zheng's Ramdisk", 40);
-         while (strlen((char *)channels[channel].drives[device].model_no) < 40) {
-           strcat ((char*)channels[channel].drives[device].model_no, " ");
-         }
-
-         Ramdisk_Print("CDROM on target %d/%d\n", channel, device);
+               if (controller->drq_index >= (unsigned)drive->atapi.drq_bytes) {
+                   controller->status.drq = 0;
+                   controller->drq_index = 0;
+       
+                   drive->atapi.total_bytes_remaining -= drive->atapi.drq_bytes;
+       
+                   if (drive->atapi.total_bytes_remaining > 0) {
+                       // one or more blocks remaining (works only for single block commands)
          
-         channels[channel].drives[device].device_type = IDE_CDROM;
-         channels[channel].drives[device].cdrom.locked = 0;
-         channels[channel].drives[device].sense.sense_key = SENSE_NONE;
-         channels[channel].drives[device].sense.asc = 0;
-         channels[channel].drives[device].sense.ascq = 0;
+                       PrintDebug("\t\tPACKET drq bytes read\n");
+                       controller->interrupt_reason.i_o = 1;
+                       controller->status.busy = 0;
+                       controller->status.drq = 1;
+                       controller->interrupt_reason.c_d = 0;
          
-
-         //Check bit fields
-         channels[channel].drives[device].controller.sector_count = 0;
-         channels[channel].drives[device].controller.interrupt_reason.c_d = 1;
-         if (channels[channel].drives[device].controller.sector_count != 0x01) {
-           Ramdisk_Print("interrupt reason bit field error\n");
-           return INTR_REASON_BIT_ERR;
-         }
-
-         channels[channel].drives[device].controller.sector_count = 0;
-         channels[channel].drives[device].controller.interrupt_reason.i_o = 1;
-         if (channels[channel].drives[device].controller.sector_count != 0x02) {
-           Ramdisk_Print("interrupt reason bit field error\n");
-           return INTR_REASON_BIT_ERR;
-         }
+                       // set new byte count if last block
+                       if (drive->atapi.total_bytes_remaining < controller->byte_count) {
+                           controller->byte_count = drive->atapi.total_bytes_remaining;
+                       }
+                       drive->atapi.drq_bytes = controller->byte_count;
          
-         channels[channel].drives[device].controller.sector_count = 0;
-         channels[channel].drives[device].controller.interrupt_reason.rel = 1;
-         if (channels[channel].drives[device].controller.sector_count != 0x04) {
-           Ramdisk_Print("interrupt reason bit field error\n");
-           return INTR_REASON_BIT_ERR;
-         }
-       
-         channels[channel].drives[device].controller.sector_count = 0;
-         channels[channel].drives[device].controller.interrupt_reason.tag = 3;
-         if (channels[channel].drives[device].controller.sector_count != 0x18) {
-           Ramdisk_Print("interrupt reason bit field error\n");
-           return INTR_REASON_BIT_ERR;
-         }
+                       rd_raise_interrupt(dev, channel);
+                   } else {
+                       // all bytes read
+                       PrintDebug("\t\tPACKET all bytes read\n");
          
+                       controller->interrupt_reason.i_o = 1;
+                       controller->interrupt_reason.c_d = 1;
+                       controller->status.drive_ready = 1;
+                       controller->interrupt_reason.rel = 0;
+                       controller->status.busy = 0;
+                       controller->status.drq = 0;
+                       controller->status.err = 0;
          
-         channels[channel].drives[device].controller.sector_count = 0;
+                       rd_raise_interrupt(dev, channel);
+                   }
+               }
+               return length;
+               break;
+           }
 
-         // allocate low level driver
-         channels[channel].drives[device].cdrom.cd = (struct cdrom_interface*)V3_Malloc(sizeof(struct cdrom_interface));
-         Ramdisk_Print("cd = %x\n", channels[channel].drives[device].cdrom.cd);
-         V3_ASSERT(channels[channel].drives[device].cdrom.cd != NULL);
-         
-         struct cdrom_interface *cdif = channels[channel].drives[device].cdrom.cd;
-         memset(cdif, 0, sizeof(struct cdrom_interface));
-         init_cdrom(cdif);
-         cdif->ops.init(cdif);
+       default:
+           PrintError("\t\tunsupported command: %02x\n", controller->current_command);
+           break;
+    }
 
-         Ramdisk_Print("\t\tCD on ata%d-%d: '%s'\n",channel, device, "");
-         
-         if((channels[channel].drives[device].cdrom.cd->ops).insert_cdrom(cdif, NULL)) {
-           Ramdisk_Print("\t\tMedia present in CD-ROM drive\n");
-           channels[channel].drives[device].cdrom.ready = 1;
-           channels[channel].drives[device].cdrom.capacity = channels[channel].drives[device].cdrom.cd->ops.capacity(cdif);
-         } else {                  
-           Ramdisk_Print("\t\tCould not locate CD-ROM, continuing with media not present\n");
-           channels[channel].drives[device].cdrom.ready = 0;
-         }
-         
-       }//if device = 0
-      }//if channel = 0
-    }//for device
-  }//for channel
-
-  ramdisk->private_data = dev;
-  ramdisk_state = ramdisk;
-  Ramdisk_Print("ramdisk_state = %x\n", ramdisk_state);
-  Ramdisk_Print("ramdisk = %x\n", ramdisk);
-  //  rd_print_state(ramdisk, dev);
-  return 0;
+    return -1;
 }
 
 
-void   rd_reset_harddrive(struct ramdisk_t *ramdisk, unsigned type)
-{
-  return;
-}
 
 
-void   rd_close_harddrive(struct ramdisk_t *ramdisk)
-{
-  return;
+static int write_data_port(ushort_t port, void * src, uint_t length, struct vm_device * dev) {
+    struct ramdisk_t * ramdisk  = (struct ramdisk_t *)(dev->private_data);
+    struct channel_t * channel = NULL;
+    struct drive_t * drive = NULL;
+    struct controller_t * controller = NULL;
+
+    if (is_primary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[0]);
+    } else if (is_secondary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[1]);
+    } else {
+       PrintError("Invalid Port: %d\n", port);
+       return -1;
+    }
+  
+    drive = get_selected_drive(channel);
+    controller = &(drive->controller);
+
+
+    PrintDebug("[write_data_handler] IO write at 0x%x, current_cmd = 0x%02x\n", 
+              port, controller->current_command);
+
+
+    //PrintDebug("[write_data_handler]\n");
+    switch (controller->current_command) {
+       case 0x30: // WRITE SECTORS
+           PrintError("\t\tneed to implement 0x30(write sector) to port 0x%x\n", port);
+           return -1;
+    
+       case 0xa0: // PACKET
+    
+           if (handle_atapi_packet_command(dev, channel, *(ushort_t *)src) == -1) {
+               PrintError("Error sending atapi packet command in PACKET write to data port\n");
+               return -1;
+           }
+
+           return length;
+    
+       default:
+           PrintError("\t\tIO write(0x%x): current command is %02xh\n", 
+                      port, controller->current_command);
+
+           return -1;
+    }
+
+
+    return -1;
 }
 
 
-////////////////////////////////////////////////////////////////////
 
 
-static
-Bit32u rd_read_handler(struct channel_t *channels, Bit32u address, unsigned io_len)
-{
-  Bit8u value8;
-  Bit16u value16;
-  Bit32u value32;
 
-  unsigned drive_select;
-  unsigned index;      
-  unsigned increment = 0;
 
-  Bit8u  channel = MAX_ATA_CHANNEL;
-  Bit32u port = 0xff; // undefined
 
-  Ramdisk_Print("[rd_read_handler]\n");
+static int read_status_port(ushort_t port, void * dst, uint_t length, struct vm_device * dev) {
+    struct ramdisk_t * ramdisk  = (struct ramdisk_t *)(dev->private_data);
+    struct channel_t * channel = NULL;
+    struct drive_t * drive = NULL;
+    struct controller_t * controller = NULL;
+
 
-  for (channel=0; channel<MAX_ATA_CHANNEL; channel++) {
-    if ((address & 0xfff8) == channels[channel].ioaddr1) {
-      port = address - channels[channel].ioaddr1;
-      break;
-      }
-    else if ((address & 0xfff8) == channels[channel].ioaddr2) {
-      port = address - channels[channel].ioaddr2 + 0x10;
-      break;
-      }
-    }
 
-  if (channel == MAX_ATA_CHANNEL) {
-    if ((address < 0x03f6) || (address > 0x03f7)) {
-      RD_PANIC("Error: read: unable to find ATA channel, ioport=0x%04x\n", address);
-      return 0;
+
+    if (is_primary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[0]);
+    } else if (is_secondary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[1]);
     } else {
-      channel = 0;
-      port = address - 0x03e0;
+       PrintError("Invalid Port: %d\n", port);
+       return -1;
     }
-  }
-
-  drive_select = channels[channel].drive_select;
-  if (port != 0x00){
-    Ramdisk_Print("[R_handler] IO read addr at %x, on drive %d/%d, curcmd = %02x\n", address, channel, drive_select, SELECTED_CONTROLLER(channel).current_command);
-  }else{
-    
-  }
+  
+    drive = get_selected_drive(channel);
+    controller = &(drive->controller);
 
+    PrintDebug("[read_status_handler] IO read at 0x%x, on drive %d/%d\n", 
+              port, get_channel_no(ramdisk, channel), 
+              channel->drive_select);
 
-  struct cdrom_interface *cdif = channels[channel].drives[drive_select].cdrom.cd;
-  switch (port) {
 
-  case 0x00: // hard disk data (16bit) 0x1f0
+    if (num_drives_on_channel(channel) == 0) {
+       PrintDebug("Setting value to zero because 0 devices on channel\n");
+       // (mch) Just return zero for these registers
+       memset(dst, 0, length);
 
-    switch (SELECTED_CONTROLLER(channel).current_command) {
-    case 0xec:    // IDENTIFY DEVICE
-    case 0xa1:
+    } else {
+       uchar_t val = (
+                      (controller->status.busy << 7)            |
+                      (controller->status.drive_ready << 6)     |
+                      (controller->status.write_fault << 5)     |
+                      (controller->status.seek_complete << 4)   |
+                      (controller->status.drq << 3)             |
+                      (controller->status.corrected_data << 2)  |
+                      (controller->status.index_pulse << 1)     |
+                      (controller->status.err) );
 
-      index = 0;
-      SELECTED_CONTROLLER(channel).status.busy = 0;
-      SELECTED_CONTROLLER(channel).status.drive_ready = 1;
-      SELECTED_CONTROLLER(channel).status.write_fault = 0;
-      SELECTED_CONTROLLER(channel).status.seek_complete = 1;
-      SELECTED_CONTROLLER(channel).status.corrected_data = 0;
-      SELECTED_CONTROLLER(channel).status.err = 0;
-       
-      index = SELECTED_CONTROLLER(channel).buffer_index;
-      value32 = SELECTED_CONTROLLER(channel).buffer[index];
-      index++;
 
-      if (io_len >= 2) {
-       value32 |= (SELECTED_CONTROLLER(channel).buffer[index] << 8);
-       index++;
-      }
-      if (io_len == 4) {
-       value32 |= (SELECTED_CONTROLLER(channel).buffer[index] << 16);
-       value32 |= (SELECTED_CONTROLLER(channel).buffer[index+1] << 24);
-       index += 2;
-      }
-      SELECTED_CONTROLLER(channel).buffer_index = index;
-      
-      if (SELECTED_CONTROLLER(channel).buffer_index >= 512) {
-       
-       SELECTED_CONTROLLER(channel).status.drq = 0;
-      }
-      GOTO_RETURN_VALUE;
-
-    case 0xa0: //send packet cmd 
-
-       index = SELECTED_CONTROLLER(channel).buffer_index;
-       increment = 0;
-       Ramdisk_Print("\t\tatapi.command(%02x), index(%d), cdrom.remaining_blocks(%d)\n", SELECTED_DRIVE(channel).atapi.command, index, SELECTED_DRIVE(channel).cdrom.remaining_blocks);
-       // Load block if necessary
-       if (index >= 2048) {
-         if (index > 2048)
-           RD_PANIC("\t\tindex > 2048 : 0x%x\n",index);
-         switch (SELECTED_DRIVE(channel).atapi.command) {
-         case 0x28: // read (10)
-         case 0xa8: // read (12)
-
-           if (!SELECTED_DRIVE(channel).cdrom.ready) {
-             RD_PANIC("\t\tRead with CDROM not ready\n");
-           } 
-           SELECTED_DRIVE(channel).cdrom.cd->ops.read_block(cdif, SELECTED_CONTROLLER(channel).buffer,
-                                                           SELECTED_DRIVE(channel).cdrom.next_lba);
-           SELECTED_DRIVE(channel).cdrom.next_lba++;
-           SELECTED_DRIVE(channel).cdrom.remaining_blocks--;
-           
-           
-           if (!SELECTED_DRIVE(channel).cdrom.remaining_blocks)
-             Ramdisk_Print("\t\tLast READ block loaded {CDROM}\n");
-           else
-             Ramdisk_Print("\t\tREAD block loaded (%d remaining) {CDROM}\n",
-                           SELECTED_DRIVE(channel).cdrom.remaining_blocks);
-           
-           // one block transfered, start at beginning
-           index = 0;
-           break;
-           
-         default: // no need to load a new block
-           break;
-         }
-       }
+       memcpy(dst, &val, length);
 
-       value32 = SELECTED_CONTROLLER(channel).buffer[index+increment];
-       increment++;
-       if (io_len >= 2) {
-         value32 |= (SELECTED_CONTROLLER(channel).buffer[index+increment] << 8);
-         increment++;
-       }
-       if (io_len == 4) {
-         value32 |= (SELECTED_CONTROLLER(channel).buffer[index+increment] << 16);
-         value32 |= (SELECTED_CONTROLLER(channel).buffer[index+increment+1] << 24);
-         increment += 2;
-       }
-       SELECTED_CONTROLLER(channel).buffer_index = index + increment;
-       SELECTED_CONTROLLER(channel).drq_index += increment;
-       
-       if (SELECTED_CONTROLLER(channel).drq_index >= (unsigned)SELECTED_DRIVE(channel).atapi.drq_bytes) {
-         SELECTED_CONTROLLER(channel).status.drq = 0;
-         SELECTED_CONTROLLER(channel).drq_index = 0;
-         
-         SELECTED_DRIVE(channel).atapi.total_bytes_remaining -= SELECTED_DRIVE(channel).atapi.drq_bytes;
-         
-         if (SELECTED_DRIVE(channel).atapi.total_bytes_remaining > 0) {
-           // one or more blocks remaining (works only for single block commands)
-
-           Ramdisk_Print("\t\tPACKET drq bytes read\n");
-           SELECTED_CONTROLLER(channel).interrupt_reason.i_o = 1;
-           SELECTED_CONTROLLER(channel).status.busy = 0;
-           SELECTED_CONTROLLER(channel).status.drq = 1;
-           SELECTED_CONTROLLER(channel).interrupt_reason.c_d = 0;
-           
-           // set new byte count if last block
-           if (SELECTED_DRIVE(channel).atapi.total_bytes_remaining < SELECTED_CONTROLLER(channel).byte_count) {
-             SELECTED_CONTROLLER(channel).byte_count = SELECTED_DRIVE(channel).atapi.total_bytes_remaining;
-           }
-           SELECTED_DRIVE(channel).atapi.drq_bytes = SELECTED_CONTROLLER(channel).byte_count;
-           
-           rd_raise_interrupt(channels, channel);
-         } else {
-           // all bytes read
-           Ramdisk_Print("\t\tPACKET all bytes read\n");
-           SELECTED_CONTROLLER(channel).interrupt_reason.i_o = 1;
-           SELECTED_CONTROLLER(channel).interrupt_reason.c_d = 1;
-           SELECTED_CONTROLLER(channel).status.drive_ready = 1;
-           SELECTED_CONTROLLER(channel).interrupt_reason.rel = 0;
-           SELECTED_CONTROLLER(channel).status.busy = 0;
-           SELECTED_CONTROLLER(channel).status.drq = 0;
-           SELECTED_CONTROLLER(channel).status.err = 0;
-           
-           rd_raise_interrupt(channels, channel);
-         }
-       }
-       GOTO_RETURN_VALUE;
-       break;
-      
-    default:
-      Ramdisk_Print("\t\tread need support more command: %02x\n", SELECTED_CONTROLLER(channel).current_command);
-      break;
-    }
-    ///////////////////////////////////////////
-
-  case 0x01: // hard disk error register 0x1f1
-
-    SELECTED_CONTROLLER(channel).status.err = 0;
-    value8 = (!SELECTED_IS_PRESENT(channel)) ? 0 : SELECTED_CONTROLLER(channel).error_register;
-    goto return_value8;
-    break;
-  case 0x02: // hard disk sector count / interrupt reason 0x1f2
-    value8 = (!SELECTED_IS_PRESENT(channel)) ? 0 : SELECTED_CONTROLLER(channel).sector_count;
-    goto return_value8;
-    break;
-  case 0x03: // sector number 0x1f3
-    value8 = (!SELECTED_IS_PRESENT(channel)) ? 0 : SELECTED_CONTROLLER(channel).sector_no;
-    goto return_value8;
-  case 0x04: // cylinder low 0x1f4  
-    // -- WARNING : On real hardware the controller registers are shared between drives. 
-    // So we must respond even if the select device is not present. Some OS uses this fact 
-    // to detect the disks.... minix2 for example
-    value8 = (!ANY_IS_PRESENT(channel)) ? 0 : (SELECTED_CONTROLLER(channel).cylinder_no & 0x00ff);
-    goto return_value8;
-  case 0x05: // cylinder high 0x1f5
-    // -- WARNING : On real hardware the controller registers are shared between drives. 
-    // So we must respond even if the select device is not present. Some OS uses this fact 
-    // to detect the disks.... minix2 for example
-    value8 = (!ANY_IS_PRESENT(channel)) ? 0 : SELECTED_CONTROLLER(channel).cylinder_no >> 8;
-    goto return_value8;
+       controller->status.index_pulse_count++;
+       controller->status.index_pulse = 0;
     
-  case 0x06: // hard disk drive and head register 0x1f6
-    // b7 Extended data field for ECC
-    // b6/b5: Used to be sector size.  00=256,01=512,10=1024,11=128
-    //   Since 512 was always used, bit 6 was taken to mean LBA mode:
-    //     b6 1=LBA mode, 0=CHS mode
-    //     b5 1
-    // b4: DRV
-    // b3..0 HD3..HD0
-    value8 = (1 << 7) |
-      ((SELECTED_CONTROLLER(channel).lba_mode>0) << 6) |
-      (1 << 5) | // 01b = 512 sector size
-      (channels[channel].drive_select << 4) |
-      (SELECTED_CONTROLLER(channel).head_no << 0);
-    goto return_value8;
-    break;
-    //CONTROLLER(channel,0).lba_mode
-    
-  case 0x07: // Hard Disk Status 0x1f7
-  case 0x16: // Hard Disk Alternate Status 0x3f6
-    if (!ANY_IS_PRESENT(channel)) {
-      // (mch) Just return zero for these registers
-      value8 = 0;
-    } else {
-      value8 = (
-               (SELECTED_CONTROLLER(channel).status.busy << 7) |
-               (SELECTED_CONTROLLER(channel).status.drive_ready << 6) |
-               (SELECTED_CONTROLLER(channel).status.write_fault << 5) |
-               (SELECTED_CONTROLLER(channel).status.seek_complete << 4) |
-               (SELECTED_CONTROLLER(channel).status.drq << 3) |
-               (SELECTED_CONTROLLER(channel).status.corrected_data << 2) |
-               (SELECTED_CONTROLLER(channel).status.index_pulse << 1) |
-               (SELECTED_CONTROLLER(channel).status.err) );
-      SELECTED_CONTROLLER(channel).status.index_pulse_count++;
-      SELECTED_CONTROLLER(channel).status.index_pulse = 0;
-      if (SELECTED_CONTROLLER(channel).status.index_pulse_count >= INDEX_PULSE_CYCLE) {
-        SELECTED_CONTROLLER(channel).status.index_pulse = 1;
-        SELECTED_CONTROLLER(channel).status.index_pulse_count = 0;
-      }
-    }
-    if (port == 0x07) {
-      rd_lower_irq((struct vm_device *)(ramdisk_state->private_data), channels[channel].irq);
+       if (controller->status.index_pulse_count >= INDEX_PULSE_CYCLE) {
+           controller->status.index_pulse = 1;
+           controller->status.index_pulse_count = 0;
+       }
     }
-    goto return_value8;
-    break;
-    
-  case 0x17: // Hard Disk Address Register 0x3f7
-    // Obsolete and unsupported register.  Not driven by hard
-    // disk controller.  Report all 1's.  If floppy controller
-    // is handling this address, it will call this function
-    // set/clear D7 (the only bit it handles), then return
-    // the combined value
-    value8 = 0xff;
-    goto return_value8;
-    break;
-    
-  default:
-    RD_PANIC("hard drive: io read to address %x unsupported\n",
-             (unsigned) address);
-    
-    
-    ////////////////////////////////////////////
-  }
-  
-  Ramdisk_Print("\t\tError: hard drive: shouldnt get here!\n");
-  return 0;
   
-return_value32:
-  Ramdisk_Print("\t\t32-bit read from %04x = %08x {%s}\n",
-           (unsigned) address, value32, SELECTED_TYPE_STRING(channel));
-  return value32;
+    if ((port == SEC_CMD_PORT) || (port == PRI_CMD_PORT)) {
+       rd_lower_irq(dev, channel);
+    }
   
- return_value16:
-  Ramdisk_Print("\t\t16-bit read from %04x = %04x {%s}\n",
-           (unsigned) address, value16, SELECTED_TYPE_STRING(channel));
-  return value16;
+    PrintDebug("\t\tRead STATUS = 0x%x\n", *(uchar_t *)dst);
+
+    return length;
   
- return_value8:
-  Ramdisk_Print("\t\t8-bit read from %x = %02x {%s}\n",
-           (unsigned) address, value8, SELECTED_TYPE_STRING(channel));
-  return value8;
 }
 
 
-static
-void rd_write_handler(struct channel_t *channels, Bit32u address, 
-                     Bit32u value, unsigned io_len)
-{
+static int write_cmd_port(ushort_t port, void * src, uint_t length, struct vm_device * dev) {
+    struct ramdisk_t * ramdisk  = (struct ramdisk_t *)(dev->private_data);
+    struct channel_t * channel = NULL;
+    struct drive_t * drive = NULL;
+    struct controller_t * controller = NULL;
+    uchar_t value = *(uchar_t *)src;
 
-  //  off_t logical_sector;
-  //  off_t ret;
-  rd_bool prev_control_reset;
+    if (length != 1) {
+       PrintError("Invalid Command port write length: %d (port=%d)\n", length, port);
+       return -1;
+    }
 
-  Bit32u id;
-  int toc_length;
+    if (is_primary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[0]);
+    } else if (is_secondary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[1]);
+    } else {
+       PrintError("Invalid Port: %d\n", port);
+       return -1;
+    }
+  
+    drive = get_selected_drive(channel);
+    controller = &(drive->controller);
+
+
+    PrintDebug("[write_command_handler] IO write at 0x%x, on drive %d/%d (val = 0x%x)\n", 
+              port, get_channel_no(ramdisk, channel), 
+              get_drive_no(channel, drive), 
+              value);
+
+    switch (value) {
+#if 0
+       case 0xec: // IDENTIFY DEVICE
+           {
+
+               if (drive->device_type == IDE_NONE) {
+                   PrintError("\t\tError: disk ata%d-%d not present, aborting\n", 
+                              get_channel_no(ramdisk, channel), 
+                              get_drive_no(channel, drive));
+                   rd_command_aborted(dev, channel, value);
+                   break;
+               } else if (drive->device_type == IDE_CDROM) {
+                   PrintDebug("Identifying CDROM...Going to abort????\n");
+                   controller->head_no        = 0;
+                   controller->sector_count   = 1;
+                   controller->sector_no      = 1;
+                   controller->cylinder_no    = 0xeb14;
+                   rd_command_aborted(dev, channel, 0xec);
+               } else {
+                   PrintError("\t\tError: Want to identify HDD!!\n");
+                   /*
+                     SELECTED_CONTROLLER(channel).current_command = value;
+                     SELECTED_CONTROLLER(channel).error_register = 0;
+         
+                     // See ATA/ATAPI-4, 8.12
+                     SELECTED_CONTROLLER(channel).status.busy  = 0;
+                     SELECTED_CONTROLLER(channel).status.drive_ready = 1;
+                     SELECTED_CONTROLLER(channel).status.write_fault = 0;
+                     SELECTED_CONTROLLER(channel).status.drq   = 1;
+                     SELECTED_CONTROLLER(channel).status.err   = 0;
+         
+                     SELECTED_CONTROLLER(channel).status.seek_complete = 1;
+                     SELECTED_CONTROLLER(channel).status.corrected_data = 0;
+         
+                     SELECTED_CONTROLLER(channel).buffer_index = 0;
+                     raise_interrupt(channel);
+                     identify_drive(channel);
+                   */
+               }
 
-  Bit8u  channel = MAX_ATA_CHANNEL;
-  Bit32u port = 0xff; // undefined
+               break;
+           }
+#endif
+           // ATAPI commands
+       case 0xa1: // IDENTIFY PACKET DEVICE
+           {
+               if (drive->device_type == IDE_CDROM) {
+                   controller->current_command = value;
+                   controller->error_register = 0;
+       
+                   controller->status.busy = 0;
+                   controller->status.drive_ready = 1;
+                   controller->status.write_fault = 0;
+                   controller->status.drq   = 1;
+                   controller->status.err   = 0;
+       
+                   controller->status.seek_complete = 1;
+                   controller->status.corrected_data = 0;
+       
+                   controller->buffer_index = 0;
+                   rd_raise_interrupt(dev, channel);
+                   rd_identify_ATAPI_drive(dev, channel);
+               } else {
+                   PrintError("Identifying non cdrom device not supported - ata %d/%d\n", 
+                              get_channel_no(ramdisk, channel),
+                              get_drive_no(channel, drive));
+                   rd_command_aborted(dev, channel, 0xa1);
+               }
+               break;
+           }
+       case 0xa0: // SEND PACKET (atapi)
+           {
+               if (drive->device_type == IDE_CDROM) {
+                   // PACKET
+       
+                   if (controller->features & (1 << 0)) {
+                       PrintError("\t\tPACKET-DMA not supported");
+                       return -1;
+                   }
+       
+                   if (controller->features & (1 << 1)) {
+                       PrintError("\t\tPACKET-overlapped not supported");
+                       return -1;
+                   }
+       
+                   // We're already ready!
+                   controller->sector_count = 1;
+                   controller->status.busy = 0;
+                   controller->status.write_fault = 0;
 
-  Ramdisk_Print("[rd_write_handler]\n");
-  //  Bit8u atapi_command;
-  //int alloc_length;
+                   // serv bit??
+                   controller->status.drq = 1;
+                   controller->status.err = 0;
+       
+                   // NOTE: no interrupt here
+                   controller->current_command = value;
+                   controller->buffer_index = 0;
+               } else {
+                   PrintError("Sending packet to non cdrom device not supported\n");
+                   rd_command_aborted (dev, channel, 0xa0);
+               }
+               break;
+           }
+       default:
+           PrintError("\t\tneed translate command %2x - ata %d\%d\n", value, 
+                      get_channel_no(ramdisk, channel), 
+                      get_drive_no(channel, drive));
+           //return -1;
+           /* JRL THIS NEEDS TO CHANGE */
+           return length;
 
-  for (channel=0; channel<MAX_ATA_CHANNEL; channel++) {
-    if ((address & 0xfff8) == channels[channel].ioaddr1) {
-      port = address - channels[channel].ioaddr1;
-      break;
     }
-    else if ((address & 0xfff8) == channels[channel].ioaddr2) {
-      port = address - channels[channel].ioaddr2 + 0x10;
-      break;
-      }
+    return length;
+}
+
+
+static int write_ctrl_port(ushort_t port, void * src, uint_t length, struct vm_device * dev) {
+    struct ramdisk_t * ramdisk  = (struct ramdisk_t *)(dev->private_data);
+    struct channel_t * channel = NULL;
+    struct drive_t * master_drive = NULL;
+    struct drive_t * slave_drive = NULL;
+    struct controller_t * controller = NULL;
+    uchar_t value = *(uchar_t *)src;
+    rd_bool prev_control_reset;
+
+    if (length != 1) {
+       PrintError("Invalid Status port read length: %d (port=%d)\n", length, port);
+       return -1;
     }
 
-  if (channel == MAX_ATA_CHANNEL) {
-    if (address != 0x03f6) {
-      RD_PANIC("Panic: write: unable to find ATA channel, ioport=0x%04x\n", address);
+    if (is_primary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[0]);
+    } else if (is_secondary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[1]);
     } else {
-      channel = 0;
-      port = address - 0x03e0;
+       PrintError("Invalid Port: %d\n", port);
+       return -1;
     }
-  }
 
-  Ramdisk_Print("[W_handler] IO write to %x = %02x, channel = %d\n", (unsigned) address, (unsigned) value, channel);
+    master_drive = &(channel->drives[0]);
+    slave_drive = &(channel->drives[1]);
 
-  struct cdrom_interface *cdif = SELECTED_DRIVE(channel).cdrom.cd;
+    controller = &(get_selected_drive(channel)->controller);
 
-  switch (port) {
 
-  case 0x00: // 0x1f0
-    Ramdisk_Print("\t\twrite port 170\n");
+    PrintDebug("[write_control_handler] IO write at 0x%x, on drive %d/%d (val = 0x%x)\n", 
+              port, get_channel_no(ramdisk, channel), 
+              channel->drive_select, 
+              value);
 
-    //////////////////////////////////////////////////////////
-    switch (SELECTED_CONTROLLER(channel).current_command) {
-    case 0x30: // WRITE SECTORS
-      RD_PANIC("\t\tneed to implement 0x30(write sector) to port 0x170\n");
-      break;
-      
-    case 0xa0: // PACKET
-      if (SELECTED_CONTROLLER(channel).buffer_index >= PACKET_SIZE)
-       RD_PANIC("IO write(0x%04x): buffer_index >= PACKET_SIZE", address);
-      SELECTED_CONTROLLER(channel).buffer[SELECTED_CONTROLLER(channel).buffer_index] = value;
-      SELECTED_CONTROLLER(channel).buffer[SELECTED_CONTROLLER(channel).buffer_index+1] = (value >> 8);
-      SELECTED_CONTROLLER(channel).buffer_index += 2;
-      
-      /* if packet completely writtten */
-      if (SELECTED_CONTROLLER(channel).buffer_index >= PACKET_SIZE) {
-       // complete command received
-       Bit8u atapi_command = SELECTED_CONTROLLER(channel).buffer[0];
-       
-       Ramdisk_Print("\t\tcdrom: ATAPI command 0x%x started\n", atapi_command);
+    // (mch) Even if device 1 was selected, a write to this register
+    // goes to device 0 (if device 1 is absent)
+  
+    prev_control_reset = controller->control.reset;
 
-       switch (atapi_command) {
-       case 0x00: // test unit ready
-         if (SELECTED_DRIVE(channel).cdrom.ready) {
-           rd_atapi_cmd_nop(channels, channel);
-         } else {
-           rd_atapi_cmd_error(channels, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
-         }
-         rd_raise_interrupt(channels, channel);
-         break;
-         
-       case 0x03: { // request sense
-         int alloc_length = SELECTED_CONTROLLER(channel).buffer[4];
-         rd_init_send_atapi_command(channels, channel, atapi_command, 18, alloc_length, false);
-                                   
-         // sense data
-         SELECTED_CONTROLLER(channel).buffer[0] = 0x70 | (1 << 7);
-         SELECTED_CONTROLLER(channel).buffer[1] = 0;
-         SELECTED_CONTROLLER(channel).buffer[2] = SELECTED_DRIVE(channel).sense.sense_key;
-         SELECTED_CONTROLLER(channel).buffer[3] = SELECTED_DRIVE(channel).sense.information.arr[0];
-         SELECTED_CONTROLLER(channel).buffer[4] = SELECTED_DRIVE(channel).sense.information.arr[1];
-         SELECTED_CONTROLLER(channel).buffer[5] = SELECTED_DRIVE(channel).sense.information.arr[2];
-         SELECTED_CONTROLLER(channel).buffer[6] = SELECTED_DRIVE(channel).sense.information.arr[3];
-         SELECTED_CONTROLLER(channel).buffer[7] = 17-7;
-         SELECTED_CONTROLLER(channel).buffer[8] = SELECTED_DRIVE(channel).sense.specific_inf.arr[0];
-         SELECTED_CONTROLLER(channel).buffer[9] = SELECTED_DRIVE(channel).sense.specific_inf.arr[1];
-         SELECTED_CONTROLLER(channel).buffer[10] = SELECTED_DRIVE(channel).sense.specific_inf.arr[2];
-         SELECTED_CONTROLLER(channel).buffer[11] = SELECTED_DRIVE(channel).sense.specific_inf.arr[3];
-         SELECTED_CONTROLLER(channel).buffer[12] = SELECTED_DRIVE(channel).sense.asc;
-         SELECTED_CONTROLLER(channel).buffer[13] = SELECTED_DRIVE(channel).sense.ascq;
-         SELECTED_CONTROLLER(channel).buffer[14] = SELECTED_DRIVE(channel).sense.fruc;
-         SELECTED_CONTROLLER(channel).buffer[15] = SELECTED_DRIVE(channel).sense.key_spec.arr[0];
-         SELECTED_CONTROLLER(channel).buffer[16] = SELECTED_DRIVE(channel).sense.key_spec.arr[1];
-         SELECTED_CONTROLLER(channel).buffer[17] = SELECTED_DRIVE(channel).sense.key_spec.arr[2];
-         
-         rd_ready_to_send_atapi(channels, channel);
-       }
-         break;
-         
-       case 0x1b: { // start stop unit
-         //bx_bool Immed = (SELECTED_CONTROLLER(channel).buffer[1] >> 0) & 1;
-         rd_bool LoEj = (SELECTED_CONTROLLER(channel).buffer[4] >> 1) & 1;
-         rd_bool Start = (SELECTED_CONTROLLER(channel).buffer[4] >> 0) & 1;
-         
-         if (!LoEj && !Start) { // stop the disc
-           RD_ERROR("FIXME: Stop disc not implemented\n");
-           rd_atapi_cmd_nop(channels, channel);
-           rd_raise_interrupt(channels, channel);
-         } else if (!LoEj && Start) { // start (spin up) the disc
-
-           SELECTED_DRIVE(channel).cdrom.cd->ops.start_cdrom(cdif);
-
-           RD_ERROR("FIXME: ATAPI start disc not reading TOC\n");
-           rd_atapi_cmd_nop(channels, channel);
-           rd_raise_interrupt(channels, channel);
-         } else if (LoEj && !Start) { // Eject the disc
-           rd_atapi_cmd_nop(channels, channel);
-           
-           if (SELECTED_DRIVE(channel).cdrom.ready) {
 
-             SELECTED_DRIVE(channel).cdrom.cd->ops.eject_cdrom(cdif);
+    if (value & 0x04) {
+       PrintDebug("RESET Signaled\n");
+    }
+
+    master_drive->controller.control.reset         = value & 0x04;
+    slave_drive->controller.control.reset         = value & 0x04;
+
+    // CGS: was: SELECTED_CONTROLLER(channel).control.disable_irq    = value & 0x02;
+    master_drive->controller.control.disable_irq = value & 0x02;
+    slave_drive->controller.control.disable_irq = value & 0x02;
+  
+    PrintDebug("\t\tadpater control reg: reset controller = %d\n",
+              (unsigned) (controller->control.reset) ? 1 : 0);
+    PrintDebug("\t\tadpater control reg: disable_irq(X) = %d\n",
+              (unsigned) (controller->control.disable_irq) ? 1 : 0);
+  
+    if ((!prev_control_reset) && (controller->control.reset)) {
+       uint_t id = 0;
 
-             SELECTED_DRIVE(channel).cdrom.ready = 0;
-             //bx_options.atadevice[channel][SLAVE_SELECTED(channel)].Ostatus->set(EJECTED);
-             //bx_gui->update_drive_status_buttons();
+       // transition from 0 to 1 causes all drives to reset
+       PrintDebug("\t\thard drive: RESET\n");
+    
+       // (mch) Set BSY, drive not ready
+       for (id = 0; id < 2; id++) {
+           struct controller_t * ctrl = NULL;
+
+           if (id == 0) {
+               ctrl = &(master_drive->controller);
+           } else if (id == 1) {
+               ctrl = &(slave_drive->controller);
            }
-           rd_raise_interrupt(channels, channel);
-         } else { // Load the disc
-           // My guess is that this command only closes the tray, that's a no-op for us
-           rd_atapi_cmd_nop(channels, channel);
-           rd_raise_interrupt(channels, channel);
-         }
-       }
-         break;
-         
-       case 0xbd: { // mechanism status
-         uint16 alloc_length = rd_read_16bit(SELECTED_CONTROLLER(channel).buffer + 8);
-         
-         if (alloc_length == 0)
-           RD_PANIC("Zero allocation length to MECHANISM STATUS not impl.\n");
-         
-         rd_init_send_atapi_command(channels, channel, atapi_command, 8, alloc_length, false);
-         
-         SELECTED_CONTROLLER(channel).buffer[0] = 0; // reserved for non changers
-         SELECTED_CONTROLLER(channel).buffer[1] = 0; // reserved for non changers
-         
-         SELECTED_CONTROLLER(channel).buffer[2] = 0; // Current LBA (TODO!)
-         SELECTED_CONTROLLER(channel).buffer[3] = 0; // Current LBA (TODO!)
-         SELECTED_CONTROLLER(channel).buffer[4] = 0; // Current LBA (TODO!)
-         
-         SELECTED_CONTROLLER(channel).buffer[5] = 1; // one slot
-         
-         SELECTED_CONTROLLER(channel).buffer[6] = 0; // slot table length
-         SELECTED_CONTROLLER(channel).buffer[7] = 0; // slot table length
-         
-         rd_ready_to_send_atapi(channels, channel);
-       }
-         break;
-         
-       case 0x5a: { // mode sense
-         uint16 alloc_length = rd_read_16bit(SELECTED_CONTROLLER(channel).buffer + 7);
-         
-         Bit8u PC = SELECTED_CONTROLLER(channel).buffer[2] >> 6;
-         Bit8u PageCode = SELECTED_CONTROLLER(channel).buffer[2] & 0x3f;
-         
-         switch (PC) {
-         case 0x0: // current values
-           switch (PageCode) {
-           case 0x01: // error recovery
-             rd_init_send_atapi_command(channels, channel, atapi_command, sizeof(struct error_recovery_t) + 8, alloc_length, false);
-             
-             rd_init_mode_sense_single(channels, channel, &SELECTED_DRIVE(channel).cdrom.current.error_recovery,
-                                    sizeof(struct error_recovery_t));
-             rd_ready_to_send_atapi(channels, channel);
-             break;
-             
-           case 0x2a: // CD-ROM capabilities & mech. status
-             rd_init_send_atapi_command(channels, channel, atapi_command, 28, alloc_length, false);
-             rd_init_mode_sense_single(channels, channel, &SELECTED_CONTROLLER(channel).buffer[8], 28);
-             SELECTED_CONTROLLER(channel).buffer[8] = 0x2a;
-             SELECTED_CONTROLLER(channel).buffer[9] = 0x12;
-             SELECTED_CONTROLLER(channel).buffer[10] = 0x00;
-             SELECTED_CONTROLLER(channel).buffer[11] = 0x00;
-             // Multisession, Mode 2 Form 2, Mode 2 Form 1
-             SELECTED_CONTROLLER(channel).buffer[12] = 0x70; 
-             SELECTED_CONTROLLER(channel).buffer[13] = (3 << 5);
-             SELECTED_CONTROLLER(channel).buffer[14] = (unsigned char)
-               (1 |
-                (SELECTED_DRIVE(channel).cdrom.locked ? (1 << 1) : 0) |
-                (1 << 3) |
-                (1 << 5));
-             SELECTED_CONTROLLER(channel).buffer[15] = 0x00;
-             SELECTED_CONTROLLER(channel).buffer[16] = (706 >> 8) & 0xff;
-             SELECTED_CONTROLLER(channel).buffer[17] = 706 & 0xff;
-             SELECTED_CONTROLLER(channel).buffer[18] = 0;
-             SELECTED_CONTROLLER(channel).buffer[19] = 2;
-             SELECTED_CONTROLLER(channel).buffer[20] = (512 >> 8) & 0xff;
-             SELECTED_CONTROLLER(channel).buffer[21] = 512 & 0xff;
-             SELECTED_CONTROLLER(channel).buffer[22] = (706 >> 8) & 0xff;
-             SELECTED_CONTROLLER(channel).buffer[23] = 706 & 0xff;
-             SELECTED_CONTROLLER(channel).buffer[24] = 0;
-             SELECTED_CONTROLLER(channel).buffer[25] = 0;
-             SELECTED_CONTROLLER(channel).buffer[26] = 0;
-             SELECTED_CONTROLLER(channel).buffer[27] = 0;
-             rd_ready_to_send_atapi(channels, channel);
-             break;
-             
-           case 0x0d: // CD-ROM
-           case 0x0e: // CD-ROM audio control
-           case 0x3f: // all
-             RD_ERROR("cdrom: MODE SENSE (curr), code=%x not implemented yet\n",
-                       PageCode);
-           rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST,
-                           ASC_INV_FIELD_IN_CMD_PACKET);
-           rd_raise_interrupt(channels, channel);
-           break;
-             
-         default:
-           // not implemeted by this device
-           Ramdisk_Print("\t\tcdrom: MODE SENSE PC=%x, PageCode=%x, not implemented by device\n",
-                    PC, PageCode);
-           rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST,
-                           ASC_INV_FIELD_IN_CMD_PACKET);
-           rd_raise_interrupt(channels, channel);
-           break;
-         }
-         break;
-           
-         case 0x1: // changeable values
-           switch (PageCode) {
-           case 0x01: // error recovery
-           case 0x0d: // CD-ROM
-           case 0x0e: // CD-ROM audio control
-           case 0x2a: // CD-ROM capabilities & mech. status
-           case 0x3f: // all
-             RD_ERROR("cdrom: MODE SENSE (chg), code=%x not implemented yet\n",
-                      PageCode);
-           rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST,
-                             ASC_INV_FIELD_IN_CMD_PACKET);
-           rd_raise_interrupt(channels, channel);
-           break;
-           
-         default:
-             // not implemeted by this device
-           Ramdisk_Print("\t\tcdrom: MODE SENSE PC=%x, PageCode=%x, not implemented by device\n",
-                         PC, PageCode);
-         rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST,
-                            ASC_INV_FIELD_IN_CMD_PACKET);
-         rd_raise_interrupt(channels, channel);
-         break;
-       }
-         break;
-         
-       case 0x2: // default values
-         switch (PageCode) {
-         case 0x01: // error recovery
-         case 0x0d: // CD-ROM
-         case 0x0e: // CD-ROM audio control
-         case 0x2a: // CD-ROM capabilities & mech. status
-         case 0x3f: // all
-           RD_PANIC("cdrom: MODE SENSE (dflt), code=%x\n",
-                    PageCode);
-           break;
-           
-           default:
-             // not implemeted by this device
-             Ramdisk_Print("\t\tcdrom: MODE SENSE PC=%x, PageCode=%x, not implemented by device\n",
-                     PC, PageCode);
-             rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST,
-                                ASC_INV_FIELD_IN_CMD_PACKET);
-             rd_raise_interrupt(channels, channel);
-             break;
-         }
-         break;
-         
-       case 0x3: // saved values not implemented
-         rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST, ASC_SAVING_PARAMETERS_NOT_SUPPORTED);
-         rd_raise_interrupt(channels, channel);
-         break;
-         
-       default:
-         RD_PANIC("Should not get here!\n");
-         break;
-       }
-      }
-      break;
-      
-    case 0x12: { // inquiry
-      uint8 alloc_length = SELECTED_CONTROLLER(channel).buffer[4];
+
+           ctrl->status.busy           = 1;
+           ctrl->status.drive_ready    = 0;
+           ctrl->reset_in_progress     = 1;
       
-      rd_init_send_atapi_command(channels, channel, atapi_command, 36, alloc_length, false);
+           ctrl->status.write_fault    = 0;
+           ctrl->status.seek_complete  = 1;
+           ctrl->status.drq            = 0;
+           ctrl->status.corrected_data = 0;
+           ctrl->status.err            = 0;
       
-      SELECTED_CONTROLLER(channel).buffer[0] = 0x05; // CD-ROM
-      SELECTED_CONTROLLER(channel).buffer[1] = 0x80; // Removable
-      SELECTED_CONTROLLER(channel).buffer[2] = 0x00; // ISO, ECMA, ANSI version
-      SELECTED_CONTROLLER(channel).buffer[3] = 0x21; // ATAPI-2, as specified
-      SELECTED_CONTROLLER(channel).buffer[4] = 31; // additional length (total 36)
-      SELECTED_CONTROLLER(channel).buffer[5] = 0x00; // reserved
-      SELECTED_CONTROLLER(channel).buffer[6] = 0x00; // reserved
-      SELECTED_CONTROLLER(channel).buffer[7] = 0x00; // reserved
+           ctrl->error_register = 0x01; // diagnostic code: no error
       
-      // Vendor ID
-      const char* vendor_id = "VTAB    ";
-      int i;
-      for (i = 0; i < 8; i++)
-       SELECTED_CONTROLLER(channel).buffer[8+i] = vendor_id[i];
+           ctrl->current_command = 0x00;
+           ctrl->buffer_index = 0;
       
-      // Product ID
-      const char* product_id = "Turbo CD-ROM    ";
-      for (i = 0; i < 16; i++)
-       SELECTED_CONTROLLER(channel).buffer[16+i] = product_id[i];
+           ctrl->sectors_per_block = 0x80;
+           ctrl->lba_mode          = 0;
       
-      // Product Revision level
-      const char* rev_level = "1.0 ";
-      for (i = 0; i < 4; i++)
-       SELECTED_CONTROLLER(channel).buffer[32+i] = rev_level[i];
+           ctrl->control.disable_irq = 0;
+       }
+
+       rd_lower_irq(dev, channel);
+
+    } else if ((controller->reset_in_progress) &&
+              (!controller->control.reset)) {
+       uint_t id;
+       // Clear BSY and DRDY
+       PrintDebug("\t\tReset complete {%s}\n", device_type_to_str(get_selected_drive(channel)->device_type));
+
+       for (id = 0; id < 2; id++) {
+           struct controller_t * ctrl = NULL;
+           struct drive_t * drv = NULL;
+
+           if (id == 0) {
+               ctrl = &(master_drive->controller);
+               drv = master_drive;
+           } else if (id == 1) {
+               ctrl = &(slave_drive->controller);
+               drv = slave_drive;
+           }
+
+           ctrl->status.busy           = 0;
+           ctrl->status.drive_ready    = 1;
+           ctrl->reset_in_progress     = 0;
       
-      rd_ready_to_send_atapi(channels, channel);
+           // Device signature
+           if (drv->device_type == IDE_DISK) {
+               PrintDebug("\t\tdrive %d/%d is harddrive\n", get_channel_no(ramdisk, channel), id);
+               ctrl->head_no        = 0;
+               ctrl->sector_count   = 1;
+               ctrl->sector_no      = 1;
+               ctrl->cylinder_no    = 0;
+           } else {
+               ctrl->head_no        = 0;
+               ctrl->sector_count   = 1;
+               ctrl->sector_no      = 1;
+               ctrl->cylinder_no    = 0xeb14;
+           }
+       }
     }
-      break;
-      
-       case 0x25: { // read cd-rom capacity
-         // no allocation length???
-         rd_init_send_atapi_command(channels, channel, atapi_command, 8, 8, false);
+
+    PrintDebug("\t\ts[0].controller.control.disable_irq = %02x\n", 
+              master_drive->controller.control.disable_irq);
+    PrintDebug("\t\ts[1].controller.control.disable_irq = %02x\n", 
+              slave_drive->controller.control.disable_irq);
+    return length;
+}
+
+
+static int read_general_port(ushort_t port, void * dst, uint_t length, struct vm_device * dev) {
+    struct ramdisk_t * ramdisk  = (struct ramdisk_t *)(dev->private_data);
+    struct channel_t * channel = NULL;
+    struct drive_t * drive = NULL;
+    struct controller_t * controller = NULL;
+
+
+    if (length != 1) {
+       PrintError("Invalid Status port read length: %d (port=%d)\n", length, port);
+       return -1;
+    }
+
+    if (is_primary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[0]);
+    } else if (is_secondary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[1]);
+    } else {
+       PrintError("Invalid Port: %d\n", port);
+       return -1;
+    }
+  
+    drive = get_selected_drive(channel);
+    controller = &(drive->controller);
+
+
+    PrintDebug("[read_general_handler] IO read addr at %x, on drive %d/%d, curcmd = %02x\n", 
+              port, get_channel_no(ramdisk, channel), 
+              channel->drive_select, 
+              controller->current_command);
+  
+
+    switch (port) {
+       case PRI_FEATURES_PORT:
+       case SEC_FEATURES_PORT: // hard disk error register 0x1f1
+           {    
+               uchar_t val = (drive->device_type == IDE_NONE) ? 0 : controller->error_register;
       
-         if (SELECTED_DRIVE(channel).cdrom.ready) {
-           uint32 capacity = SELECTED_DRIVE(channel).cdrom.capacity;
-           Ramdisk_Print("\t\tCapacity is %d sectors (%d bytes)\n", capacity, capacity * 2048);
-           SELECTED_CONTROLLER(channel).buffer[0] = (capacity >> 24) & 0xff;
-           SELECTED_CONTROLLER(channel).buffer[1] = (capacity >> 16) & 0xff;
-           SELECTED_CONTROLLER(channel).buffer[2] = (capacity >> 8) & 0xff;
-           SELECTED_CONTROLLER(channel).buffer[3] = (capacity >> 0) & 0xff;
-           SELECTED_CONTROLLER(channel).buffer[4] = (2048 >> 24) & 0xff;
-           SELECTED_CONTROLLER(channel).buffer[5] = (2048 >> 16) & 0xff;
-           SELECTED_CONTROLLER(channel).buffer[6] = (2048 >> 8) & 0xff;
-           SELECTED_CONTROLLER(channel).buffer[7] = (2048 >> 0) & 0xff;
-           rd_ready_to_send_atapi(channels, channel);
-         } else {
-           rd_atapi_cmd_error(channels, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
-           rd_raise_interrupt(channels, channel);
-         }
-       }
-         break;
+               controller->status.err = 0;
       
-       case 0xbe: { // read cd
-         if (SELECTED_DRIVE(channel).cdrom.ready) {
-           RD_ERROR("Read CD with CD present not implemented\n");
-           rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST, ASC_INV_FIELD_IN_CMD_PACKET);
-           rd_raise_interrupt(channels, channel);
-         } else {
-           rd_atapi_cmd_error(channels, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
-           rd_raise_interrupt(channels, channel);
-         }
-       }
-         break;
+               PrintDebug("\t\tRead FEATURES = 0x%x\n", val);
+
+               *(uchar_t *)dst = val;
+               return length;
       
-       case 0x43: { // read toc
-         if (SELECTED_DRIVE(channel).cdrom.ready) {
-           
-           bool msf = (SELECTED_CONTROLLER(channel).buffer[1] >> 1) & 1;
-           uint8 starting_track = SELECTED_CONTROLLER(channel).buffer[6];
-           
-           uint16 alloc_length = rd_read_16bit(SELECTED_CONTROLLER(channel).buffer + 7);
-           
-           uint8 format = (SELECTED_CONTROLLER(channel).buffer[9] >> 6);
-           int i;
-           switch (format) {
-           case 0:
-             
-             if (!(SELECTED_DRIVE(channel).cdrom.cd->ops.read_toc(cdif, SELECTED_CONTROLLER(channel).buffer,
-                                                              &toc_length, msf, starting_track))) {
-               rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST,
-                                  ASC_INV_FIELD_IN_CMD_PACKET);
-               rd_raise_interrupt(channels, channel);
-             } else {
-               rd_init_send_atapi_command(channels, channel, atapi_command, toc_length, alloc_length, false);
-               rd_ready_to_send_atapi(channels, channel);
-             }
-             break;
-             
-           case 1:
-             // multi session stuff. we ignore this and emulate a single session only
-             rd_init_send_atapi_command(channels, channel, atapi_command, 12, alloc_length, false);
-             
-             SELECTED_CONTROLLER(channel).buffer[0] = 0;
-             SELECTED_CONTROLLER(channel).buffer[1] = 0x0a;
-             SELECTED_CONTROLLER(channel).buffer[2] = 1;
-             SELECTED_CONTROLLER(channel).buffer[3] = 1;
-             for (i = 0; i < 8; i++)
-               SELECTED_CONTROLLER(channel).buffer[4+i] = 0;
-             
-             rd_ready_to_send_atapi(channels, channel);
-             break;
-             
-           case 2:
-           default:
-             RD_PANIC("(READ TOC) Format %d not supported\n", format);
-             break;
+               break;
            }
-         } else {
-           rd_atapi_cmd_error(channels, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
-           rd_raise_interrupt(channels, channel);
-         }
-       }
-         break;
-      
-       case 0x28: // read (10)
-       case 0xa8: // read (12)
-         { 
-       
-           uint32 transfer_length;
-           if (atapi_command == 0x28)
-             transfer_length = rd_read_16bit(SELECTED_CONTROLLER(channel).buffer + 7);
-           else
-             transfer_length = rd_read_32bit(SELECTED_CONTROLLER(channel).buffer + 6);
-           
-           uint32 lba = rd_read_32bit(SELECTED_CONTROLLER(channel).buffer + 2);
-           
-           if (!SELECTED_DRIVE(channel).cdrom.ready) {
-             rd_atapi_cmd_error(channels, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
-             rd_raise_interrupt(channels, channel);
-             break;
+
+       case PRI_SECT_CNT_PORT:
+       case SEC_SECT_CNT_PORT:  // hard disk sector count / interrupt reason 0x1f2
+           {
+               uchar_t val = (drive->device_type == IDE_NONE) ? 0 : controller->sector_count;
+               PrintDebug("\t\tRead SECTOR COUNT = 0x%x\n", val);
+               *(uchar_t *)dst = val;
+               return length;
+
+               break;
            }
-           
-           if (transfer_length == 0) {
-             rd_atapi_cmd_nop(channels, channel);
-             rd_raise_interrupt(channels, channel);
-             Ramdisk_Print("\t\tREAD(%d) with transfer length 0, ok\n", atapi_command==0x28?10:12);
-             break;
+       case PRI_SECT_ADDR1_PORT:
+       case SEC_SECT_ADDR1_PORT: // sector number 0x1f3
+           { 
+               uchar_t val = (drive->device_type == IDE_NONE) ? 0 : controller->sector_no;
+
+               PrintDebug("\t\tRead SECTOR ADDR1 = 0x%x\n", val);
+
+               *(uchar_t *)dst = val;
+               return length;
+
+               break;
            }
-           
-           if (lba + transfer_length > SELECTED_DRIVE(channel).cdrom.capacity) {
-             rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST, ASC_LOGICAL_BLOCK_OOR);
-             rd_raise_interrupt(channels, channel);
-             break;
+
+       case PRI_SECT_ADDR2_PORT:
+       case SEC_SECT_ADDR2_PORT:  // cylinder low 0x1f4  
+           {
+               // -- WARNING : On real hardware the controller registers are shared between drives. 
+               // So we must respond even if the select device is not present. Some OS uses this fact 
+               // to detect the disks.... minix2 for example
+               uchar_t val = (num_drives_on_channel(channel) == 0) ? 0 : (controller->cylinder_no & 0x00ff);
+
+               PrintDebug("\t\tRead SECTOR ADDR2 = 0x%x\n", val);
+
+               *(uchar_t *)dst = val;
+               return length;
+
+               break;      
            }
-           
-           Ramdisk_Print("\t\tcdrom: READ (%d) LBA=%d LEN=%d\n", atapi_command==0x28?10:12, lba, transfer_length);
-           
-           // handle command
-           rd_init_send_atapi_command(channels, channel, atapi_command, transfer_length * 2048,
-                                      transfer_length * 2048, true);
-           SELECTED_DRIVE(channel).cdrom.remaining_blocks = transfer_length;
-           SELECTED_DRIVE(channel).cdrom.next_lba = lba;
-           rd_ready_to_send_atapi(channels, channel);
-         }
-         break;
-         
-       case 0x2b: { // seek
-         uint32 lba = rd_read_32bit(SELECTED_CONTROLLER(channel).buffer + 2);
-         if (!SELECTED_DRIVE(channel).cdrom.ready) {
-           rd_atapi_cmd_error(channels, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
-           rd_raise_interrupt(channels, channel);
-           break;
-         }
-         
-         if (lba > SELECTED_DRIVE(channel).cdrom.capacity) {
-           rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST, ASC_LOGICAL_BLOCK_OOR);
-           rd_raise_interrupt(channels, channel);
-           break;
-         }
-         Ramdisk_Print("\t\tcdrom: SEEK (ignored)\n");
-         rd_atapi_cmd_nop(channels, channel);
-         rd_raise_interrupt(channels, channel);
-       }
-         break;
-      
-       case 0x1e: { // prevent/allow medium removal
-         if (SELECTED_DRIVE(channel).cdrom.ready) {
-           SELECTED_DRIVE(channel).cdrom.locked = SELECTED_CONTROLLER(channel).buffer[4] & 1;
-           rd_atapi_cmd_nop(channels, channel);
-         } else {
-           rd_atapi_cmd_error(channels, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
-         }
-         rd_raise_interrupt(channels, channel);
-       }
-         break;
-      
-       case 0x42: { // read sub-channel
-         bool msf = get_packet_field(channel,1, 1, 1);
-         bool sub_q = get_packet_field(channel,2, 6, 1);
-         uint8 data_format = get_packet_byte(channel,3);
-         uint8 track_number = get_packet_byte(channel,6);
-         uint16 alloc_length = get_packet_word(channel,7);
-         UNUSED(msf);
-         UNUSED(data_format);
-         UNUSED(track_number);
-         
-         if (!SELECTED_DRIVE(channel).cdrom.ready) {
-           rd_atapi_cmd_error(channels, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
-           rd_raise_interrupt(channels, channel);
-         } else {
-           SELECTED_CONTROLLER(channel).buffer[0] = 0;
-           SELECTED_CONTROLLER(channel).buffer[1] = 0; // audio not supported
-           SELECTED_CONTROLLER(channel).buffer[2] = 0;
-           SELECTED_CONTROLLER(channel).buffer[3] = 0;
-       
-           int ret_len = 4; // header size
-       
-           if (sub_q) { // !sub_q == header only
-             RD_ERROR("Read sub-channel with SubQ not implemented\n");
-             rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST,
-                                ASC_INV_FIELD_IN_CMD_PACKET);
-             rd_raise_interrupt(channels, channel);
+
+       case PRI_SECT_ADDR3_PORT:
+       case SEC_SECT_ADDR3_PORT: // cylinder high 0x1f5
+           {
+               // -- WARNING : On real hardware the controller registers are shared between drives. 
+               // So we must respond even if the select device is not present. Some OS uses this fact 
+               // to detect the disks.... minix2 for example
+               uchar_t val = (num_drives_on_channel(channel) == 0) ? 0 : (controller->cylinder_no >> 8);
+
+               PrintDebug("\t\tRead SECTOR ADDR3 = 0x%x\n", val);
+
+               *(uchar_t *)dst = val;
+               return length;
+
+               break;    
            }
-       
-           rd_init_send_atapi_command(channels, channel, atapi_command, ret_len, alloc_length, false);
-           rd_ready_to_send_atapi(channels, channel);
-         }
-       }
-         break;
+       case PRI_DRV_SEL_PORT:
+       case SEC_DRV_SEL_PORT:  // hard disk drive and head register 0x1f6
+           {
+               // b7 Extended data field for ECC
+               // b6/b5: Used to be sector size.  00=256,01=512,10=1024,11=128
+               //   Since 512 was always used, bit 6 was taken to mean LBA mode:
+               //     b6 1=LBA mode, 0=CHS mode
+               //     b5 1
+               // b4: DRV
+               // b3..0 HD3..HD0
+               uchar_t val = ((1 << 7)                          |
+                              ((controller->lba_mode > 0) << 6) |
+                              (1 << 5)                          |            // 01b = 512 sector size
+                              (channel->drive_select << 4)      |
+                              (controller->head_no << 0));
       
-       case 0x51: { // read disc info
-         // no-op to keep the Linux CD-ROM driver happy
-         rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST, ASC_INV_FIELD_IN_CMD_PACKET);
-         rd_raise_interrupt(channels, channel);
-       }
-         break;
-      
-       case 0x55: // mode select
-       case 0xa6: // load/unload cd
-       case 0x4b: // pause/resume
-       case 0x45: // play audio
-       case 0x47: // play audio msf
-       case 0xbc: // play cd
-       case 0xb9: // read cd msf
-       case 0x44: // read header
-       case 0xba: // scan
-       case 0xbb: // set cd speed
-       case 0x4e: // stop play/scan
-       case 0x46: // ???
-       case 0x4a: // ???
-         RD_ERROR("ATAPI command 0x%x not implemented yet\n",
-                  atapi_command);
-         rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST, ASC_INV_FIELD_IN_CMD_PACKET);
-         rd_raise_interrupt(channels, channel);
-         break;
+               PrintDebug("\t\tRead DRIVE SELECT = 0x%x\n", val);
+               *(uchar_t *)dst = val;
+               return length;
+
+               break;
+           }
+       case PRI_ADDR_REG_PORT:
+       case SEC_ADDR_REG_PORT: // Hard Disk Address Register 0x3f7
+           {
+               // Obsolete and unsupported register.  Not driven by hard
+               // disk controller.  Report all 1's.  If floppy controller
+               // is handling this address, it will call this function
+               // set/clear D7 (the only bit it handles), then return
+               // the combined value
+               *(uchar_t *)dst = 0xff;
+               return length;
+           }
+
        default:
-         RD_PANIC("Unknown ATAPI command 0x%x (%d)\n",
-                  atapi_command, atapi_command);
-         // We'd better signal the error if the user chose to continue
-         rd_atapi_cmd_error(channels, channel, SENSE_ILLEGAL_REQUEST, ASC_INV_FIELD_IN_CMD_PACKET);
-         rd_raise_interrupt(channels, channel);
-         break;
-       }
-      }
+           PrintError("Invalid Port: %d\n", port);
+           return -1;
+    }
+}
+
+
+
+
+static int write_general_port(ushort_t port, void * src, uint_t length, struct vm_device * dev) {
+    struct ramdisk_t * ramdisk  = (struct ramdisk_t *)(dev->private_data);
+    struct channel_t * channel = NULL;
+    struct drive_t * drive = NULL;
+    struct controller_t * controller = NULL;
+    uchar_t value = *(uchar_t *)src;
+
+    if (length != 1) {
+       PrintError("Invalid Status port read length: %d (port=%d)\n", length, port);
+       return -1;
+    }
+
+    if (is_primary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[0]);
+    } else if (is_secondary_port(ramdisk, port)) {
+       channel = &(ramdisk->channels[1]);
+    } else {
+       PrintError("Invalid Port: %d\n", port);
+       return -1;
+    }
+  
+    drive = get_selected_drive(channel);
+    controller = &(drive->controller);
+
+
+    PrintDebug("[write_general_handler] IO write to port %x (val=0x%02x), channel = %d\n", 
+              port, value, get_channel_no(ramdisk, channel));
+
+    switch (port) {
+
+       case PRI_FEATURES_PORT:
+       case SEC_FEATURES_PORT: // hard disk write precompensation 0x1f1
+           {
+               write_features(channel, value);
+               break;
+           }
+       case PRI_SECT_CNT_PORT:
+       case SEC_SECT_CNT_PORT: // hard disk sector count 0x1f2
+           {
+               write_sector_count(channel, value);
+               break;
+           }
+       case PRI_SECT_ADDR1_PORT:
+       case SEC_SECT_ADDR1_PORT: // hard disk sector number 0x1f3
+           {
+               write_sector_number(channel, value);
+               break;
+           }
+       case PRI_SECT_ADDR2_PORT:
+       case SEC_SECT_ADDR2_PORT: // hard disk cylinder low 0x1f4
+           {
+               write_cylinder_low(channel, value);
+               break;
+           }
+       case PRI_SECT_ADDR3_PORT:
+       case SEC_SECT_ADDR3_PORT: // hard disk cylinder high 0x1f5
+           {
+               write_cylinder_high(channel, value);
+               break;
+           }
+       case PRI_DRV_SEL_PORT:
+       case SEC_DRV_SEL_PORT: // hard disk drive and head register 0x1f6
+           {
+               // b7 Extended data field for ECC
+               // b6/b5: Used to be sector size.  00=256,01=512,10=1024,11=128
+               //   Since 512 was always used, bit 6 was taken to mean LBA mode:
+               //     b6 1=LBA mode, 0=CHS mode
+               //     b5 1
+               // b4: DRV
+               // b3..0 HD3..HD0
+
+               // 1x1xxxxx
+
+               PrintDebug("\tDrive Select value=%x\n", value);
+
+               if ((value & 0xa0) != 0xa0) { 
+                   PrintDebug("\t\tIO write 0x%x (%02x): not 1x1xxxxxb\n", port, (unsigned) value);
+               }
       
-      break;
+               write_head_no(channel, value & 0xf);
+               if ((controller->lba_mode == 0) && (((value >> 6) & 1) == 1)) {
+                   PrintDebug("\t\tenabling LBA mode\n");
+               }
+
+               write_lba_mode(channel, (value >> 6) & 1);
+
+
+
+               if (drive->cdrom.cd) {
+                   PrintDebug("\t\tSetting LBA on CDROM: %d\n", (value >> 6) & 1);
+                   drive->cdrom.cd->set_LBA(drive->private_data, (value >> 6) & 1);
+               }
       
+
+               channel->drive_select = (value >> 4) & 0x01;
+               drive = get_selected_drive(channel);
+
+               if (drive->device_type == IDE_NONE) {
+                   PrintError("\t\tError: device set to %d which does not exist! channel = 0x%x\n",
+                              channel->drive_select, get_channel_no(ramdisk, channel));
+
+                   controller->error_register = 0x04; // aborted
+                   controller->status.err = 1;
+               }
       
-    default:
-      RD_PANIC("\t\tIO write(0x%x): current command is %02xh\n", address,
-              (unsigned) SELECTED_CONTROLLER(channel).current_command);
+               break;
+           }
+       default:
+           PrintError("\t\thard drive: io write to unhandled port 0x%x  (value = %c)\n", port, value);
+           //return -1;
     }
 
-/////////////////////////////////////////////////////////
-    break;
-  case 0x01: // hard disk write precompensation 0x1f1
-    WRITE_FEATURES(channel,value);
-    break;
+    return length;
+}
+
 
-  case 0x02: // hard disk sector count 0x1f2
-    WRITE_SECTOR_COUNT(channel,value);
-    break;
-    
-  case 0x03: // hard disk sector number 0x1f3
-    WRITE_SECTOR_NUMBER(channel,value);
-    break;
-    
-  case 0x04: // hard disk cylinder low 0x1f4
-    WRITE_CYLINDER_LOW(channel,value);
-    break;
-    
-  case 0x05: // hard disk cylinder high 0x1f5
-    WRITE_CYLINDER_HIGH(channel,value);
-    break;
-    
-  case 0x06: // hard disk drive and head register 0x1f6
-    // b7 Extended data field for ECC
-    // b6/b5: Used to be sector size.  00=256,01=512,10=1024,11=128
-    //   Since 512 was always used, bit 6 was taken to mean LBA mode:
-    //     b6 1=LBA mode, 0=CHS mode
-    //     b5 1
-    // b4: DRV
-    // b3..0 HD3..HD0
-    
-    if ( (value & 0xa0) != 0xa0 ) // 1x1xxxxx
-      Ramdisk_Print("\t\tIO write 0x%x (%02x): not 1x1xxxxxb\n", address, (unsigned) value);
-    
-    Bit32u drvsel = channels[channel].drive_select = (value >> 4) & 0x01;
-    WRITE_HEAD_NO(channel,value & 0xf);
-    if (SELECTED_CONTROLLER(channel).lba_mode == 0 && ((value >> 6) & 1) == 1){
-      Ramdisk_Print("\t\tenabling LBA mode\n");
-       }
-    WRITE_LBA_MODE(channel,(value >> 6) & 1);
-    SELECTED_DRIVE(channel).cdrom.cd->lba = (value >> 6) & 1;
-    
-    
-    if (!SELECTED_IS_PRESENT(channel)) {
-      Ramdisk_Print ("\t\tError: device set to %d which does not exist! channel = %d\n",drvsel, channel);
-      SELECTED_CONTROLLER(channel).error_register = 0x04; // aborted
-      SELECTED_CONTROLLER(channel).status.err = 1;
+
+
+static void rd_raise_interrupt(struct vm_device * dev, struct channel_t * channel) {
+    //  struct ramdisk_t * ramdisk = (struct ramdisk_t *)(dev->private_data);
+    struct drive_t * drive = get_selected_drive(channel);
+    struct controller_t * controller = &(drive->controller);
+
+    PrintDebug("[raise_interrupt] disable_irq = 0x%02x\n", controller->control.disable_irq);
+
+    if (!(controller->control.disable_irq)) {
+       PrintDebug("\t\tRaising interrupt %d {%s}\n\n", channel->irq, device_type_to_str(drive->device_type));
+
+       v3_raise_irq(dev->vm, channel->irq);
+    } else {
+       PrintDebug("\t\tRaising irq but irq is disabled\n");
     }
-    
-    break;
-    
-    
-  case 0x07: // hard disk command 0x1f7
-
-      switch (value) {
-        // ATAPI commands
-        case 0xa1: // IDENTIFY PACKET DEVICE
-             if (SELECTED_IS_CD(channel)) {
-                   SELECTED_CONTROLLER(channel).current_command = value;
-                   SELECTED_CONTROLLER(channel).error_register = 0;
-
-                   SELECTED_CONTROLLER(channel).status.busy = 0;
-                   SELECTED_CONTROLLER(channel).status.drive_ready = 1;
-                   SELECTED_CONTROLLER(channel).status.write_fault = 0;
-                   SELECTED_CONTROLLER(channel).status.drq   = 1;
-                   SELECTED_CONTROLLER(channel).status.err   = 0;
-
-                   SELECTED_CONTROLLER(channel).status.seek_complete = 1;
-                   SELECTED_CONTROLLER(channel).status.corrected_data = 0;
-
-                   SELECTED_CONTROLLER(channel).buffer_index = 0;
-                   rd_raise_interrupt(channels, channel);
-                   rd_identify_ATAPI_drive(channels, channel);
-             } else {
-               rd_command_aborted(channels, channel, 0xa1);
-             }
-             break;
-
-        case 0xa0: // SEND PACKET (atapi)
-             if (SELECTED_IS_CD(channel)) {
-                   // PACKET
-                   if (SELECTED_CONTROLLER(channel).features & (1 << 0))
-                         RD_PANIC("\t\tPACKET-DMA not supported");
-                   if (SELECTED_CONTROLLER(channel).features & (1 << 1))
-                         RD_PANIC("\t\tPACKET-overlapped not supported");
+  
+    return;
+}
 
-                   // We're already ready!
-                   SELECTED_CONTROLLER(channel).sector_count = 1;
-                   SELECTED_CONTROLLER(channel).status.busy = 0;
-                   SELECTED_CONTROLLER(channel).status.write_fault = 0;
-                   // serv bit??
-                   SELECTED_CONTROLLER(channel).status.drq = 1;
-                   SELECTED_CONTROLLER(channel).status.err = 0;
+static void rd_lower_irq(struct vm_device *dev, struct channel_t * channel) {
+    PrintDebug("[lower_irq] irq = %d\n", channel->irq);
+    v3_lower_irq(dev->vm, channel->irq);
+}
 
-                   // NOTE: no interrupt here
-                   SELECTED_CONTROLLER(channel).current_command = value;
-                   SELECTED_CONTROLLER(channel).buffer_index = 0;
-             } else {
-               rd_command_aborted (channels, channel, 0xa0);
-             }
-             break;
-
-      default:
-       Ramdisk_Print("\t\tneed translate command %2x\n", value);
-       break;
-      }//switch(value)
 
-    
-  case 0x16: // hard disk adapter control 0x3f6 
-    // (mch) Even if device 1 was selected, a write to this register
-    // goes to device 0 (if device 1 is absent)
 
-    prev_control_reset = SELECTED_CONTROLLER(channel).control.reset;
-    channels[channel].drives[0].controller.control.reset         = value & 0x04;
-    channels[channel].drives[1].controller.control.reset         = value & 0x04;
-    // CGS: was: SELECTED_CONTROLLER(channel).control.disable_irq    = value & 0x02;
-    channels[channel].drives[0].controller.control.disable_irq = value & 0x02;
-    channels[channel].drives[1].controller.control.disable_irq = value & 0x02;
+
+
+
+
+//////////////////////////////////////////////////////////////////////////
+
+/*
+ * ATAPI subroutines
+ */
+
+
+
+int handle_atapi_packet_command(struct vm_device * dev, struct channel_t * channel, ushort_t value) {
+    struct ramdisk_t * ramdisk  = (struct ramdisk_t *)(dev->private_data);
+    struct drive_t * drive = get_selected_drive(channel);
+    struct controller_t * controller = &(drive->controller);
+
+    if (controller->buffer_index >= PACKET_SIZE) {
+       PrintError("ATAPI packet exceeded maximum length: buffer_index (%d) >= PACKET_SIZE\n", 
+                  controller->buffer_index);
+       return -1;
+    }
+
+    controller->buffer[controller->buffer_index] = value;
+    controller->buffer[controller->buffer_index + 1] = (value >> 8);
+    controller->buffer_index += 2;
+  
+  
+    /* if packet completely writtten */
+    if (controller->buffer_index >= PACKET_SIZE) {
+       // complete command received
+       Bit8u atapi_command = controller->buffer[0];
     
-    Ramdisk_Print("\t\tadpater control reg: reset controller = %d\n",
-                 (unsigned) (SELECTED_CONTROLLER(channel).control.reset) ? 1 : 0);
-    Ramdisk_Print("\t\tadpater control reg: disable_irq(X) = %d\n",
-                 (unsigned) (SELECTED_CONTROLLER(channel).control.disable_irq) ? 1 : 0);
+       PrintDebug("\t\tcdrom: ATAPI command 0x%x started\n", atapi_command);
     
-    if (!prev_control_reset && SELECTED_CONTROLLER(channel).control.reset) {
-      // transition from 0 to 1 causes all drives to reset
-      Ramdisk_Print("\t\thard drive: RESET\n");
+       switch (atapi_command) {
+           case 0x00: // test unit ready
+               {
+                   PrintDebug("Testing unit ready\n");
+                   if (drive->cdrom.ready) {
+                       rd_atapi_cmd_nop(dev, channel);
+                   } else {
+                       PrintError("CDROM not ready in test unit ready\n");
+                       rd_atapi_cmd_error(dev, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
+                   }
+       
+                   rd_raise_interrupt(dev, channel);
+       
+                   break;
+               }
+           case 0x03:  // request sense
+               {
+                   int alloc_length = controller->buffer[4];
+
+                   if (rd_init_send_atapi_command(dev, channel, atapi_command, 18, alloc_length, false) == -1) {
+                       PrintError("Error sending atapi command in Request Sense\n");
+                       return -1;
+                   }
+       
+                   // sense data
+                   controller->buffer[0] = 0x70 | (1 << 7);
+                   controller->buffer[1] = 0;
+                   controller->buffer[2] = drive->sense.sense_key;
+                   controller->buffer[3] = drive->sense.information.arr[0];
+                   controller->buffer[4] = drive->sense.information.arr[1];
+                   controller->buffer[5] = drive->sense.information.arr[2];
+                   controller->buffer[6] = drive->sense.information.arr[3];
+                   controller->buffer[7] = 17 - 7;
+                   controller->buffer[8] = drive->sense.specific_inf.arr[0];
+                   controller->buffer[9] = drive->sense.specific_inf.arr[1];
+                   controller->buffer[10] = drive->sense.specific_inf.arr[2];
+                   controller->buffer[11] = drive->sense.specific_inf.arr[3];
+                   controller->buffer[12] = drive->sense.asc;
+                   controller->buffer[13] = drive->sense.ascq;
+                   controller->buffer[14] = drive->sense.fruc;
+                   controller->buffer[15] = drive->sense.key_spec.arr[0];
+                   controller->buffer[16] = drive->sense.key_spec.arr[1];
+                   controller->buffer[17] = drive->sense.key_spec.arr[2];
+       
+                   rd_ready_to_send_atapi(dev, channel);
+                   break;
+               }
+           case 0x1b:  // start stop unit
+               {
+                   //bx_bool Immed = (controller->buffer[1] >> 0) & 1;
+                   rd_bool LoEj = (controller->buffer[4] >> 1) & 1;
+                   rd_bool Start = (controller->buffer[4] >> 0) & 1;
+
+                   // stop the disc
+                   if ((!LoEj) && (!Start)) { 
+                       PrintError("FIXME: Stop disc not implemented\n");
+
+                       rd_atapi_cmd_nop(dev, channel);
+                       rd_raise_interrupt(dev, channel);
+
+                   } else if (!LoEj && Start) { // start (spin up) the disc
+         
+                       drive->cdrom.cd->start_cdrom(drive->private_data);
+         
+                       PrintError("FIXME: ATAPI start disc not reading TOC\n");
+                       rd_atapi_cmd_nop(dev, channel);
+                       rd_raise_interrupt(dev, channel);
+
+                   } else if (LoEj && !Start) { // Eject the disc
+                       rd_atapi_cmd_nop(dev, channel);
+                       PrintDebug("Ejecting Disk\n");
+                       if (drive->cdrom.ready) {
+           
+                           drive->cdrom.cd->eject_cdrom(drive->private_data);
+           
+                           drive->cdrom.ready = 0;
+                           //bx_options.atadevice[channel][SLAVE_SELECTED(channel)].Ostatus->set(EJECTED);
+                           //bx_gui->update_drive_status_buttons();
+                       }
+                       rd_raise_interrupt(dev, channel);
+
+                   } else { // Load the disc
+                       // My guess is that this command only closes the tray, that's a no-op for us
+                       rd_atapi_cmd_nop(dev, channel);
+                       rd_raise_interrupt(dev, channel);
+                   }
+                   break;
+               }
+           case 0xbd: // mechanism status
+               {
+                   uint16_t alloc_length = rd_read_16bit(controller->buffer + 8);
+       
+                   if (alloc_length == 0) {
+                       PrintError("Zero allocation length to MECHANISM STATUS not impl.\n");
+                       return -1;
+                   }
+       
+                   if (rd_init_send_atapi_command(dev, channel, atapi_command, 8, alloc_length, false) == -1) {
+                       PrintError("Error sending atapi command in mechanism status\n");
+                       return -1;
+                   }
+       
+                   controller->buffer[0] = 0; // reserved for non changers
+                   controller->buffer[1] = 0; // reserved for non changers
+       
+                   controller->buffer[2] = 0; // Current LBA (TODO!)
+                   controller->buffer[3] = 0; // Current LBA (TODO!)
+                   controller->buffer[4] = 0; // Current LBA (TODO!)
+       
+                   controller->buffer[5] = 1; // one slot
+       
+                   controller->buffer[6] = 0; // slot table length
+                   controller->buffer[7] = 0; // slot table length
+       
+                   rd_ready_to_send_atapi(dev, channel);
+                   break;
+               }
+           case 0x5a:  // mode sense
+               {
+                   uint16_t alloc_length = rd_read_16bit(controller->buffer + 7);
+       
+                   Bit8u PC = controller->buffer[2] >> 6;
+                   Bit8u PageCode = controller->buffer[2] & 0x3f;
+       
+                   switch (PC) {
+                       case 0x0: // current values
+                           {
+                               switch (PageCode) {
+                                   case 0x01: // error recovery
+                                       {
+               
+                                           if (rd_init_send_atapi_command(dev, channel, atapi_command, sizeof(struct error_recovery_t) + 8, alloc_length, false) == -1) {
+                                               PrintError("Error sending atapi command in mode sense error recovery\n");
+                                               return -1;
+                                           }
+               
+                                           rd_init_mode_sense_single(dev, channel, &(drive->cdrom.current.error_recovery),
+                                                                     sizeof(struct error_recovery_t));
+                                           rd_ready_to_send_atapi(dev, channel);
+                                           break;
+                                       }
+                                   case 0x2a: // CD-ROM capabilities & mech. status
+                                       {
+
+                                           if (rd_init_send_atapi_command(dev, channel, atapi_command, 28, alloc_length, false) == -1) {
+                                               PrintError("Error sending atapi command in CDROM caps/mech mode-sense\n");
+                                               return -1;
+                                           }
+
+                                           rd_init_mode_sense_single(dev, channel, &(controller->buffer[8]), 28);
+               
+                                           controller->buffer[8] = 0x2a;
+                                           controller->buffer[9] = 0x12;
+                                           controller->buffer[10] = 0x00;
+                                           controller->buffer[11] = 0x00;
+                                           // Multisession, Mode 2 Form 2, Mode 2 Form 1
+                                           controller->buffer[12] = 0x70; 
+                                           controller->buffer[13] = (3 << 5);
+                                           controller->buffer[14] = (unsigned char) (1 |
+                                                                                     (drive->cdrom.locked ? (1 << 1) : 0) |
+                                                                                     (1 << 3) |
+                                                                                     (1 << 5));
+                                           controller->buffer[15] = 0x00;
+                                           controller->buffer[16] = (706 >> 8) & 0xff;
+                                           controller->buffer[17] = 706 & 0xff;
+                                           controller->buffer[18] = 0;
+                                           controller->buffer[19] = 2;
+                                           controller->buffer[20] = (512 >> 8) & 0xff;
+                                           controller->buffer[21] = 512 & 0xff;
+                                           controller->buffer[22] = (706 >> 8) & 0xff;
+                                           controller->buffer[23] = 706 & 0xff;
+                                           controller->buffer[24] = 0;
+                                           controller->buffer[25] = 0;
+                                           controller->buffer[26] = 0;
+                                           controller->buffer[27] = 0;
+                                           rd_ready_to_send_atapi(dev, channel);
+                                           break;
+                                       }
+                                   case 0x0d: // CD-ROM
+                                   case 0x0e: // CD-ROM audio control
+                                   case 0x3f: // all
+                                       {
+                                           PrintError("Ramdisk: cdrom: MODE SENSE (curr), code=%x not implemented yet\n",
+                                                      PageCode);
+                                           rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST,
+                                                              ASC_INV_FIELD_IN_CMD_PACKET);
+                                           rd_raise_interrupt(dev, channel);
+                                           break;
+                                       }
+                                   default:
+                                       {
+                                           // not implemeted by this device
+                                           PrintError("\t\tcdrom: MODE SENSE PC=%x, PageCode=%x, not implemented by device\n",
+                                                      PC, PageCode);
+                                           rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST,
+                                                              ASC_INV_FIELD_IN_CMD_PACKET);
+                                           rd_raise_interrupt(dev, channel);
+                                           break;
+                                       }
+                               }
+                               break;
+                           }
+                       case 0x1: // changeable values
+                           {
+                               switch (PageCode) {
+                                   case 0x01: // error recovery
+                                   case 0x0d: // CD-ROM
+                                   case 0x0e: // CD-ROM audio control
+                                   case 0x2a: // CD-ROM capabilities & mech. status
+                                   case 0x3f: // all
+                                       {
+                                           PrintError("cdrom: MODE SENSE (chg), code=%x not implemented yet\n",
+                                                      PageCode);
+                                           rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST,
+                                                              ASC_INV_FIELD_IN_CMD_PACKET);
+                                           rd_raise_interrupt(dev, channel);
+                                           break;
+                                       }
+                                   default:
+                                       {
+                                           // not implemeted by this device
+                                           PrintError("Changeable values of mode sense not supported by cdrom\n");
+                                           PrintDebug("\t\tcdrom: MODE SENSE PC=%x, PageCode=%x, not implemented by device\n",
+                                                      PC, PageCode);
+                                           rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST,
+                                                              ASC_INV_FIELD_IN_CMD_PACKET);
+                                           rd_raise_interrupt(dev, channel);
+                                           break;
+                                       }
+                               }
+                               break;
+                           }
+                       case 0x2: // default values
+                           {
+                               switch (PageCode) {
+                                   case 0x01: // error recovery
+                                   case 0x0d: // CD-ROM
+                                   case 0x0e: // CD-ROM audio control
+                                   case 0x2a: // CD-ROM capabilities & mech. status
+                                   case 0x3f: // all
+                                       PrintError("Default values of mode sense not supported by cdrom\n");
+                                       PrintDebug("cdrom: MODE SENSE (dflt), code=%x\n",
+                                                  PageCode);
+                                       return -1;
+             
+                                   default:
+                                       {
+                                           PrintError("Default values of mode sense not implemented in cdrom\n");
+                                           // not implemeted by this device
+                                           PrintDebug("cdrom: MODE SENSE PC=%x, PageCode=%x, not implemented by device\n",
+                                                      PC, PageCode);
+                                           rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST,
+                                                              ASC_INV_FIELD_IN_CMD_PACKET);
+                                           rd_raise_interrupt(dev, channel);
+                                           break;
+                                       }
+                               }
+                               break;
+                           }
+                       case 0x3: // saved values not implemented
+                           {
+                               PrintError("\t\tSaved values not implemented in mode sense\n");
+                               rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST, ASC_SAVING_PARAMETERS_NOT_SUPPORTED);
+                               rd_raise_interrupt(dev, channel);
+                               break;
+                           }
+                       default:
+                           {
+                               PrintError("Unsupported Mode sense value\n");
+                               return -1;
+                               break;
+                           }
+                   }
+                   break;
+               }
+           case 0x12: // inquiry
+               { 
+                   uint8_t alloc_length = controller->buffer[4];
+       
+                   if (rd_init_send_atapi_command(dev, channel, atapi_command, 36, alloc_length, false) == -1) {
+                       PrintError("Error sending atapi command in inquiry\n");
+                       return -1;
+                   }
+       
+                   controller->buffer[0] = 0x05; // CD-ROM
+                   controller->buffer[1] = 0x80; // Removable
+                   controller->buffer[2] = 0x00; // ISO, ECMA, ANSI version
+                   controller->buffer[3] = 0x21; // ATAPI-2, as specified
+                   controller->buffer[4] = 31; // additional length (total 36)
+                   controller->buffer[5] = 0x00; // reserved
+                   controller->buffer[6] = 0x00; // reserved
+                   controller->buffer[7] = 0x00; // reserved
+       
+                   // Vendor ID
+                   const char* vendor_id = "VTAB    ";
+                   int i;
+                   for (i = 0; i < 8; i++) {
+                       controller->buffer[8+i] = vendor_id[i];
+                   }
+
+                   // Product ID
+                   const char* product_id = "Turbo CD-ROM    ";
+                   for (i = 0; i < 16; i++) {
+                       controller->buffer[16+i] = product_id[i];
+                   }
+
+                   // Product Revision level
+                   const char* rev_level = "1.0 ";     
+                   for (i = 0; i < 4; i++) {
+                       controller->buffer[32 + i] = rev_level[i];
+                   }
+
+                   rd_ready_to_send_atapi(dev, channel);
+                   break;
+               }
+           case 0x25:  // read cd-rom capacity
+               {
+                   // no allocation length???
+                   if (rd_init_send_atapi_command(dev, channel, atapi_command, 8, 8, false) == -1) {
+                       PrintError("Error sending atapi command in read cdrom capacity\n");
+                       return -1;
+                   }
+       
+                   if (drive->cdrom.ready) {
+                       uint32_t capacity = drive->cdrom.capacity;
+
+                       PrintDebug("\t\tCapacity is %d sectors (%d bytes)\n", capacity, capacity * 2048);
+
+                       controller->buffer[0] = (capacity >> 24) & 0xff;
+                       controller->buffer[1] = (capacity >> 16) & 0xff;
+                       controller->buffer[2] = (capacity >> 8) & 0xff;
+                       controller->buffer[3] = (capacity >> 0) & 0xff;
+                       controller->buffer[4] = (2048 >> 24) & 0xff;
+                       controller->buffer[5] = (2048 >> 16) & 0xff;
+                       controller->buffer[6] = (2048 >> 8) & 0xff;
+                       controller->buffer[7] = (2048 >> 0) & 0xff;
+
+                       rd_ready_to_send_atapi(dev, channel);
+                   } else {
+                       PrintError("CDROM not ready in read cdrom capacity\n");
+                       rd_atapi_cmd_error(dev, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
+                       rd_raise_interrupt(dev, channel);
+                   }
+                   break;
+               }
+      
       
-      // (mch) Set BSY, drive not ready
-      for (id = 0; id < 2; id++) {
-       CONTROLLER(channel,id).status.busy           = 1;
-       CONTROLLER(channel,id).status.drive_ready    = 0;
-       CONTROLLER(channel,id).reset_in_progress     = 1;
+           case 0xbe:  // read cd
+               {
+                   if (drive->cdrom.ready) {
+                       PrintError("Read CD with CD present not implemented\n");
+                       rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST, ASC_INV_FIELD_IN_CMD_PACKET);
+                       rd_raise_interrupt(dev, channel);
+                   } else {
+                       PrintError("Drive not ready in read cd with CD present\n");
+                       rd_atapi_cmd_error(dev, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
+                       rd_raise_interrupt(dev, channel);
+                   }
+                   break;
+               }
+           case 0x43: // read toc
+               { 
+                   if (drive->cdrom.ready) {
+                       int toc_length = 0;  
+                       bool msf = (controller->buffer[1] >> 1) & 1;
+                       uint8_t starting_track = controller->buffer[6];
+         
+                       uint16_t alloc_length = rd_read_16bit(controller->buffer + 7);
+         
+                       uint8_t format = (controller->buffer[9] >> 6);
+                       int i;
+
+                       PrintDebug("Reading CDROM TOC: Format=%d (byte count=%d) (toc length:%d)\n", 
+                                  format, controller->byte_count, toc_length);
+
+                       switch (format) {
+                           case 0:
+                               if (!(drive->cdrom.cd->read_toc(drive->private_data, controller->buffer,
+                                                               &toc_length, msf, starting_track))) {
+                                   PrintError("CDROM: Reading Table of Contents Failed\n");
+                                   rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST,
+                                                      ASC_INV_FIELD_IN_CMD_PACKET);
+                                   rd_raise_interrupt(dev, channel);
+                                   break;
+                               }
+
+             
+                               if (rd_init_send_atapi_command(dev, channel, atapi_command, toc_length, alloc_length, false) == -1) {
+                                   PrintError("Failed to init send atapi command in read toc (fmt=%d)\n", format);
+                                   return -1;
+                               }
+
+                               rd_ready_to_send_atapi(dev, channel);    
+
+                               break;
+
+                           case 1:
+                               // multi session stuff. we ignore this and emulate a single session only
+
+                               if (rd_init_send_atapi_command(dev, channel, atapi_command, 12, alloc_length, false) == -1) {
+                                   PrintError("Failed to init send atapi command in read toc (fmt=%d)\n", format);
+                                   return -1;
+                               }
+           
+                               controller->buffer[0] = 0;
+                               controller->buffer[1] = 0x0a;
+                               controller->buffer[2] = 1;
+                               controller->buffer[3] = 1;
+
+                               for (i = 0; i < 8; i++) {
+                                   controller->buffer[4 + i] = 0;
+                               }
+
+                               rd_ready_to_send_atapi(dev, channel);
+                               break;
+           
+                           case 2:
+                           default:
+                               PrintError("(READ TOC) Format %d not supported\n", format);
+                               return -1;
+                       }
+                   } else {
+                       PrintError("CDROM not ready in read toc\n");
+                       rd_atapi_cmd_error(dev, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
+                       rd_raise_interrupt(dev, channel);
+                   }
+                   break;
+               }
+           case 0x28: // read (10)
+           case 0xa8: // read (12)
+               { 
        
-       CONTROLLER(channel,id).status.write_fault    = 0;
-       CONTROLLER(channel,id).status.seek_complete  = 1;
-       CONTROLLER(channel,id).status.drq            = 0;
-       CONTROLLER(channel,id).status.corrected_data = 0;
-       CONTROLLER(channel,id).status.err            = 0;
+                   uint32_t transfer_length;
+                   if (atapi_command == 0x28) {
+                       transfer_length = rd_read_16bit(controller->buffer + 7);
+                   } else {
+                       transfer_length = rd_read_32bit(controller->buffer + 6);
+                   }
+
+                   uint32_t lba = rd_read_32bit(controller->buffer + 2);
        
-       CONTROLLER(channel,id).error_register = 0x01; // diagnostic code: no error
+                   if (!(drive->cdrom.ready)) {
+                       PrintError("CDROM Error: Not Ready (ATA%d/%d)\n", 
+                                  get_channel_no(ramdisk, channel), get_drive_no(channel, drive));
+                       rd_atapi_cmd_error(dev, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
+                       rd_raise_interrupt(dev, channel);
+                       break;
+                   }
        
-       CONTROLLER(channel,id).current_command = 0x00;
-       CONTROLLER(channel,id).buffer_index = 0;
+                   if (transfer_length == 0) {
+                       PrintError("READ(%d) with transfer length 0, ok\n", 
+                                  (atapi_command == 0x28) ? 10 : 12);
+                       rd_atapi_cmd_nop(dev, channel);
+                       rd_raise_interrupt(dev, channel);
+                       break;
+                   }
        
-       CONTROLLER(channel,id).sectors_per_block = 0x80;
-       CONTROLLER(channel,id).lba_mode          = 0;
+                   if (lba + transfer_length > drive->cdrom.capacity) {
+                       PrintError("CDROM Error: Capacity exceeded [capacity=%d] (ATA%d/%d)\n",
+                                  drive->cdrom.capacity,
+                                  get_channel_no(ramdisk, channel), get_drive_no(channel, drive));
+                       rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST, ASC_LOGICAL_BLOCK_OOR);
+                       rd_raise_interrupt(dev, channel);
+                       break;
+                   }
        
-       CONTROLLER(channel,id).control.disable_irq = 0;
-       rd_lower_irq((struct vm_device *)(ramdisk_state->private_data), channels[channel].irq);
-      }
-    } else if (SELECTED_CONTROLLER(channel).reset_in_progress &&
-              !SELECTED_CONTROLLER(channel).control.reset) {
-      // Clear BSY and DRDY
-      Ramdisk_Print("\t\tReset complete {%s}\n", SELECTED_TYPE_STRING(channel));
-      for (id = 0; id < 2; id++) {
-       CONTROLLER(channel,id).status.busy           = 0;
-       CONTROLLER(channel,id).status.drive_ready    = 1;
-       CONTROLLER(channel,id).reset_in_progress     = 0;
+                   PrintDebug("\t\tcdrom: READ (%d) LBA=%d LEN=%d\n", 
+                              (atapi_command == 0x28) ? 10 : 12, 
+                              lba, transfer_length);
+       
+                   // handle command
+                   if (rd_init_send_atapi_command(dev, channel, atapi_command, transfer_length * 2048,
+                                                  transfer_length * 2048, true) == -1) {
+                       PrintError("CDROM Error: Atapi command send error\n");
+                       return -1;
+                   }
+
+                   drive->cdrom.remaining_blocks = transfer_length;
+                   drive->cdrom.next_lba = lba;
+                   rd_ready_to_send_atapi(dev, channel);
+                   break;
+               }
+           case 0x2b:  // seek
+               {
+                   uint32_t lba = rd_read_32bit(controller->buffer + 2);
+
+                   if (!(drive->cdrom.ready)) {
+                       PrintError("CDROM not ready in seek\n");
+                       rd_atapi_cmd_error(dev, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
+                       rd_raise_interrupt(dev, channel);
+                       break;
+                   }
+       
+                   if (lba > drive->cdrom.capacity) {
+                       PrintError("LBA is greater than CDROM capacity in seek\n");
+                       rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST, ASC_LOGICAL_BLOCK_OOR);
+                       rd_raise_interrupt(dev, channel);
+                       break;
+                   }
+       
+                   PrintError("\t\tcdrom: SEEK (ignored)\n");
+
+                   rd_atapi_cmd_nop(dev, channel);
+                   rd_raise_interrupt(dev, channel);
+
+                   break;
+               }
+           case 0x1e:  // prevent/allow medium removal
+               {
+
+                   if (drive->cdrom.ready) {
+                       drive->cdrom.locked = controller->buffer[4] & 1;
+                       rd_atapi_cmd_nop(dev, channel);
+                   } else {
+                       PrintError("CD not ready in prevent/allow medium removal\n");
+                       rd_atapi_cmd_error(dev, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
+                   }
+
+                   rd_raise_interrupt(dev, channel);
+
+                   break;
+               }
+           case 0x42:  // read sub-channel
+               {
+                   //bool msf = get_packet_field(channel, 1, 1, 1);
+                   bool sub_q = get_packet_field(channel, 2, 6, 1);
+                   //uint8_t data_format = get_packet_byte(channel, 3);
+                   //uint8_t track_number = get_packet_byte(channel, 6);
+                   uint16_t alloc_length = get_packet_word(channel, 7);
        
-       // Device signature
-       if (DRIVE_IS_HD(channel,id)) {
-         Ramdisk_Print("\t\tdrive %d/%d is harddrive\n", channel, id);
-         CONTROLLER(channel,id).head_no        = 0;
-         CONTROLLER(channel,id).sector_count   = 1;
-         CONTROLLER(channel,id).sector_no      = 1;
-         CONTROLLER(channel,id).cylinder_no    = 0;
-       } else {
-         CONTROLLER(channel,id).head_no        = 0;
-         CONTROLLER(channel,id).sector_count   = 1;
-         CONTROLLER(channel,id).sector_no      = 1;
-         CONTROLLER(channel,id).cylinder_no    = 0xeb14;
+
+                   /*
+                     UNUSED(msf);
+                     UNUSED(data_format);
+                     UNUSED(track_number);
+                   */
+                   if (!(drive->cdrom.ready)) {
+                       PrintError("CDROM not ready in read sub-channel\n");
+                       rd_atapi_cmd_error(dev, channel, SENSE_NOT_READY, ASC_MEDIUM_NOT_PRESENT);
+                       rd_raise_interrupt(dev, channel);
+                   } else {
+                       controller->buffer[0] = 0;
+                       controller->buffer[1] = 0; // audio not supported
+                       controller->buffer[2] = 0;
+                       controller->buffer[3] = 0;
+         
+                       int ret_len = 4; // header size
+         
+                       if (sub_q) { // !sub_q == header only
+                           PrintError("Read sub-channel with SubQ not implemented\n");
+                           rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST,
+                                              ASC_INV_FIELD_IN_CMD_PACKET);
+                           rd_raise_interrupt(dev, channel);
+                       }
+         
+                       if (rd_init_send_atapi_command(dev, channel, atapi_command, ret_len, alloc_length, false) == -1) {
+                           PrintError("Error sending atapi command in read sub-channel\n");
+                           return -1;
+                       }
+                       rd_ready_to_send_atapi(dev, channel);
+                   }
+                   break;
+               }
+           case 0x51:  // read disc info
+               {
+                   // no-op to keep the Linux CD-ROM driver happy
+                   PrintError("Error: Read disk info no-op to keep the Linux CD-ROM driver happy\n");
+                   rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST, ASC_INV_FIELD_IN_CMD_PACKET);
+                   rd_raise_interrupt(dev, channel);
+                   break;
+               }
+           case 0x55: // mode select
+           case 0xa6: // load/unload cd
+           case 0x4b: // pause/resume
+           case 0x45: // play audio
+           case 0x47: // play audio msf
+           case 0xbc: // play cd
+           case 0xb9: // read cd msf
+           case 0x44: // read header
+           case 0xba: // scan
+           case 0xbb: // set cd speed
+           case 0x4e: // stop play/scan
+           case 0x46: // ???
+           case 0x4a: // ???
+               PrintError("ATAPI command 0x%x not implemented yet\n",
+                          atapi_command);
+               rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST, ASC_INV_FIELD_IN_CMD_PACKET);
+               rd_raise_interrupt(dev, channel);
+               break;
+           default:
+               PrintError("Unknown ATAPI command 0x%x (%d)\n",
+                          atapi_command, atapi_command);
+               // We'd better signal the error if the user chose to continue
+               rd_atapi_cmd_error(dev, channel, SENSE_ILLEGAL_REQUEST, ASC_INV_FIELD_IN_CMD_PACKET);
+               rd_raise_interrupt(dev, channel);
+               break;
        }
-      }
     }
-    Ramdisk_Print("\t\ts[0].controller.control.disable_irq = %02x\n", (channels[channel].drives[0]).controller.control.disable_irq);
-    Ramdisk_Print("\t\ts[1].controller.control.disable_irq = %02x\n", (channels[channel].drives[1]).controller.control.disable_irq);
-    break;
-    
-  default:
-    RD_PANIC("\t\thard drive: io write to address %x = %02x\n",
-                 (unsigned) address, (unsigned) value);
-  }  
-  
-  return;
+       
+             
+    return 0;
 }
 
 
-static 
-void rd_identify_ATAPI_drive(struct channel_t *channels, Bit8u channel)
+
+
+int rd_init_send_atapi_command(struct vm_device * dev, struct channel_t * channel, Bit8u command, int req_length, int alloc_length, bool lazy)
 {
-  unsigned i;
-  const char* serial_number = " VT00001\0\0\0\0\0\0\0\0\0\0\0\0";
-  const char* firmware = "ALPHA1  ";
+    struct drive_t * drive = &(channel->drives[channel->drive_select]);
+    struct controller_t * controller = &(drive->controller);
+
+    // controller->byte_count is a union of controller->cylinder_no;
+    // lazy is used to force a data read in the buffer at the next read.
+  
+    PrintDebug("[rd_init_send_atapi_cmd]\n");
 
-  SELECTED_DRIVE(channel).id_drive[0] = (2 << 14) | (5 << 8) | (1 << 7) | (2 << 5) | (0 << 0); // Removable CDROM, 50us response, 12 byte packets
+    if (controller->byte_count == 0xffff) {
+       controller->byte_count = 0xfffe;
+    }
 
-  for (i = 1; i <= 9; i++)
-       SELECTED_DRIVE(channel).id_drive[i] = 0;
+    if ((controller->byte_count & 1) && 
+       !(alloc_length <= controller->byte_count)) {
+      
+       PrintDebug("\t\tOdd byte count (0x%04x) to ATAPI command 0x%02x, using 0x%x\n", 
+                  controller->byte_count, 
+                  command, 
+                  controller->byte_count - 1);
+    
+       controller->byte_count -= 1;
+    }
+  
+    if (controller->byte_count == 0) {
+       PrintError("\t\tATAPI command with zero byte count\n");
+       return -1;
+    }
 
+    if (alloc_length < 0) {
+       PrintError("\t\tAllocation length < 0\n");
+       return -1;
+    }
 
-  for (i = 0; i < 10; i++) {
-       SELECTED_DRIVE(channel).id_drive[10+i] = (serial_number[i*2] << 8) |
-             serial_number[i*2 + 1];
-  }
+    if (alloc_length == 0) {
+       alloc_length = controller->byte_count;
+    }
+  
+    controller->interrupt_reason.i_o = 1;
+    controller->interrupt_reason.c_d = 0;
+    controller->status.busy = 0;
+    controller->status.drq = 1;
+    controller->status.err = 0;
+  
+    // no bytes transfered yet
+    if (lazy) {
+       controller->buffer_index = 2048;
+    } else {
+       controller->buffer_index = 0;
+    }
 
-  for (i = 20; i <= 22; i++)
-       SELECTED_DRIVE(channel).id_drive[i] = 0;
+    controller->drq_index = 0;
+  
+    if (controller->byte_count > req_length) {
+       controller->byte_count = req_length;
+    }
 
+    if (controller->byte_count > alloc_length) {
+       controller->byte_count = alloc_length;
+    }  
 
-  for (i = 0; i < strlen(firmware)/2; i++) {
-       SELECTED_DRIVE(channel).id_drive[23+i] = (firmware[i*2] << 8) |
-             firmware[i*2 + 1];
-  }
-  V3_ASSERT((23+i) == 27);
+    drive->atapi.command = command;
+    drive->atapi.drq_bytes = controller->byte_count;
+    drive->atapi.total_bytes_remaining = (req_length < alloc_length) ? req_length : alloc_length;
   
-  for (i = 0; i < strlen((char *) SELECTED_MODEL(channel))/2; i++) {
-       SELECTED_DRIVE(channel).id_drive[27+i] = (SELECTED_MODEL(channel)[i*2] << 8) |
-             SELECTED_MODEL(channel)[i*2 + 1];
-  }
-  V3_ASSERT((27+i) == 47);
-
-  SELECTED_DRIVE(channel).id_drive[47] = 0;
-  SELECTED_DRIVE(channel).id_drive[48] = 1; // 32 bits access
-
-  SELECTED_DRIVE(channel).id_drive[49] = (1 << 9); // LBA supported
-
-  SELECTED_DRIVE(channel).id_drive[50] = 0;
-  SELECTED_DRIVE(channel).id_drive[51] = 0;
-  SELECTED_DRIVE(channel).id_drive[52] = 0;
-
-  SELECTED_DRIVE(channel).id_drive[53] = 3; // words 64-70, 54-58 valid
-
-  for (i = 54; i <= 62; i++)
-       SELECTED_DRIVE(channel).id_drive[i] = 0;
-
-  // copied from CFA540A
-  SELECTED_DRIVE(channel).id_drive[63] = 0x0103; // variable (DMA stuff)
-  SELECTED_DRIVE(channel).id_drive[64] = 0x0001; // PIO
-  SELECTED_DRIVE(channel).id_drive[65] = 0x00b4;
-  SELECTED_DRIVE(channel).id_drive[66] = 0x00b4;
-  SELECTED_DRIVE(channel).id_drive[67] = 0x012c;
-  SELECTED_DRIVE(channel).id_drive[68] = 0x00b4;
-
-  SELECTED_DRIVE(channel).id_drive[69] = 0;
-  SELECTED_DRIVE(channel).id_drive[70] = 0;
-  SELECTED_DRIVE(channel).id_drive[71] = 30; // faked
-  SELECTED_DRIVE(channel).id_drive[72] = 30; // faked
-  SELECTED_DRIVE(channel).id_drive[73] = 0;
-  SELECTED_DRIVE(channel).id_drive[74] = 0;
-
-  SELECTED_DRIVE(channel).id_drive[75] = 0;
-
-  for (i = 76; i <= 79; i++)
-       SELECTED_DRIVE(channel).id_drive[i] = 0;
-
-  SELECTED_DRIVE(channel).id_drive[80] = 0x1e; // supports up to ATA/ATAPI-4
-  SELECTED_DRIVE(channel).id_drive[81] = 0;
-  SELECTED_DRIVE(channel).id_drive[82] = 0;
-  SELECTED_DRIVE(channel).id_drive[83] = 0;
-  SELECTED_DRIVE(channel).id_drive[84] = 0;
-  SELECTED_DRIVE(channel).id_drive[85] = 0;
-  SELECTED_DRIVE(channel).id_drive[86] = 0;
-  SELECTED_DRIVE(channel).id_drive[87] = 0;
-  SELECTED_DRIVE(channel).id_drive[88] = 0;
-
-  for (i = 89; i <= 126; i++)
-       SELECTED_DRIVE(channel).id_drive[i] = 0;
-
-  SELECTED_DRIVE(channel).id_drive[127] = 0;
-  SELECTED_DRIVE(channel).id_drive[128] = 0;
-
-  for (i = 129; i <= 159; i++)
-       SELECTED_DRIVE(channel).id_drive[i] = 0;
-
-  for (i = 160; i <= 255; i++)
-       SELECTED_DRIVE(channel).id_drive[i] = 0;
-
-  // now convert the id_drive array (native 256 word format) to
-  // the controller buffer (512 bytes)
-  Bit16u temp16;
-  for (i = 0; i <= 255; i++) {
-       temp16 = SELECTED_DRIVE(channel).id_drive[i];
-       SELECTED_CONTROLLER(channel).buffer[i*2] = temp16 & 0x00ff;
-       SELECTED_CONTROLLER(channel).buffer[i*2+1] = temp16 >> 8;
-  }
+    // if (lazy) {
+    // // bias drq_bytes and total_bytes_remaining
+    // SELECTED_DRIVE(channel).atapi.drq_bytes += 2048;
+    // SELECTED_DRIVE(channel).atapi.total_bytes_remaining += 2048;
+    // }
 
-  return;
+    return 0;
 }
 
 
 
-static 
-void rd_raise_interrupt(struct channel_t *channels, Bit8u channel)
+void rd_ready_to_send_atapi(struct vm_device * dev, struct channel_t * channel) {
+    PrintDebug("[rd_ready_to_send_atapi]\n");
+  
+    rd_raise_interrupt(dev, channel);
+}
+
+
+
+
+
+void rd_atapi_cmd_error(struct vm_device * dev, struct channel_t * channel, sense_t sense_key, asc_t asc)
 {
-  Bit32u irq;
-  struct vm_device *dev;
+    struct drive_t * drive = &(channel->drives[channel->drive_select]);
+    struct controller_t * controller = &(drive->controller);
 
-  Ramdisk_Print("[raise_interrupt] disable_irq = %02x\n", SELECTED_CONTROLLER(channel).control.disable_irq);
 
-  if (!SELECTED_CONTROLLER(channel).control.disable_irq) { 
-    Ramdisk_Print("\t\traising interrupt\n"); 
-  } else { 
-    Ramdisk_Print("\t\tNot raising interrupt\n"); 
-  }
-  if (!SELECTED_CONTROLLER(channel).control.disable_irq) {
-    irq = channels[channel].irq; 
-    Ramdisk_Print("\t\tRaising interrupt %d {%s}\n\n", irq, SELECTED_TYPE_STRING(channel));
-    //        DEV_pic_raise_irq(irq);
-    dev = (struct vm_device*) ramdisk_state->private_data;
-    Ramdisk_Print("\t\tdev = %x\n", dev);
-    dev->vm->vm_ops.raise_irq(dev->vm, irq);
-  } else {
-    Ramdisk_Print("\t\tirq is disabled\n");
-  }
+    struct ramdisk_t *ramdisk = (struct ramdisk_t *)(dev->private_data);
+    PrintError("[rd_atapi_cmd_error]\n");
+    PrintError("Error: atapi_cmd_error channel=%02x key=%02x asc=%02x\n", 
+              get_channel_no(ramdisk, channel), sense_key, asc);
   
-  return;
+
+    controller->error_register = sense_key << 4;
+    controller->interrupt_reason.i_o = 1;
+    controller->interrupt_reason.c_d = 1;
+    controller->interrupt_reason.rel = 0;
+    controller->status.busy = 0;
+    controller->status.drive_ready = 1;
+    controller->status.write_fault = 0;
+    controller->status.drq = 0;
+    controller->status.err = 1;
+  
+    drive->sense.sense_key = sense_key;
+    drive->sense.asc = asc;
+    drive->sense.ascq = 0;
 }
 
-static
-void rd_lower_irq(struct vm_device *dev, Bit32u irq)// __attribute__(regparm(1))
+
+
+void rd_atapi_cmd_nop(struct vm_device * dev, struct channel_t * channel)
 {
-  Ramdisk_Print("[lower_irq] irq = %d\n", irq);
-  dev->vm->vm_ops.lower_irq(dev->vm, irq);
+    struct drive_t * drive = &(channel->drives[channel->drive_select]);
+    struct controller_t * controller = &(drive->controller);
+
+    PrintDebug("[rd_atapi_cmd_nop]\n");
+    controller->interrupt_reason.i_o = 1;
+    controller->interrupt_reason.c_d = 1;
+    controller->interrupt_reason.rel = 0;
+    controller->status.busy = 0;
+    controller->status.drive_ready = 1;
+    controller->status.drq = 0;
+    controller->status.err = 0;
 }
 
 
-/*
- * Public Routines
- */
-static
-uint_t ramdisk_read_port(ushort_t port,
-                        void *src,
-                        uint_t length,
-                        struct vm_device *dev)
+
+
+void rd_identify_ATAPI_drive(struct vm_device * dev, struct channel_t * channel)
 {
-  uint_t i;
-  Ramdisk_Print("[ramdisk_read_port] port = %x, length = %d\n", port, length);
-    switch (length) {
-    case 1:
-      ((uchar_t*)src)[0] = rd_read_handler(ramdisk_state->channels, port, length);
-      break;
-    case 2:
-      ((ushort_t*)src)[0] = rd_read_handler(ramdisk_state->channels, port, length);
-      break;
-    case 4:
-      ((uint_t*)src)[0] = rd_read_handler(ramdisk_state->channels, port, length);
-      break;
-    default:
-      for (i = 0; i < length; i++) { 
-       ((uchar_t*)src)[i] = rd_read_handler(ramdisk_state->channels, port, 1);
-      }
-    }//switch length
+    struct drive_t * drive = &(channel->drives[channel->drive_select]);
+    struct controller_t * controller = &(drive->controller);
 
-  return length;
-}
 
+    uint_t i;
+    const char* serial_number = " VT00001\0\0\0\0\0\0\0\0\0\0\0\0";
+    const char* firmware = "ALPHA1  ";
 
-static
-uint_t ramdisk_write_port(ushort_t port,
-                        void *src,
-                        uint_t length,
-                        struct vm_device *dev)
-{
-  Ramdisk_Print("[ramdisk_write_port] port = %x, length = %d\n", port, length);
-  /*
-  uint_t i;
-
-  for (i = 0; i < length; i++)
-    Ramdisk_Print("\t\tsrc[%d] = 0x%02x\n", i, ((uchar_t*)src)[i]);
-  */
-
-  switch(length) {
-  case 1:
-    rd_write_handler(ramdisk_state->channels, port, *((uchar_t *)src), length);
-    break;
-  case 2:
-    rd_write_handler(ramdisk_state->channels, port, *((ushort_t *)src), length);
-    break;
-  case 4:
-    rd_write_handler(ramdisk_state->channels, port, *((uint_t *)src), length);
-    break;
-  default:
-    rd_write_handler(ramdisk_state->channels, port, *((uchar_t *)src), length);
-    break;
-  }
+    drive->id_drive[0] = (2 << 14) | (5 << 8) | (1 << 7) | (2 << 5) | (0 << 0); // Removable CDROM, 50us response, 12 byte packets
 
-  return 1;
-}
+    for (i = 1; i <= 9; i++) {
+       drive->id_drive[i] = 0;
+    }
 
+    for (i = 0; i < 10; i++) {
+       drive->id_drive[10 + i] = ((serial_number[i * 2] << 8) |
+                                  (serial_number[(i * 2) + 1]));
+    }
 
-static void trace_info(ushort_t port, void *src, uint_t length)
-{
-  switch(port){
-
-  case 0x3e8:
-    if (length == 1 && *((uchar_t*) src) == ATA_DETECT)
-      Ramdisk_Print("ata_dectect()\n");
-    break;
-
-  case 0x3e9:
-    if (length == 1 && *((uchar_t*) src) == ATA_RESET)
-      Ramdisk_Print("ata_reset()\n");
-    break;
-
-  case 0x3ea:
-    if (length == 1 && *((uchar_t*) src) == ATA_CMD_DATA_IN)
-      Ramdisk_Print("ata_cmd_data_in()\n");
-    break;
-
-  case 0x3eb:
-    if (length == 1 && *((uchar_t*) src) == ATA_CMD_DATA_OUT)
-      Ramdisk_Print("ata_cmd_data_out()\n");
-    break;
-
-  case 0x3ec:
-    if (length == 1 && *((uchar_t*) src) == ATA_CMD_PACKET)
-      Ramdisk_Print("ata_cmd_packet()\n");
-    break;
-
-  case 0x3ed:
-    if (length == 1 && *((uchar_t*) src) == ATAPI_GET_SENSE)
-      Ramdisk_Print("atapi_get_sense()\n");
-    break;
-
-  case 0x3ee:
-    if (length == 1 && *((uchar_t*) src) == ATAPI_IS_READY)
-      Ramdisk_Print("atapi_is_ready()\n");
-    break;
-
-  case 0x3ef:
-    if (length == 1 && *((uchar_t*) src) == ATAPI_IS_CDROM)
-      Ramdisk_Print("atapi_is_cdrom()\n");
-    break;
-
-
-  case 0x2e8:
-    if (length == 1 && *((uchar_t*) src) == CDEMU_INIT)
-      Ramdisk_Print("cdemu_init()\n");
-    break;
-
-  case 0x2e9:
-    if (length == 1 && *((uchar_t*) src) == CDEMU_ISACTIVE)
-      Ramdisk_Print("cdemu_isactive()\n");
-    break;
-
-  case 0x2ea:
-    if (length == 1 && *((uchar_t*) src) == CDEMU_EMULATED_DRIVE)
-      Ramdisk_Print("cdemu_emulated_drive()\n");
-    break;
-
-  case 0x2eb:
-    if (length == 1 && *((uchar_t*) src) == CDROM_BOOT)
-      Ramdisk_Print("cdrom_boot()\n");
-    break;
-
-  case 0x2ec:
-    if (length == 1 && *((uchar_t*) src) == HARD_DRIVE_POST)
-      Ramdisk_Print("ata_hard_drive_post()\n");
-    break;
-
-  case 0x2ed:
-    if (length == 1)
-      Ramdisk_Print("ata_device_no(%d)\n", *((uchar_t*) src));
-    break;
-
-  case 0x2ee:
-    if (length == 1)
-      Ramdisk_Print("ata_device_type(%d)\n", *((uchar_t*) src));
-    break;
-
-  case 0x2ef:
-    if (length == 1 && *((uchar_t*) src) == INT13_HARDDISK)
-      Ramdisk_Print("int13_harddrive()\n");
-    break;
-
-  case 0x2f8:
-    if (length == 1 && *((uchar_t*) src) == INT13_CDROM)
-      Ramdisk_Print("int13_cdrom()\n");
-    break;
-
-  case 0x2f9:
-    if (length == 1 && *((uchar_t*) src) == INT13_CDEMU)
-      Ramdisk_Print("int13_cdemu()\n");
-    break;
-
-  case 0x2fa:
-    if (length == 1 && *((uchar_t*) src) == INT13_ELTORITO)
-      Ramdisk_Print("int13_eltorito()\n");
-    break;
-
-  case 0x2fb:
-    if (length == 1 && *((uchar_t*) src) == INT13_DISKETTE_FUNCTION)
-      Ramdisk_Print("int13_diskette_function()\n");
-    break;
-
-
-  default:
-    break;
-  }
-}
+    for (i = 20; i <= 22; i++) {
+       drive->id_drive[i] = 0;
+    }
 
+    for (i = 0; i < strlen(firmware) / 2; i++) {
+       drive->id_drive[23 + i] = ((firmware[i * 2] << 8) |
+                                  (firmware[(i * 2) + 1]));
+    }
+    V3_ASSERT((23 + i) == 27);
+  
+    for (i = 0; i < strlen((char *)(drive->model_no)) / 2; i++) {
+       drive->id_drive[27 + i] = ((drive->model_no[i * 2] << 8) |
+                                  (drive->model_no[(i * 2) + 1]));
+    }
 
-uint_t ramdisk_read_port_ignore(ushort_t port,
-                        void *src,
-                        uint_t length,
-                        struct vm_device *dev)
-{
-  //  Ramdisk_Print("[ramdisk_read_port_ignore] port = %x, length = %d\n", port, length);
-  return 1;
-}
+    V3_ASSERT((27 + i) == 47);
 
-uint_t ramdisk_write_port_ignore(ushort_t port,
-                        void *src,
-                        uint_t length,
-                        struct vm_device *dev)
-{
+    drive->id_drive[47] = 0;
+    drive->id_drive[48] = 1; // 32 bits access
 
-  //  Ramdisk_Print("[ramdisk_write_port_ignore] port = %x, length = %d\n", port, length);
+    drive->id_drive[49] = (1 << 9); // LBA supported
 
-  trace_info(port, src, length);
-  return 1;
-}
+    drive->id_drive[50] = 0;
+    drive->id_drive[51] = 0;
+    drive->id_drive[52] = 0;
 
-//////////////////////////////////////////////////////////////////////////
+    drive->id_drive[53] = 3; // words 64-70, 54-58 valid
 
-/*
- * ATAPI subroutines
- */
+    for (i = 54; i <= 62; i++) {
+       drive->id_drive[i] = 0;
+    }
 
-static 
-void rd_init_send_atapi_command(struct channel_t *channels, Bit8u channel, Bit8u command, int req_length, int alloc_length, bool lazy)
-{
-  // SELECTED_CONTROLLER(channel).byte_count is a union of SELECTED_CONTROLLER(channel).cylinder_no;
-  // lazy is used to force a data read in the buffer at the next read.
-  
-  Ramdisk_Print("[rd_init_send_atapi_cmd]\n");
-  if (SELECTED_CONTROLLER(channel).byte_count == 0xffff)
-    SELECTED_CONTROLLER(channel).byte_count = 0xfffe;
-  
-  if ((SELECTED_CONTROLLER(channel).byte_count & 1)
-      && !(alloc_length <= SELECTED_CONTROLLER(channel).byte_count)) {
-    Ramdisk_Print("\t\tOdd byte count (0x%04x) to ATAPI command 0x%02x, using 0x%x\n", 
-                 SELECTED_CONTROLLER(channel).byte_count, command, SELECTED_CONTROLLER(channel).byte_count - 1);
-    SELECTED_CONTROLLER(channel).byte_count -= 1;
-  }
-  
-  if (SELECTED_CONTROLLER(channel).byte_count == 0)
-    RD_PANIC("\t\tATAPI command with zero byte count\n");
-  
-  if (alloc_length < 0)
-    RD_PANIC("\t\tAllocation length < 0\n");
-  if (alloc_length == 0)
-    alloc_length = SELECTED_CONTROLLER(channel).byte_count;
-  
-  SELECTED_CONTROLLER(channel).interrupt_reason.i_o = 1;
-  SELECTED_CONTROLLER(channel).interrupt_reason.c_d = 0;
-  SELECTED_CONTROLLER(channel).status.busy = 0;
-  SELECTED_CONTROLLER(channel).status.drq = 1;
-  SELECTED_CONTROLLER(channel).status.err = 0;
-  
-  // no bytes transfered yet
-  if (lazy)
-    SELECTED_CONTROLLER(channel).buffer_index = 2048;
-  else
-    SELECTED_CONTROLLER(channel).buffer_index = 0;
-  SELECTED_CONTROLLER(channel).drq_index = 0;
-  
-  if (SELECTED_CONTROLLER(channel).byte_count > req_length)
-    SELECTED_CONTROLLER(channel).byte_count = req_length;
-  
-  if (SELECTED_CONTROLLER(channel).byte_count > alloc_length)
-    SELECTED_CONTROLLER(channel).byte_count = alloc_length;
-  
-  SELECTED_DRIVE(channel).atapi.command = command;
-  SELECTED_DRIVE(channel).atapi.drq_bytes = SELECTED_CONTROLLER(channel).byte_count;
-  SELECTED_DRIVE(channel).atapi.total_bytes_remaining = (req_length < alloc_length) ? req_length : alloc_length;
-  
-  // if (lazy) {
-  // // bias drq_bytes and total_bytes_remaining
-  // SELECTED_DRIVE(channel).atapi.drq_bytes += 2048;
-  // SELECTED_DRIVE(channel).atapi.total_bytes_remaining += 2048;
-  // }
+    // copied from CFA540A
+    drive->id_drive[63] = 0x0103; // variable (DMA stuff)
+    drive->id_drive[64] = 0x0001; // PIO
+    drive->id_drive[65] = 0x00b4;
+    drive->id_drive[66] = 0x00b4;
+    drive->id_drive[67] = 0x012c;
+    drive->id_drive[68] = 0x00b4;
+
+    drive->id_drive[69] = 0;
+    drive->id_drive[70] = 0;
+    drive->id_drive[71] = 30; // faked
+    drive->id_drive[72] = 30; // faked
+    drive->id_drive[73] = 0;
+    drive->id_drive[74] = 0;
+
+    drive->id_drive[75] = 0;
+
+    for (i = 76; i <= 79; i++) {
+       drive->id_drive[i] = 0;
+    }
+
+    drive->id_drive[80] = 0x1e; // supports up to ATA/ATAPI-4
+    drive->id_drive[81] = 0;
+    drive->id_drive[82] = 0;
+    drive->id_drive[83] = 0;
+    drive->id_drive[84] = 0;
+    drive->id_drive[85] = 0;
+    drive->id_drive[86] = 0;
+    drive->id_drive[87] = 0;
+    drive->id_drive[88] = 0;
+
+    for (i = 89; i <= 126; i++) {
+       drive->id_drive[i] = 0;
+    }
+
+    drive->id_drive[127] = 0;
+    drive->id_drive[128] = 0;
+
+    for (i = 129; i <= 159; i++) {
+       drive->id_drive[i] = 0;
+    }
+
+    for (i = 160; i <= 255; i++) {
+       drive->id_drive[i] = 0;
+    }
+
+
+    return;
 }
 
 
+
+
+
+
+
 static 
-void rd_atapi_cmd_error(struct channel_t *channels, Bit8u channel, sense_t sense_key, asc_t asc)
+void rd_init_mode_sense_single(struct vm_device * dev, 
+                              struct channel_t * channel, const void* src, int size)
 {
-  Ramdisk_Print("[rd_atapi_cmd_error]\n");
-  Ramdisk_Print("Error: atapi_cmd_error channel=%02x key=%02x asc=%02x\n", channel, sense_key, asc);
-
-  SELECTED_CONTROLLER(channel).error_register = sense_key << 4;
-  SELECTED_CONTROLLER(channel).interrupt_reason.i_o = 1;
-  SELECTED_CONTROLLER(channel).interrupt_reason.c_d = 1;
-  SELECTED_CONTROLLER(channel).interrupt_reason.rel = 0;
-  SELECTED_CONTROLLER(channel).status.busy = 0;
-  SELECTED_CONTROLLER(channel).status.drive_ready = 1;
-  SELECTED_CONTROLLER(channel).status.write_fault = 0;
-  SELECTED_CONTROLLER(channel).status.drq = 0;
-  SELECTED_CONTROLLER(channel).status.err = 1;
+    struct drive_t * drive = &(channel->drives[channel->drive_select]);
+    struct controller_t * controller = &(drive->controller);
+
+    PrintDebug("[rd_init_mode_sense_single]\n");
+
+    // Header
+    controller->buffer[0] = (size + 6) >> 8;
+    controller->buffer[1] = (size + 6) & 0xff;
+    controller->buffer[2] = 0x70; // no media present
+    controller->buffer[3] = 0; // reserved
+    controller->buffer[4] = 0; // reserved
+    controller->buffer[5] = 0; // reserved
+    controller->buffer[6] = 0; // reserved
+    controller->buffer[7] = 0; // reserved
   
-  SELECTED_DRIVE(channel).sense.sense_key = sense_key;
-  SELECTED_DRIVE(channel).sense.asc = asc;
-  SELECTED_DRIVE(channel).sense.ascq = 0;
+    // Data
+    memcpy(controller->buffer + 8, src, size);
 }
 
 
-static 
-void rd_atapi_cmd_nop(struct channel_t *channels, Bit8u channel)
-{
-  Ramdisk_Print("[rd_atapi_cmd_nop]\n");
-  SELECTED_CONTROLLER(channel).interrupt_reason.i_o = 1;
-  SELECTED_CONTROLLER(channel).interrupt_reason.c_d = 1;
-  SELECTED_CONTROLLER(channel).interrupt_reason.rel = 0;
-  SELECTED_CONTROLLER(channel).status.busy = 0;
-  SELECTED_CONTROLLER(channel).status.drive_ready = 1;
-  SELECTED_CONTROLLER(channel).status.drq = 0;
-  SELECTED_CONTROLLER(channel).status.err = 0;
+
+static void rd_command_aborted(struct vm_device * dev, 
+                              struct channel_t * channel, unsigned value) {
+    struct drive_t * drive = &(channel->drives[channel->drive_select]);
+    struct controller_t * controller = &(drive->controller);
+
+    PrintError("[rd_command_aborted]\n");
+    PrintError("\t\taborting on command 0x%02x {%s}\n", value, device_type_to_str(drive->device_type));
+
+    controller->current_command = 0;
+    controller->status.busy = 0;
+    controller->status.drive_ready = 1;
+    controller->status.err = 1;
+    controller->error_register = 0x04; // command ABORTED
+    controller->status.drq = 0;
+    controller->status.seek_complete = 0;
+    controller->status.corrected_data = 0;
+    controller->buffer_index = 0;
+
+    rd_raise_interrupt(dev, channel);
 }
 
 
-static 
-void rd_init_mode_sense_single(struct channel_t *channels, 
-                              Bit8u channel, const void* src, int size)
-{
-  Ramdisk_Print("[rd_init_mode_sense_single]\n");
-  // Header
-  SELECTED_CONTROLLER(channel).buffer[0] = (size+6) >> 8;
-  SELECTED_CONTROLLER(channel).buffer[1] = (size+6) & 0xff;
-  SELECTED_CONTROLLER(channel).buffer[2] = 0x70; // no media present
-  SELECTED_CONTROLLER(channel).buffer[3] = 0; // reserved
-  SELECTED_CONTROLLER(channel).buffer[4] = 0; // reserved
-  SELECTED_CONTROLLER(channel).buffer[5] = 0; // reserved
-  SELECTED_CONTROLLER(channel).buffer[6] = 0; // reserved
-  SELECTED_CONTROLLER(channel).buffer[7] = 0; // reserved
+/*    
+static void init_pci(struct ramdisk_t * ramdisk) {
+struct v3_pci_bar bars[6];
+    struct pci_device * pci_dev;
+    int i;
+    
+    for (i = 0; i < 6; i++) {
+       bars[i].type = PCI_BAR_NONE;
+       bars[i].mem_hook = 0;
+       bars[i].num_pages = 0;
+       bars[i].bar_update = NULL;
+    }
+
+    bars[4].type = PCI_BAR_MEM32;
+    bars[4].mem_hook = 0;
+    bars[4].num_pages = 1;
+    bars[4].bar_update = NULL;
+
+    pci_dev = v3_pci_register_device(ramdisk->pci, PCI_STD_DEVICE, 0, "IDE", -1, bars, NULL, NULL, NULL, NULL);
+
+
+    pci_dev->config_header.vendor_id = 0x8086;
+    pci_dev->config_header.device_id = 0x2421;
+
+
+}
+    */
+static int ramdisk_init_device(struct vm_device *dev) {
+    struct ramdisk_t *ramdisk= (struct ramdisk_t *)dev->private_data;
+
+    PrintDebug("Initializing Ramdisk\n");
+
+
+    rd_init_hardware(ramdisk);
+
+
+    v3_dev_hook_io(dev, PRI_CTRL_PORT, 
+                  &read_status_port, &write_ctrl_port);
+
+    v3_dev_hook_io(dev, PRI_DATA_PORT, 
+                  &read_data_port, &write_data_port);
+    v3_dev_hook_io(dev, PRI_FEATURES_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, PRI_SECT_CNT_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, PRI_SECT_ADDR1_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, PRI_SECT_ADDR2_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, PRI_SECT_ADDR3_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, PRI_DRV_SEL_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, PRI_CMD_PORT, 
+                  &read_status_port, &write_cmd_port);
+
+
+    v3_dev_hook_io(dev, SEC_CTRL_PORT, 
+                  &read_status_port, &write_ctrl_port);
+
+    v3_dev_hook_io(dev, SEC_DATA_PORT, 
+                  &read_data_port, &write_data_port);
+    v3_dev_hook_io(dev, SEC_FEATURES_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, SEC_SECT_CNT_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, SEC_SECT_ADDR1_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, SEC_SECT_ADDR2_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, SEC_SECT_ADDR3_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, SEC_DRV_SEL_PORT, 
+                  &read_general_port, &write_general_port);
+    v3_dev_hook_io(dev, SEC_CMD_PORT, 
+                  &read_status_port, &write_cmd_port);
+  
   
-  // Data
-  memcpy(SELECTED_CONTROLLER(channel).buffer + 8, src, size);
+
+    v3_dev_hook_io(dev, SEC_ADDR_REG_PORT, 
+                  &read_general_port, &write_general_port);
+
+    v3_dev_hook_io(dev, PRI_ADDR_REG_PORT, 
+                  &read_general_port, &write_general_port);
+
+
+
+
+
+    return 0;
+
 }
 
 
-static 
-void rd_ready_to_send_atapi(struct channel_t *channels, Bit8u channel)
-{
-  Ramdisk_Print("[rd_ready_to_send_atapi]\n");
-  rd_raise_interrupt(ramdisk_state->channels, channel);
+static int ramdisk_deinit_device(struct vm_device *dev) {
+    struct ramdisk_t *ramdisk = (struct ramdisk_t *)(dev->private_data);
+    rd_close_harddrive(ramdisk);
+    return 0;
 }
 
+static struct vm_device_ops dev_ops = {
+    .init = ramdisk_init_device,
+    .deinit = ramdisk_deinit_device,
+    .reset = NULL,
+    .start = NULL,
+    .stop = NULL,
+};
 
-static 
-void rd_command_aborted(struct channel_t *channels, 
-                       Bit8u channel, unsigned value)
+
+
+
+struct vm_device * v3_create_ramdisk(struct vm_device * pci)
 {
-  Ramdisk_Print("[rd_command_aborted]\n");
-  Ramdisk_Print("\t\taborting on command 0x%02x {%s}\n", value, SELECTED_TYPE_STRING(channel));
-  SELECTED_CONTROLLER(channel).current_command = 0;
-  SELECTED_CONTROLLER(channel).status.busy = 0;
-  SELECTED_CONTROLLER(channel).status.drive_ready = 1;
-  SELECTED_CONTROLLER(channel).status.err = 1;
-  SELECTED_CONTROLLER(channel).error_register = 0x04; // command ABORTED
-  SELECTED_CONTROLLER(channel).status.drq = 0;
-  SELECTED_CONTROLLER(channel).status.seek_complete = 0;
-  SELECTED_CONTROLLER(channel).status.corrected_data = 0;
-  SELECTED_CONTROLLER(channel).buffer_index = 0;
-  rd_raise_interrupt(ramdisk_state->channels, channel);
+
+    struct ramdisk_t *ramdisk;
+    ramdisk = (struct ramdisk_t *)V3_Malloc(sizeof(struct ramdisk_t));  
+    V3_ASSERT(ramdisk != NULL);  
+
+    //    ramdisk->pci = pci;
+
+    PrintDebug("[create_ramdisk]\n");
+
+    struct vm_device * device = v3_create_device("RAMDISK", &dev_ops, ramdisk);
+
+    
+
+    return device;
 }
 
 
 
-/*
- * Success: return 0; 
- * Failure: return integer greater than 0
- */
 
-struct ramdisk_t * create_ramdisk()
-{
-  struct ramdisk_t *ramdisk;
-  ramdisk = (struct ramdisk_t *)V3_Malloc(sizeof(struct ramdisk_t));  
-  V3_ASSERT(ramdisk != NULL);
+#ifdef DEBUG_RAMDISK
+
+static void rd_print_state(struct ramdisk_t * ramdisk) {
+    uchar_t channel; 
+    uchar_t device;
+    struct channel_t * channels = (struct channel_t *)(&(ramdisk->channels));
+
+    /*
+      for (channel = 0; channel < MAX_ATA_CHANNEL; channel++) {
+      memset((char *)(channels + channel), 0, sizeof(struct channel_t));
+      }
+    */
+
+
+
+    for (channel = 0; channel < MAX_ATA_CHANNEL; channel++){
   
-  ramdisk->cops.init = &rd_init_harddrive;
-  ramdisk->cops.close = &rd_close_harddrive;
-  ramdisk->cops.reset = &rd_reset_harddrive;
-
-  ramdisk->eops.read_port = &ramdisk_read_port;
-  ramdisk->eops.write_port = &ramdisk_write_port;
-  ramdisk->eops.read_port_ignore = &ramdisk_read_port_ignore;
-  ramdisk->eops.write_port_ignore = &ramdisk_write_port_ignore;
-  return ramdisk;
+       for (device = 0; device < 2; device++){
+                  
+           // Initialize controller state, even if device is not present
+           PrintDebug("channels[%d].drives[%d].controller.status.busy = %d\n",
+                      channel, device, 
+                      channels[channel].drives[device].controller.status.busy);
+           PrintDebug("channels[%d].drives[%d].controller.status.drive_ready = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.status.drive_ready);
+           PrintDebug("channels[%d].drives[%d].controller.status.write_fault = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.status.write_fault);
+           PrintDebug("channels[%d].drives[%d].controller.status.seek_complete = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.status.seek_complete);
+           PrintDebug("channels[%d].drives[%d].controller.status.drq = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.status.drq);
+           PrintDebug("channels[%d].drives[%d].controller.status.corrected_data = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.status.corrected_data);
+           PrintDebug("channels[%d].drives[%d].controller.status.index_pulse = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.status.index_pulse);
+           PrintDebug("channels[%d].drives[%d].controller.status.index_pulse_count = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.status.index_pulse_count);
+           PrintDebug("channels[%d].drives[%d].controller.status.err = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.status.err);
+
+
+           PrintDebug("channels[%d].drives[%d].controller.error_register = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.error_register);
+           PrintDebug("channels[%d].drives[%d].controller.head_no = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.head_no);
+           PrintDebug("channels[%d].drives[%d].controller.sector_count = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.sector_count);
+           PrintDebug("channels[%d].drives[%d].controller.sector_no = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.sector_no);
+           PrintDebug("channels[%d].drives[%d].controller.cylinder_no = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.cylinder_no);
+           PrintDebug("channels[%d].drives[%d].controller.current_command = %02x\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.current_command);
+           PrintDebug("channels[%d].drives[%d].controller.buffer_index = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.buffer_index);
+
+
+           PrintDebug("channels[%d].drives[%d].controller.control.reset = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.control.reset);
+           PrintDebug("channels[%d].drives[%d].controller.control.disable_irq = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.control.disable_irq);
+
+
+           PrintDebug("channels[%d].drives[%d].controller.reset_in_progress = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.reset_in_progress);
+           PrintDebug("channels[%d].drives[%d].controller.sectors_per_block = %02x\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.sectors_per_block); 
+           PrintDebug("channels[%d].drives[%d].controller.lba_mode = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.lba_mode); 
+           PrintDebug("channels[%d].drives[%d].controller.features = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.features); 
+
+
+           PrintDebug("channels[%d].drives[%d].model_no = %s\n", 
+                      channel, device, 
+                      channels[channel].drives[device].model_no); 
+           PrintDebug("channels[%d].drives[%d].device_type = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].device_type); 
+           PrintDebug("channels[%d].drives[%d].cdrom.locked = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].cdrom.locked); 
+           PrintDebug("channels[%d].drives[%d].sense.sense_key = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].sense.sense_key); 
+           PrintDebug("channels[%d].drives[%d].sense.asc = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].sense.asc); 
+           PrintDebug("channels[%d].drives[%d].sense.ascq = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].sense.ascq); 
+
+
+
+           PrintDebug("channels[%d].drives[%d].controller.interrupt_reason.c_d = %02x\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.interrupt_reason.c_d);
+
+           PrintDebug("channels[%d].drives[%d].controller.interrupt_reason.i_o = %02x\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.interrupt_reason.i_o);
+
+           PrintDebug("channels[%d].drives[%d].controller.interrupt_reason.rel = %02x\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.interrupt_reason.rel);
+
+           PrintDebug("channels[%d].drives[%d].controller.interrupt_reason.tag = %02x\n", 
+                      channel, device, 
+                      channels[channel].drives[device].controller.interrupt_reason.tag);
+
+           PrintDebug("channels[%d].drives[%d].cdrom.ready = %d\n", 
+                      channel, device, 
+                      channels[channel].drives[device].cdrom.ready);
+      
+       }  //for device
+    }  //for channel
+  
+    return;
 }
+
+
+#endif