cleanup:
edg_wll_FreeContext(ctx);
+
+ return NULL;
}
static void
#include "glite/lb/xml_conversions.h"
#include "glite/lb/jobstat.h"
-extern char *edg_wll_TagListToString(edg_wll_TagValue *);
-
static void dgerr(edg_wll_Context,char *);
static void printstat(edg_wll_JobStat,int);
/**
- * Free allocated edg_wll_TagValue * list
- * \param list IN: list to free
- */
-extern void edg_wll_FreeTagList(
- edg_wll_TagValue *list
-);
-
-
-/**
* \typedef edg_wll_KeyNameCode
* Predefined ULM key types
*/
edg_wll_Event * event
);
-extern int edg_wll_TagListParse(
- const char *src,
- edg_wll_TagValue **list);
-
-extern int edg_wll_TagListCompare(
- edg_wll_TagValue *a,
- edg_wll_TagValue *b);
-
#ifdef __cplusplus
}
#endif
*/
extern char *edg_wll_VMStatToString(enum edg_wll_StatVm_state);
+/**
+ * Convert string VM status to numeric code
+ */
+extern enum edg_wll_StatVm_state edg_wll_StringToVMStat(const char* name);
/**
* Extract a variable from the JDL attribute
edg_wll_NotifId edg_wll_from_string_to_notifid(edg_wll_XML_ctx *XMLCtx);
edg_wll_JobStatCode edg_wll_from_string_to_edg_wll_JobStatCode(edg_wll_XML_ctx *XMLCtx);
enum edg_wll_StatVm_state edg_wll_from_string_to_edg_wll_StatVm_state(edg_wll_XML_ctx *XMLCtx);
+enum edg_wll_StatJobtype edg_wll_from_string_to_edg_wll_StatJobtype(edg_wll_XML_ctx *XMLCtx);
int edg_wll_from_string_to_int(edg_wll_XML_ctx *XMLCtx);
float edg_wll_from_string_to_float(edg_wll_XML_ctx *XMLCtx);
double edg_wll_from_string_to_double(edg_wll_XML_ctx *XMLCtx);
}
@@@}
-extern void edg_wll_FreeTagList(edg_wll_TagValue *);
-
void edg_wll_FreeStatus(edg_wll_JobStat *stat)
{
if (stat) {
#include "jobstat.h"
-extern char *edg_wll_TagListToString(edg_wll_TagValue *);
-
static const struct timeval null_timeval = {0,0};
edg_wll_TagValue *edg_wll_from_string_to_taglist(edg_wll_XML_ctx *XMLCtx)
{
- char *s, *out = NULL;
+ char *s;
+ edg_wll_TagValue *out = NULL;
s = glite_lbu_UnescapeXML((const char*) XMLCtx->char_buf);
if(s) {
struct server_msg *server_msg_create(il_octet_string_t *, long);
struct server_msg *server_msg_copy(struct server_msg *);
int server_msg_init(struct server_msg *, il_octet_string_t *);
-#if defined(INTERLOGD_EMS)
int server_msg_is_priority(struct server_msg *);
-#endif
int server_msg_free(struct server_msg *);
void server_msg_use(struct server_msg *);
int server_msg_release(struct server_msg *);
#include <sys/un.h>
#include <sys/time.h>
#include <unistd.h>
+#include <utime.h>
#include <errno.h>
#include <assert.h>
#include <string.h>
DL_RESOLVESYM(plugin->plugin_def.plugin_init, dl_handle, "plugin_init", int(*)(char *));
DL_RESOLVESYM(plugin->plugin_def.plugin_supports_scheme, dl_handle, "plugin_supports_scheme", int(*)(const char *));
- DL_RESOLVESYM(plugin->plugin_def.event_queue_connect, dl_handle, "event_queue_connect", int (*)(struct event_queue*));
- DL_RESOLVESYM(plugin->plugin_def.event_queue_send, dl_handle, "event_queue_send", int (*)(struct event_queue *));
- DL_RESOLVESYM(plugin->plugin_def.event_queue_close, dl_handle, "event_queue_close", int (*)(struct event_queue *));
+ DL_RESOLVESYM(plugin->plugin_def.event_queue_connect, dl_handle, "event_queue_connect", int (*)(struct event_queue*, struct queue_thread *));
+ DL_RESOLVESYM(plugin->plugin_def.event_queue_send, dl_handle, "event_queue_send", int (*)(struct event_queue *,struct queue_thread *));
+ DL_RESOLVESYM(plugin->plugin_def.event_queue_close, dl_handle, "event_queue_close", int (*)(struct event_queue *,struct queue_thread *));
return (*plugin->plugin_def.plugin_init)(cfg);
}
int edg_wll_QueryToHTML(edg_wll_Context,edg_wll_Event *,char **);
int edg_wll_ConfigurationToHTML(edg_wll_Context ctx, int admin, char **message, int text);
+int edg_wll_WSDLOutput(edg_wll_Context ctx, char **message, char *filename);
int edg_wll_GeneralJobStatusToHTML(edg_wll_Context, edg_wll_JobStat, char **, int text);
int edg_wll_UserInfoToHTML(edg_wll_Context, edg_wlc_JobId *, edg_wll_JobStat *, char **, int text);
int edg_wll_UserNotifsToHTML(edg_wll_Context ctx, char **notifids, char **message, http_admin_option option, int adm);
} edg_wll_TagValue;
+/**
+ * Free allocated edg_wll_TagValue * list
+ * \param list IN: list to free
+ */
+void edg_wll_FreeTagList(edg_wll_TagValue *list);
+
+/**
+ * Deep copy the tag list
+ */
+edg_wll_TagValue *edg_wll_CopyTagList(edg_wll_TagValue *src);
+
+/**
+ * Function for parsing name=value tag lists
+ */
+int edg_wll_TagListParse(const char *src, edg_wll_TagValue **list);
+
+/**
+ * Comparing tag list values
+ */
+int edg_wll_TagListCompare(edg_wll_TagValue *a, edg_wll_TagValue *b);
+
+/**
+ * Function for stringifying name=value tag lists
+ */
+char * edg_wll_TagListToString(edg_wll_TagValue *list);
+
+
#ifdef __cplusplus
}
#endif
*/
+#define _GNU_SOURCE
+
#include <stdlib.h>
#include <string.h>
#include <stdio.h>