job.h

/* **************************************************************
Copyright (C) 2010-2013 Hewlett-Packard Development Company, L.P.
Copyright (C) 2015 Siemens AG

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
version 2 as published by the Free Software Foundation.

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.,
51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
************************************************************** */

#ifndef JOB_H_INCLUDE
#define JOB_H_INCLUDE

/* local includes */
#include <logging.h>

/* std library includes */
#include <stdio.h>
#include <event.h>
#include <libpq-fe.h>

/* glib includes */
#include <glib.h>

/* ************************************************************************** */
/* **** Data Types ********************************************************** */
/* ************************************************************************** */

#define JOB_STATUS_TYPES(apply)                        \
  apply(NOT_AVAILABLE)                                 \
 \
  apply(CHECKEDOUT)                                    \
       \
  apply(STARTED)                                       \
   \
  apply(COMPLETE)                                      \
                               \
  apply(RESTART)                                       \
   \
  apply(FAILED)                                        \
                 \
  apply(PAUSED)

#define SELECT_ENUM(passed) JB_##passed,
typedef enum { JOB_STATUS_TYPES(SELECT_ENUM) } job_status;
#undef SELECT_ENUM

extern const char* job_status_strings[];

typedef struct
{
    /* associated agent information */
    char*  agent_type;      
    char*  required_host;   
    GList* running_agents;  
    GList* finished_agents; 
    GList* failed_agents;   
    log_t*  log;            

    /* information for data manipulation */
    job_status status;    
    gchar*     data;      
    gchar     *jq_cmd_args; 
    PGresult*  db_result; 
    GMutex*    lock;      
    uint32_t   idx;       

    /* information about job status */
    gchar*   message;   
    int32_t  priority;  
    int32_t  verbose;   
    int32_t  parent_id; 
    int32_t  id;        
    int32_t  user_id;   
    int32_t  group_id;  
} job_t;

/* ************************************************************************** */
/* **** Constructor Destructor ********************************************** */
/* ************************************************************************** */

job_t* job_init(GTree* job_list, GSequence* job_queue, char* type, char* host,
    int id, int parent_id, int user_id, int group_id, int priority, char *jq_cmd_args);
void   job_destroy(job_t* job);

/* ************************************************************************** */
/* **** Functions and events ************************************************ */
/* ************************************************************************** */

void job_verbose_event (scheduler_t* scheduler, job_t* j);
void job_status_event  (scheduler_t* scheduler, arg_int* params);
void job_pause_event   (scheduler_t* scheduler, arg_int* params);
void job_restart_event (scheduler_t* scheduler, arg_int* params);
void job_priority_event(scheduler_t* scheduler, arg_int* params);
void job_fail_event    (scheduler_t* scheduler, job_t* job);

void job_add_agent(job_t* job, void* a);
void job_remove_agent(job_t* job, GTree* job_list, void* a);
void job_finish_agent(job_t* job, void* a);
void job_fail_agent(job_t* job, void* a);
void job_set_data(scheduler_t* scheduler, job_t* job, char* data, int sql);
void job_update(scheduler_t* scheduler, job_t* job);

gboolean  job_is_open(scheduler_t* scheduler, job_t* job);
gchar*    job_next(job_t* job);
log_t*    job_log(job_t* job);

/* ************************************************************************** */
/* **** Job list Functions ************************************************** */
/* ************************************************************************** */

job_t*   next_job(GSequence* job_queue);
job_t*   peek_job(GSequence* job_queue);
uint32_t active_jobs(GTree* job_list);

#endif /* JOB_H_INCLUDE */