#ifndef __DC_API_LOCAL_MASTER_H
#define __DC_API_LOCAL_MASTER_H

#ifdef __cplusplus
extern "C" {
#endif

#include <dc.h>
#include <dc_internal.h>
#include <uuid/uuid.h>
#include <glib.h>

#include "local_common.h"

/********************************************************************
 * Constants
 */

/* DCAPI configuration keys */
#define CFG_SLEEPINTERVAL	"SleepingInterval"

#define DEFAULT_SLEEP_INTERVAL	5

/* File types in the working directory */
typedef enum
{
	FILE_IN,
	FILE_OUT,
	FILE_CKPT,
	FILE_DCAPI
} WorkdirFile;


/********************************************************************
 * Data types
 */

struct _DC_Workunit
{
	/* Arguments passed to DC_createWU() */
	char			*client_name;
	char			*client_path;
	char			**argv;
	int			argc;
	char			*tag;
	int			subresults;

	/* State of the WU */
	char			*name;
	uuid_t			uuid;
	char			*uuid_str;
	DC_WUState		state;
	char			*workdir;
	int			pid;

	/* Input file definitions. Elements are of type DC_LogicalFile */
	GList			*input_files;
	int			num_inputs;

	/* Output file definitions. Elements are of type char * */
	GList			*output_files;
	int			num_outputs;
};

struct _DC_Result
{
	DC_Workunit		*wu;

	int			exit_code;

	/* List of output files. Elements are of type DC_PhysicalFile */
	GList			*output_files;
	int			num_outputs;
};


/********************************************************************
 * Global variables
 */

extern DC_ResultCallback	_dc_resultcb;
extern DC_SubresultCallback	_dc_subresultcb;
extern DC_MessageCallback	_dc_messagecb;

extern char project_uuid_str[37]; 
extern uuid_t project_uuid;
extern int sleep_interval;

/********************************************************************
 * Function prototypes
 */

/* Allocates a physical file descriptor */
DC_PhysicalFile *_DC_createPhysicalFile(const char *label,
        const char *path);

/* De-allocates a physical file descriptor */
void _DC_destroyPhysicalFile(DC_PhysicalFile *file);

/* Calls a g_hash_table_foreach function for the wu_table */
int _DC_searchForEvents(void);

/* Creates a new DC_Result */
DC_Result *_DC_createResult(const char *wu_name);

/* Destroys a DC_Result */
void _DC_destroyResult(DC_Result *result);

/* Looks up a WU by name */
DC_Workunit *_DC_getWUByName(const char *name);

#ifdef __cplusplus
}
#endif

#endif /* __DC_API_LOCAL_MASTER_H */