int edg_wll_JobStatus(
edg_wll_Context context,
- const edg_wlc_JobId jobid,
+ glite_jobid_const_t jobid,
int flags,
edg_wll_JobStat *status
);
*/
int edg_wll_JobStatusProxy(
edg_wll_Context context,
- const edg_wlc_JobId jobid,
+ glite_jobid_const_t jobid,
int flags,
edg_wll_JobStat *status
);
int edg_wll_JobLog(
edg_wll_Context context,
- const edg_wlc_JobId jobId,
+ glite_jobid_const_t jobId,
edg_wll_Event ** events
);
*/
int edg_wll_JobLogProxy(
edg_wll_Context context,
- const edg_wlc_JobId jobId,
+ glite_jobid_const_t jobId,
edg_wll_Event ** events
);
int edg_wll_QuerySequenceCodeProxy(
edg_wll_Context context,
- edg_wlc_JobId jobId,
+ glite_jobid_const_t jobId,
char ** code
);
break;
case JOBID:
- if(glite_jobid_dup(jobid_value.c_jobid(), &out.value.j)) {
+ if(glite_jobid_dup(jobid_value.c_jobid(), (glite_jobid_t*)&out.value.j)) {
throw std::bad_alloc();
}
break;
int edg_wll_JobLog(
edg_wll_Context ctx,
- edg_wlc_JobId job,
+ glite_jobid_const_t job,
edg_wll_Event **eventsOut)
{
edg_wll_QueryRec j[2], e[2];
int edg_wll_JobStatus(
edg_wll_Context ctx,
- edg_wlc_JobId job,
+ glite_jobid_const_t job,
int flags,
edg_wll_JobStat *stat)
{
return(error);
}
-int edg_wll_QuerySequenceCodeProxy(edg_wll_Context ctx, edg_wlc_JobId jobId, char **code)
+int edg_wll_QuerySequenceCodeProxy(edg_wll_Context ctx, glite_jobid_const_t jobId, char **code)
{
int error = 0;
char *response = NULL,
int edg_wll_JobLogProxy(
edg_wll_Context ctx,
- edg_wlc_JobId job,
+ glite_jobid_const_t job,
edg_wll_Event **eventsOut)
{
ctx->isProxy = 1;
int edg_wll_JobStatusProxy(
edg_wll_Context ctx,
- edg_wlc_JobId job,
+ glite_jobid_const_t job,
int flags,
edg_wll_JobStat *stat)
{
"char *", "EDG_WLL_ARGS_STRING",
"int", "EDG_WLL_ARGS_INT",
"double", "EDG_WLL_ARGS_DOUBLE",
- "edg_wlc_JobId", "EDG_WLL_ARGS_JOBID",
+ "glite_jobid_t", "EDG_WLL_ARGS_JOBID",
"edg_wll_NotifId", "EDG_WLL_ARGS_NOTIFID",
"edg_wll_Source", "EDG_WLL_ARGS_SOURCE",
"uint16_t", "EDG_WLL_ARGS_UINT16"
int i; /**< integer query attribute value */
char *c; /**< character query attribute value */
struct timeval t; /**< time query attribute value */
- edg_wlc_JobId j; /**< JobId query attribute value */
+ glite_jobid_const_t j; /**< JobId query attribute value */
} value, value2;
} edg_wll_QueryRec;
void edg_wll_add_float_to_XMLBody(char **body, const float toAdd, const char *tag, const float null);
void edg_wll_add_double_to_XMLBody(char **body, const double toAdd, const char *tag, const double null);
void edg_wll_add_timeval_to_XMLBody(char **body, struct timeval toAdd, const char *tag, const struct timeval null);
-void edg_wll_add_jobid_to_XMLBody(char **body, edg_wlc_JobId toAdd, const char *tag, const void *null);
+void edg_wll_add_jobid_to_XMLBody(char **body, glite_jobid_const_t toAdd, const char *tag, const void *null);
void edg_wll_add_notifid_to_XMLBody(char **body, edg_wll_NotifId toAdd, const char *tag, const void *null);
void edg_wll_add_edg_wll_JobStatCode_to_XMLBody(char **body, edg_wll_JobStatCode toAdd, const char *tag, const edg_wll_JobStatCode null);
void edg_wll_add_edg_wll_EventCode_to_XMLBody(char **body, edg_wll_EventCode toAdd, const char *tag, const edg_wll_EventCode null);
extern int edg_wll_NotifRequestToXML( edg_wll_Context ctx, const char *function, const edg_wll_NotifId notifId, const char *address, edg_wll_NotifChangeOp op, edg_wll_QueryRec const * const *conditions, char **message);
-extern int edg_wll_QuerySequenceCodeToXML(edg_wll_Context ctx, edg_wlc_JobId jobId, char **message);
+extern int edg_wll_QuerySequenceCodeToXML(edg_wll_Context ctx, glite_jobid_const_t jobId, char **message);
#ifdef __cplusplus
/* edg_wll_add_jobid_to_XMLBody(&body, eventsOut[i].any.jobId, "jobId", NULL) */
-void edg_wll_add_jobid_to_XMLBody(char **body, edg_wlc_JobId toAdd, const char *tag, const void *null)
+void edg_wll_add_jobid_to_XMLBody(char **body, glite_jobid_const_t toAdd, const char *tag, const void *null)
{
if (toAdd != (edg_wlc_JobId) null) {
char *newBody, *pom;
/* construct Message-Body of Request-Line for edg_wll_QuerySequeceCode function */
int edg_wll_QuerySequenceCodeToXML(
edg_wll_Context ctx,
- edg_wlc_JobId jobId,
+ glite_jobid_const_t jobId,
char **message)
{
char *pomA=NULL, *pomC=NULL;
#include "glite/lb/query_rec.h"
int convert_event_head(edg_wll_Context,char **,edg_wll_Event *);
-int check_strict_jobid(edg_wll_Context, const edg_wlc_JobId);
+int check_strict_jobid(edg_wll_Context, glite_jobid_const_t);
int match_status(edg_wll_Context, const edg_wll_JobStat *stat,const edg_wll_QueryRec **conditions);
#define NOTIF_ALL_JOBS "all_jobs"
int
edg_wll_EventSendProxy(
edg_wll_Context ctx,
- const edg_wlc_JobId jobid,
+ glite_jobid_const_t jobid,
const char *event)
{
long filepos;
int edg_wll_JobStatus(
edg_wll_Context ctx,
- const edg_wlc_JobId job,
+ glite_jobid_const_t job,
int flags,
edg_wll_JobStat *stat)
{
int edg_wll_intJobStatus(
edg_wll_Context ctx,
- const edg_wlc_JobId job,
+ glite_jobid_const_t job,
int flags,
intJobStat *intstat,
int update_db)
SUBJOB_CLASS_REST
} subjobClassCodes;
-int edg_wll_JobStatus(edg_wll_Context, const edg_wlc_JobId, int, edg_wll_JobStat *);
+int edg_wll_JobStatus(edg_wll_Context, glite_jobid_const_t, int, edg_wll_JobStat *);
void destroy_intJobStat(intJobStat *);
void destroy_intJobStat_extension(intJobStat *p);
-int edg_wll_intJobStatus( edg_wll_Context, const edg_wlc_JobId, int, intJobStat *, int);
+int edg_wll_intJobStatus( edg_wll_Context, glite_jobid_const_t, int, intJobStat *, int);
edg_wll_ErrorCode edg_wll_StoreIntState(edg_wll_Context, intJobStat *, int);
edg_wll_ErrorCode edg_wll_StoreIntStateEmbryonic(edg_wll_Context, edg_wlc_JobId, char *icnames, char *values, glite_lbu_bufInsert *bi);
edg_wll_ErrorCode edg_wll_LoadIntState(edg_wll_Context , edg_wlc_JobId , int, intJobStat **);
extern int debug;
-int edg_wll_JobSemaphore(const edg_wll_Context ctx, const edg_wlc_JobId job)
+int edg_wll_JobSemaphore(const edg_wll_Context ctx, glite_jobid_const_t job)
{
char *un = edg_wlc_JobIdGetUnique(job);
int n,i;
return(n % ctx->semaphores);
}
-int edg_wll_LockUnlockJob(const edg_wll_Context ctx,const edg_wlc_JobId job,int lock)
+int edg_wll_LockUnlockJob(const edg_wll_Context ctx,glite_jobid_const_t job,int lock)
{
struct sembuf s;
int n;
#define edg_wll_LockJob(ctx,job) edg_wll_LockUnlockJob((ctx),(job),-1)
#define edg_wll_UnlockJob(ctx,job) edg_wll_LockUnlockJob((ctx),(job),1)
-int edg_wll_LockUnlockJob(const edg_wll_Context,const edg_wlc_JobId,int);
-int edg_wll_JobSemaphore(const edg_wll_Context ctx, const edg_wlc_JobId job);
+int edg_wll_LockUnlockJob(const edg_wll_Context,glite_jobid_const_t,int);
+int edg_wll_JobSemaphore(const edg_wll_Context ctx, glite_jobid_const_t job);
#endif /* GLITE_LB_LOCK_H */
}
-int check_strict_jobid(edg_wll_Context ctx, const edg_wlc_JobId job)
+int check_strict_jobid(edg_wll_Context ctx, glite_jobid_const_t job)
{
char *job_host;
unsigned int job_port;
NULL
};
-static int purge_one(edg_wll_Context ctx,const edg_wlc_JobId,int,int);
+static int purge_one(edg_wll_Context ctx,glite_jobid_const_t,int,int);
int unset_proxy_flag(edg_wll_Context ctx, edg_wlc_JobId job);
static int unset_server_flag(edg_wll_Context ctx, edg_wlc_JobId job);
}
-int purge_one(edg_wll_Context ctx,const edg_wlc_JobId job,int dump, int purge)
+int purge_one(edg_wll_Context ctx,glite_jobid_const_t job,int dump, int purge)
{
char *dbjob;
char *stmt = NULL;
#include "db_supp.h"
static int store_user(edg_wll_Context,const char *,const char *);
-static int store_job(edg_wll_Context,const edg_wlc_JobId,const char *, int, int);
+static int store_job(edg_wll_Context,glite_jobid_const_t,const char *, int, int);
#ifdef LB_BUF
-static int store_job_block(edg_wll_Context, const edg_wlc_JobId, const char *, glite_lbu_bufInsert *, int, int);
+static int store_job_block(edg_wll_Context, glite_jobid_const_t, const char *, glite_lbu_bufInsert *, int, int);
#endif
-static int store_job_grey(edg_wll_Context,const edg_wlc_JobId,time_t);
+static int store_job_grey(edg_wll_Context,glite_jobid_const_t,time_t);
static int store_flesh(edg_wll_Context,edg_wll_Event *,char *,int);
static int store_seq(edg_wll_Context,edg_wll_Event *,int);
static int check_dup(edg_wll_Context,edg_wll_Event *);
return edg_wll_Error(ctx,NULL,NULL);
}
-static int store_job(edg_wll_Context ctx,const edg_wlc_JobId job,const char *userid, int proxy, int server)
+static int store_job(edg_wll_Context ctx,glite_jobid_const_t job,const char *userid, int proxy, int server)
{
char *jobstr = edg_wlc_JobIdUnparse(job);
char *jobid = edg_wlc_JobIdGetUnique(job);
}
#ifdef LB_BUF
-static int store_job_block(edg_wll_Context ctx,const edg_wlc_JobId job,const char *userid, glite_lbu_bufInsert *bi, int proxy, int server)
+static int store_job_block(edg_wll_Context ctx,glite_jobid_const_t job,const char *userid, glite_lbu_bufInsert *bi, int proxy, int server)
{
char *jobstr = edg_wlc_JobIdUnparse(job);
char *jobid = edg_wlc_JobIdGetUnique(job);
}
#endif
-static int store_job_grey(edg_wll_Context ctx,const edg_wlc_JobId job,time_t etime)
+static int store_job_grey(edg_wll_Context ctx,glite_jobid_const_t job,time_t etime)
{
char *jobstr = edg_wlc_JobIdUnparse(job);
char *jobid = edg_wlc_JobIdGetUnique(job);
userid = strdup(strmd5("unknown_to_proxy", NULL));
if (store_user(ctx,userid,"unknown_to_proxy")) goto err;
- if (store_job(ctx,(const edg_wlc_JobId) event->any.jobId,
+ if (store_job(ctx,(glite_jobid_const_t) event->any.jobId,
userid, 1, ctx->serverRunning)) goto err;
}
userid = strdup(strmd5(event->any.user, NULL));
if (store_user(ctx,userid,event->any.user)) goto err;
- if (store_job(ctx,(const edg_wlc_JobId) event->any.jobId,
+ if (store_job(ctx,(glite_jobid_const_t) event->any.jobId,
userid, 1, 0)) goto err;
}
}
userid = strdup(strmd5(event->any.user, NULL));
if (store_user(ctx,userid,event->any.user)) goto err;
- store_job(ctx,(const edg_wlc_JobId) event->any.jobId,
+ store_job(ctx,(glite_jobid_const_t) event->any.jobId,
userid, 1, 0);
edg_wll_ResetError(ctx);
userid = strdup(strmd5(can_peername, NULL));
if (store_user(ctx,userid,can_peername)) goto err;
- if (store_job(ctx,(const edg_wlc_JobId) event->any.jobId,
+ if (store_job(ctx,(glite_jobid_const_t) event->any.jobId,
userid, 0, 1)) goto err;
}
}
if (debug) {
char *cjobid = NULL, *cflags = NULL;
- cjobid = edg_wlc_JobIdUnparse((const edg_wlc_JobId) j);
+ cjobid = edg_wlc_JobIdUnparse(j);
cflags = edg_wll_stat_flags_to_string(flags);
dprintf(("[%d] \n\t<flags>%s</flags>\n\t<jobId>%s</jobId>\n\n",getpid(),cflags,cjobid));
free(cjobid);
extern int edg_wll_UserJobsResToSoap(
struct soap *,
- const edg_wlc_JobId *,
+ glite_jobid_const_t *,
const edg_wll_JobStat *,
struct _lbe__UserJobsResponse *);
taglist=>'"edg_wll_TagValue *"',
stslist=>'"struct _edg_wll_JobStat *"',
timeval=>'"struct timeval"',
- jobid=>'"edg_wlc_JobId"',
+ jobid=>'"glite_jobid_t"',
notifid=>'"edg_wll_NotifId"',
logsrc=>'"edg_wll_Source"',
port=>'"uint16_t"',
'C++'=>{
string=>'"std::string"',
timeval=>'"struct timeval"',
- jobid=>'"edg::workload::common::jobid::JobId"',
+ jobid=>'"glite::jobid::JobId"',
bool=>'"int"',
intlist=>'"std::vector<int>"',
strlist=>'"std::vector<std::string>"',