]> cloudbase.mooo.com Git - z180-stamp.git/blobdiff - avr/z180-serv.c
set MAX_DRIVE (number of CP/M disks) from 2 to 4
[z180-stamp.git] / avr / z180-serv.c
index d28cb9839783806274c6bce287fcfdd8cc99ba69..dfdb022d3fff18eafa1844209fbe2ba16d55b3c9 100644 (file)
 /*
+ * (C) Copyright 2014 Leo C. <erbl259-lmu@yahoo.de>
+ *
+ * SPDX-License-Identifier:    GPL-2.0+
  */
 
 #include "common.h"
-//#include <avr/power.h>
-//#include <avr/pgmspace.h>
-//#include <util/atomic.h>
-//#include <avr/sleep.h>
-//#include <string.h>
-
-
-#include "debug.h"
+#include <stdlib.h>
+#include <string.h>
+#include <stdbool.h>
+#include <util/atomic.h>
+
+#include "background.h"
+#include "env.h"
+#include "ff.h"
 #include "serial.h"
 #include "z80-if.h"
-
-
-/* ugly hack to get Z180 loadfile into flash memory */
-#define const const FLASH
-#include "../z180/hdrom.h"
-#undef const
-
+#include "debug.h"
+#include "print-utils.h"
+#include "z180-serv.h"
 
 /*--------------------------------------------------------------------------*/
 
-uint32_t z80_sram_cmp(uint32_t addr, uint32_t length, uint8_t wval, int inc)
-{
-       uint8_t rval;
-       int_fast8_t errors = 0;
-       
-       DBG_P(1, "SRAM: Check 0x%.5lx byte... ", length);
-       while (length--) {
-               if ((rval = z80_read(addr)) != wval) {
-                       if (errors == 0) { 
-                               DBG_P(1, "\nSRAM: Address   W    R\n" \
-                                        "      ------------------\n");
-                       }
-                       errors++;
-                       if (errors > 20) {
-                               DBG_P(1, "      ...\n");
-                               break;
-                       }
-                       DBG_P(1, "      0x%.5lx  0x%.2x 0x%.2x\n", addr, wval, rval);
-               }
-               addr++;
-               wval += inc;
-       }
-       DBG_P(1, "Done.\n");
-
-       return addr;
-}
-
-void z80_sram_fill(uint32_t addr, uint32_t length, uint8_t startval, int inc)
-{
-       printf("SRAM: Write 0x%.5lx byte... ", length);
-       while (length--) {
-               z80_write(addr, startval);
-               ++addr; 
-               startval += inc;
-       }
-       printf("Done.\n");
-}
-
-
-#if 0
-void z80_sram_fill_string(uint32_t addr, int length, const char *text)
-{
-       char c;
-       const char *p = text;
-
-       while (length--) {
-               z80_write(addr++, c = *p++);
-               if (c == 0)
-                       p = text;
-       }
-}
-
-
-uint32_t z80_sram_cmp_string(uint32_t addr, int length, const char *text)
-{
-       char c;
-       const char *p = text;
-
-       while (length--) {
-               c = *p++;
-               if (z80_read(addr) != c)
-                       break;
-               ++addr;
-               if (c == 0)
-                       p = text;
-       }
-       return addr;
-}
-
-const char * const qbfox = "Zhe quick brown fox jumps over the lazy dog!";
-const char * const qbcat = "Zhe quick brown fox jumps over the lazy cat!";
-
-#endif
 
 uint8_t z80_get_byte(uint32_t adr)
 {
        uint8_t data;
-       
-       z80_request_bus();
-       data = z80_read(adr),
-       z80_release_bus();
-       
+
+       z80_bus_cmd(Request);
+       data = z80_read(adr);
+       z80_bus_cmd(Release);
+
        return data;
 }
 
@@ -131,19 +57,31 @@ uint32_t msg_to_addr(uint8_t *msg)
        return addr.as32;
 }
 
-void do_msg_ini_msgfifo(uint8_t subf, int len, uint8_t * msg)
+
+static int msg_xmit_header(uint8_t func, uint8_t subf, int len)
 {
-       (void)subf; (void)len;
+       z80_memfifo_putc(fifo_msgout, 0xAE);
+       z80_memfifo_putc(fifo_msgout, len+2);
+       z80_memfifo_putc(fifo_msgout, func);
+       z80_memfifo_putc(fifo_msgout, subf);
 
-       z80_init_msg_fifo(msg_to_addr(msg));
+       return 0;
 }
 
+int msg_xmit(uint8_t func, uint8_t subf, int len, uint8_t *msg)
+{
+       msg_xmit_header(func, subf, len);
+       while (len--)
+               z80_memfifo_putc(fifo_msgout, *msg++);
+
+       return 0;
+}
 
 void do_msg_ini_memfifo(uint8_t subf, int len, uint8_t * msg)
 {
        (void)len;
 
-       z80_memfifo_init(subf - 1, msg_to_addr(msg));
+       z80_memfifo_init(subf, msg_to_addr(msg));
 }
 
 
@@ -155,18 +93,233 @@ void do_msg_char_out(uint8_t subf, int len, uint8_t * msg)
                putchar(*msg++);
 }
 
+/* echo message */
+void do_msg_echo(uint8_t subf, int len, uint8_t * msg)
+{
+       (void)subf;
+
+       /* send re-echo */
+       msg_xmit(1, 3, len, msg);
+}
+
+/* ---------------------------------------------------------------------------*/
+
+#define MAX_DRIVE      4
+#define BLOCK_SIZE     512
+
+
+struct cpm_drive_s {
+       uint8_t drv;
+       uint8_t device;
+       char *img_name;
+       FIL fd;
+};
+
+static uint8_t disk_buffer[BLOCK_SIZE];
+static struct cpm_drive_s drv_table[MAX_DRIVE];
+
+/*
+       db      2       ; disk command
+       ds      1       ; subcommand (login/read/write)
+       ds      1       ; @adrv (8 bits)        +0
+       ds      1       ; @rdrv (8 bits)        +1
+       ds      3       ; @xdph (24 bits)       +2
+*/
+
+void do_msg_cpm_login(uint8_t subf, int len, uint8_t * msg)
+{
+
+       FRESULT res = 0;
+       uint8_t rc = 0;
+       uint8_t drv;
+       char *np;
+       uint8_t result_msg[3];
+
+       (void)subf;
+
+       if (len != 5) {     /* TODO: check adrv, rdrv */
+               rc = 0x01;
+               goto out;
+       }
+
+       debug("\n##  login: %c:\n", msg[0]+'A');
+
+
+       drv = msg[0];
+       if ( drv>= MAX_DRIVE) {
+               rc = 0x02;
+               goto out;
+       }
+
+/*
+       uint32_t dph = ((uint32_t)msg[4] << 16) + ((uint16_t)msg[3] << 8) + msg[2];
+*/
+
+       if (drv_table[drv].img_name != NULL) {
+               debug("##  close: '%s'\n", drv_table[drv].img_name);
+               f_close(&drv_table[drv].fd);
+               free(drv_table[drv].img_name);
+               drv_table[drv].img_name = NULL;
+       }
+
+       strcpy_P((char *)disk_buffer, PSTR("dsk0"));
+       disk_buffer[3] = msg[0] + '0';
+       if (((np = getenv((char*)disk_buffer)) == NULL) ||
+                       ((drv_table[drv].img_name = strdup(np)) == NULL)) {
+               rc = 0x03;
+               goto out;
+       }
+
+
+       res = f_open(&drv_table[drv].fd, drv_table[drv].img_name,
+                       FA_WRITE | FA_READ);
+
+    debug("##   open: '%s', (env: '%s'), res: %d\n",
+                       drv_table[drv].img_name, disk_buffer, res);
+
+out:
+
+       if (res)
+               rc |= 0x80;
+
+       result_msg[0] = rc;
+       result_msg[1] = res;
+       result_msg[2] = res >> 8;
+
+       if (rc) {
+               debug("##   error    rc: %.02x, res: %d\n", rc, res);
+       };
+
+       /* send  result*/
+       msg_xmit(2, subf, sizeof(result_msg), result_msg);
+}
+
+
+/*
+       db      2       ; disk command
+       ds      1       ; subcommand (login/read/write)
+       ds      1       ; @adrv (8 bits)        +0
+       ds      1       ; @rdrv (8 bits)        +1
+       ds      1       ; @cnt  (8 bits)        +2
+       ds      2       ; @trk (16 bits)        +3
+       ds      2       ; @sect(16 bits)        +5
+       ds      3       ; phys. transfer addr   +7
+*/
+
+void do_msg_cpm_rw(uint8_t subf, int len, uint8_t * msg)
+{
+       uint8_t drv;
+       uint32_t addr;
+       uint32_t pos;
+
+       bool dowrite = (subf == 2);
+       FRESULT res = 0;
+       uint8_t rc = 0;
+       bool buserr = 0;
+       uint8_t result_msg[3];
+
+       if (len != 10) {     /* TODO: check adrv, rdrv */
+               rc = 0x01;
+               goto out;
+       }
+
+       drv = msg[0];
+       if ( drv>= MAX_DRIVE) {
+               rc = 0x02;
+               goto out;
+       }
+
+       addr = ((uint32_t)msg[9] << 16) + ((uint16_t)msg[8] << 8) + msg[7];
+
+       /* bytes = BLOCK_SIZE; */                       /* TODO: multi sector count */
+       pos = (((uint16_t)(msg[4] << 8) + msg[3]) * 8
+                       + ((uint32_t)(msg[6] << 8) + msg[5])) * BLOCK_SIZE;
+
+
+       debug("## cpm_rw: %s %c: trk: %4d, sec: %d, pos: 0x%.5lx, addr: 0x%.5lx\n",
+                       dowrite ? "write" : " read", msg[0]+'A',
+                       ((uint16_t)(msg[4] << 8) + msg[3]), msg[5], pos, addr);
+
+
+
+       /* TODO: check bank boundary crossing */
+       /*
+          if (addr + BLOCK_SIZE > MAX_MEMORY)
+               ... = MAX_MEMORY - addr;
+       */
+
+
+       res = f_lseek(&drv_table[drv].fd, pos);
+       if (!res) {
+               unsigned int br;
+
+               if (dowrite) {
+                       if (!(z80_bus_cmd(Request) & ZST_ACQUIRED)) {
+                               buserr = 1;
+                       } else {
+                               z80_read_block(disk_buffer, addr, BLOCK_SIZE);
+                               z80_bus_cmd(Release);
+                               res = f_write(&drv_table[drv].fd, disk_buffer, BLOCK_SIZE, &br);
+                               if (!res)
+                                       res = f_sync(&drv_table[drv].fd);
+                       }
+               } else {
+                       res = f_read(&drv_table[drv].fd, disk_buffer, BLOCK_SIZE, &br);
+                       if (res == FR_OK) {
+                               if (!(z80_bus_cmd(Request) & ZST_ACQUIRED)) {
+                                       buserr = 1;
+                               } else {
+                                       z80_write_block(disk_buffer, addr, br);
+                                       z80_bus_cmd(Release);
+                               }
+                       }
+               }
+
+               if (br != BLOCK_SIZE) {
+                       debug("##  f_read res: %d, bytes rd/wr: %u\n", res, br);
+                       dump_ram(disk_buffer, 0, 64, "Read Data");
+                       res = -1;
+               }
+       }
+
+out:
+       if (buserr) {
+               debug("Bus timeout\n");
+               rc = 0x03;
+       }
+       if (res)
+               rc |= 0x80;
+
+       result_msg[0] = rc;
+       result_msg[1] = res;
+       result_msg[2] = res >> 8;
+
+       if (rc) {
+               debug("#### error rc: %.02x, res: %d\n", rc, res);
+       }
+
+       /* send  result*/
+       msg_xmit(2, subf, sizeof(result_msg), result_msg);
+}
+
 
 const FLASH struct msg_item z80_messages[] =
 {
        { 0,                    /* fct nr. */
-         0, 0,                 /* sub fct nr. from, to */
-         do_msg_ini_msgfifo},
-       { 0,
-         1, 2,
+         1, 3,                 /* sub fct nr. from, to */
          do_msg_ini_memfifo},
        { 1,
          1, 1,
          do_msg_char_out},
+       { 1,
+         2, 2,
+         do_msg_echo},
+       { 2,
+         0, 0,
+         do_msg_cpm_login},
+       { 2,
+         1, 2,
+         do_msg_cpm_rw},
        { 0xff,                         /* end mark */
          0, 0,
          0},
@@ -186,17 +339,19 @@ void do_message(int len, uint8_t *msg)
                sub_fct = *msg++;
                len -= 2;
 
-               while (fct != z80_messages[i].fct)
-                       ++i;
+               while (fct != z80_messages[i].fct) {
+                       if (z80_messages[i].fct == 0xff) {
+                               DBG_P(1, "do_message: Unknown function: %i, %i\n",
+                                               fct, sub_fct);
+                               return; /* TODO: unknown message # */
+                       }
 
-               if (z80_messages[i].fct == 0xff) {
-                       DBG_P(1, "do_message: Unknown function: %i, %i\n",
-                                       fct, sub_fct);
-                       return; /* TODO: unknown message # */
+                       ++i;
                }
 
                while (fct == z80_messages[i].fct) {
-                       if (sub_fct >= z80_messages[i].sub_min && sub_fct <= z80_messages[i].sub_max )
+                       if (sub_fct >= z80_messages[i].sub_min &&
+                                       sub_fct <= z80_messages[i].sub_max )
                                break;
                        ++i;
                }
@@ -227,10 +382,10 @@ void check_msg_fifo(void)
        static int msglen,idx;
        static uint8_t buffer[CTRBUF_LEN];
 
-       while (state != 3 && (ch = z80_msg_fifo_getc()) >= 0) {
+       while ((ch = z80_memfifo_getc(fifo_msgin)) >= 0) {
                switch (state) {
                case 0:         /* wait for start of message */
-                       if (ch == 0x81) {
+                       if (ch == 0xAE) { /* TODO: magic number */
                                msglen = 0;
                                idx = 0;
                                state = 1;
@@ -245,59 +400,81 @@ void check_msg_fifo(void)
                        break;
                case 2:         /* get message */
                        buffer[idx++] = ch;
-                       if (idx == msglen)
-                               state = 3;
+                       if (idx == msglen) {
+                               do_message(msglen, buffer);
+                               state = 0;
+                       }
                        break;
                }
        }
+}
+
+
+int msg_handling(int state)
+{
+       uint8_t pending;
 
-       if (state == 3) {
-               do_message(msglen, buffer);
-               state = 0;
+       ATOMIC_BLOCK(ATOMIC_FORCEON) {
+               pending = (Stat & S_MSG_PENDING) != 0;
+               Stat &= ~S_MSG_PENDING;
        }
+
+       if (pending) {
+               switch (state) {
+               case 0:                 /* need init */
+                       /* Get address of fifo_list */
+                       z80_bus_cmd(Request);
+                       uint32_t fifo_list = z80_read(0x40) +
+                               ((uint16_t) z80_read(0x41) << 8) +
+                               ((uint32_t) z80_read(0x42) << 16);
+                       z80_bus_cmd(Release);
+                       if (fifo_list != 0) {
+                               /* Get address of fifo 0 */
+                               z80_bus_cmd(Request);
+                               uint32_t fifo_addr = z80_read(fifo_list) +
+                                       ((uint16_t) z80_read(fifo_list+1) << 8) +
+                                       ((uint32_t) z80_read(fifo_list+2) << 16);
+                               z80_bus_cmd(Release);
+                               if (fifo_addr != 0) {
+                                       z80_memfifo_init(fifo_msgin, fifo_addr);
+                                       state = 1;
+                               }
+                       }
+                       break;
+               case 1:                 /* awaiting messages */
+                       check_msg_fifo();
+                       break;
+               }
+       }
+
+       return state;
 }
 
 
-/*--------------------------------------------------------------------------*/
+static int handle_msg_handling;
 
-void dump_mem(const FLASH uint8_t *addr, uint32_t len)
+void setup_z180_serv(void)
 {
-       DBG_P(1, "hdrom dump:");
-       while (len) {
-               DBG_P(1, "\n    %.5x:", addr);
-               for (unsigned i = 0; i<16; i++)
-                       DBG_P(1, " %.2x", *addr++);
-               len -= len > 16 ? 16 : len;
-       }
-       DBG_P(1, "\n");
-}
 
-/*--------------------------------------------------------------------------*/
+       handle_msg_handling = bg_register(msg_handling, 0);
+}
 
-void z80_load_mem(void)
+void restart_z180_serv(void)
 {
-       unsigned sec = 0;
-       uint32_t sec_base = hdrom_start;
-
-       DBG_P(1, "Loading z80 memory... \n");
-
-       while (sec < hdrom_sections) {
-               DBG_P(2, "  From: 0x%.5lX to: 0x%.5lX    (%5li bytes)\n",
-                               hdrom_address[sec],
-                               hdrom_address[sec]+hdrom_length_of_sections[sec] - 1,
-                               hdrom_length_of_sections[sec]);
-
-               z80_write_block((const FLASH unsigned char *) &hdrom[sec_base],  /* src */
-                               hdrom_address[sec],                  /* dest */
-                               hdrom_length_of_sections[sec]);      /* len */
-               sec_base+=hdrom_length_of_sections[sec];
-               sec++;
-       }
+       z80_bus_cmd(Request);
+       z80_write(0x40, 0);
+       z80_write(0x41, 0);
+       z80_write(0x42, 0);
+       z80_bus_cmd(Release);
+
+       for (int i = 0; i < NUM_FIFOS; i++)
+               z80_memfifo_init(i, 0);
+       bg_setstat(handle_msg_handling, 0);
+
 }
 
 /*--------------------------------------------------------------------------*/
 
-
 const FLASH uint8_t iniprog[] = {
        0xAF,                   // xor     a
        0xED, 0x39, 0x36,       // out0    (rcr),a         ;disable  DRAM refresh
@@ -335,20 +512,15 @@ const FLASH uint8_t test1[] = {
        0x21, 0x1E, 0x00,  //   ld      hl,dmclrt       ;load DMA registers
        0x06, 0x08,        //   ld      b,dmct_e-dmclrt
        0x0E, 0x20,        //   ld      c,sar0l
-       0xED, 0x93,        //   otimr   
+       0xED, 0x93,        //   otimr
        0x3E, 0xC3,        //   ld      a,0c3h          ;dst +1, src +1, burst
        0xED, 0x39, 0x31,  //   out0    (dmode),a       ;
-       0x3E, 0x62,        //   ld      a,062h          ;enable dma0, 
+       0x3E, 0x62,        //   ld      a,062h          ;enable dma0,
        0xED, 0x39, 0x30,  //cl_1:      out0    (dstat),a       ;copy 64k
        0x18, 0xFB,        //   jr      cl_1            ;
-       0x00, 0x00,        //dmclrt:    dw      0               ;src (inc) 
+       0x00, 0x00,        //dmclrt:    dw      0               ;src (inc)
        0x00,              //   db      0               ;src
        0x00, 0x00,        //   dw      0               ;dst (inc),
        0x00,              //   db      0               ;dst
        0x00, 0x00,        //   dw      0               ;count (64k)
 };
-
-
-
-//             check_msg_fifo();
-