/** \file   event.c
 * \brief   Event handling
 *
 * \author  Andreas Boose <viceteam@t-online.de>
 * \author  Andreas Matthies <aDOTmatthiesATgmxDOTnet>
 */

/*
 * This file is part of VICE, the Versatile Commodore Emulator.
 * See README for copyright notice.
 *
 *  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.
 *
 */

/* #define EVENT_DEBUG */

#include "vice.h"

#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include "alarm.h"
#include "archdep.h"
#include "attach.h"
#include "autostart.h"
#include "cmdline.h"
#include "crc32.h"
#include "datasette.h"
#include "debug.h"
#include "interrupt.h"
#include "joystick.h"
#include "keyboard.h"
#include "lib.h"
#include "log.h"
#include "machine.h"
#include "maincpu.h"
#include "network.h"
#include "resources.h"
#include "snapshot.h"
#include "tape.h"
#include "tapeport.h"
#include "types.h"
#include "uiapi.h"
#include "util.h"
#include "version.h"
#include "vice-event.h"

#ifdef EVENT_DEBUG
#define DBG(x) log_printf  x
#else
#define DBG(x)
#endif

#define EVENT_START_SNAPSHOT "start.vsf"
#define EVENT_END_SNAPSHOT "end.vsf"
#define EVENT_MILESTONE_SNAPSHOT "milestone.vsf"


/** \brief  Size of the CRC32 entries
 *
 * CRC32 entries are stored as little endian values
 */
#define CRC32_SIZE  (sizeof(uint32_t))


struct event_image_list_s {
    char *orig_filename;
    char *mapped_filename;
    struct event_image_list_s *next;
};
typedef struct event_image_list_s event_image_list_t;

static event_list_state_t *event_list = NULL;
static event_image_list_t *event_image_list_base = NULL;
static int image_number;

static alarm_t *event_alarm = NULL;

static log_t event_log = LOG_DEFAULT;

static unsigned int playback_active = 0, record_active = 0;

static unsigned int current_timestamp, milestone_timestamp, playback_time;
static CLOCK next_timestamp_clk;
static CLOCK milestone_timestamp_alarm;

/* the VICE version an event history was made with */
static char event_version[16];

static char *event_snapshot_dir = NULL;
static char *event_start_snapshot = NULL;
static char *event_end_snapshot = NULL;
static char *event_snapshot_path_str = NULL;
static int event_start_mode;
static int event_image_include;

static char *event_snapshot_path(const char *snapshot_file)
{
    lib_free(event_snapshot_path_str);
    event_snapshot_path_str = util_concat(event_snapshot_dir, snapshot_file, NULL);

    return event_snapshot_path_str;
}


/* searches for a filename in the image list    */
/* returns 0 if found                           */
/* returns 1 and appends it if not found        */
static int event_image_append(const char *filename, char **mapped_name, int append)
{
    event_image_list_t *event_image_list_ptr = event_image_list_base;

    while (event_image_list_ptr->next != NULL) {
        if (strcmp(filename, event_image_list_ptr->next->orig_filename) == 0) {
            if (mapped_name != NULL) {
                if (append == 0) {
                    if (event_image_list_ptr->next->mapped_filename != NULL) {
                        *mapped_name = lib_strdup(event_image_list_ptr->next->mapped_filename);
                    } else {
                        return 1;
                    }
                } else {
                    event_image_list_ptr->next->mapped_filename = lib_strdup(*mapped_name);
                }
            }
            return 0;
        }
        event_image_list_ptr = event_image_list_ptr->next;
    }

    event_image_list_ptr->next = lib_calloc(1, sizeof(event_image_list_t));

    event_image_list_ptr = event_image_list_ptr->next;
    event_image_list_ptr->next = NULL;
    event_image_list_ptr->orig_filename = lib_strdup(filename);
    event_image_list_ptr->mapped_filename = NULL;
    if (mapped_name != NULL && append) {
        event_image_list_ptr->mapped_filename = lib_strdup(*mapped_name);
    }

    return 1;
}


void event_record_attach_in_list(event_list_state_t *list, unsigned int unit,
                                 unsigned int drive,
                                 const char *filename, unsigned int read_only)
{
    char *event_data;
    unsigned int size;
    char *strdir, *strfile;

    list->current->type = EVENT_ATTACHIMAGE;
    list->current->clk = maincpu_clk;
    list->current->next = lib_calloc(1, sizeof(event_list_t));

    util_fname_split(filename, &strdir, &strfile);

    if (event_image_include) {
        size = (unsigned int)strlen(filename) + 3;
    } else {
        size = (unsigned int)strlen(strfile) + CRC32_SIZE + 4;
    }

    event_data = lib_malloc(size);
    event_data[0] = unit;
    event_data[1] = drive;
    event_data[2] = read_only;

    if (event_image_include) {
        strcpy(&event_data[3], filename);
        if (event_image_append(filename, NULL, 0) == 1) {
            FILE *fd;
            off_t file_len = 0;

            fd = fopen(filename, MODE_READ);

            if (fd != NULL) {
                file_len = archdep_file_size(fd);
                if (file_len >= 0) {
                    event_data = lib_realloc(event_data, size + (unsigned int)file_len);
                    if (fread(&event_data[size], (size_t)file_len, 1, fd) != 1) {
                        log_error(event_log, "Cannot load image file %s", filename);
                    }
                    fclose(fd);
                }
            } else {
                log_error(event_log, "Cannot open image file %s", filename);
            }
            size += (unsigned int)file_len;
        }
    } else {
        uint32_t crc = crc32_file(filename);

        strcpy(&event_data[3], "");

        /* store crc32 in little-endian format */
        crc32_to_le(((uint8_t *)event_data + 3), crc);

        strcpy(&event_data[4 + CRC32_SIZE], strfile);
    }

    lib_free(strdir);
    lib_free(strfile);

    list->current->size = size;
    list->current->data = event_data;
    list->current = list->current->next;
}

void event_record_attach_image(unsigned int unit, unsigned int drive, const char *filename,
                               unsigned int read_only)
{
    if (record_active == 0) {
        return;
    }

    event_record_attach_in_list(event_list, unit, drive, filename, read_only);
}


static void event_playback_attach_image(void *data, unsigned int size)
{
    unsigned int unit, drive, read_only;
    char *orig_filename, *filename = NULL;
    size_t file_len;
    uint32_t crc_to_attach;

    uint8_t crc_file[CRC32_SIZE];   /* CRC32 little endian value of file */
    uint8_t crc_snap[CRC32_SIZE];   /* CRC32 of file in the snapshot */

    unit = (unsigned int)((char*)data)[0];
    drive = (unsigned int)((char*)data)[1];
    read_only = (unsigned int)((char*)data)[2];
    orig_filename = &((char*)data)[3];

    if (*orig_filename == 0) {
        /* no image attached */
        orig_filename = (char *) data + 4 + CRC32_SIZE;

        if (event_image_append(orig_filename, &filename, 0) != 0) {
#if 0
            crc_to_attach = *(uint32_t *)(((char *)data) + 4);
#endif
            /* looks weird, but crc_to_attach is used in messages */
            crc_to_attach = crc32_from_le((const uint8_t *)data + 3);
            crc32_to_le(crc_file, crc_to_attach);

            while (1) {
                uint32_t file_crc;

                filename = ui_get_file(
                        "Please attach image %s (CRC32 checksum 0x%" PRIu32 ")",
                        (char *) data + 4 + sizeof(uint32_t), crc_to_attach);
                if (filename == NULL) {
                    break;
                }

                /* get CRC32 of current file */
                file_crc = crc32_file(filename);
                /* convert crc32 to little endian */
                crc32_to_le(crc_snap, file_crc);
                /* check CRC32 */
                if (memcmp(crc_snap, crc_file, CRC32_SIZE) != 0) {
                    break;
                }
            }
            if (filename == NULL) {
                ui_error("Image wasn't attached. Playback will probably get out of sync.");
                return;
            }
            event_image_append(orig_filename, &filename, 1);
        }
    } else {
        file_len = size - strlen(orig_filename) - 4;

        if (file_len > 0) {
            FILE *fd;

            fd = archdep_mkstemp_fd(&filename, MODE_WRITE);

            if (fd == NULL) {
                ui_error("Cannot create image file '%s'!", filename);
                goto error;
            }

            if (fwrite((char*)data + strlen(orig_filename) + 4, file_len, 1, fd) != 1) {
                ui_error("Cannot write image file %s", filename);
                goto error;
            }

            fclose(fd);
            event_image_append(orig_filename, &filename, 1);
        } else {
            if (event_image_append(orig_filename, &filename, 0) != 0) {
                ui_error("Cannot find mapped name for %s", orig_filename);
                return;
            }
        }
    }
    /* now filename holds the name to attach    */
    /* FIXME: read_only isn't handled for tape  */
    if (unit == 1 || unit == 2) {
        tape_image_event_playback(unit, filename);
    } else {
        resources_set_int_sprintf("AttachDevice%ud%uReadonly", read_only, unit, drive);
        file_system_event_playback(unit, drive, filename);
    }

error:
    lib_free(filename);
}


void event_record_in_list(event_list_state_t *list, unsigned int type,
                          void *data, unsigned int size)
{
    void *event_data = NULL;

    DBG(("event_record_in_list type:%u size:%u clock:%lu", type, size, maincpu_clk));

    if (type == EVENT_RESETCPU) {
        next_timestamp_clk -= maincpu_clk;
    }

    switch (type) {
        case EVENT_RESETCPU:            /* fall through */
        case EVENT_KEYBOARD_MATRIX:     /* fall through */
        case EVENT_KEYBOARD_RESTORE:    /* fall through */
        case EVENT_KEYBOARD_DELAY:      /* fall through */
        case EVENT_JOYSTICK_VALUE:      /* fall through */
        case EVENT_DATASETTE:           /* fall through */
        case EVENT_ATTACHDISK:          /* fall through */
        case EVENT_ATTACHTAPE:          /* fall through */
        case EVENT_ATTACHIMAGE:         /* fall through */
        case EVENT_INITIAL:             /* fall through */
        case EVENT_SYNC_TEST:           /* fall through */
        case EVENT_RESOURCE:
            event_data = lib_malloc(size);
            memcpy(event_data, data, size);
            break;
        case EVENT_LIST_END:            /* fall through */
        case EVENT_KEYBOARD_CLEAR:
            break;
        default:
            log_error(event_log, "Unknown event type %u.", type);
            return;
    }

    if (list && list->current) {
        list->current->type = type;
        list->current->clk = maincpu_clk;
        list->current->size = size;
        list->current->data = event_data;
        list->current->next = lib_calloc(1, sizeof(event_list_t));
        list->current = list->current->next;
        list->current->type = EVENT_LIST_END;
    } else {
        log_error(event_log, "event_record_in_list: Could not append to event list (type:%u size:%u clock:%"PRIX64")",
                  type, size, maincpu_clk);
    }
}

void event_record(unsigned int type, void *data, unsigned int size)
{
    if (record_active == 1) {
        event_record_in_list(event_list, type, data, size);
    }
}


static void next_alarm_set(void)
{
    CLOCK new_value;

    new_value = event_list->current->clk;

    alarm_set(event_alarm, new_value);
}
static void next_current_list(void)
{
    event_list->current = event_list->current->next;
}

static void event_alarm_handler(CLOCK offset, void *data)
{
    alarm_unset(event_alarm);

    /* when recording set a timestamp */
    if (record_active) {
        ui_display_event_time(current_timestamp++, 0);
        next_timestamp_clk = next_timestamp_clk + (CLOCK)machine_get_cycles_per_second();
        alarm_set(event_alarm, next_timestamp_clk);
        return;
    }

    /*log_debug(LOG_DEFAULT, "EVENT PLAYBACK %i CLK %i", event_list_current->type,
              event_list_current->clk);*/

    switch (event_list->current->type) {
        case EVENT_KEYBOARD_MATRIX:
            keyboard_event_playback(offset, event_list->current->data);
            break;
        case EVENT_KEYBOARD_RESTORE:
            keyboard_restore_event_playback(offset, event_list->current->data);
            break;
        case EVENT_JOYSTICK_VALUE:
            joystick_event_playback(offset, event_list->current->data);
            break;
        case EVENT_DATASETTE:
            datasette_event_playback_port1(offset, event_list->current->data);
            break;
        case EVENT_ATTACHIMAGE:
            event_playback_attach_image(event_list->current->data,
                                        event_list->current->size);
            break;
        case EVENT_ATTACHDISK:
        case EVENT_ATTACHTAPE:
            {
                /* old style attach via absolute filename and detach*/
                unsigned int unit;
                const char *filename;

                unit = (unsigned int)((char*)event_list->current->data)[0];
                filename = &((char*)event_list->current->data)[1];

                if (unit == 1 || unit == 2) {
                    tape_image_event_playback(unit, filename);
                } else {
                    /* TODO: drive 1? */
                    file_system_event_playback(unit, 0, filename);
                }
            }
            break;
        case EVENT_RESETCPU:
            machine_reset_event_playback(offset, event_list->current->data);
            break;
        case EVENT_TIMESTAMP:
            ui_display_event_time(current_timestamp++, playback_time);
            break;
        case EVENT_LIST_END:
            event_playback_stop();
            break;
        default:
            log_error(event_log, "Unknow event type %u.",
                    event_list->current->type);
    }

    if (event_list->current->type != EVENT_LIST_END
        && event_list->current->type != EVENT_RESETCPU) {
        next_current_list();
        next_alarm_set();
    }
}

/*-----------------------------------------------------------------------*/
void event_playback_event_list(event_list_state_t *list)
{
    event_list_t *current = list->base;

    DBG(("event_playback_event_list entry %p current: %p", list, current));

    while (current->type != EVENT_LIST_END) {
        DBG(("event_playback_event_list current: %p type: %d size: %d data: %p",
            current, current->type, current->size, current->data));
        switch (current->type) {
            case EVENT_SYNC_TEST:
                break;
            case EVENT_KEYBOARD_DELAY:
                keyboard_register_delay(*(unsigned int*)current->data);
                break;
            case EVENT_KEYBOARD_MATRIX:
                keyboard_event_delayed_playback(current->data);
                break;
            case EVENT_KEYBOARD_RESTORE:
                keyboard_restore_event_playback(0, current->data);
                break;
            case EVENT_KEYBOARD_CLEAR:
                keyboard_register_clear();
                break;
            case EVENT_JOYSTICK_DELAY:
                joystick_register_delay(*(unsigned int*)current->data);
                break;
            case EVENT_JOYSTICK_VALUE:
                joystick_event_delayed_playback(current->data);
                break;
            case EVENT_DATASETTE:
                datasette_event_playback_port1(0, current->data);
                break;
            case EVENT_RESETCPU:
                machine_reset_event_playback(0, current->data);
                break;
            case EVENT_ATTACHDISK:
            case EVENT_ATTACHTAPE:
                {
                    /* in fact this is only for detaching */
                    unsigned int unit;

                    unit = (unsigned int)((char*)current->data)[0];

                    if (unit == 1) {
                        tape_image_event_playback(unit, NULL);
                    } else {
                        /* TODO: drive 1? */
                        file_system_event_playback(unit, 0, NULL);
                    }
                    break;
                }
            case EVENT_ATTACHIMAGE:
                event_playback_attach_image(current->data, current->size);
                break;
            case EVENT_RESOURCE:
                resources_set_value_event(current->data, current->size);
                break;
            default:
                log_error(event_log, "Unknow event type %u.", current->type);
        }
        current = current->next;
    }
    DBG(("event_playback_event_list exit"));
}

void event_register_event_list(event_list_state_t *list)
{
    DBG(("event_register_event_list %p", list));
    list->base = lib_calloc(1, sizeof(event_list_t));
    list->current = list->base;
}

void event_init_image_list(void)
{
    event_image_list_base = lib_calloc(1, sizeof(event_image_list_t));
    image_number = 0;
}

static void create_list(void)
{
    event_list = lib_malloc(sizeof(event_list_state_t));
    event_register_event_list(event_list);
    event_init_image_list();
}


static void cut_list(event_list_t *cut_base)
{
    event_list_t *c1, *c2;

    c1 = cut_base;

    while (c1 != NULL) {
        c2 = c1->next;
        lib_free(c1->data);
        lib_free(c1);
        c1 = c2;
    }
}

void event_destroy_image_list(void)
{
    event_image_list_t *d1, *d2;

    d1 = event_image_list_base;

    while (d1 != NULL) {
        d2 = d1->next;
        lib_free(d1->orig_filename);
        lib_free(d1->mapped_filename);
        lib_free(d1);
        d1 = d2;
    }

    event_image_list_base = NULL;
}

void event_clear_list(event_list_state_t *list)
{
    DBG(("event_clear_list %p", list));
    if (list != NULL && list->base != NULL) {
        cut_list(list->base);
    }
}

static void destroy_list(void)
{
    event_clear_list(event_list);
    lib_free(event_list);
    event_destroy_image_list();
}

static void warp_end_list(void)
{
    event_list_t *curr;

    curr = event_list->base;

    while (curr->type != EVENT_LIST_END) {
        if (curr->type == EVENT_ATTACHIMAGE) {
            event_image_append(&((char*)curr->data)[3], NULL, 0);
        }

        curr = curr->next;
    }

    memset(curr, 0, sizeof(event_list_t));
    event_list->current = curr;
}
/*-----------------------------------------------------------------------*/
/* writes or replaces version string in the initial event                */
static void event_write_version(void)
{
    uint8_t *new_data;
    uint8_t *data;
    unsigned int ver_idx;

    if (event_list->base->type != EVENT_INITIAL) {
        /* EVENT_INITIAL is missing (bug in 1.14.xx); fix it */
        event_list_t *new_event;

        new_event = lib_calloc(1, sizeof(event_list_t));
        new_event->clk = event_list->base->clk;
        new_event->size = (unsigned int)strlen(event_start_snapshot) + 2;
        new_event->type = EVENT_INITIAL;
        data = lib_malloc(new_event->size);
        data[0] = EVENT_START_MODE_FILE_SAVE;
        strcpy((char *)&data[1], event_start_snapshot);
        new_event->data = data;
        new_event->next = event_list->base;
        event_list->base = new_event;
    }

    data = event_list->base->data;

    ver_idx = 1;
    if (data[0] == EVENT_START_MODE_FILE_SAVE) {
        ver_idx += (unsigned int)strlen((char *)&data[1]) + 1;
    }

    event_list->base->size = ver_idx + (unsigned int)strlen(VERSION) + 1;
    new_data = lib_malloc(event_list->base->size);

    memcpy(new_data, data, ver_idx);

    strcpy((char *)&new_data[ver_idx], VERSION);

    event_list->base->data = new_data;
    lib_free(data);
}

static void event_initial_write(void)
{
    uint8_t *data = NULL;
    size_t len = 0;

    switch (event_start_mode) {
        case EVENT_START_MODE_FILE_SAVE:
            len = 1 + strlen(event_start_snapshot) + 1;
            data = lib_malloc(len);
            data[0] = EVENT_START_MODE_FILE_SAVE;
            strcpy((char *)&data[1], event_start_snapshot);
            break;
        case EVENT_START_MODE_RESET:
            len = 1;
            data = lib_malloc(len);
            data[0] = EVENT_START_MODE_RESET;
            break;
    }

    event_record(EVENT_INITIAL, (void *)data, (unsigned int)len);

    event_write_version();

    lib_free(data);
}

/*-----------------------------------------------------------------------*/

static void event_record_start_trap(uint16_t addr, void *data)
{
    switch (event_start_mode) {
        case EVENT_START_MODE_FILE_SAVE:
            if (machine_write_snapshot(
                        event_snapshot_path(event_start_snapshot),
                        1, 1, 0) < 0) {
                ui_error("Could not create start snapshot file %s.",
                        event_snapshot_path(event_start_snapshot));
                ui_display_recording(UI_RECORDING_STATUS_NONE);
                return;
            }
            destroy_list();
            create_list();
            record_active = 1;
            event_initial_write();
            next_timestamp_clk = maincpu_clk;
            current_timestamp = 0;
            break;
        case EVENT_START_MODE_FILE_LOAD:
            if (machine_read_snapshot(event_snapshot_path(event_end_snapshot),
                        1) < 0) {
                ui_error("Error reading end snapshot file %s.",
                        event_snapshot_path(event_end_snapshot));
                return;
            }
            warp_end_list();
            record_active = 1;
            next_timestamp_clk = maincpu_clk;
            current_timestamp = playback_time;
            break;
        case EVENT_START_MODE_RESET:
            machine_trigger_reset(MACHINE_RESET_MODE_POWER_CYCLE);
            destroy_list();
            create_list();
            record_active = 1;
            event_initial_write();
            next_timestamp_clk = 0;
            current_timestamp = 0;
            break;
        case EVENT_START_MODE_PLAYBACK:
            cut_list(event_list->current->next);
            event_list->current->next = NULL;
            event_list->current->type = EVENT_LIST_END;
            event_destroy_image_list();
            event_write_version();
            record_active = 1;
            next_timestamp_clk = maincpu_clk;
            break;
        default:
            log_error(event_log, "Unknown event start mode %i", event_start_mode);
            return;
    }

#ifdef  DEBUG
    debug_start_recording();
#endif

    /* use alarm for timestamps */
    milestone_timestamp_alarm = 0;
    alarm_set(event_alarm, next_timestamp_clk);

    record_active = 1;
    ui_display_recording(UI_RECORDING_STATUS_EVENTS);
}

int event_record_start(void)
{
    if (event_start_mode == EVENT_START_MODE_PLAYBACK) {
        if (playback_active != 0) {
            event_playback_stop();
        } else {
            return -1;
        }
    }

    if (record_active != 0 || autostart_in_progress()) {
        return -1;
    }

    interrupt_maincpu_trigger_trap(event_record_start_trap, (void *)0);

    return 0;
}

static void event_record_stop_trap(uint16_t addr, void *data)
{
    if (machine_write_snapshot(event_snapshot_path(event_end_snapshot), 1, 1, 1) < 0) {
        ui_error("Could not create end snapshot file %s.", event_snapshot_path(event_end_snapshot));
        return;
    }
    record_active = 0;

#ifdef  DEBUG
    debug_stop_recording();
#endif
}

int event_record_stop(void)
{
    if (record_active == 0) {
        return -1;
    }

    event_record(EVENT_LIST_END, NULL, 0);

    interrupt_maincpu_trigger_trap(event_record_stop_trap, (void *)0);

    ui_display_recording(UI_RECORDING_STATUS_NONE);

    alarm_unset(event_alarm);

    return 0;
}

/*-----------------------------------------------------------------------*/

static unsigned int playback_reset_ack = 0;

void event_reset_ack(void)
{
    if (event_list == NULL) {
        return;
    }

    if (playback_reset_ack) {
        playback_reset_ack = 0;
        next_alarm_set();
    }

    if (event_list->current && event_list->current->type == EVENT_RESETCPU) {
        next_current_list();
        next_alarm_set();
    }

    /* timestamp alarm needs to be set */
    if (record_active) {
        alarm_set(event_alarm, next_timestamp_clk);
    }
}

/* XXX: the 'unused' (prev. 'data') param is only passed from one function:
 *      interrupt_maincpu_trigger_trap(), and that one passes (void*)0, ie NULL.
 *      So fixing the shadowing of 'data' should be fine.
 */
static void event_playback_start_trap(uint16_t addr, void *unused)
{
    snapshot_t *s;
    uint8_t minor, major;

    event_version[0] = 0;

    s = snapshot_open(
        event_snapshot_path(event_end_snapshot), &major, &minor, machine_get_name());

    if (s == NULL) {
        ui_error("Could not open end snapshot file %s.", event_snapshot_path(event_end_snapshot));
        ui_display_playback(0, NULL);
        return;
    }

    destroy_list();
    create_list();

    if (event_snapshot_read_module(s, 1) < 0) {
        snapshot_close(s);
        ui_error("Could not find event section in end snapshot file.");
        ui_display_playback(0, NULL);
        return;
    }

    snapshot_close(s);

    event_list->current = event_list->base;

    if (event_list->current->type == EVENT_INITIAL) {
        uint8_t *data = (uint8_t *)(event_list->current->data);
        switch (data[0]) {
            case EVENT_START_MODE_FILE_SAVE:
                /*log_debug(LOG_DEFAULT, "READING %s", (char *)(&data[1]));*/
                if (machine_read_snapshot(
                        event_snapshot_path((char *)(&data[1])), 0) < 0
                    && machine_read_snapshot(
                        event_snapshot_path(event_start_snapshot), 0) < 0) {
                    char *st = lib_strdup(event_snapshot_path((char *)(&data[1])));
                    ui_error("Error reading start snapshot file. Tried %s and %s", st, event_snapshot_path(event_start_snapshot));
                    lib_free(st);
                    ui_display_playback(0, NULL);
                    return;
                }

                if (event_list->current->size > strlen((char *)&data[1]) + 2) {
                    strncpy(event_version, (char *)(&data[strlen((char *)&data[1]) + 2]), 15);
                }

                next_current_list();
                next_alarm_set();
                break;
            case EVENT_START_MODE_RESET:
                /*log_debug(LOG_DEFAULT, "RESET MODE!");*/
                machine_trigger_reset(MACHINE_RESET_MODE_POWER_CYCLE);
                if (event_list->current->size > 1) {
                    strncpy(event_version, (char *)(&data[1]), 15);
                }
                next_current_list();
                /* Alarm will be set if reset is ack'ed.  */
                playback_reset_ack = 1;
                break;
        }
    } else {
        if (machine_read_snapshot(event_snapshot_path(event_start_snapshot), 0) < 0) {
            ui_error("Error reading start snapshot file.");
            ui_display_playback(0, NULL);
            return;
        }
        next_alarm_set();
    }

    playback_active = 1;
    current_timestamp = 0;

    ui_display_playback(1, event_version);

#ifdef  DEBUG
    debug_start_playback();
#endif
}


int event_playback_start(void)
{
    if (record_active != 0 || playback_active != 0 || autostart_in_progress()) {
        return -1;
    }

    interrupt_maincpu_trigger_trap(event_playback_start_trap, (void *)0);

    return 0;
}

int event_playback_stop(void)
{
    if (playback_active == 0) {
        return -1;
    }

    playback_active = 0;

    alarm_unset(event_alarm);

    ui_display_playback(0, NULL);

#ifdef  DEBUG
    debug_stop_playback();
#endif

    return 0;
}

static void event_record_set_milestone_trap(uint16_t addr, void *data)
{
    if (machine_write_snapshot(event_snapshot_path(event_end_snapshot), 1, 1, 1) < 0) {
        ui_error("Could not create end snapshot file %s.", event_snapshot_path(event_end_snapshot));
    } else {
        milestone_timestamp_alarm = next_timestamp_clk;
        milestone_timestamp = current_timestamp;
#ifdef  DEBUG
        debug_set_milestone();
#endif
    }
}

int event_record_set_milestone(void)
{
    if (record_active == 0) {
        return -1;
    }

    interrupt_maincpu_trigger_trap(event_record_set_milestone_trap, (void *)0);

    return 0;
}

static void event_record_reset_milestone_trap(uint16_t addr, void *data)
{
    /* We need to disable recording to avoid events being recorded while
       snapshot reading. */
    record_active = 0;

    if (machine_read_snapshot(
            event_snapshot_path(event_end_snapshot), 1) < 0) {
        ui_error("Error reading end snapshot file %s.", event_snapshot_path(event_end_snapshot));
        return;
    }
    warp_end_list();
    record_active = 1;
    if (milestone_timestamp_alarm > 0) {
        alarm_set(event_alarm, milestone_timestamp_alarm);
        next_timestamp_clk = milestone_timestamp_alarm;
        current_timestamp = milestone_timestamp;
    }
#ifdef  DEBUG
    debug_reset_milestone();
#endif
}

int event_record_reset_milestone(void)
{
    if (playback_active != 0) {
        return -1;
    }

    if (record_active == 0) {
        return -1;
    }

    interrupt_maincpu_trigger_trap(event_record_reset_milestone_trap, (void *)0);

    return 0;
}


/*-----------------------------------------------------------------------*/

int event_record_active(void)
{
    return record_active;
}

int event_playback_active(void)
{
    return playback_active;
}

/*-----------------------------------------------------------------------*/

int event_snapshot_read_module(struct snapshot_s *s, int event_mode)
{
    snapshot_module_t *m;
    uint8_t major_version, minor_version;
    event_list_t *curr;
    unsigned int num_of_timestamps;

    if (event_mode == 0) {
        return 0;
    }

    m = snapshot_module_open(s, "EVENT", &major_version, &minor_version);

    /* This module is not mandatory.  */
    if (m == NULL) {
        return 0;
    }

    destroy_list();
    create_list();

    curr = event_list->base;
    num_of_timestamps = 0;
    playback_time = 0;
    next_timestamp_clk = CLOCK_MAX;

    while (1) {
        unsigned int type, size;
        CLOCK clk;
        uint8_t *data = NULL;

        /*
            throw away recorded timestamp (recording them  was introduced in
            1.14.x so there might exist history files with TIMESTAMP events)
        */
        do {
            if (SMR_DW_UINT(m, &(type)) < 0) {
                snapshot_module_close(m);
                return -1;
            }

            if (SMR_CLOCK(m, &(clk)) < 0) {
                snapshot_module_close(m);
                return -1;
            }

            if (SMR_DW_UINT(m, &(size)) < 0) {
                snapshot_module_close(m);
                return -1;
            }
        } while (type == EVENT_TIMESTAMP);

        if (size > 0) {
            data = lib_malloc(size);
            if (SMR_BA(m, data, size) < 0) {
                snapshot_module_close(m);
                return -1;
            }
        }

        if (next_timestamp_clk == CLOCK_MAX) { /* if EVENT_INITIAL is missing */
            next_timestamp_clk = clk;
        }

        if (type == EVENT_INITIAL) {
            if (data[0] == EVENT_START_MODE_RESET) {
                next_timestamp_clk = 0;
            } else {
                next_timestamp_clk = clk;
            }
        } else {
            /* insert timestamps each second */
            while (next_timestamp_clk < clk)
            {
                curr->type = EVENT_TIMESTAMP;
                curr->clk = next_timestamp_clk;
                curr->size = 0;
                curr->next = lib_calloc(1, sizeof(event_list_t));
                curr = curr->next;
                next_timestamp_clk += machine_get_cycles_per_second();
                num_of_timestamps++;
            }
        }

        curr->type = type;
        curr->clk = clk;
        curr->size = size;
        curr->data = (size > 0 ? data : NULL);

        if (type == EVENT_LIST_END) {
            break;
        }

        if (type == EVENT_RESETCPU) {
            next_timestamp_clk -= clk;
        }

        curr->next = lib_calloc(1, sizeof(event_list_t));
        curr = curr->next;
    }

    if (num_of_timestamps > 0) {
        playback_time = num_of_timestamps - 1;
    }

    snapshot_module_close(m);

    return 0;
}

int event_snapshot_write_module(struct snapshot_s *s, int event_mode)
{
    snapshot_module_t *m;
    event_list_t *curr;

    if (event_mode == 0) {
        return 0;
    }

    m = snapshot_module_create(s, "EVENT", 0, 1);

    if (m == NULL) {
        return -1;
    }

    curr = event_list->base;

    while (curr != NULL) {
        if (curr->type != EVENT_TIMESTAMP
            && (0
                || SMW_DW(m, (uint32_t)curr->type) < 0
                || SMW_CLOCK(m, curr->clk) < 0
                || SMW_DW(m, (uint32_t)curr->size) < 0
                || SMW_BA(m, curr->data, curr->size) < 0)) {
            snapshot_module_close(m);
            return -1;
        }
        curr = curr->next;
    }

    if (snapshot_module_close(m) < 0) {
        return -1;
    }

    return 0;
}

/*-----------------------------------------------------------------------*/

static int set_event_snapshot_dir(const char *val, void *param)
{
    const char *s = val;

    /* Make sure that the string ends with ARCHDEP_DIR_SEP_STR */
    if (s[strlen(s) - 1] == ARCHDEP_DIR_SEP_CHR) {
        util_string_set(&event_snapshot_dir, s);
    } else {
        lib_free(event_snapshot_dir);
        event_snapshot_dir = util_concat(s, ARCHDEP_DIR_SEP_STR, NULL);
    }

    return 0;
}

static int set_event_start_snapshot(const char *val, void *param)
{
    if (util_string_set(&event_start_snapshot, val)) {
        return 0;
    }

    return 0;
}

static int set_event_end_snapshot(const char *val, void *param)
{
    if (util_string_set(&event_end_snapshot, val)) {
        return 0;
    }

    return 0;
}

static int set_event_start_mode(int mode, void *param)
{
    switch (mode) {
        case EVENT_START_MODE_FILE_SAVE:
        case EVENT_START_MODE_FILE_LOAD:
        case EVENT_START_MODE_RESET:
        case EVENT_START_MODE_PLAYBACK:
            break;
        default:
            return -1;
    }

    event_start_mode = mode;

    return 0;
}

static int set_event_image_include(int enable, void *param)
{
    event_image_include = enable ? 1 : 0;

    return 0;
}

static const resource_string_t resources_string[] = {
    { "EventSnapshotDir",
      ARCHDEP_FSDEVICE_DEFAULT_DIR ARCHDEP_DIR_SEP_STR, RES_EVENT_NO, NULL,
      &event_snapshot_dir, set_event_snapshot_dir, NULL },
    { "EventStartSnapshot", EVENT_START_SNAPSHOT, RES_EVENT_NO, NULL,
      &event_start_snapshot, set_event_start_snapshot, NULL },
    { "EventEndSnapshot", EVENT_END_SNAPSHOT, RES_EVENT_NO, NULL,
      &event_end_snapshot, set_event_end_snapshot, NULL },
    RESOURCE_STRING_LIST_END
};

static const resource_int_t resources_int[] = {
    { "EventStartMode", EVENT_START_MODE_FILE_SAVE, RES_EVENT_NO, NULL,
      &event_start_mode, set_event_start_mode, NULL },
    { "EventImageInclude", 1, RES_EVENT_NO, NULL,
      &event_image_include, set_event_image_include, NULL },
    RESOURCE_INT_LIST_END
};

int event_resources_init(void)
{
    if (resources_register_string(resources_string) < 0) {
        return -1;
    }

    return resources_register_int(resources_int);
}

void event_shutdown(void)
{
    lib_free(event_start_snapshot);
    lib_free(event_end_snapshot);
    lib_free(event_snapshot_dir);
    lib_free(event_snapshot_path_str);
    event_snapshot_path_str = NULL;
    destroy_list();
}

/*-----------------------------------------------------------------------*/

static int cmdline_help(const char *param, void *extra_param)
{
    return event_playback_start();
}

static const cmdline_option_t cmdline_options[] =
{
    { "-playback", CALL_FUNCTION, CMDLINE_ATTRIB_NONE,
      cmdline_help, NULL, NULL, NULL,
      NULL, "Playback recorded events" },
    { "-eventsnapshotdir", SET_RESOURCE, CMDLINE_ATTRIB_NEED_ARGS,
      NULL, NULL, "EventSnapshotDir", NULL,
      "<Name>", "Set event snapshot directory" },
    { "-eventstartsnapshot", SET_RESOURCE, CMDLINE_ATTRIB_NEED_ARGS,
      NULL, NULL, "EventStartSnapshot", NULL,
      "<Name>", "Set event start snapshot" },
    { "-eventendsnapshot", SET_RESOURCE, CMDLINE_ATTRIB_NEED_ARGS,
      NULL, NULL, "EventEndSnapshot", NULL,
      "<Name>", "Set event end snapshot" },
    { "-eventstartmode", SET_RESOURCE, CMDLINE_ATTRIB_NEED_ARGS,
      NULL, NULL, "EventStartMode", NULL,
      "<Mode>", "Set event start mode (0: file save, 1: file load, 2: reset, 3: playback)" },
    { "-eventimageinc", SET_RESOURCE, CMDLINE_ATTRIB_NONE,
      NULL, NULL, "EventImageInclude", (resource_value_t)1,
      NULL, "Enable including disk images" },
    { "+eventimageinc", SET_RESOURCE, CMDLINE_ATTRIB_NONE,
      NULL, NULL, "EventImageInclude", (resource_value_t)0,
      NULL, "Disable including disk images" },
    CMDLINE_LIST_END
};

int event_cmdline_options_init(void)
{
    return cmdline_register_options(cmdline_options);
}

/*-----------------------------------------------------------------------*/

void event_init(void)
{
    event_log = log_open("Event");

    event_alarm = alarm_new(maincpu_alarm_context, "Event",
                            event_alarm_handler, NULL);
}