/*
 * VARCem	Virtual Archaelogical Computer EMulator.
 *		An emulator of (mostly) x86-based PC systems and devices,
 *		using the ISA,EISA,VLB,MCA  and PCI system buses, roughly
 *		spanning the era between 1981 and 1995.
 *
 *		This file is part of the VARCem Project.
 *
 *		Implementation of 8250-style serial port.
 *
 * Version:	@(#)serial.c	1.0.1	2018/02/14
 *
 * Authors:	Fred N. van Kempen, <decwiz@yahoo.com>
 *		Miran Grca, <mgrca8@gmail.com>
 *		Sarah Walker, <tommowalker@tommowalker.co.uk>
 *
 *		Copyright 2017,2018 Fred N. van Kempen.
 *		Copyright 2016-2018 Miran Grca.
 *		Copyright 2008-2018 Sarah Walker.
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free  Software  Foundation; either  version 2 of the License, or
 * (at your option) any later version.
 *
 * This program 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
 * General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the:
 *
 *   Free Software Foundation, Inc.
 *   59 Temple Place - Suite 330
 *   Boston, MA 02111-1307
 *   USA.
 */
#include <stdio.h>
#include <stdint.h>
#include <string.h>
#include <stdlib.h>
#include <wchar.h>
#include "emu.h"
#include "machine/machine.h"
#include "io.h"
#include "pic.h"
#include "mem.h"
#include "rom.h"
#include "serial.h"
#include "timer.h"
#include "mouse.h"


enum {
    SERIAL_INT_LSR = 1,
    SERIAL_INT_RECEIVE = 2,
    SERIAL_INT_TRANSMIT = 4,
    SERIAL_INT_MSR = 8
};


SERIAL serial1, serial2;
int serial_do_log = 0;


void
serial_reset(void)
{
    serial1.iir = serial1.ier = serial1.lcr = 0;
    serial2.iir = serial2.ier = serial2.lcr = 0;
    serial1.fifo_read = serial1.fifo_write = 0;
    serial2.fifo_read = serial2.fifo_write = 0;
}


void
serial_update_ints(SERIAL *serial)
{
    int stat = 0;

    serial->iir = 1;

    if ((serial->ier & 4) && (serial->int_status & SERIAL_INT_LSR)) /*Line status interrupt*/ {
	stat = 1;
	serial->iir = 6;
    } else if ((serial->ier & 1) && (serial->int_status & SERIAL_INT_RECEIVE)) /*Recieved data available*/ {
	stat = 1;
	serial->iir = 4;
    } else if ((serial->ier & 2) && (serial->int_status & SERIAL_INT_TRANSMIT)) /*Transmit data empty*/ {
	stat = 1;
	serial->iir = 2;
    } else if ((serial->ier & 8) && (serial->int_status & SERIAL_INT_MSR)) /*Modem status interrupt*/ {
	stat = 1;
	serial->iir = 0;
    }

    if (stat && ((serial->mctrl & 8) || PCJR))
	picintlevel(1 << serial->irq);
      else
	picintc(1 << serial->irq);
}


void
serial_clear_fifo(SERIAL *serial)
{
    memset(serial->fifo, 0, 256);
    serial->fifo_read = serial->fifo_write = 0;
}


void
serial_write_fifo(SERIAL *serial, uint8_t dat)
{
    serial->fifo[serial->fifo_write] = dat;
    serial->fifo_write = (serial->fifo_write + 1) & 0xFF;
    if (!(serial->lsr & 1)) {
	serial->lsr |= 1;
	serial->int_status |= SERIAL_INT_RECEIVE;
	serial_update_ints(serial);
    }
}


uint8_t
serial_read_fifo(SERIAL *serial)
{
    if (serial->fifo_read != serial->fifo_write) {
	serial->dat = serial->fifo[serial->fifo_read];
	serial->fifo_read = (serial->fifo_read + 1) & 0xFF;
    }

    return serial->dat;
}


void
serial_write(uint16_t addr, uint8_t val, void *p)
{
    SERIAL *serial = (SERIAL *)p;

    switch (addr&7) {
	case 0:
                if (serial->lcr & 0x80) {
                        serial->dlab1 = val;
                        return;
                }
                serial->thr = val;
                serial->lsr |= 0x20;
                serial->int_status |= SERIAL_INT_TRANSMIT;
                serial_update_ints(serial);
                if (serial->mctrl & 0x10) {
                        serial_write_fifo(serial, val);
                }
                break;
	case 1:
                if (serial->lcr & 0x80) {
                        serial->dlab2 = val;
                        return;
                }
                serial->ier = val & 0xf;
                serial_update_ints(serial);
                break;
	case 2:
                serial->fcr = val;
                break;
	case 3:
                serial->lcr = val;
                break;
	case 4:
                if ((val & 2) && !(serial->mctrl & 2)) {
                        if (serial->rcr_callback)
                                serial->rcr_callback((struct SERIAL *)serial, serial->rcr_callback_p);
                }
                serial->mctrl = val;
                if (val & 0x10) {
                        uint8_t new_msr;
                        
                        new_msr = (val & 0x0c) << 4;
                        new_msr |= (val & 0x02) ? 0x10: 0;
                        new_msr |= (val & 0x01) ? 0x20: 0;
                        
                        if ((serial->msr ^ new_msr) & 0x10)
                                new_msr |= 0x01;
                        if ((serial->msr ^ new_msr) & 0x20)
                                new_msr |= 0x02;
                        if ((serial->msr ^ new_msr) & 0x80)
                                new_msr |= 0x08;
                        if ((serial->msr & 0x40) && !(new_msr & 0x40))
                                new_msr |= 0x04;
                        
                        serial->msr = new_msr;
                }
                break;
	case 5:
                serial->lsr = val;
                if (serial->lsr & 0x01)
                        serial->int_status |= SERIAL_INT_RECEIVE;
                if (serial->lsr & 0x1e)
                        serial->int_status |= SERIAL_INT_LSR;
                if (serial->lsr & 0x20)
                        serial->int_status |= SERIAL_INT_TRANSMIT;
                serial_update_ints(serial);
                break;
	case 6:
                serial->msr = val;
                if (serial->msr & 0x0f)
                        serial->int_status |= SERIAL_INT_MSR;
                serial_update_ints(serial);
                break;
	case 7:
                serial->scratch = val;
                break;
    }
}


uint8_t
serial_read(uint16_t addr, void *p)
{
    SERIAL *serial = (SERIAL *)p;
    uint8_t temp = 0;

    switch (addr&7) {
	case 0:
                if (serial->lcr & 0x80) {
                        temp = serial->dlab1;
                        break;
                }

                serial->lsr &= ~1;
                serial->int_status &= ~SERIAL_INT_RECEIVE;
                serial_update_ints(serial);
                temp = serial_read_fifo(serial);
                if (serial->fifo_read != serial->fifo_write) {
                        serial->recieve_delay = 1000LL * TIMER_USEC;
		}
                break;
	case 1:
                if (serial->lcr & 0x80)
                        temp = serial->dlab2;
                  else
                        temp = serial->ier;
                break;
	case 2: 
                temp = serial->iir;
                if ((temp & 0xe) == 2) {
                        serial->int_status &= ~SERIAL_INT_TRANSMIT;
                        serial_update_ints(serial);
                }
                if (serial->fcr & 1)
                        temp |= 0xc0;
                break;
	case 3:
                temp = serial->lcr;
                break;
	case 4:
                temp = serial->mctrl;
                break;
	case 5:
                if (serial->lsr & 0x20)
                        serial->lsr |= 0x40;
                serial->lsr |= 0x20;
                temp = serial->lsr;
                if (serial->lsr & 0x1f)
                        serial->lsr &= ~0x1e;
                serial->int_status &= ~SERIAL_INT_LSR;
                serial_update_ints(serial);
                break;
	case 6:
                temp = serial->msr;
                serial->msr &= ~0x0f;
                serial->int_status &= ~SERIAL_INT_MSR;
                serial_update_ints(serial);
                break;
	case 7:
                temp = serial->scratch;
                break;
    }

    return temp;
}


void
serial_recieve_callback(void *p)
{
    SERIAL *serial = (SERIAL *)p;
        
    serial->recieve_delay = 0;
        
    if (serial->fifo_read != serial->fifo_write) {
                serial->lsr |= 1;
                serial->int_status |= SERIAL_INT_RECEIVE;
                serial_update_ints(serial);
    }
}


uint16_t base_address[2] = { 0x0000, 0x0000 };


void
serial_remove(int port)
{
    if ((port < 1) || (port > 2)) {
		fatal("serial_remove(): Invalid serial port: %i\n", port);
		exit(-1);
    }

    if (! serial_enabled[port - 1]) return;

    if (! base_address[port - 1]) return;

/* pclog("Removing serial port %i at %04X...\n", port, base_address[port - 1]); */

    switch(port) {
	case 1:
		io_removehandler(base_address[0], 0x0008, serial_read, NULL, NULL, serial_write, NULL, NULL, &serial1);
		base_address[0] = 0x0000;
		break;
	case 2:
		io_removehandler(base_address[1], 0x0008, serial_read, NULL, NULL, serial_write, NULL, NULL, &serial2);
		base_address[1] = 0x0000;
		break;
    }
}


void
serial_setup(int port, uint16_t addr, int irq)
{
    /* pclog("Adding serial port %i at %04X...\n", port, addr); */

    switch(port) {
	case 1:
		if (!serial_enabled[0]) return;

		if (base_address[0] != 0x0000)
			serial_remove(port);
		if (addr != 0x0000) {
			base_address[0] = addr;
			io_sethandler(addr, 0x0008, serial_read, NULL, NULL, serial_write, NULL, NULL, &serial1);
		}
		serial1.irq = irq;
		break;

	case 2:
		if (! serial_enabled[1]) return;

		if (base_address[1] != 0x0000)
				serial_remove(port);
		if (addr != 0x0000) {
			base_address[1] = addr;
			io_sethandler(addr, 0x0008, serial_read, NULL, NULL, serial_write, NULL, NULL, &serial2);
		}
		serial2.irq = irq;
		break;

	default:
		fatal("serial_setup(): Invalid serial port: %i\n", port);
		break;
    }
}


void
serial_init(void)
{
    base_address[0] = 0x03f8;
    base_address[1] = 0x02f8;

    if (serial_enabled[0]) {
	/* pclog("Adding serial port 1...\n"); */
	memset(&serial1, 0, sizeof(serial1));
	io_sethandler(0x3f8, 0x0008, serial_read,  NULL, NULL, serial_write,  NULL, NULL, &serial1);
	serial1.irq = 4;
	serial1.rcr_callback = NULL;
	timer_add(serial_recieve_callback, &serial1.recieve_delay, &serial1.recieve_delay, &serial1);
    }

    if (serial_enabled[1]) {
	/* pclog("Adding serial port 2...\n"); */
	memset(&serial2, 0, sizeof(serial2));
	io_sethandler(0x2f8, 0x0008, serial_read, NULL, NULL, serial_write, NULL, NULL, &serial2);
	serial2.irq = 3;
	serial2.rcr_callback = NULL;
	timer_add(serial_recieve_callback, &serial2.recieve_delay, &serial2.recieve_delay, &serial2);
    }
}