00001 #ifndef __EDG_WORKLOAD_LOGGING_CLIENT_PRODUCER_H__
00002 #define __EDG_WORKLOAD_LOGGING_CLIENT_PRODUCER_H__
00003
00009 #ident "$Header: /cvs/glite/org.glite.lb.client-interface/interface/Attic/producer.h.T,v 1.10.2.2 2010/03/16 09:12:22 zsustr Exp $"
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035 #ifdef __cplusplus
00036 extern "C" {
00037 #endif
00038
00039 #include "glite/lb/context.h"
00040 #include "glite/lb/events.h"
00041
00042
00043
00044 #if 0
00045 #define EDG_WLL_SOURCE_UI "UserInterface"
00046 #define EDG_WLL_SOURCE_RB "ResourceBroker"
00047 #define EDG_WLL_SOURCE_JSS "JobSubmissionService"
00048 #define EDG_WLL_SOURCE_JOBMGR "GlobusJobmanager"
00049 #define EDG_WLL_SOURCE_LRMS "LocalResourceManager"
00050 #define EDG_WLL_SOURCE_APP "Application"
00051
00052 #define EDG_WLL_SOURCE_NS "NetworkServer"
00053 #define EDG_WLL_SOURCE_WM "WorkloadManager"
00054 #define EDG_WLL_SOURCE_BH "BigHelper"
00055 #define EDG_WLL_SOURCE_LM "LogMonitor"
00056
00057 #endif
00058
00059
00060
00061 #define EDG_WLL_FORMAT_COMMON "DATE=%s HOST=\"%|Us\" PROG=edg-wms LVL=%s DG.PRIORITY=%d DG.SOURCE=\"%|Us\" DG.SRC_INSTANCE=\"%|Us\" DG.EVNT=\"%s\" DG.JOBID=\"%s\" DG.SEQCODE=\"%|Us\" "
00062 #define EDG_WLL_FORMAT_USER "DG.USER=\"%|Us\" "
00063 #define EDG_WLL_FORMAT_TRANSFER "DG.TRANSFER.DESTINATION=\"%s\" DG.TRANSFER.DEST_HOST=\"%|Us\" DG.TRANSFER.DEST_INSTANCE=\"%|Us\" DG.TRANSFER.JOB=\"%|Us\" DG.TRANSFER.RESULT=\"%s\" DG.TRANSFER.REASON=\"%|Us\" DG.TRANSFER.DEST_JOBID=\"%|Us\" "
00064 #define EDG_WLL_FORMAT_ACCEPTED "DG.ACCEPTED.FROM=\"%s\" DG.ACCEPTED.FROM_HOST=\"%|Us\" DG.ACCEPTED.FROM_INSTANCE=\"%|Us\" DG.ACCEPTED.LOCAL_JOBID=\"%|Us\" "
00065 #define EDG_WLL_FORMAT_REFUSED "DG.REFUSED.FROM=\"%s\" DG.REFUSED.FROM_HOST=\"%|Us\" DG.REFUSED.FROM_INSTANCE=\"%|Us\" DG.REFUSED.REASON=\"%|Us\" "
00066 #define EDG_WLL_FORMAT_ENQUEUED "DG.ENQUEUED.QUEUE=\"%|Us\" DG.ENQUEUED.JOB=\"%|Us\" DG.ENQUEUED.RESULT=\"%s\" DG.ENQUEUED.REASON=\"%|Us\" "
00067 #define EDG_WLL_FORMAT_DEQUEUED "DG.DEQUEUED.QUEUE=\"%|Us\" DG.DEQUEUED.LOCAL_JOBID=\"%|Us\" "
00068 #define EDG_WLL_FORMAT_HELPERCALL "DG.HELPERCALL.HELPER_NAME=\"%|Us\" DG.HELPERCALL.HELPER_PARAMS=\"%|Us\" DG.HELPERCALL.SRC_ROLE=\"%s\" "
00069 #define EDG_WLL_FORMAT_HELPERRETURN "DG.HELPERRETURN.HELPER_NAME=\"%|Us\" DG.HELPERRETURN.RETVAL=\"%|Us\" DG.HELPERRETURN.SRC_ROLE=\"%s\" "
00070 #define EDG_WLL_FORMAT_RUNNING "DG.RUNNING.NODE=\"%|Us\" "
00071 #define EDG_WLL_FORMAT_RESUBMISSION "DG.RESUBMISSION.RESULT=\"%s\" DG.RESUBMISSION.REASON=\"%|Us\" DG.RESUBMISSION.TAG=\"%|Us\" "
00072 #define EDG_WLL_FORMAT_DONE "DG.DONE.STATUS_CODE=\"%s\" DG.DONE.REASON=\"%|Us\" DG.DONE.EXIT_CODE=\"%d\" "
00073 #define EDG_WLL_FORMAT_CANCEL "DG.CANCEL.STATUS_CODE=\"%s\" DG.CANCEL.REASON=\"%|Us\" "
00074 #define EDG_WLL_FORMAT_ABORT "DG.ABORT.REASON=\"%|Us\" "
00075 #define EDG_WLL_FORMAT_CLEAR "DG.CLEAR.REASON=\"%s\" "
00076 #define EDG_WLL_FORMAT_PURGE ""
00077 #define EDG_WLL_FORMAT_MATCH "DG.MATCH.DEST_ID=\"%|Us\" "
00078 #define EDG_WLL_FORMAT_PENDING "DG.PENDING.REASON=\"%|Us\" "
00079 #define EDG_WLL_FORMAT_REGJOB "DG.REGJOB.JDL=\"%|Us\" DG.REGJOB.NS=\"%|Us\" DG.REGJOB.PARENT=\"%s\" DG.REGJOB.JOBTYPE=\"%s\" DG.REGJOB.NSUBJOBS=\"%d\" DG.REGJOB.SEED=\"%|Us\" "
00080 #define EDG_WLL_FORMAT_CHKPT "DG.CHKPT.TAG=\"%|Us\" DG.CHKPT.CLASSAD=\"%|Us\" "
00081 #define EDG_WLL_FORMAT_LISTENER "DG.LISTENER.SVC_NAME=\"%|Us\" DG.LISTENER.SVC_HOST=\"%|Us\" DG.LISTENER.SVC_PORT=\"%d\" "
00082 #define EDG_WLL_FORMAT_CURDESCR "DG.CURDESCR.DESCR=\"%|Us\" "
00083 #define EDG_WLL_FORMAT_USERTAG "DG.USERTAG.NAME=\"%|Us\" DG.USERTAG.VALUE=\"%|Us\" "
00084 #define EDG_WLL_FORMAT_CHANGEACL "DG.CHANGEACL.USER_ID=\"%|Us\" DG.CHANGEACL.USER_ID_TYPE=\"%d\" DG.CHANGEACL.PERMISSION=\"%d\" DG.CHANGEACL.PERMISSION_TYPE=\"%d\" DG.CHANGEACL.OPERATION=\"%d\" "
00085 #define EDG_WLL_FORMAT_NOTIFICATION "DG.NOTIFICATION.NOTIFID=\"%s\" DG.NOTIFICATION.OWNER=\"%|Us\" DG.NOTIFICATION.DEST_HOST=\"%|Us\" DG.NOTIFICATION.DEST_PORT=\"%d\" DG.NOTIFICATION.EXPIRES=\"%d\" DG.NOTIFICATION.JOBSTAT=\"%|Us\" "
00086 #define EDG_WLL_FORMAT_RESOURCEUSAGE "DG.RESOURCEUSAGE.RESOURCE=\"%|Us\" DG.RESOURCEUSAGE.QUANTITY=\"%f\" DG.RESOURCEUSAGE.UNIT=\"%|Us\" "
00087 #define EDG_WLL_FORMAT_REALLYRUNNING "DG.REALLYRUNNING.WN_SEQ=\"%|Us\" "
00088 #define EDG_WLL_FORMAT_SUSPEND "DG.SUSPEND.REASON=\"%|Us\" "
00089 #define EDG_WLL_FORMAT_RESUME "DG.RESUME.REASON=\"%|Us\" "
00090 #define EDG_WLL_FORMAT_COLLECTIONSTATE "DG.COLLECTIONSTATE.STATE=\"%|Us\" DG.COLLECTIONSTATE.DONE_CODE=\"%d\" DG.COLLECTIONSTATE.HISTOGRAM=\"%|Us\" DG.COLLECTIONSTATE.CHILD=\"%s\" DG.COLLECTIONSTATE.CHILD_EVENT=\"%|Us\" "
00091 #define EDG_WLL_FORMAT_PBSQUEUED "DG.PBSQUEUED.QUEUE=\"%|Us\" DG.PBSQUEUED.OWNER=\"%|Us\" DG.PBSQUEUED.NAME=\"%|Us\" "
00092 #define EDG_WLL_FORMAT_PBSMATCH "DG.PBSMATCH.DEST_HOST=\"%|Us\" "
00093 #define EDG_WLL_FORMAT_PBSPENDING "DG.PBSPENDING.REASON=\"%|Us\" "
00094 #define EDG_WLL_FORMAT_PBSRUN "DG.PBSRUN.SCHEDULER=\"%|Us\" DG.PBSRUN.DEST_HOST=\"%|Us\" DG.PBSRUN.PID=\"%d\" "
00095 #define EDG_WLL_FORMAT_PBSRERUN ""
00096 #define EDG_WLL_FORMAT_PBSDONE "DG.PBSDONE.EXIT_STATUS=\"%d\" "
00097 #define EDG_WLL_FORMAT_PBSDEQUEUED ""
00098 #define EDG_WLL_FORMAT_PBSRESOURCEUSAGE "DG.PBSRESOURCEUSAGE.USAGE=\"%s\" DG.PBSRESOURCEUSAGE.NAME=\"%|Us\" DG.PBSRESOURCEUSAGE.QUANTITY=\"%f\" DG.PBSRESOURCEUSAGE.UNIT=\"%|Us\" "
00099 #define EDG_WLL_FORMAT_PBSERROR "DG.PBSERROR.ERROR_DESC=\"%|Us\" "
00100 #define EDG_WLL_FORMAT_CONDORMATCH "DG.CONDORMATCH.OWNER=\"%|Us\" DG.CONDORMATCH.DEST_HOST=\"%|Us\" DG.CONDORMATCH.PREEMPTING=\"%|Us\" "
00101 #define EDG_WLL_FORMAT_CONDORREJECT "DG.CONDORREJECT.OWNER=\"%|Us\" DG.CONDORREJECT.STATUS_CODE=\"%s\" "
00102 #define EDG_WLL_FORMAT_CONDORSHADOWSTARTED "DG.CONDORSHADOWSTARTED.SHADOW_HOST=\"%|Us\" DG.CONDORSHADOWSTARTED.SHADOW_PORT=\"%d\" DG.CONDORSHADOWSTARTED.SHADOW_PID=\"%d\" DG.CONDORSHADOWSTARTED.SHADOW_STATUS=\"%|Us\" "
00103 #define EDG_WLL_FORMAT_CONDORSHADOWEXITED "DG.CONDORSHADOWEXITED.SHADOW_PID=\"%d\" DG.CONDORSHADOWEXITED.SHADOW_EXIT_STATUS=\"%d\" "
00104 #define EDG_WLL_FORMAT_CONDORSTARTERSTARTED "DG.CONDORSTARTERSTARTED.STARTER_PID=\"%d\" DG.CONDORSTARTERSTARTED.UNIVERSE=\"%|Us\" "
00105 #define EDG_WLL_FORMAT_CONDORSTARTEREXITED "DG.CONDORSTARTEREXITED.STARTER_PID=\"%d\" DG.CONDORSTARTEREXITED.STARTER_EXIT_STATUS=\"%d\" DG.CONDORSTARTEREXITED.JOB_PID=\"%d\" DG.CONDORSTARTEREXITED.JOB_EXIT_STATUS=\"%d\" "
00106 #define EDG_WLL_FORMAT_CONDORRESOURCEUSAGE "DG.CONDORRESOURCEUSAGE.USAGE=\"%s\" DG.CONDORRESOURCEUSAGE.NAME=\"%|Us\" DG.CONDORRESOURCEUSAGE.QUANTITY=\"%f\" DG.CONDORRESOURCEUSAGE.UNIT=\"%|Us\" "
00107 #define EDG_WLL_FORMAT_CONDORERROR "DG.CONDORERROR.ERROR_DESC=\"%|Us\" "
00108 #define EDG_WLL_FORMAT_NOTIFICATION_COMMON "DATE=%s HOST=\"%|Us\" PROG=edg-wms LVL=%s DG.SOURCE=\"%|Us\" DG.SRC_INSTANCE=\"%|Us\" DG.TYPE=\"notification\" "
00109 #define EDG_WLL_FORMAT_SYSCMPSTAT "DG.SCHED.STATUS=\"%|Us\" "
00110 #define EDG_WLL_FORMAT_SYSCLSTAT "DG.SCHED.NODE=\"%|Us\" DG.SCHED.STATUS=\"%|Us\" "
00111
00112
00113
00114
00131 extern int edg_wll_LogTransfer(edg_wll_Context context, const edg_wll_Source destination, const char * dest_host, const char * dest_instance, const char * job, const char * result, const char * reason, const char * dest_jobid);
00132
00149 extern int edg_wll_LogTransferProxy(edg_wll_Context context, const edg_wll_Source destination, const char * dest_host, const char * dest_instance, const char * job, const char * result, const char * reason, const char * dest_jobid);
00150
00166 extern int edg_wll_LogTransferSTART(edg_wll_Context context, const edg_wll_Source destination, const char * dest_host, const char * dest_instance, const char * job, const char * reason, const char * dest_jobid);
00167
00183 extern int edg_wll_LogTransferSTARTProxy(edg_wll_Context context, const edg_wll_Source destination, const char * dest_host, const char * dest_instance, const char * job, const char * reason, const char * dest_jobid);
00184
00200 extern int edg_wll_LogTransferOK(edg_wll_Context context, const edg_wll_Source destination, const char * dest_host, const char * dest_instance, const char * job, const char * reason, const char * dest_jobid);
00201
00217 extern int edg_wll_LogTransferOKProxy(edg_wll_Context context, const edg_wll_Source destination, const char * dest_host, const char * dest_instance, const char * job, const char * reason, const char * dest_jobid);
00218
00234 extern int edg_wll_LogTransferREFUSED(edg_wll_Context context, const edg_wll_Source destination, const char * dest_host, const char * dest_instance, const char * job, const char * reason, const char * dest_jobid);
00235
00251 extern int edg_wll_LogTransferREFUSEDProxy(edg_wll_Context context, const edg_wll_Source destination, const char * dest_host, const char * dest_instance, const char * job, const char * reason, const char * dest_jobid);
00252
00268 extern int edg_wll_LogTransferFAIL(edg_wll_Context context, const edg_wll_Source destination, const char * dest_host, const char * dest_instance, const char * job, const char * reason, const char * dest_jobid);
00269
00285 extern int edg_wll_LogTransferFAILProxy(edg_wll_Context context, const edg_wll_Source destination, const char * dest_host, const char * dest_instance, const char * job, const char * reason, const char * dest_jobid);
00286
00300 extern int edg_wll_LogAccepted(edg_wll_Context context, const edg_wll_Source from, const char * from_host, const char * from_instance, const char * local_jobid);
00301
00315 extern int edg_wll_LogAcceptedProxy(edg_wll_Context context, const edg_wll_Source from, const char * from_host, const char * from_instance, const char * local_jobid);
00316
00330 extern int edg_wll_LogRefused(edg_wll_Context context, const edg_wll_Source from, const char * from_host, const char * from_instance, const char * reason);
00331
00345 extern int edg_wll_LogRefusedProxy(edg_wll_Context context, const edg_wll_Source from, const char * from_host, const char * from_instance, const char * reason);
00346
00360 extern int edg_wll_LogEnQueued(edg_wll_Context context, const char * queue, const char * job, const char * result, const char * reason);
00361
00375 extern int edg_wll_LogEnQueuedProxy(edg_wll_Context context, const char * queue, const char * job, const char * result, const char * reason);
00376
00389 extern int edg_wll_LogEnQueuedSTART(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00390
00403 extern int edg_wll_LogEnQueuedSTARTProxy(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00404
00417 extern int edg_wll_LogEnQueuedOK(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00418
00431 extern int edg_wll_LogEnQueuedOKProxy(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00432
00445 extern int edg_wll_LogEnQueuedREFUSED(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00446
00459 extern int edg_wll_LogEnQueuedREFUSEDProxy(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00460
00473 extern int edg_wll_LogEnQueuedFAIL(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00474
00487 extern int edg_wll_LogEnQueuedFAILProxy(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00488
00500 extern int edg_wll_LogDeQueued(edg_wll_Context context, const char * queue, const char * local_jobid);
00501
00513 extern int edg_wll_LogDeQueuedProxy(edg_wll_Context context, const char * queue, const char * local_jobid);
00514
00527 extern int edg_wll_LogHelperCall(edg_wll_Context context, const char * helper_name, const char * helper_params, const char * src_role);
00528
00541 extern int edg_wll_LogHelperCallProxy(edg_wll_Context context, const char * helper_name, const char * helper_params, const char * src_role);
00542
00554 extern int edg_wll_LogHelperCallCALLING(edg_wll_Context context, const char * helper_name, const char * helper_params);
00555
00567 extern int edg_wll_LogHelperCallCALLINGProxy(edg_wll_Context context, const char * helper_name, const char * helper_params);
00568
00580 extern int edg_wll_LogHelperCallCALLED(edg_wll_Context context, const char * helper_name, const char * helper_params);
00581
00593 extern int edg_wll_LogHelperCallCALLEDProxy(edg_wll_Context context, const char * helper_name, const char * helper_params);
00594
00607 extern int edg_wll_LogHelperReturn(edg_wll_Context context, const char * helper_name, const char * retval, const char * src_role);
00608
00621 extern int edg_wll_LogHelperReturnProxy(edg_wll_Context context, const char * helper_name, const char * retval, const char * src_role);
00622
00634 extern int edg_wll_LogHelperReturnCALLING(edg_wll_Context context, const char * helper_name, const char * retval);
00635
00647 extern int edg_wll_LogHelperReturnCALLINGProxy(edg_wll_Context context, const char * helper_name, const char * retval);
00648
00660 extern int edg_wll_LogHelperReturnCALLED(edg_wll_Context context, const char * helper_name, const char * retval);
00661
00673 extern int edg_wll_LogHelperReturnCALLEDProxy(edg_wll_Context context, const char * helper_name, const char * retval);
00674
00685 extern int edg_wll_LogRunning(edg_wll_Context context, const char * node);
00686
00697 extern int edg_wll_LogRunningProxy(edg_wll_Context context, const char * node);
00698
00711 extern int edg_wll_LogResubmission(edg_wll_Context context, const char * result, const char * reason, const char * tag);
00712
00725 extern int edg_wll_LogResubmissionProxy(edg_wll_Context context, const char * result, const char * reason, const char * tag);
00726
00738 extern int edg_wll_LogResubmissionWILLRESUB(edg_wll_Context context, const char * reason, const char * tag);
00739
00751 extern int edg_wll_LogResubmissionWILLRESUBProxy(edg_wll_Context context, const char * reason, const char * tag);
00752
00764 extern int edg_wll_LogResubmissionWONTRESUB(edg_wll_Context context, const char * reason, const char * tag);
00765
00777 extern int edg_wll_LogResubmissionWONTRESUBProxy(edg_wll_Context context, const char * reason, const char * tag);
00778
00790 extern int edg_wll_LogResubmissionSHALLOW(edg_wll_Context context, const char * reason, const char * tag);
00791
00803 extern int edg_wll_LogResubmissionSHALLOWProxy(edg_wll_Context context, const char * reason, const char * tag);
00804
00817 extern int edg_wll_LogDone(edg_wll_Context context, const char * status_code, const char * reason, const int exit_code);
00818
00831 extern int edg_wll_LogDoneProxy(edg_wll_Context context, const char * status_code, const char * reason, const int exit_code);
00832
00844 extern int edg_wll_LogDoneOK(edg_wll_Context context, const char * reason, const int exit_code);
00845
00857 extern int edg_wll_LogDoneOKProxy(edg_wll_Context context, const char * reason, const int exit_code);
00858
00870 extern int edg_wll_LogDoneFAILED(edg_wll_Context context, const char * reason, const int exit_code);
00871
00883 extern int edg_wll_LogDoneFAILEDProxy(edg_wll_Context context, const char * reason, const int exit_code);
00884
00896 extern int edg_wll_LogDoneCANCELLED(edg_wll_Context context, const char * reason, const int exit_code);
00897
00909 extern int edg_wll_LogDoneCANCELLEDProxy(edg_wll_Context context, const char * reason, const int exit_code);
00910
00922 extern int edg_wll_LogCancel(edg_wll_Context context, const char * status_code, const char * reason);
00923
00935 extern int edg_wll_LogCancelProxy(edg_wll_Context context, const char * status_code, const char * reason);
00936
00947 extern int edg_wll_LogCancelREQ(edg_wll_Context context, const char * reason);
00948
00959 extern int edg_wll_LogCancelREQProxy(edg_wll_Context context, const char * reason);
00960
00971 extern int edg_wll_LogCancelREFUSE(edg_wll_Context context, const char * reason);
00972
00983 extern int edg_wll_LogCancelREFUSEProxy(edg_wll_Context context, const char * reason);
00984
00995 extern int edg_wll_LogCancelDONE(edg_wll_Context context, const char * reason);
00996
01007 extern int edg_wll_LogCancelDONEProxy(edg_wll_Context context, const char * reason);
01008
01019 extern int edg_wll_LogCancelABORT(edg_wll_Context context, const char * reason);
01020
01031 extern int edg_wll_LogCancelABORTProxy(edg_wll_Context context, const char * reason);
01032
01043 extern int edg_wll_LogAbort(edg_wll_Context context, const char * reason);
01044
01055 extern int edg_wll_LogAbortProxy(edg_wll_Context context, const char * reason);
01056
01067 extern int edg_wll_LogClear(edg_wll_Context context, const char * reason);
01068
01079 extern int edg_wll_LogClearProxy(edg_wll_Context context, const char * reason);
01080
01090 extern int edg_wll_LogClearUSER(edg_wll_Context context);
01091
01101 extern int edg_wll_LogClearUSERProxy(edg_wll_Context context);
01102
01112 extern int edg_wll_LogClearTIMEOUT(edg_wll_Context context);
01113
01123 extern int edg_wll_LogClearTIMEOUTProxy(edg_wll_Context context);
01124
01134 extern int edg_wll_LogClearNOOUTPUT(edg_wll_Context context);
01135
01145 extern int edg_wll_LogClearNOOUTPUTProxy(edg_wll_Context context);
01146
01156 extern int edg_wll_LogPurge(edg_wll_Context context);
01157
01167 extern int edg_wll_LogPurgeProxy(edg_wll_Context context);
01168
01179 extern int edg_wll_LogMatch(edg_wll_Context context, const char * dest_id);
01180
01191 extern int edg_wll_LogMatchProxy(edg_wll_Context context, const char * dest_id);
01192
01203 extern int edg_wll_LogPending(edg_wll_Context context, const char * reason);
01204
01215 extern int edg_wll_LogPendingProxy(edg_wll_Context context, const char * reason);
01216
01232 extern int edg_wll_LogRegJob(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const char * jobtype, const int nsubjobs, const char * seed);
01233
01249 extern int edg_wll_LogRegJobProxy(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const char * jobtype, const int nsubjobs, const char * seed);
01250
01265 extern int edg_wll_LogRegJobSIMPLE(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01266
01281 extern int edg_wll_LogRegJobSIMPLEProxy(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01282
01297 extern int edg_wll_LogRegJobDAG(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01298
01313 extern int edg_wll_LogRegJobDAGProxy(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01314
01329 extern int edg_wll_LogRegJobPARTITIONABLE(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01330
01345 extern int edg_wll_LogRegJobPARTITIONABLEProxy(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01346
01361 extern int edg_wll_LogRegJobPARTITIONED(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01362
01377 extern int edg_wll_LogRegJobPARTITIONEDProxy(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01378
01393 extern int edg_wll_LogRegJobCOLLECTION(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01394
01409 extern int edg_wll_LogRegJobCOLLECTIONProxy(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01410
01425 extern int edg_wll_LogRegJobPBS(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01426
01441 extern int edg_wll_LogRegJobPBSProxy(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01442
01457 extern int edg_wll_LogRegJobCONDOR(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01458
01473 extern int edg_wll_LogRegJobCONDORProxy(edg_wll_Context context, const char * jdl, const char * ns, const edg_wlc_JobId parent, const int nsubjobs, const char * seed);
01474
01486 extern int edg_wll_LogChkpt(edg_wll_Context context, const char * tag, const char * classad);
01487
01499 extern int edg_wll_LogChkptProxy(edg_wll_Context context, const char * tag, const char * classad);
01500
01513 extern int edg_wll_LogListener(edg_wll_Context context, const char * svc_name, const char * svc_host, const uint16_t svc_port);
01514
01527 extern int edg_wll_LogListenerProxy(edg_wll_Context context, const char * svc_name, const char * svc_host, const uint16_t svc_port);
01528
01539 extern int edg_wll_LogCurDescr(edg_wll_Context context, const char * descr);
01540
01551 extern int edg_wll_LogCurDescrProxy(edg_wll_Context context, const char * descr);
01552
01564 extern int edg_wll_LogUserTag(edg_wll_Context context, const char * name, const char * value);
01565
01577 extern int edg_wll_LogUserTagProxy(edg_wll_Context context, const char * name, const char * value);
01578
01593 extern int edg_wll_LogChangeACL(edg_wll_Context context, const char * user_id, const int user_id_type, const int permission, const int permission_type, const int operation);
01594
01609 extern int edg_wll_LogChangeACLProxy(edg_wll_Context context, const char * user_id, const int user_id_type, const int permission, const int permission_type, const int operation);
01610
01626 extern int edg_wll_LogNotification(edg_wll_Context context, const edg_wll_NotifId notifId, const char * owner, const char * dest_host, const uint16_t dest_port, const int expires, const char * jobstat);
01627
01643 extern int edg_wll_LogNotificationProxy(edg_wll_Context context, const edg_wll_NotifId notifId, const char * owner, const char * dest_host, const uint16_t dest_port, const int expires, const char * jobstat);
01644
01657 extern int edg_wll_LogResourceUsage(edg_wll_Context context, const char * resource, const double quantity, const char * unit);
01658
01671 extern int edg_wll_LogResourceUsageProxy(edg_wll_Context context, const char * resource, const double quantity, const char * unit);
01672
01683 extern int edg_wll_LogReallyRunning(edg_wll_Context context, const char * wn_seq);
01684
01695 extern int edg_wll_LogReallyRunningProxy(edg_wll_Context context, const char * wn_seq);
01696
01707 extern int edg_wll_LogSuspend(edg_wll_Context context, const char * reason);
01708
01719 extern int edg_wll_LogSuspendProxy(edg_wll_Context context, const char * reason);
01720
01731 extern int edg_wll_LogResume(edg_wll_Context context, const char * reason);
01732
01743 extern int edg_wll_LogResumeProxy(edg_wll_Context context, const char * reason);
01744
01759 extern int edg_wll_LogCollectionState(edg_wll_Context context, const char * state, const int done_code, const char * histogram, const edg_wlc_JobId child, const char * child_event);
01760
01775 extern int edg_wll_LogCollectionStateProxy(edg_wll_Context context, const char * state, const int done_code, const char * histogram, const edg_wlc_JobId child, const char * child_event);
01776
01789 extern int edg_wll_LogPBSQueued(edg_wll_Context context, const char * queue, const char * owner, const char * name);
01790
01803 extern int edg_wll_LogPBSQueuedProxy(edg_wll_Context context, const char * queue, const char * owner, const char * name);
01804
01815 extern int edg_wll_LogPBSMatch(edg_wll_Context context, const char * dest_host);
01816
01827 extern int edg_wll_LogPBSMatchProxy(edg_wll_Context context, const char * dest_host);
01828
01839 extern int edg_wll_LogPBSPending(edg_wll_Context context, const char * reason);
01840
01851 extern int edg_wll_LogPBSPendingProxy(edg_wll_Context context, const char * reason);
01852
01865 extern int edg_wll_LogPBSRun(edg_wll_Context context, const char * scheduler, const char * dest_host, const int pid);
01866
01879 extern int edg_wll_LogPBSRunProxy(edg_wll_Context context, const char * scheduler, const char * dest_host, const int pid);
01880
01890 extern int edg_wll_LogPBSRerun(edg_wll_Context context);
01891
01901 extern int edg_wll_LogPBSRerunProxy(edg_wll_Context context);
01902
01913 extern int edg_wll_LogPBSDone(edg_wll_Context context, const int exit_status);
01914
01925 extern int edg_wll_LogPBSDoneProxy(edg_wll_Context context, const int exit_status);
01926
01936 extern int edg_wll_LogPBSDequeued(edg_wll_Context context);
01937
01947 extern int edg_wll_LogPBSDequeuedProxy(edg_wll_Context context);
01948
01962 extern int edg_wll_LogPBSResourceUsage(edg_wll_Context context, const char * usage, const char * name, const double quantity, const char * unit);
01963
01977 extern int edg_wll_LogPBSResourceUsageProxy(edg_wll_Context context, const char * usage, const char * name, const double quantity, const char * unit);
01978
01991 extern int edg_wll_LogPBSResourceUsageREQUESTED(edg_wll_Context context, const char * name, const double quantity, const char * unit);
01992
02005 extern int edg_wll_LogPBSResourceUsageREQUESTEDProxy(edg_wll_Context context, const char * name, const double quantity, const char * unit);
02006
02019 extern int edg_wll_LogPBSResourceUsageUSED(edg_wll_Context context, const char * name, const double quantity, const char * unit);
02020
02033 extern int edg_wll_LogPBSResourceUsageUSEDProxy(edg_wll_Context context, const char * name, const double quantity, const char * unit);
02034
02045 extern int edg_wll_LogPBSError(edg_wll_Context context, const char * error_desc);
02046
02057 extern int edg_wll_LogPBSErrorProxy(edg_wll_Context context, const char * error_desc);
02058
02071 extern int edg_wll_LogCondorMatch(edg_wll_Context context, const char * owner, const char * dest_host, const char * preempting);
02072
02085 extern int edg_wll_LogCondorMatchProxy(edg_wll_Context context, const char * owner, const char * dest_host, const char * preempting);
02086
02098 extern int edg_wll_LogCondorReject(edg_wll_Context context, const char * owner, const char * status_code);
02099
02111 extern int edg_wll_LogCondorRejectProxy(edg_wll_Context context, const char * owner, const char * status_code);
02112
02123 extern int edg_wll_LogCondorRejectNOMATCH(edg_wll_Context context, const char * owner);
02124
02135 extern int edg_wll_LogCondorRejectNOMATCHProxy(edg_wll_Context context, const char * owner);
02136
02147 extern int edg_wll_LogCondorRejectOTHER(edg_wll_Context context, const char * owner);
02148
02159 extern int edg_wll_LogCondorRejectOTHERProxy(edg_wll_Context context, const char * owner);
02160
02174 extern int edg_wll_LogCondorShadowStarted(edg_wll_Context context, const char * shadow_host, const uint16_t shadow_port, const int shadow_pid, const char * shadow_status);
02175
02189 extern int edg_wll_LogCondorShadowStartedProxy(edg_wll_Context context, const char * shadow_host, const uint16_t shadow_port, const int shadow_pid, const char * shadow_status);
02190
02202 extern int edg_wll_LogCondorShadowExited(edg_wll_Context context, const int shadow_pid, const int shadow_exit_status);
02203
02215 extern int edg_wll_LogCondorShadowExitedProxy(edg_wll_Context context, const int shadow_pid, const int shadow_exit_status);
02216
02228 extern int edg_wll_LogCondorStarterStarted(edg_wll_Context context, const int starter_pid, const char * universe);
02229
02241 extern int edg_wll_LogCondorStarterStartedProxy(edg_wll_Context context, const int starter_pid, const char * universe);
02242
02256 extern int edg_wll_LogCondorStarterExited(edg_wll_Context context, const int starter_pid, const int starter_exit_status, const int job_pid, const int job_exit_status);
02257
02271 extern int edg_wll_LogCondorStarterExitedProxy(edg_wll_Context context, const int starter_pid, const int starter_exit_status, const int job_pid, const int job_exit_status);
02272
02286 extern int edg_wll_LogCondorResourceUsage(edg_wll_Context context, const char * usage, const char * name, const double quantity, const char * unit);
02287
02301 extern int edg_wll_LogCondorResourceUsageProxy(edg_wll_Context context, const char * usage, const char * name, const double quantity, const char * unit);
02302
02315 extern int edg_wll_LogCondorResourceUsageREQUESTED(edg_wll_Context context, const char * name, const double quantity, const char * unit);
02316
02329 extern int edg_wll_LogCondorResourceUsageREQUESTEDProxy(edg_wll_Context context, const char * name, const double quantity, const char * unit);
02330
02343 extern int edg_wll_LogCondorResourceUsageUSED(edg_wll_Context context, const char * name, const double quantity, const char * unit);
02344
02357 extern int edg_wll_LogCondorResourceUsageUSEDProxy(edg_wll_Context context, const char * name, const double quantity, const char * unit);
02358
02369 extern int edg_wll_LogCondorError(edg_wll_Context context, const char * error_desc);
02370
02381 extern int edg_wll_LogCondorErrorProxy(edg_wll_Context context, const char * error_desc);
02382
02383
02399 extern int edg_wll_LogEvent(
02400 edg_wll_Context context,
02401 edg_wll_EventCode event,
02402 char *fmt, ...);
02403
02421 extern int edg_wll_LogEventSync(
02422 edg_wll_Context context,
02423 edg_wll_EventCode event,
02424 char *fmt, ...);
02425
02441 extern int edg_wll_LogEventProxy(
02442 edg_wll_Context context,
02443 edg_wll_EventCode event,
02444 char *fmt, ...);
02445
02457 extern int edg_wll_LogFlush(
02458 edg_wll_Context context,
02459 struct timeval *timeout);
02460
02461
02468 extern int edg_wll_LogFlushAll(
02469 edg_wll_Context context,
02470 struct timeval *timeout);
02471
02480 extern int edg_wll_SetLoggingJob(
02481 edg_wll_Context context,
02482 const edg_wlc_JobId job,
02483 const char * code,
02484 int flags
02485 );
02486
02496 extern int edg_wll_SetLoggingJobProxy(
02497 edg_wll_Context context,
02498 const edg_wlc_JobId job,
02499 const char * code,
02500 const char * user,
02501 int flags
02502 );
02503
02524
02525 #define EDG_WLL_JOB_SIMPLE EDG_WLL_REGJOB_SIMPLE
02526
02527 extern int edg_wll_RegisterJob(
02528 edg_wll_Context context,
02529 const edg_wlc_JobId job,
02530 enum edg_wll_RegJobJobtype type,
02531 const char * jdl,
02532 const char * ns,
02533 int num_subjobs,
02534 const char * seed,
02535 edg_wlc_JobId ** subjobs
02536 );
02537
02542 extern int edg_wll_RegisterJobSync(
02543 edg_wll_Context context,
02544 const edg_wlc_JobId job,
02545 enum edg_wll_RegJobJobtype type,
02546 const char * jdl,
02547 const char * ns,
02548 int num_subjobs,
02549 const char * seed,
02550 edg_wlc_JobId ** subjobs
02551 );
02552
02572 extern int edg_wll_RegisterJobProxy(
02573 edg_wll_Context context,
02574 const edg_wlc_JobId job,
02575 enum edg_wll_RegJobJobtype type,
02576 const char * jdl,
02577 const char * ns,
02578 int num_subjobs,
02579 const char * seed,
02580 edg_wlc_JobId ** subjobs
02581 );
02582
02583 #ifdef LB_PERF
02584
02585 extern int edg_wll_RegisterJobProxyOld(
02586 edg_wll_Context context,
02587 const edg_wlc_JobId job,
02588 enum edg_wll_RegJobJobtype type,
02589 const char * jdl,
02590 const char * ns,
02591 int num_subjobs,
02592 const char * seed,
02593 edg_wlc_JobId ** subjobs
02594 );
02595
02596
02597
02598
02599 extern int edg_wll_RegisterJobProxyOnly(
02600 edg_wll_Context context,
02601 const edg_wlc_JobId job,
02602 enum edg_wll_RegJobJobtype type,
02603 const char * jdl,
02604 const char * ns,
02605 int num_subjobs,
02606 const char * seed,
02607 edg_wlc_JobId ** subjobs
02608 );
02609 #endif
02610
02611
02612
02621 extern int edg_wll_RegisterSubjobs(
02622 edg_wll_Context context,
02623 const edg_wlc_JobId parent,
02624 char const * const * jdls,
02625 const char * ns,
02626 edg_wlc_JobId const * subjobs
02627 );
02628
02629
02638 extern int edg_wll_RegisterSubjobsProxy(
02639 edg_wll_Context context,
02640 const edg_wlc_JobId parent,
02641 char const * const * jdls,
02642 const char * ns,
02643 edg_wlc_JobId const * subjobs
02644 );
02645
02652 extern int edg_wll_GenerateSubjobIds(
02653 edg_wll_Context context,
02654 const edg_wlc_JobId parent,
02655 int num_subjobs,
02656 const char * seed,
02657 edg_wlc_JobId ** subjobs
02658 );
02659
02660
02661 enum edg_wll_Permission {
02662 EDG_WLL_PERM_READ = 1,
02663 EDG_WLL_PERM_WRITE = 4,
02664 EDG_WLL_PERM_ADMIN = 8,
02665 };
02666
02667 enum edg_wll_PermissionType {
02668 EDG_WLL_PERM_ALLOW,
02669 EDG_WLL_PERM_DENY,
02670 };
02671
02672 enum edg_wll_ACLOperation {
02673 EDG_WLL_ACL_ADD,
02674 EDG_WLL_ACL_REMOVE,
02675 };
02676
02677 enum edg_wll_UserIdType {
02678 EDG_WLL_USER_SUBJECT,
02679 EDG_WLL_USER_VOMS_GROUP,
02680 };
02681
02695 extern int edg_wll_ChangeACL(
02696 edg_wll_Context context,
02697 const edg_wlc_JobId job,
02698 const char * user_id,
02699 enum edg_wll_UserIdType user_id_type,
02700 enum edg_wll_Permission permission,
02701 enum edg_wll_PermissionType permission_type,
02702 enum edg_wll_ACLOperation operation
02703 );
02704
02705
02706 #ifdef __cplusplus
02707 }
02708 #endif
02709
02710 #endif