LIBOBJS:=connection.o consumer.o notification.o prod_proto.o \
producer.o uiwrap.o statistics.o
-PLUSOBJS:=Event.o Job.o JobStatus.o Notification.o ServerConnection.o
+PLUSOBJS:=Event.o Job.o JobStatus.o Notification.o ServerConnection.o stat_fields.o
HDRS:=consumer.h notification.h statistics.h prod_proto.h connection.h \
Job.h Notification.h ServerConnection.h
logevent: logevent.o args.o
${LINK} -o $@ logevent.o args.o ${LIB} ${EXT_LIB}
-notify: notify.o notify_supp.o
- ${LINKXX} -o $@ notify.o notify_supp.o ${PLUSLIB} ${EXT_LIB}
+notify: notify.o
+ ${LINKXX} -o $@ notify.o ${PLUSLIB} ${EXT_LIB}
${TOOLS} ${EXAMPLES}: %: %.o
${LINK} -o $@ $< ${LIB} ${EXT_LIB}
${TOOLS}: ${LIB}
-notify_supp.o ${PLUSOBJS}: %.o: %.cpp
+${PLUSOBJS}: %.o: %.cpp
${CXXCOMPILE} -c $<
${PLUSTHROBJS}: %.thr.o: %.cpp
--- /dev/null
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+char * glite_lb_parse_stat_fields(const char *,void **);
+void glite_lb_print_stat_fields(void **,edg_wll_JobStat *);
+void glite_lb_dump_stat_fields(void);
+
+
+#ifdef __cplusplus
+}
+#endif
#include "glite/lb/context.h"
#include "notification.h"
-#include "notify_supp.h"
+#include "stat_fields.h"
static char *me;
"\n -a, -t, and -r are unusable with -s\n"
, me);
fprintf(stderr,"\navailable fields:\n\t");
- dump_fields();
+ glite_lb_dump_stat_fields();
putc(10,stderr);
}
if ( !cmd || !strcmp(cmd, "drop") )
if (opt_valid == 0) opt_valid = 3600;
- if ((err = parse_fields(field_arg,&fields))) {
+ if ((err = glite_lb_parse_stat_fields(field_arg,&fields))) {
fprintf(stderr,"%s: invalid argument\n",err);
return EX_USAGE;
}
if (err != ETIMEDOUT) goto receive_err;
}
- else print_fields(fields,recv_nid,&stat);
+ else glite_lb_print_stat_fields(fields,&stat);
if ((now = time(NULL)) >= client_tout) return 0;
+++ /dev/null
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-char * parse_fields(const char *,void **);
-void print_fields(void **,const edg_wll_NotifId,edg_wll_JobStat *);
-void dump_fields(void);
-
-
-#ifdef __cplusplus
-}
-#endif
#include "JobStatus.h"
#include "notification.h"
-#include "notify_supp.h"
+#include "stat_fields.h"
using namespace glite::lb;
typedef std::pair<JobStatus::Attr,std::string> FieldPair;
-char * parse_fields(const char *arg,void **out)
+char * glite_lb_parse_stat_fields(const char *arg,void **out)
{
char *aux = strdup(arg),*p;
std::vector<FieldPair> *fields = new std::vector<FieldPair>;
}
-std::string & escape(std::string &s)
+static std::string & escape(std::string &s)
{
for (std::string::iterator p = s.begin(); p < s.end(); p++) switch (*p) {
case '\n':
typedef std::vector<std::pair<JobStatus::Attr,JobStatus::AttrType> > attrs_t;
-void dump_fields(void)
+void glite_lb_dump_stat_fields(void)
{
JobStatus s;
attrs_t a = s.getAttrs();
extern "C" { char * TimeToStr(time_t); }
-void print_fields(void **ff,const edg_wll_NotifId n,edg_wll_JobStat *s)
+void glite_lb_print_stat_fields(void **ff,edg_wll_JobStat *s)
{
std::vector<FieldPair> *fields = (std::vector<FieldPair> *) ff;
JobStatus stat(*s,0);