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/producer.h.T,v 1.10 2006/10/15 21:16:42 jpospi Exp $"
00010
00011
00012
00013
00014
00015
00016
00017
00018 #ifdef __cplusplus
00019 extern "C" {
00020 #endif
00021
00022 #include "glite/lb/context.h"
00023 #include "glite/lb/events.h"
00024
00025
00026
00027 #if 0
00028 #define EDG_WLL_SOURCE_UI "UserInterface"
00029 #define EDG_WLL_SOURCE_RB "ResourceBroker"
00030 #define EDG_WLL_SOURCE_JSS "JobSubmissionService"
00031 #define EDG_WLL_SOURCE_JOBMGR "GlobusJobmanager"
00032 #define EDG_WLL_SOURCE_LRMS "LocalResourceManager"
00033 #define EDG_WLL_SOURCE_APP "Application"
00034
00035 #define EDG_WLL_SOURCE_NS "NetworkServer"
00036 #define EDG_WLL_SOURCE_WM "WorkloadManager"
00037 #define EDG_WLL_SOURCE_BH "BigHelper"
00038 #define EDG_WLL_SOURCE_LM "LogMonitor"
00039
00040 #endif
00041
00042
00043
00044 #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\" "
00045 #define EDG_WLL_FORMAT_USER "DG.USER=\"%|Us\" "
00046 #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\" "
00047 #define EDG_WLL_FORMAT_ACCEPTED "DG.ACCEPTED.FROM=\"%s\" DG.ACCEPTED.FROM_HOST=\"%|Us\" DG.ACCEPTED.FROM_INSTANCE=\"%|Us\" DG.ACCEPTED.LOCAL_JOBID=\"%|Us\" "
00048 #define EDG_WLL_FORMAT_REFUSED "DG.REFUSED.FROM=\"%s\" DG.REFUSED.FROM_HOST=\"%|Us\" DG.REFUSED.FROM_INSTANCE=\"%|Us\" DG.REFUSED.REASON=\"%|Us\" "
00049 #define EDG_WLL_FORMAT_ENQUEUED "DG.ENQUEUED.QUEUE=\"%|Us\" DG.ENQUEUED.JOB=\"%|Us\" DG.ENQUEUED.RESULT=\"%s\" DG.ENQUEUED.REASON=\"%|Us\" "
00050 #define EDG_WLL_FORMAT_DEQUEUED "DG.DEQUEUED.QUEUE=\"%|Us\" DG.DEQUEUED.LOCAL_JOBID=\"%|Us\" "
00051 #define EDG_WLL_FORMAT_HELPERCALL "DG.HELPERCALL.HELPER_NAME=\"%|Us\" DG.HELPERCALL.HELPER_PARAMS=\"%|Us\" DG.HELPERCALL.SRC_ROLE=\"%s\" "
00052 #define EDG_WLL_FORMAT_HELPERRETURN "DG.HELPERRETURN.HELPER_NAME=\"%|Us\" DG.HELPERRETURN.RETVAL=\"%|Us\" DG.HELPERRETURN.SRC_ROLE=\"%s\" "
00053 #define EDG_WLL_FORMAT_RUNNING "DG.RUNNING.NODE=\"%|Us\" "
00054 #define EDG_WLL_FORMAT_RESUBMISSION "DG.RESUBMISSION.RESULT=\"%s\" DG.RESUBMISSION.REASON=\"%|Us\" DG.RESUBMISSION.TAG=\"%|Us\" "
00055 #define EDG_WLL_FORMAT_DONE "DG.DONE.STATUS_CODE=\"%s\" DG.DONE.REASON=\"%|Us\" DG.DONE.EXIT_CODE=\"%d\" "
00056 #define EDG_WLL_FORMAT_CANCEL "DG.CANCEL.STATUS_CODE=\"%s\" DG.CANCEL.REASON=\"%|Us\" "
00057 #define EDG_WLL_FORMAT_ABORT "DG.ABORT.REASON=\"%|Us\" "
00058 #define EDG_WLL_FORMAT_CLEAR "DG.CLEAR.REASON=\"%s\" "
00059 #define EDG_WLL_FORMAT_PURGE ""
00060 #define EDG_WLL_FORMAT_MATCH "DG.MATCH.DEST_ID=\"%|Us\" "
00061 #define EDG_WLL_FORMAT_PENDING "DG.PENDING.REASON=\"%|Us\" "
00062 #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\" "
00063 #define EDG_WLL_FORMAT_CHKPT "DG.CHKPT.TAG=\"%|Us\" DG.CHKPT.CLASSAD=\"%|Us\" "
00064 #define EDG_WLL_FORMAT_LISTENER "DG.LISTENER.SVC_NAME=\"%|Us\" DG.LISTENER.SVC_HOST=\"%|Us\" DG.LISTENER.SVC_PORT=\"%d\" "
00065 #define EDG_WLL_FORMAT_CURDESCR "DG.CURDESCR.DESCR=\"%|Us\" "
00066 #define EDG_WLL_FORMAT_USERTAG "DG.USERTAG.NAME=\"%|Us\" DG.USERTAG.VALUE=\"%|Us\" "
00067 #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\" "
00068 #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.JOBSTAT=\"%|Us\" "
00069 #define EDG_WLL_FORMAT_RESOURCEUSAGE "DG.RESOURCEUSAGE.RESOURCE=\"%|Us\" DG.RESOURCEUSAGE.QUANTITY=\"%f\" DG.RESOURCEUSAGE.UNIT=\"%|Us\" "
00070 #define EDG_WLL_FORMAT_REALLYRUNNING "DG.REALLYRUNNING.WN_SEQ=\"%|Us\" "
00071 #define EDG_WLL_FORMAT_SUSPEND "DG.SUSPEND.REASON=\"%|Us\" "
00072 #define EDG_WLL_FORMAT_RESUME "DG.RESUME.REASON=\"%|Us\" "
00073 #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\" "
00074 #define EDG_WLL_FORMAT_PBSQUEUED "DG.PBSQUEUED.QUEUE=\"%|Us\" DG.PBSQUEUED.OWNER=\"%|Us\" DG.PBSQUEUED.NAME=\"%|Us\" "
00075 #define EDG_WLL_FORMAT_PBSMATCH "DG.PBSMATCH.DEST_HOST=\"%|Us\" "
00076 #define EDG_WLL_FORMAT_PBSPENDING "DG.PBSPENDING.REASON=\"%|Us\" "
00077 #define EDG_WLL_FORMAT_PBSRUN "DG.PBSRUN.SCHEDULER=\"%|Us\" DG.PBSRUN.DEST_HOST=\"%|Us\" DG.PBSRUN.PID=\"%d\" "
00078 #define EDG_WLL_FORMAT_PBSRERUN ""
00079 #define EDG_WLL_FORMAT_PBSDONE "DG.PBSDONE.EXIT_STATUS=\"%d\" "
00080 #define EDG_WLL_FORMAT_PBSDEQUEUED ""
00081 #define EDG_WLL_FORMAT_PBSRESOURCEUSAGE "DG.PBSRESOURCEUSAGE.USAGE=\"%s\" DG.PBSRESOURCEUSAGE.NAME=\"%|Us\" DG.PBSRESOURCEUSAGE.QUANTITY=\"%f\" DG.PBSRESOURCEUSAGE.UNIT=\"%|Us\" "
00082 #define EDG_WLL_FORMAT_PBSERROR "DG.PBSERROR.ERROR_DESC=\"%|Us\" "
00083 #define EDG_WLL_FORMAT_CONDORMATCH "DG.CONDORMATCH.OWNER=\"%|Us\" DG.CONDORMATCH.DEST_HOST=\"%|Us\" DG.CONDORMATCH.PREEMPTING=\"%|Us\" "
00084 #define EDG_WLL_FORMAT_CONDORREJECT "DG.CONDORREJECT.OWNER=\"%|Us\" DG.CONDORREJECT.STATUS_CODE=\"%s\" "
00085 #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\" "
00086 #define EDG_WLL_FORMAT_CONDORSHADOWEXITED "DG.CONDORSHADOWEXITED.SHADOW_PID=\"%d\" DG.CONDORSHADOWEXITED.SHADOW_EXIT_STATUS=\"%d\" "
00087 #define EDG_WLL_FORMAT_CONDORSTARTERSTARTED "DG.CONDORSTARTERSTARTED.STARTER_PID=\"%d\" DG.CONDORSTARTERSTARTED.UNIVERSE=\"%|Us\" "
00088 #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\" "
00089 #define EDG_WLL_FORMAT_CONDORRESOURCEUSAGE "DG.CONDORRESOURCEUSAGE.USAGE=\"%s\" DG.CONDORRESOURCEUSAGE.NAME=\"%|Us\" DG.CONDORRESOURCEUSAGE.QUANTITY=\"%f\" DG.CONDORRESOURCEUSAGE.UNIT=\"%|Us\" "
00090 #define EDG_WLL_FORMAT_CONDORERROR "DG.CONDORERROR.ERROR_DESC=\"%|Us\" "
00091 #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\" "
00092 #define EDG_WLL_FORMAT_SYSCMPSTAT "DG.SCHED.STATUS=\"%|Us\" "
00093 #define EDG_WLL_FORMAT_SYSCLSTAT "DG.SCHED.NODE=\"%|Us\" DG.SCHED.STATUS=\"%|Us\" "
00094
00095
00096
00097
00112 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);
00113
00114 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);
00115
00130 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);
00131
00132 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);
00133
00148 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);
00149
00150 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);
00151
00166 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);
00167
00168 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);
00169
00184 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);
00185
00186 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);
00187
00199 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);
00200
00201 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);
00202
00214 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);
00215
00216 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);
00217
00229 extern int edg_wll_LogEnQueued(edg_wll_Context context, const char * queue, const char * job, const char * result, const char * reason);
00230
00231 extern int edg_wll_LogEnQueuedProxy(edg_wll_Context context, const char * queue, const char * job, const char * result, const char * reason);
00232
00244 extern int edg_wll_LogEnQueuedSTART(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00245
00246 extern int edg_wll_LogEnQueuedSTARTProxy(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00247
00259 extern int edg_wll_LogEnQueuedOK(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00260
00261 extern int edg_wll_LogEnQueuedOKProxy(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00262
00274 extern int edg_wll_LogEnQueuedREFUSED(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00275
00276 extern int edg_wll_LogEnQueuedREFUSEDProxy(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00277
00289 extern int edg_wll_LogEnQueuedFAIL(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00290
00291 extern int edg_wll_LogEnQueuedFAILProxy(edg_wll_Context context, const char * queue, const char * job, const char * reason);
00292
00302 extern int edg_wll_LogDeQueued(edg_wll_Context context, const char * queue, const char * local_jobid);
00303
00304 extern int edg_wll_LogDeQueuedProxy(edg_wll_Context context, const char * queue, const char * local_jobid);
00305
00316 extern int edg_wll_LogHelperCall(edg_wll_Context context, const char * helper_name, const char * helper_params, const char * src_role);
00317
00318 extern int edg_wll_LogHelperCallProxy(edg_wll_Context context, const char * helper_name, const char * helper_params, const char * src_role);
00319
00330 extern int edg_wll_LogHelperCallCALLING(edg_wll_Context context, const char * helper_name, const char * helper_params);
00331
00332 extern int edg_wll_LogHelperCallCALLINGProxy(edg_wll_Context context, const char * helper_name, const char * helper_params);
00333
00344 extern int edg_wll_LogHelperCallCALLED(edg_wll_Context context, const char * helper_name, const char * helper_params);
00345
00346 extern int edg_wll_LogHelperCallCALLEDProxy(edg_wll_Context context, const char * helper_name, const char * helper_params);
00347
00358 extern int edg_wll_LogHelperReturn(edg_wll_Context context, const char * helper_name, const char * retval, const char * src_role);
00359
00360 extern int edg_wll_LogHelperReturnProxy(edg_wll_Context context, const char * helper_name, const char * retval, const char * src_role);
00361
00372 extern int edg_wll_LogHelperReturnCALLING(edg_wll_Context context, const char * helper_name, const char * retval);
00373
00374 extern int edg_wll_LogHelperReturnCALLINGProxy(edg_wll_Context context, const char * helper_name, const char * retval);
00375
00386 extern int edg_wll_LogHelperReturnCALLED(edg_wll_Context context, const char * helper_name, const char * retval);
00387
00388 extern int edg_wll_LogHelperReturnCALLEDProxy(edg_wll_Context context, const char * helper_name, const char * retval);
00389
00398 extern int edg_wll_LogRunning(edg_wll_Context context, const char * node);
00399
00400 extern int edg_wll_LogRunningProxy(edg_wll_Context context, const char * node);
00401
00412 extern int edg_wll_LogResubmission(edg_wll_Context context, const char * result, const char * reason, const char * tag);
00413
00414 extern int edg_wll_LogResubmissionProxy(edg_wll_Context context, const char * result, const char * reason, const char * tag);
00415
00426 extern int edg_wll_LogResubmissionWILLRESUB(edg_wll_Context context, const char * reason, const char * tag);
00427
00428 extern int edg_wll_LogResubmissionWILLRESUBProxy(edg_wll_Context context, const char * reason, const char * tag);
00429
00440 extern int edg_wll_LogResubmissionWONTRESUB(edg_wll_Context context, const char * reason, const char * tag);
00441
00442 extern int edg_wll_LogResubmissionWONTRESUBProxy(edg_wll_Context context, const char * reason, const char * tag);
00443
00454 extern int edg_wll_LogResubmissionSHALLOW(edg_wll_Context context, const char * reason, const char * tag);
00455
00456 extern int edg_wll_LogResubmissionSHALLOWProxy(edg_wll_Context context, const char * reason, const char * tag);
00457
00468 extern int edg_wll_LogDone(edg_wll_Context context, const char * status_code, const char * reason, const int exit_code);
00469
00470 extern int edg_wll_LogDoneProxy(edg_wll_Context context, const char * status_code, const char * reason, const int exit_code);
00471
00482 extern int edg_wll_LogDoneOK(edg_wll_Context context, const char * reason, const int exit_code);
00483
00484 extern int edg_wll_LogDoneOKProxy(edg_wll_Context context, const char * reason, const int exit_code);
00485
00496 extern int edg_wll_LogDoneFAILED(edg_wll_Context context, const char * reason, const int exit_code);
00497
00498 extern int edg_wll_LogDoneFAILEDProxy(edg_wll_Context context, const char * reason, const int exit_code);
00499
00510 extern int edg_wll_LogDoneCANCELLED(edg_wll_Context context, const char * reason, const int exit_code);
00511
00512 extern int edg_wll_LogDoneCANCELLEDProxy(edg_wll_Context context, const char * reason, const int exit_code);
00513
00523 extern int edg_wll_LogCancel(edg_wll_Context context, const char * status_code, const char * reason);
00524
00525 extern int edg_wll_LogCancelProxy(edg_wll_Context context, const char * status_code, const char * reason);
00526
00536 extern int edg_wll_LogCancelREQ(edg_wll_Context context, const char * reason);
00537
00538 extern int edg_wll_LogCancelREQProxy(edg_wll_Context context, const char * reason);
00539
00549 extern int edg_wll_LogCancelREFUSE(edg_wll_Context context, const char * reason);
00550
00551 extern int edg_wll_LogCancelREFUSEProxy(edg_wll_Context context, const char * reason);
00552
00562 extern int edg_wll_LogCancelDONE(edg_wll_Context context, const char * reason);
00563
00564 extern int edg_wll_LogCancelDONEProxy(edg_wll_Context context, const char * reason);
00565
00575 extern int edg_wll_LogCancelABORT(edg_wll_Context context, const char * reason);
00576
00577 extern int edg_wll_LogCancelABORTProxy(edg_wll_Context context, const char * reason);
00578
00587 extern int edg_wll_LogAbort(edg_wll_Context context, const char * reason);
00588
00589 extern int edg_wll_LogAbortProxy(edg_wll_Context context, const char * reason);
00590
00599 extern int edg_wll_LogClear(edg_wll_Context context, const char * reason);
00600
00601 extern int edg_wll_LogClearProxy(edg_wll_Context context, const char * reason);
00602
00611 extern int edg_wll_LogClearUSER(edg_wll_Context context);
00612
00613 extern int edg_wll_LogClearUSERProxy(edg_wll_Context context);
00614
00623 extern int edg_wll_LogClearTIMEOUT(edg_wll_Context context);
00624
00625 extern int edg_wll_LogClearTIMEOUTProxy(edg_wll_Context context);
00626
00635 extern int edg_wll_LogClearNOOUTPUT(edg_wll_Context context);
00636
00637 extern int edg_wll_LogClearNOOUTPUTProxy(edg_wll_Context context);
00638
00646 extern int edg_wll_LogPurge(edg_wll_Context context);
00647
00648 extern int edg_wll_LogPurgeProxy(edg_wll_Context context);
00649
00658 extern int edg_wll_LogMatch(edg_wll_Context context, const char * dest_id);
00659
00660 extern int edg_wll_LogMatchProxy(edg_wll_Context context, const char * dest_id);
00661
00670 extern int edg_wll_LogPending(edg_wll_Context context, const char * reason);
00671
00672 extern int edg_wll_LogPendingProxy(edg_wll_Context context, const char * reason);
00673
00687 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);
00688
00689 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);
00690
00704 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);
00705
00706 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);
00707
00721 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);
00722
00723 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);
00724
00738 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);
00739
00740 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);
00741
00755 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);
00756
00757 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);
00758
00772 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);
00773
00774 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);
00775
00789 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);
00790
00791 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);
00792
00806 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);
00807
00808 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);
00809
00819 extern int edg_wll_LogChkpt(edg_wll_Context context, const char * tag, const char * classad);
00820
00821 extern int edg_wll_LogChkptProxy(edg_wll_Context context, const char * tag, const char * classad);
00822
00833 extern int edg_wll_LogListener(edg_wll_Context context, const char * svc_name, const char * svc_host, const uint16_t svc_port);
00834
00835 extern int edg_wll_LogListenerProxy(edg_wll_Context context, const char * svc_name, const char * svc_host, const uint16_t svc_port);
00836
00845 extern int edg_wll_LogCurDescr(edg_wll_Context context, const char * descr);
00846
00847 extern int edg_wll_LogCurDescrProxy(edg_wll_Context context, const char * descr);
00848
00858 extern int edg_wll_LogUserTag(edg_wll_Context context, const char * name, const char * value);
00859
00860 extern int edg_wll_LogUserTagProxy(edg_wll_Context context, const char * name, const char * value);
00861
00874 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);
00875
00876 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);
00877
00890 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 char * jobstat);
00891
00892 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 char * jobstat);
00893
00904 extern int edg_wll_LogResourceUsage(edg_wll_Context context, const char * resource, const double quantity, const char * unit);
00905
00906 extern int edg_wll_LogResourceUsageProxy(edg_wll_Context context, const char * resource, const double quantity, const char * unit);
00907
00916 extern int edg_wll_LogReallyRunning(edg_wll_Context context, const char * wn_seq);
00917
00918 extern int edg_wll_LogReallyRunningProxy(edg_wll_Context context, const char * wn_seq);
00919
00928 extern int edg_wll_LogSuspend(edg_wll_Context context, const char * reason);
00929
00930 extern int edg_wll_LogSuspendProxy(edg_wll_Context context, const char * reason);
00931
00940 extern int edg_wll_LogResume(edg_wll_Context context, const char * reason);
00941
00942 extern int edg_wll_LogResumeProxy(edg_wll_Context context, const char * reason);
00943
00956 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);
00957
00958 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);
00959
00970 extern int edg_wll_LogPBSQueued(edg_wll_Context context, const char * queue, const char * owner, const char * name);
00971
00972 extern int edg_wll_LogPBSQueuedProxy(edg_wll_Context context, const char * queue, const char * owner, const char * name);
00973
00982 extern int edg_wll_LogPBSMatch(edg_wll_Context context, const char * dest_host);
00983
00984 extern int edg_wll_LogPBSMatchProxy(edg_wll_Context context, const char * dest_host);
00985
00994 extern int edg_wll_LogPBSPending(edg_wll_Context context, const char * reason);
00995
00996 extern int edg_wll_LogPBSPendingProxy(edg_wll_Context context, const char * reason);
00997
01008 extern int edg_wll_LogPBSRun(edg_wll_Context context, const char * scheduler, const char * dest_host, const int pid);
01009
01010 extern int edg_wll_LogPBSRunProxy(edg_wll_Context context, const char * scheduler, const char * dest_host, const int pid);
01011
01019 extern int edg_wll_LogPBSRerun(edg_wll_Context context);
01020
01021 extern int edg_wll_LogPBSRerunProxy(edg_wll_Context context);
01022
01031 extern int edg_wll_LogPBSDone(edg_wll_Context context, const int exit_status);
01032
01033 extern int edg_wll_LogPBSDoneProxy(edg_wll_Context context, const int exit_status);
01034
01042 extern int edg_wll_LogPBSDequeued(edg_wll_Context context);
01043
01044 extern int edg_wll_LogPBSDequeuedProxy(edg_wll_Context context);
01045
01057 extern int edg_wll_LogPBSResourceUsage(edg_wll_Context context, const char * usage, const char * name, const double quantity, const char * unit);
01058
01059 extern int edg_wll_LogPBSResourceUsageProxy(edg_wll_Context context, const char * usage, const char * name, const double quantity, const char * unit);
01060
01071 extern int edg_wll_LogPBSResourceUsageREQUESTED(edg_wll_Context context, const char * name, const double quantity, const char * unit);
01072
01073 extern int edg_wll_LogPBSResourceUsageREQUESTEDProxy(edg_wll_Context context, const char * name, const double quantity, const char * unit);
01074
01085 extern int edg_wll_LogPBSResourceUsageUSED(edg_wll_Context context, const char * name, const double quantity, const char * unit);
01086
01087 extern int edg_wll_LogPBSResourceUsageUSEDProxy(edg_wll_Context context, const char * name, const double quantity, const char * unit);
01088
01097 extern int edg_wll_LogPBSError(edg_wll_Context context, const char * error_desc);
01098
01099 extern int edg_wll_LogPBSErrorProxy(edg_wll_Context context, const char * error_desc);
01100
01111 extern int edg_wll_LogCondorMatch(edg_wll_Context context, const char * owner, const char * dest_host, const char * preempting);
01112
01113 extern int edg_wll_LogCondorMatchProxy(edg_wll_Context context, const char * owner, const char * dest_host, const char * preempting);
01114
01124 extern int edg_wll_LogCondorReject(edg_wll_Context context, const char * owner, const char * status_code);
01125
01126 extern int edg_wll_LogCondorRejectProxy(edg_wll_Context context, const char * owner, const char * status_code);
01127
01136 extern int edg_wll_LogCondorRejectNOMATCH(edg_wll_Context context, const char * owner);
01137
01138 extern int edg_wll_LogCondorRejectNOMATCHProxy(edg_wll_Context context, const char * owner);
01139
01148 extern int edg_wll_LogCondorRejectOTHER(edg_wll_Context context, const char * owner);
01149
01150 extern int edg_wll_LogCondorRejectOTHERProxy(edg_wll_Context context, const char * owner);
01151
01163 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);
01164
01165 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);
01166
01176 extern int edg_wll_LogCondorShadowExited(edg_wll_Context context, const int shadow_pid, const int shadow_exit_status);
01177
01178 extern int edg_wll_LogCondorShadowExitedProxy(edg_wll_Context context, const int shadow_pid, const int shadow_exit_status);
01179
01189 extern int edg_wll_LogCondorStarterStarted(edg_wll_Context context, const int starter_pid, const char * universe);
01190
01191 extern int edg_wll_LogCondorStarterStartedProxy(edg_wll_Context context, const int starter_pid, const char * universe);
01192
01204 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);
01205
01206 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);
01207
01219 extern int edg_wll_LogCondorResourceUsage(edg_wll_Context context, const char * usage, const char * name, const double quantity, const char * unit);
01220
01221 extern int edg_wll_LogCondorResourceUsageProxy(edg_wll_Context context, const char * usage, const char * name, const double quantity, const char * unit);
01222
01233 extern int edg_wll_LogCondorResourceUsageREQUESTED(edg_wll_Context context, const char * name, const double quantity, const char * unit);
01234
01235 extern int edg_wll_LogCondorResourceUsageREQUESTEDProxy(edg_wll_Context context, const char * name, const double quantity, const char * unit);
01236
01247 extern int edg_wll_LogCondorResourceUsageUSED(edg_wll_Context context, const char * name, const double quantity, const char * unit);
01248
01249 extern int edg_wll_LogCondorResourceUsageUSEDProxy(edg_wll_Context context, const char * name, const double quantity, const char * unit);
01250
01259 extern int edg_wll_LogCondorError(edg_wll_Context context, const char * error_desc);
01260
01261 extern int edg_wll_LogCondorErrorProxy(edg_wll_Context context, const char * error_desc);
01262
01263
01279 extern int edg_wll_LogEvent(
01280 edg_wll_Context context,
01281 edg_wll_EventCode event,
01282 char *fmt, ...);
01283
01301 extern int edg_wll_LogEventSync(
01302 edg_wll_Context context,
01303 edg_wll_EventCode event,
01304 char *fmt, ...);
01305
01321 extern int edg_wll_LogEventProxy(
01322 edg_wll_Context context,
01323 edg_wll_EventCode event,
01324 char *fmt, ...);
01325
01337 extern int edg_wll_LogFlush(
01338 edg_wll_Context context,
01339 struct timeval *timeout);
01340
01341
01348 extern int edg_wll_LogFlushAll(
01349 edg_wll_Context context,
01350 struct timeval *timeout);
01351
01360 extern int edg_wll_SetLoggingJob(
01361 edg_wll_Context context,
01362 const edg_wlc_JobId job,
01363 const char * code,
01364 int flags
01365 );
01366
01376 extern int edg_wll_SetLoggingJobProxy(
01377 edg_wll_Context context,
01378 const edg_wlc_JobId job,
01379 const char * code,
01380 const char * user,
01381 int flags
01382 );
01383
01404
01405 #define EDG_WLL_JOB_SIMPLE EDG_WLL_REGJOB_SIMPLE
01406
01407 extern int edg_wll_RegisterJob(
01408 edg_wll_Context context,
01409 const edg_wlc_JobId job,
01410 enum edg_wll_RegJobJobtype type,
01411 const char * jdl,
01412 const char * ns,
01413 int num_subjobs,
01414 const char * seed,
01415 edg_wlc_JobId ** subjobs
01416 );
01417
01422 extern int edg_wll_RegisterJobSync(
01423 edg_wll_Context context,
01424 const edg_wlc_JobId job,
01425 enum edg_wll_RegJobJobtype type,
01426 const char * jdl,
01427 const char * ns,
01428 int num_subjobs,
01429 const char * seed,
01430 edg_wlc_JobId ** subjobs
01431 );
01432
01452 extern int edg_wll_RegisterJobProxy(
01453 edg_wll_Context context,
01454 const edg_wlc_JobId job,
01455 enum edg_wll_RegJobJobtype type,
01456 const char * jdl,
01457 const char * ns,
01458 int num_subjobs,
01459 const char * seed,
01460 edg_wlc_JobId ** subjobs
01461 );
01462
01463 #ifdef LB_PERF
01464
01465 extern int edg_wll_RegisterJobProxyOld(
01466 edg_wll_Context context,
01467 const edg_wlc_JobId job,
01468 enum edg_wll_RegJobJobtype type,
01469 const char * jdl,
01470 const char * ns,
01471 int num_subjobs,
01472 const char * seed,
01473 edg_wlc_JobId ** subjobs
01474 );
01475
01476
01477
01478
01479 extern int edg_wll_RegisterJobProxyOnly(
01480 edg_wll_Context context,
01481 const edg_wlc_JobId job,
01482 enum edg_wll_RegJobJobtype type,
01483 const char * jdl,
01484 const char * ns,
01485 int num_subjobs,
01486 const char * seed,
01487 edg_wlc_JobId ** subjobs
01488 );
01489 #endif
01490
01491
01492
01501 extern int edg_wll_RegisterSubjobs(
01502 edg_wll_Context context,
01503 const edg_wlc_JobId parent,
01504 char const * const * jdls,
01505 const char * ns,
01506 edg_wlc_JobId const * subjobs
01507 );
01508
01509
01518 extern int edg_wll_RegisterSubjobsProxy(
01519 edg_wll_Context context,
01520 const edg_wlc_JobId parent,
01521 char const * const * jdls,
01522 const char * ns,
01523 edg_wlc_JobId const * subjobs
01524 );
01525
01532 extern int edg_wll_GenerateSubjobIds(
01533 edg_wll_Context context,
01534 const edg_wlc_JobId parent,
01535 int num_subjobs,
01536 const char * seed,
01537 edg_wlc_JobId ** subjobs
01538 );
01539
01540
01541 enum edg_wll_Permission {
01542 EDG_WLL_PERM_READ = 1,
01543 EDG_WLL_PERM_WRITE = 4,
01544 EDG_WLL_PERM_ADMIN = 8,
01545 };
01546
01547 enum edg_wll_PermissionType {
01548 EDG_WLL_PERM_ALLOW,
01549 EDG_WLL_PERM_DENY,
01550 };
01551
01552 enum edg_wll_ACLOperation {
01553 EDG_WLL_ACL_ADD,
01554 EDG_WLL_ACL_REMOVE,
01555 };
01556
01557 enum edg_wll_UserIdType {
01558 EDG_WLL_USER_SUBJECT,
01559 EDG_WLL_USER_VOMS_GROUP,
01560 };
01561
01575 extern int edg_wll_ChangeACL(
01576 edg_wll_Context context,
01577 const edg_wlc_JobId job,
01578 const char * user_id,
01579 enum edg_wll_UserIdType user_id_type,
01580 enum edg_wll_Permission permission,
01581 enum edg_wll_PermissionType permission_type,
01582 enum edg_wll_ACLOperation operation
01583 );
01584
01585
01586 #ifdef __cplusplus
01587 }
01588 #endif
01589
01590 #endif