#include "glite/lb/events_parse.h"
#include "consumer.h"
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
static void free_events(edg_wll_Event *);
#include <stdio.h>
#include <unistd.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "producer.h"
#include "glite/lb/authz.h"
#include <errno.h>
#include <fcntl.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "producer.h"
#include "glite/lb/events.h"
#include <sys/wait.h>
#include "producer.h"
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
static void slave();
#include "glite/lb/events_parse.h"
#include "consumer.h"
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#ifdef USE_CALLBACKS
#include "glite/lb/consumer_fake.h"
#endif
#include <errno.h>
#include <fcntl.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "producer.h"
#include "glite/lb/events.h"
#include <string.h>
#include <errno.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "glite/lb/notifid.h"
#include "glite/lb/events.h"
#include <ctype.h>
#include <time.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "consumer.h"
#define BUFF_LEN 1024
#include <string.h>
#include <errno.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "consumer.h"
#include <signal.h>
#include <limits.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "producer.h"
#include "glite/lb/events.h"
#include <errno.h>
#include <fcntl.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "producer.h"
#include "glite/lb/events.h"
#ident "$Header$"
-#include "glite/wmsutils/jobid/JobId.h"
+#include "glite/jobid/JobId.h"
#include "glite/lb/Event.h"
* represent.
* \throws Exception Could not copy the job id.
*/
- Job(const glite::wmsutils::jobid::JobId &jobid);
+ Job(const glite::jobid::JobId &jobid);
/** Destructor.
* \returns Reference to this object.
* \throws Exception Could not copy the job id.
*/
- Job & operator= (const glite::wmsutils::jobid::JobId &jobid);
+ Job & operator= (const glite::jobid::JobId &jobid);
/*
* Status retrieval bitmasks. Used ORed as Job::status() argument,
private:
ServerConnection server;
- glite::wmsutils::jobid::JobId jobId;
+ glite::jobid::JobId jobId;
};
EWL_END_NAMESPACE
#include <utility>
#include <vector>
-#include "glite/wmsutils/jobid/JobId.h"
+#include "glite/jobid/JobId.h"
#include "glite/lb/jobstat.h"
#include "glite/lb/CountRef.h"
* \returns Value of attribute.
* \throws LoggingException Invalid attribute name.
*/
- const glite::wmsutils::jobid::JobId getValJobId(Attr name) const;
+ const glite::jobid::JobId getValJobId(Attr name) const;
/** Access method for attribute values.
*
#define GLITE_LB_NOTIFICATION_HPP
-#include "glite/wmsutils/jobid/JobId.h"
+#include "glite/jobid/JobId.h"
#include "glite/lb/consumer.h"
#include "glite/lb/notification.h"
* to propagate changes to server
* \param[in] jobId JobId
*/
- void addJob(const glite::wmsutils::jobid::JobId &jobId);
+ void addJob(const glite::jobid::JobId &jobId);
/** Remove job from the list, local op again.
* \param[in] jobId JobId
*/
- void removeJob(const glite::wmsutils::jobid::JobId &jobId);
+ void removeJob(const glite::jobid::JobId &jobId);
/** Get jobs on the list */
std::string getJobs();
int receive(glite::lb::JobStatus &,timeval &);
private:
- std::vector<glite::wmsutils::jobid::JobId> jobs;
+ std::vector<glite::jobid::JobId> jobs;
std::vector<glite::lb::JobStatus::Code> states;
edg_wll_Context ctx;
#include <string.h>
#include <list>
-#include "glite/wmsutils/jobid/JobId.h"
+#include "glite/jobid/JobId.h"
#include "glite/lb/Event.h"
#include "glite/lb/JobStatus.h"
* \param[in] value Actual value.
* \throw Exception Invalid value type for given attribute.
*/
- QueryRecord(const Attr name, const Op op, const glite::wmsutils::jobid::JobId &value);
+ QueryRecord(const Attr name, const Op op, const glite::jobid::JobId &value);
/* this one is for attr==TIME and particular state */
/** Constructor for condition on timeval typed value.
std::string tag_name;
int state;
std::string string_value;
- glite::wmsutils::jobid::JobId jobid_value;
+ glite::jobid::JobId jobid_value;
int int_value;
struct timeval timeval_value;
std::string string_value2;
* \throws LoggingException Query failed.
*/
void queryJobs(const std::vector<QueryRecord>& query,
- std::vector<glite::wmsutils::jobid::JobId>& jobList) const;
+ std::vector<glite::jobid::JobId>& jobList) const;
/** Convenience form of queryJobs.
*
* The same as above, but job id's are passed as a return
* value.
*/
- const std::vector<glite::wmsutils::jobid::JobId>
+ const std::vector<glite::jobid::JobId>
queryJobs(const std::vector<QueryRecord>& query) const;
* \throws LoggingException Query failed.
*/
void queryJobs(const std::vector<std::vector<QueryRecord> >& query,
- std::vector<glite::wmsutils::jobid::JobId>& jobList) const;
+ std::vector<glite::jobid::JobId>& jobList) const;
/** Convenience form of queryJobs.
*
* Same as above, but result is passed as a retutrn value.
*/
- const std::vector<glite::wmsutils::jobid::JobId>
+ const std::vector<glite::jobid::JobId>
queryJobs(const std::vector<std::vector<QueryRecord> >& query) const;
/** Retrieve status of jobs satisfying the given simple query.
* \param[out] jobs Id's of jobs owned by this user.
* \throws LoggingException Query failed.
*/
- void userJobs(std::vector<glite::wmsutils::jobid::JobId> &jobs) const;
+ void userJobs(std::vector<glite::jobid::JobId> &jobs) const;
/** Convenience form of userJobs.
*
* Same as above, but results are passed as a return value.
*/
- const std::vector<glite::wmsutils::jobid::JobId> userJobs() const;
+ const std::vector<glite::jobid::JobId> userJobs() const;
/** Set communication parameters of integer type.
*
#ident "$Header$"
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "glite/lb/context.h"
#include "glite/lb/events.h"
#include "glite/lb/jobstat.h"
#ident "$Header$"
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "glite/lb/notifid.h"
#include "glite/lb/notif_rec.h"
#include "glite/lb/context.h"
#include <errno.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "glite/lb/Event.h"
-#include "glite/wmsutils/jobid/JobIdExceptions.h"
#include "glite/lb/events.h"
#include "glite/lb/notifid.h"
#include "glite/lb/LoggingExceptions.h"
}
const
-glite::wmsutils::jobid::JobId
+glite::jobid::JobId
Event::getValJobId(Attr attr) const
{
edg_wll_Event const *cev = (edg_wll_Event *) flesh->ptr;
try {
edg_wlc_JobId job_id = get_val_jobid(cev,attr);
- return(glite::wmsutils::jobid::JobId(job_id));
+ return(glite::jobid::JobId(job_id));
}
catch (Exception &e) {
STACK_ADD;
#include <string>
-#include "glite/wmsutils/jobid/JobIdExceptions.h"
-
#include "glite/lb/Job.h"
#include "glite/lb/consumer.h"
#include "glite/lb/LoggingExceptions.h"
const int Job::STAT_CHILDREN = EDG_WLL_STAT_CHILDREN;
const int Job::STAT_CHILDSTAT = EDG_WLL_STAT_CHILDSTAT;
-Job::Job(void)
+Job::Job(void)
+ : jobId()
{
}
-Job::Job(const glite::wmsutils::jobid::JobId &in)
+Job::Job(const glite::jobid::JobId &in)
+ : jobId(in)
{
- try {
- jobId = in;
- } catch (Exception &e) {
- STACK_ADD;
- throw;
- }
}
}
-Job & Job::operator= (const glite::wmsutils::jobid::JobId &in)
+Job & Job::operator= (const glite::jobid::JobId &in)
{
try {
jobId = in;
try {
edg_wll_JobStat *cstat = jobStatus.c_ptr();
int ret = edg_wll_JobStatus(server.getContext(),
- jobId, // automagically converted by member operator
+ const_cast<glite_jobid_t>(jobId.c_jobid()),
flags,
cstat);
check_result(ret,
try {
context = server.getContext();
- result = edg_wll_JobLog(context, jobId, &events);
+ result = edg_wll_JobLog(context, const_cast<glite_jobid_t>(jobId.c_jobid()), &events);
if (result == E2BIG) {
edg_wll_Error(context, NULL, &errstr);
check_result(edg_wll_GetParam(context,
try {
int ret = edg_wll_QueryListener(server.getContext(),
- jobId,
- name.c_str(),
- &c_host,
- &port);
+ const_cast<glite_jobid_t>(jobId.c_jobid()),
+ name.c_str(),
+ &c_host,
+ &port);
check_result(ret,
server.getContext(),
"edg_wll_QueryListener");
#include <errno.h>
#include <stdlib.h>
-#include "glite/wmsutils/jobid/JobId.h"
+#include "glite/jobid/JobId.h"
#include "glite/lb/LoggingExceptions.h"
#include "glite/lb/consumer.h"
const
-glite::wmsutils::jobid::JobId
+glite::jobid::JobId
JobStatus::getValJobId(Attr attr) const
{
edg_wll_JobStat const *cstat = (edg_wll_JobStat *) flesh->ptr;
try {
edg_wlc_JobId job_id = get_val_jobid(cstat, attr);
- return(glite::wmsutils::jobid::JobId(job_id));
+ return(glite::jobid::JobId(job_id));
}
catch(Exception &e) {
STACK_ADD;
}
void
-Notification::addJob(const glite::wmsutils::jobid::JobId &jobId)
+Notification::addJob(const glite::jobid::JobId &jobId)
{
- std::vector<glite::wmsutils::jobid::JobId>::iterator it;
+ std::vector<glite::jobid::JobId>::iterator it;
try {
if (this->notifId != NULL) {
}
void
-Notification::removeJob(const glite::wmsutils::jobid::JobId &jobId)
+Notification::removeJob(const glite::jobid::JobId &jobId)
{
- std::vector<glite::wmsutils::jobid::JobId>::iterator it;
+ std::vector<glite::jobid::JobId>::iterator it;
int removed = 0;
try {
std::string
Notification::getJobs(void)
{
- std::vector<glite::wmsutils::jobid::JobId>::iterator it;
+ std::vector<glite::jobid::JobId>::iterator it;
std::string ret="";
try {
Notification::Register(void)
{
int ret = 0;
- std::vector<glite::wmsutils::jobid::JobId>::iterator it;
+ std::vector<glite::jobid::JobId>::iterator it;
std::vector<glite::lb::JobStatus::Code>::iterator its;
std::vector<std::vector<glite::lb::QueryRecord> > queryExt;
edg_wll_QueryRec **conditions = NULL;
#include <expat.h>
-#include "glite/wmsutils/jobid/JobId.h"
-#include "glite/wmsutils/jobid/JobIdExceptions.h"
+#include "glite/jobid/JobId.h"
#include "glite/lb/context-int.h"
#include "glite/lb/xml_conversions.h"
QueryRecord::QueryRecord(const Attr a,
const Op o,
- const glite::wmsutils::jobid::JobId& v)
+ const glite::jobid::JobId& v)
: attr(a), oper(o), state(EDG_WLL_JOB_UNDEF), jobid_value(v)
{
switch(a) {
break;
case JOBID:
- out.value.j = jobid_value;
- break;
+ if(glite_jobid_dup(jobid_value.c_jobid(), &out.value.j)) {
+ throw std::bad_alloc();
+ }
+ break;
case UNDEF:
break;
edg_wll_QueryRecFree(v);
}
+// static
+void freeQueryRecVectorExt(edg_wll_QueryRec **v)
+{
+ for(; *v; v++)
+ edg_wll_QueryRecFree(*v);
+}
+
std::vector<std::vector<std::pair<QueryRecord::Attr,std::string> > >
ServerConnection::getIndexedAttrs(void) {
edg_wll_QueryRec **recs;
}
free(events);
+ freeQueryRecVector(job_rec);
+ freeQueryRecVector(event_rec);
delete[] job_rec;
delete[] event_rec;
} catch(Exception &e) {
+ freeQueryRecVector(job_rec);
+ freeQueryRecVector(event_rec);
if(job_rec) delete[] job_rec;
if(event_rec) delete[] event_rec;
if(events) free(events);
free(events);
- for(i = 0 ; job_rec[i]; i++) delete[] job_rec[i];
- for(i = 0 ; event_rec[i]; i++) delete[] event_rec[i];
+ freeQueryRecVectorExt(job_rec);
+ freeQueryRecVectorExt(event_rec);
delete[] job_rec;
delete[] event_rec;
} catch(Exception &e) {
- if(job_rec) {
- for(i = 0 ; job_rec[i]; i++) delete[] job_rec[i];
- delete[] job_rec;
- }
- if(event_rec) {
- for(i = 0 ; event_rec[i]; i++) delete[] event_rec[i];
- delete[] event_rec;
- }
+ freeQueryRecVectorExt(job_rec);
+ freeQueryRecVectorExt(event_rec);
+ delete[] job_rec;
+ delete[] event_rec;
if(events) free(events);
STACK_ADD;
void ServerConnection::queryJobs(const std::vector<QueryRecord>& query,
- std::vector<glite::wmsutils::jobid::JobId> & ids) const
+ std::vector<glite::jobid::JobId> & ids) const
{
edg_wll_QueryRec *cond = NULL;
edg_wlc_JobId *jobs, *j;
}
for(j = jobs; *j; j++)
- ids.push_back(glite::wmsutils::jobid::JobId(*j));
+ ids.push_back(glite::jobid::JobId(*j));
if (result) {
edg_wll_SetError(context, result, errstr);
}
-const std::vector<glite::wmsutils::jobid::JobId>
+const std::vector<glite::jobid::JobId>
ServerConnection::queryJobs(const std::vector<QueryRecord>& query) const
{
- std::vector<glite::wmsutils::jobid::JobId> jobList;
+ std::vector<glite::jobid::JobId> jobList;
queryJobs(query, jobList);
return jobList;
void
ServerConnection::queryJobs(const std::vector<std::vector<QueryRecord> >& query,
- std::vector<glite::wmsutils::jobid::JobId>& ids) const
+ std::vector<glite::jobid::JobId>& ids) const
{
edg_wll_QueryRec **cond = NULL;
edg_wlc_JobId *jobs, *j;
}
for(j = jobs; *j; j++)
- ids.push_back(glite::wmsutils::jobid::JobId(*j));
+ ids.push_back(glite::jobid::JobId(*j));
if (result) {
edg_wll_SetError(context, result, errstr);
const
-std::vector<glite::wmsutils::jobid::JobId>
+std::vector<glite::jobid::JobId>
ServerConnection::queryJobs(const std::vector<std::vector<QueryRecord> >& query) const
{
- std::vector<glite::wmsutils::jobid::JobId> jobList;
+ std::vector<glite::jobid::JobId> jobList;
queryJobs(query, jobList);
return jobList;
}
-void ServerConnection::userJobs(std::vector<glite::wmsutils::jobid::JobId> & ids) const
+void ServerConnection::userJobs(std::vector<glite::jobid::JobId> & ids) const
{
edg_wlc_JobId *jobs, *j;
int result, qresults_param;
}
for(j = jobs; *j; j++)
- ids.push_back(glite::wmsutils::jobid::JobId(*j));
+ ids.push_back(glite::jobid::JobId(*j));
if (result) {
edg_wll_SetError(context, result, errstr);
}
-const std::vector<glite::wmsutils::jobid::JobId>
+const std::vector<glite::jobid::JobId>
ServerConnection::userJobs() const
{
- std::vector<glite::wmsutils::jobid::JobId> jobList;
+ std::vector<glite::jobid::JobId> jobList;
userJobs(jobList);
return jobList;
#include <expat.h>
+#include "glite/jobid/cjobid.h"
#include "glite/lb/context-int.h"
#include "glite/lb/mini_http.h"
#include "glite/lb/xml_parse.h"
#include <ctype.h> // isspace
#include "glite/security/glite_gss.h"
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "glite/lb/notifid.h"
#include "glite/lb/events.h"
#include <fcntl.h>
#include <sys/time.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "glite/lb/producer.h"
#include "glite/lb/events.h"
#include <syslog.h>
#include <string.h>
-#include "glite/wmsutils/jobid/strmd5.h"
+#include "glite/jobid/cjobid.h"
+#include "glite/jobid/strmd5.h"
#include "glite/lb/ulm_parse.h"
#include "glite/lb/trio.h"
#include "glite/lb/context-int.h"
@@@LANG: C
#include <stdlib.h>
-#include "glite/wmsutils/jobid/cjobid.h"
+#include "glite/jobid/cjobid.h"
#include "glite/lb/producer.h"
@@@{