#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/mman.h>
#include <sys/select.h>
#include <sys/stat.h>
#include <sys/time.h>
#include <sys/types.h>
#include "umka.h"
#include "shell.h"

#define MONITOR_THREAD_STACK_SIZE 0x100000

void monitor() {
    __asm__ __inline__ __volatile__ (
        "pushfd;"
        "btr dword ptr[esp], 21;"
        "popfd"
        : : : "memory");

    fprintf(stderr, "Start monitor thread\n");
//    mkfifo("/tmp/umka.fifo.2u", 0644);
//    mkfifo("/tmp/umka.fifo.4u", 0644);
    FILE *fin = fopen("/tmp/umka.fifo.2u", "r");
    FILE *fout = fopen("/tmp/umka.fifo.4u", "w");
    if (!fin || !fout) {
        fprintf(stderr, "Can't open monitor files!\n");
        return;
    }
    run_test(fin, fout, 0);
}

void restart_timer(void);
void umka_thread_ping(void);
void umka_thread_net_drv(void);

struct itimerval timeout = {.it_value = {.tv_sec = 0, .tv_usec = 10000},
                            .it_interval = {.tv_sec = 0, .tv_usec = 10000}};

int main() {
    __asm__ __inline__ __volatile__ (
        "pushfd;"
        "btr dword ptr[esp], 21;"
        "popfd"
        : : : "memory");

    umka_tool = UMKA_OS;

    struct sigaction sa;
    sa.sa_sigaction = irq0;
    sigemptyset(&sa.sa_mask);
    sa.sa_flags = SA_SIGINFO;

    if (sigaction(SIGPROF, &sa, NULL) == -1) {
        printf("Can't install signal handler!\n");
        return 1;
    }


/*
    void *app_base = mmap((void*)0x000000, 16*0x100000, PROT_READ | PROT_WRITE | PROT_EXEC, MAP_FIXED | MAP_PRIVATE | MAP_ANONYMOUS, -1, 0);
    if (app_base == MAP_FAILED) {
        perror("mmap failed");
        exit(1);
    }
*/
    printf("pid=%d, kos_lfb_base=%p\n", getpid(), (void*)kos_lfb_base);

    kos_init();
    kos_stack_init();
    uint8_t *monitor_stack = malloc(MONITOR_THREAD_STACK_SIZE);
    umka_new_sys_threads(0, monitor, monitor_stack + MONITOR_THREAD_STACK_SIZE);

    uint8_t *net_drv_stack = malloc(MONITOR_THREAD_STACK_SIZE);
    umka_new_sys_threads(0, umka_thread_net_drv, net_drv_stack + MONITOR_THREAD_STACK_SIZE);

    uint8_t *ping_stack = malloc(MONITOR_THREAD_STACK_SIZE);
    umka_new_sys_threads(0, umka_thread_ping, ping_stack + MONITOR_THREAD_STACK_SIZE);

    setitimer(ITIMER_PROF, &timeout, NULL);

    osloop();   // doesn't return

    return 0;
}