${INSTALL} -m 644 ${top_srcdir}/interface/srv_perf.h ${PREFIX}/include/${globalprefix}/${lbprefix}
clean:
- rm -rf *.c *.h *.ch *.xh *.xml *.nsmap *.o *.lo .libs glite-lb-* ${STATIC_LIB_BK} test*
+ rm -rvf *.c *.h *.ch *.xh *.xml *.nsmap *.o *.lo .libs glite-lb-* ${STATIC_LIB_BK} ${PLUGIN_LIB} test*
+ rm -rvf log.xml project/ rpmbuild/ RPMS/ tgz/
%.c: %.c.T
rm -f $@
#include <sys/types.h>
#include <sys/time.h>
-#include "glite/lb/consumer.h"
+#include "glite/lb/context.h"
#ifdef __cplusplus
extern "C" {
-#ifndef _LBS_STORE_H
-#define _LBS_STORE_H
+#ifndef __GLITE_LB_STORE_H__
+#define __GLITE_LB_STORE_H__
#ident "$Header$"
-#include "glite/lb/consumer.h"
#include "jobstat.h"
#include "lb_authz.h"
}
#endif
-#endif
+#endif /* __GLITE_LB_STORE_H__ */
#include <assert.h>
#include "glite/wmsutils/jobid/strmd5.h"
-#include "glite/lb/consumer.h"
#include "glite/lb/context-int.h"
#include "index.h"
#include "lbs_db.h"
#include "glite/security/glite_gss.h"
#include "glite/lb/srvbones.h"
-#include "glite/lb/consumer.h"
-#include "glite/lb/purge.h"
#include "glite/lb/context.h"
#include "glite/lb/mini_http.h"
#include "glite/lb/context-int.h"
#include <errno.h>
#include <stdlib.h>
-#include "glite/lb/consumer.h"
#include "glite/lb/context-int.h"
#include "glite/lb/events_parse.h"
#include "glite/lb/lb_maildir.h"
-#include "glite/lb/purge.h"
#include "purge.h"
#include "store.h"
#include "lbs_db.h"
#include "glite/lb/context-int.h"
#include "glite/lb/events_parse.h"
#include "glite/lb/ulm_parse.h"
-#include "glite/lb/purge.h"
-#include "glite/lb/purge.h"
-#include "glite/lb/dump.h"
#include "lbs_db.h"
#include "query.h"
+#ifndef __GLITE_LB_GET_EVENTS_H__
+#define __GLITE_LB_GET_EVENTS_H__
#ident "$Header$"
+#include "glite/lb/context.h"
+#include "glite/lb/events.h"
+#include "glite/lb/query_rec.h"
+
/* Internal functions for getting event sets from the LB database */
#include "lbs_db.h"
}
#endif
+#endif /* __GLITE_LB_GET_EVENTS_H__ */
-#ifndef IL_LBPROXY_H
-#define IL_LBPROXY_H
+#ifndef __GLITE_LB_IL_LBPROXY_H__
+#define __GLITE_LB_IL_LBPROXY_H__
+
+#include "glite/lb/context.h"
#ifdef __cplusplus
#extern "C" {
}
#endif
-#endif
+#endif /* __GLITE_LB_IL_LBPROXY_H__ */
-#ifndef IL_NOTIFICATION_H
-#define IL_NOTIFICATION_H
+#ifndef __GLITE_LB_IL_NOTIFICATION_H__
+#define __GLITE_LB_IL_NOTIFICATION_H__
+
+#ident "$Header$"
/* needed for the edg_wll_NotifId */
-#include "glite/lb/notification.h"
+#include "glite/lb/notifid.h"
+
/* import the edg_wll_JobStat structure */
#include "glite/lb/jobstat.h"
}
#endif
-#endif
+#endif /* __GLITE_LB_IL_NOTIFICATION_H__ */
#include <regex.h>
#include <syslog.h>
-#include "glite/lb/producer.h"
+#include "glite/lb/events.h"
#include "glite/lb/context-int.h"
#include "glite/lb/trio.h"
-/* $Header$ */
-
-#ifndef _LBS_JOBSTAT_H
-#define _LBS_JOBSTAT_H
+#ifndef __GLITE_LB_LBS_JOBSTAT_H__
+#define __GLITE_LB_LBS_JOBSTAT_H__
+#ident "$Header$"
+#include "glite/lb/jobstat.h"
#include "lbs_db.h"
/*
edg_wll_ErrorCode edg_wll_GetSubjobHistogram(edg_wll_Context, edg_wlc_JobId parent_jobid, int *hist);
edg_wll_ErrorCode edg_wll_StoreSubjobHistogram(edg_wll_Context, edg_wlc_JobId parent_jobid, intJobStat *ijs);
-#endif
+#endif /* __GLITE_LB_LBS_JOBSTAT_H__*/
#include <syslog.h>
#include "glite/wmsutils/jobid/cjobid.h"
-#include "glite/lb/producer.h"
#include "glite/lb/context-int.h"
#include "glite/lb/trio.h"
#include "glite/security/voms/voms_apic.h"
#include "glite/wmsutils/jobid/strmd5.h"
#include "glite/wmsutils/jobid/cjobid.h"
-#include "glite/lb/producer.h"
#include "glite/lb/trio.h"
#include "lbs_db.h"
#include "lb_html.h"
#include "lb_proto.h"
-#include "glite/lb/consumer.h"
#include "glite/lb/context-int.h"
#include <string.h>
-#ifndef _LB_HTML
-#define _LB_HTML
+#ifndef __GLITE_LB_HTML_H__
+#define __GLITE_LB_HTML_H__
#ident "$Header$"
-#include "glite/lb/consumer.h"
+#include "glite/lb/context.h"
+#include "glite/lb/events.h"
+#include "glite/lb/jobstat.h"
int edg_wll_QueryToHTML(edg_wll_Context,edg_wll_Event *,char **);
int edg_wll_JobStatusToHTML(edg_wll_Context, edg_wll_JobStat, char **);
int edg_wll_UserJobsToHTML(edg_wll_Context, edg_wlc_JobId *, char **);
char *edg_wll_ErrorToHTML(edg_wll_Context,int);
-#endif
+#endif /* __GLITE_LB_HTML_H__ */
#include <errno.h>
#include <unistd.h>
-#include "glite/lb/consumer.h"
#include "glite/lb/mini_http.h"
#include "glite/lb/context-int.h"
-#ifndef _LB_HTTP_H
-#define _LB_HTTP_H
+#ifndef __GLITE_LB_HTTP_H__
+#define __GLITE_LB_HTTP_H__
#ident "$Header$"
-#include <stdio.h>
-
-#include "glite/lb/consumer.h"
+#include "glite/lb/context.h"
int edg_wll_ServerHTTP(edg_wll_Context);
int edg_wll_ServerHTTPProxy(edg_wll_Context);
-#endif
+#endif /* __GLITE_LB_HTTP_H__ */
#include "glite/lb/events.h"
#include "glite/lb/events_parse.h"
#include "glite/lb/trio.h"
-#include "glite/lb/producer.h"
#include "jobstat.h"
#include "get_events.h"
#include <expat.h>
-#include "glite/lb/consumer.h"
#include "glite/lb/context-int.h"
#include "glite/lb/mini_http.h"
#include "glite/lb/xml_conversions.h"
-#include "glite/lb/dump.h"
-#include "glite/lb/load.h"
-#include "glite/lb/purge.h"
#include "lb_proto.h"
#include "lb_html.h"
-#ifndef _LB_PROTO_H
-#define _LB_PROTO_H
+#ifndef __GLITE_LB_PROTO_H__
+#define __GLITE_LB_PROTO_H__
#ident "$Header$"
-#include "glite/lb/consumer.h"
+#include "glite/lb/context.h"
extern const char* const response_headers[];
extern char *edg_wll_HTTPErrorMessage(int);
-#endif
+#endif /* __GLITE_LB_PROTO_H__ */
#include "glite/wmsutils/jobid/cjobid.h"
-#include "glite/lb/consumer.h"
#include "glite/lb/escape.h"
#include "glite/lb/context-int.h"
#include "glite/lb/trio.h"
#include "glite/lb/xml_conversions.h"
-#include "glite/lb/purge.h"
-#include "glite/lb/dump.h"
-#include "glite/lb/load.h"
-
#include "lb_xml_parse.h"
#ifdef __GNUC__
-#ifndef _LB_XML_PARSE_H
-#define _LB_XML_PARSE_H
+#ifndef __GLITE_LB_LB_XML_PARSE_H__
+#define __GLITE_LB_LB_XML_PARSE_H__
#ident "$Header$"
-#include "glite/lb/consumer.h"
-#include "glite/lb/notification.h"
-#include "glite/lb/purge.h"
-#include "glite/lb/dump.h"
-#include "glite/lb/load.h"
+#include "glite/lb/context.h"
+#include "glite/lb/jobstat.h"
+#include "glite/lb/notif_rec.h"
+#include "glite/lb/query_rec.h"
#ifdef __cplusplus
extern "C" {
}
#endif
-#endif
+#endif /* __GLITE_LB_LB_XML_PARSE_H__ */
#include "glite/wmsutils/jobid/cjobid.h"
-#include "glite/lb/consumer.h"
#include "glite/lb/escape.h"
#include "glite/lb/context-int.h"
#include "glite/lb/trio.h"
#include "glite/lb/xml_conversions.h"
-#include "glite/lb/purge.h"
-#include "glite/lb/dump.h"
-
#include "lb_xml_parse_V21.h"
#ifdef __GNUC__
-#ifndef _LB_XML_PARSE_H_V21
-#define _LB_XML_PARSE_H_V21
+#ifndef __GLITE_LB_LB_XML_PARSE_V21_H__
+#define __GLITE_LB_LB_XML_PARSE_V21_H__
#ident "$Header$"
-#include "glite/lb/consumer.h"
+#include "glite/lb/context.h"
+#include "glite/lb/jobstat.h"
+#include "glite/lb/query_rec.h"
/* function for parsing/unparsing XML requests from client */
int edg_wll_PurgeResultToXMLV21(edg_wll_Context ctx, edg_wll_PurgeResult *result, char **message);
int edg_wll_DumpResultToXMLV21(edg_wll_Context ctx, edg_wll_DumpResult *result, char **message);
-#endif
+#endif /* __GLITE_LB_LB_XML_PARSE_V21_H__ */
#include "glite/lb/context-int.h"
#include "glite/lb/events_parse.h"
#include "glite/lb/ulm_parse.h"
-#include "glite/lb/purge.h"
-#include "glite/lb/purge.h"
#include "glite/lb/events.h"
-#include "glite/lb/dump.h"
-#include "glite/lb/load.h"
#include "store.h"
#include "purge.h"
+#ifndef __GLITE_LB_LOCK_H__
+#define __GLITE_LB_LOCK_H__
+
+#ident "$Header$"
+
+#include "glite/lb/context.h"
+
#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);
+
+#endif /* __GLITE_LB_LOCK_H__ */
#include <stdio.h>
#include <syslog.h>
-#include "glite/lb/producer.h"
-#include "glite/lb/consumer.h"
#include "glite/lb/context-int.h"
#include "glite/lb/trio.h"
#include "glite/lb/trio.h"
#include "glite/lb/context-int.h"
#include "glite/lb/xml_parse.h"
-#include "glite/lb/notification.h"
+
#include "il_notification.h"
#include "lbs_db.h"
#include "query.h"
#ident "$Header$"
-#include <stdlib.h>
-
-#include "glite/lb/consumer.h"
#include "glite/lb/context-int.h"
#include "lbs_db.h"
#include <assert.h>
#include <syslog.h>
-#include "glite/lb/producer.h"
#include "glite/lb/context-int.h"
#include "jobstat.h"
#include <assert.h>
#include <syslog.h>
-#include "glite/lb/producer.h"
#include "glite/lb/context-int.h"
#include "jobstat.h"
#include <assert.h>
#include <syslog.h>
-#include "glite/lb/producer.h"
#include "glite/lb/context-int.h"
#include "jobstat.h"
-#ifndef __EDG_WORKLOAD_LOGGING_COMMON_PURGE_H__
-#define __EDG_WORKLOAD_LOGGING_COMMON_PURGE_H__
+#ifndef __GLITE_LB_PURGE_H__
+#define __GLITE_LB_PURGE_H__
+
+#ident "$Header"
+
+#include "glite/lb/context.h"
/** Server side implementation
* besides output to the SSL stream (in the context) it may produce
#define edg_wll_CreateDumpFile(ctx, f) edg_wll_CreateFileStorage(ctx,FILE_TYPE_DUMP,NULL,f)
#define edg_wll_CreatePurgeFile(ctx, f) edg_wll_CreateFileStorage(ctx,FILE_TYPE_PURGE,NULL,f)
-#endif
+#endif /* __GLITE_LB_PURGE_H__ */
#include "glite/wmsutils/jobid/strmd5.h"
-#include "glite/lb/consumer.h"
-#include "glite/lb/producer.h"
#include "glite/lb/context-int.h"
#include "glite/lb/trio.h"
#include "glite/lb/xml_conversions.h"
+#ifndef __GLITE_LB_SERVER_QUERY_H__
+#define __GLITE_LB_SERVER_QUERY_H__
+
+#ident "$Header$"
+
+#include "glite/lb/context.h"
+#include "glite/lb/events.h"
+#include "glite/lb/jobstat.h"
+#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 match_status(edg_wll_Context, const edg_wll_JobStat *stat,const edg_wll_QueryRec **conditions);
#define NOTIF_ALL_JOBS "all_jobs"
+
+#endif /* __GLITE_LB_SERVER_QUERY_H__ */
-#ifndef _EDG_WORKLOAD_LOGGING_LBSERVER_H_
-#define EDG_WLL_STATE_DUMP_START "StartDump"
-#define EDG_WLL_STATE_DUMP_END "EndDump"
+#ifndef __GLITE_LB_SERVER_STATE_H__
+#define __GLITE_LB_SERVER_STATE_H__
#ident "$Header$"
+#define EDG_WLL_STATE_DUMP_START "StartDump"
+#define EDG_WLL_STATE_DUMP_END "EndDump"
+
int edg_wll_GetServerState(edg_wll_Context,const char *,char **);
int edg_wll_SetServerState(edg_wll_Context,const char *,const char *);
-#endif
+#endif /* __GLITE_LB_SERVER_STATE_H__ */
#include "lbs_db.h"
#include "query.h"
#include "get_events.h"
-#include "glite/lb/purge.h"
-#include "glite/lb/load.h"
-#include "glite/lb/dump.h"
#include "purge.h"
#include "lb_xml_parse.h"
-#ifndef __EDG_WORKLOAD_LOGGING_LBSERVER_STATS_H__
-#define __EDG_WORKLOAD_LOGGING_LBSERVER_STATS_H__
+#ifndef __GLITE_LB_STATS_H__
+#define __GLITE_LB_STATS_H__
+
+#ident "$Header$"
+
+#include "glite/lb/context.h"
+#include "glite/lb/events.h"
+#include "glite/lb/jobstat.h"
+#include "glite/lb/query_rec.h"
int edg_wll_InitStatistics(edg_wll_Context);
int *res_to
);
-#endif
+#endif /* __GLITE_LB_STATS_H__ */
#include "glite/lb/events_parse.h"
#include "glite/lb/context-int.h"
-#include "glite/lb/producer.h"
#include "glite/lb/log_proto.h" /* for EDG_WLL_LOG_USER_DEFAULT */
#include "glite/lb/trio.h"
#include <cclassad.h>
#include "glite/lb/trio.h"
-#include "glite/lb/producer.h"
#include "glite/lb/context-int.h"
#include "glite/lb/jobstat.h"
-#ifndef __EDG_WORKLOAD_LOGGING_LBSERVER_WS_FAULT_H__
-#define __EDG_WORKLOAD_LOGGING_LBSERVER_WS_FAULT_H__
+#ifndef __GLITE_LB_WS_FAULT_H__
+#define __GLITE_LB_WS_FAULT_H__
+
+#ident "$Header$"
+
+#include "glite/lb/context.h"
extern void edg_wll_ErrToFault(const edg_wll_Context, struct soap *);
extern void edg_wll_FaultToErr(const struct soap *, edg_wll_Context);
-#endif /* __EDG_WORKLOAD_LOGGING_LBSERVER_WS_FAULT_H__ */
+#endif /* __GLITE_LB_WS_FAULT_H__ */
#include <expat.h>
#include "glite/lb/context-int.h"
-#include "glite/lb/consumer.h"
#include "glite/lb/xml_parse.h"
#include "glite/lb/xml_conversions.h"
+#ifndef __GLITE_LB_WS_TYPEMAP_H__
+#define __GLITE_LB_WS_TYPEMAP_H__
+
+#ident "$Header"
+
#if GSOAP_VERSION >= 20700
#define JOBID lbt__queryAttr__JOBID
#define LBServer lbt__eventSource__LBServer
#endif
+
+#endif /* __GLITE_LB_WS_TYPEMAP_H__ */
#include "bk_ws_H.h"
#include "ws_typemap.h"
-#include "glite/lb/consumer.h"
+#include "glite/lb/events.h"
+#include "glite/lb/query_rec.h"
/* XXX: references only, src and dest share pointers */
#include "glite/security/glite_gscompat.h"
-#ifndef __EDG_WORKLOAD_LOGGING_LBSERVER_WS_TYPEREF_H__
-#define __EDG_WORKLOAD_LOGGING_LBSERVER_WS_TYPEREF_H__
+#ifndef __GLITE_LB_WS_TYPEREF_H__
+#define __GLITE_LB_WS_TYPEREF_H__
+
+#ident "$Header"
+
+#include "glite/lb/jobstat.h"
+#include "glite/lb/query_rec.h"
+#include "glite/lb/events.h"
#ifdef __cplusplus
extern "C" {
}
#endif
-#endif /* __EDG_WORKLOAD_LOGGING_LBSERVER_WS_TYPEREF_H__ */
+#endif /* __GLITE_LB_WS_TYPEREF_H__ */
#include <cppunit/extensions/TestFactoryRegistry.h>
#include <cppunit/ui/text/TestRunner.h>
-#include <glite/lb/consumer.h>
+#include <glite/lb/query_rec.h>
#include <glite/lb/context-int.h>
#include "lbs_db.h"
#include <cppunit/extensions/TestFactoryRegistry.h>
#include <cppunit/ui/text/TestRunner.h>
-#include <glite/lb/consumer.h>
+#include <glite/lb/query_rec.h>
#include "bk_ws_H.h"
#include "ws_typeref.h"
#include <cppunit/ui/text/TestRunner.h>
-#include <glite/lb/producer.h>
#include "lb_xml_parse.h"
#include <glite/lb/xml_parse.h>