/*

    Task Spooler - a task queue system for the unix user

    Copyright (C) 2007  Lluís Batlle i Rossell

    Please find the license in the provided COPYING file.

*/

#include <stdlib.h>

#include <unistd.h>

#include <stdio.h>

#include <string.h>

#include <sys/time.h>

#include <time.h>

#include "main.h"

static enum

{

    FREE, /* No task is running */

    WAITING /* A task is running, and the server is waiting */

} state = FREE;

struct Notify

{

    int socket;

    int jobid;

    struct Notify *next;

};

/* Globals */

static struct Job *firstjob = 0;

static struct Job *first_finished_job = 0;

static int jobids = 0;

static struct Notify *first_notify = 0;

static void send_list_line(int s, const char * str)

{

    struct msg m;

    /* Message */

    m.type = LIST_LINE;

    m.u.size = strlen(str) + 1;

    send_msg(s, &m);

    /* Send the line */

    send_bytes(s, str, m.u.size);

}

static void send_urgent_ok(int s)

{

    struct msg m;

    /* Message */

    m.type = URGENT_OK;

    send_msg(s, &m);

}

static void send_swap_jobs_ok(int s)

{

    struct msg m;

    /* Message */

    m.type = SWAP_JOBS_OK;

    send_msg(s, &m);

}

static struct Job * find_previous_job(const struct Job *final)

{

    struct Job *p;

    /* Show Queued or Running jobs */

    p = firstjob;

    while(p != 0)

    {

        if (p->next == final)

            return p;

        p = p->next;

    }

    return 0;

}

static struct Job * findjob(int jobid)

{

    struct Job *p;

    /* Show Queued or Running jobs */

    p = firstjob;

    while(p != 0)

    {

        if (p->jobid == jobid)

            return p;

        p = p->next;

    }

    return 0;

}

static struct Job * find_finished_job(int jobid)

{

    struct Job *p;

    /* Show Queued or Running jobs */

    p = first_finished_job;

    while(p != 0)

    {

        if (p->jobid == jobid)

            return p;

        p = p->next;

    }

    return 0;

}

void s_mark_job_running()

{

    firstjob->state = RUNNING;

}

const char * jstate2string(enum Jobstate s)

{

    const char * jobstate;

    switch(s)

    {

        case QUEUED:

            jobstate = "queued";

            break;

        case RUNNING:

            jobstate = "running";

            break;

        case FINISHED:

            jobstate = "finished";

            break;

        case SKIPPED:

            jobstate = "skipped";

            break;

    }

    return jobstate;

}

void s_list(int s)

{

    struct Job *p;

    char *buffer;

    /* Times:   0.00/0.00/0.00 - 4+4+4+2 = 14*/ 

    buffer = joblist_headers();

    send_list_line(s,buffer);

    free(buffer);

    /* Show Queued or Running jobs */

    p = firstjob;

    while(p != 0)

    {

        buffer = joblist_line(p);

        send_list_line(s,buffer);

        free(buffer);

        p = p->next;

    }

    p = first_finished_job;

    /* Show Finished jobs */

    while(p != 0)

    {

        buffer = joblist_line(p);

        send_list_line(s,buffer);

        free(buffer);

        p = p->next;

    }

}

static struct Job * newjobptr()

{

    struct Job *p;

    if (firstjob == 0)

    {

        firstjob = (struct Job *) malloc(sizeof(*firstjob));

        firstjob->next = 0;

        firstjob->output_filename = 0;

        firstjob->command = 0;

        return firstjob;

    }

    p = firstjob;

    while(p->next != 0)

        p = p->next;

    p->next = (struct Job *) malloc(sizeof(*p));

    p->next->next = 0;

    p->next->output_filename = 0;

    p->next->command = 0;

    return p->next;

}

/* Returns job id */

int s_newjob(int s, struct msg *m)

{

    struct Job *p;

    int res;

    p = newjobptr();

    p->jobid = jobids++;

    p->state = QUEUED;

    p->store_output = m->u.newjob.store_output;

    p->should_keep_finished = m->u.newjob.should_keep_finished;

    p->depend = m->u.newjob.depend;

    pinfo_init(&p->info);

    pinfo_set_enqueue_time(&p->info);

    /* load the command */

    p->command = malloc(m->u.newjob.command_size);

    if (p->command == 0)

        error("Cannot allocate memory in s_newjob command_size (%i)",

                m->u.newjob.command_size);

    res = recv_bytes(s, p->command, m->u.newjob.command_size);

    if (res == -1)

        error("wrong bytes received");

    /* load the label */

    p->label = 0;

    if (m->u.newjob.label_size > 0)

    {

        char *ptr;

        ptr = (char *) malloc(m->u.newjob.label_size);

        if (ptr == 0)

            error("Cannot allocate memory in s_newjob env_size(%i)",

                    m->u.newjob.env_size);

        res = recv_bytes(s, ptr, m->u.newjob.label_size);

        if (res == -1)

            error("wrong bytes received");

        p->label = ptr;

    }

    /* load the info */

    if (m->u.newjob.env_size > 0)

    {

        char *ptr;

        ptr = (char *) malloc(m->u.newjob.env_size);

        if (ptr == 0)

            error("Cannot allocate memory in s_newjob env_size(%i)",

                    m->u.newjob.env_size);

        res = recv_bytes(s, ptr, m->u.newjob.env_size);

        if (res == -1)

            error("wrong bytes received");

        pinfo_addinfo(&p->info, m->u.newjob.env_size+100,

                "Environment:\n%s", ptr);

        free(ptr);

    }

    return p->jobid;

}

/* This assumes the jobid exists */

void s_removejob(int jobid)

{

    struct Job *p;

    struct Job *newnext;

    if (firstjob->jobid == jobid)

    {

        struct Job *newfirst;

        if (state == WAITING)

            state = FREE;

        /* First job is to be removed */

        newfirst = firstjob->next;

        free(firstjob->command);

        free(firstjob->output_filename);

        pinfo_free(&firstjob->info);

        free(firstjob->label);

        free(firstjob);

        firstjob = newfirst;

        return;

    }

    p = firstjob;

    /* Not first job */

    while (p->next != 0)

    {

        if (p->next->jobid == jobid)

            break;

        p = p->next;

    }

    if (p->next == 0)

        error("Job to be removed not found. jobid=%i", jobid);

    newnext = p->next->next;

    free(p->next->command);

    free(p->next);

    p->next = newnext;

}

/* -1 if no one should be run. */

int next_run_job()

{

    if (state == WAITING)

        return -1;

    if (firstjob != 0)

    {

        state = WAITING;

        return firstjob->jobid;

    }

    return -1;

}

/* Returns 1000 if no limit, The limit otherwise. */

static int get_max_finished_jobs()

{

    char *limit;

    limit = getenv("TS_MAXFINISHED");

    if (limit == NULL)

        return 1000;

    return abs(atoi(limit));

}

/* Add the job to the finished queue. */

static void new_finished_job(struct Job *j)

{

    struct Job *p;

    int count, max;

    max = get_max_finished_jobs();

    count = 0;

    if (first_finished_job == 0 && count < max)

    {

        first_finished_job = j;

        first_finished_job->next = 0;

        return;

    }

    ++count;

    p = first_finished_job;

    while(p->next != 0)

    {

        p = p->next;

        ++count;

    }

    /* If too many jobs, wipe out the first */

    if (count >= max)

    {

        struct Job *tmp;

        tmp = first_finished_job;

        first_finished_job = first_finished_job->next;

        free(tmp->command);

        free(tmp->output_filename);

        pinfo_free(&tmp->info);

        free(tmp->label);

        free(tmp);

    }

    p->next = j;

    p->next->next = 0;

    return;

}

void job_finished(const struct Result *result)

{

    struct Job *newfirst;

    if (state != WAITING)

        error("Wrong state in the server. Not WAITING, but %i", state);

    if (firstjob == 0)

        error("on job finished, firstjob values %x", firstjob);

    if (firstjob->state != RUNNING)

        error("on job finished, the firstjob is not running but %i",

                firstjob->state);

    /* Mark state */

    if (result->skipped)

        firstjob->state = SKIPPED;

    else

        firstjob->state = FINISHED;

    firstjob->result = *result;

    pinfo_set_end_time(&firstjob->info);

    /* Add it to the finished queue */

    newfirst = firstjob->next;

    if (firstjob->should_keep_finished)

        new_finished_job(firstjob);

    /* Remove it from the run queue */

    firstjob = newfirst;

    state = FREE;

}

void s_clear_finished()

{

    struct Job *p;

    if (first_finished_job == 0)

        return;

    p = first_finished_job;

    first_finished_job = 0;

    while (p != 0)

    {

        struct Job *tmp;

        tmp = p->next;

        free(p->command);

        free(p->output_filename);

        pinfo_free(&p->info);

        free(p->label);

        free(p);

        p = tmp;

    }

}

void s_process_runjob_ok(int jobid, char *oname, int pid)

{

    struct Job *p;

    p = findjob(jobid);

    if (p == 0)

        error("Job %i already run not found on runjob_ok", jobid);

    if (p->state != RUNNING)

        error("Job %i not running, but %i on runjob_ok", jobid,

                p->state);

    p->pid = pid;

    p->output_filename = oname;

    pinfo_set_start_time(&p->info);

}

void s_job_info(int s, int jobid)

{

    struct Job *p = 0;

    struct msg m;

    if (jobid == -1)

    {

        /* This means that we want the job info of the running task, or that

         * of the last job run */

        if (state == WAITING)

        {

            p = firstjob;

            if (p == 0)

                error("Internal state WAITING, but job not run."

                        "firstjob = %x", firstjob);

        }

        else

        {

            p = first_finished_job;

            if (p == 0)

            {

                send_list_line(s, "No jobs.\n");

                return;

            }

            while(p->next != 0)

                p = p->next;

        }

    } else

    {

        p = firstjob;

        while (p != 0 && p->jobid != jobid)

            p = p->next;

        /* Look in finished jobs if needed */

        if (p == 0)

        {

            p = first_finished_job;

            while (p != 0 && p->jobid != jobid)

                p = p->next;

        }

    }

    if (p == 0)

    {

        char tmp[50];

        sprintf(tmp, "Job %i not finished or not running.\n", jobid);

        send_list_line(s, tmp);

        return;

    }

    m.type = INFO_DATA;