Merge pull request #77 from yuch7/1329

1329 add pid/pgid to RUN_RUSAGE for readstream.py

Author: yuch7

examples/readstream.py

@@ -27,7 +27,17 @@ def display(eventrec):
         for i in range(0,numhosts):
             hoststr += lsf.stringArray_getitem(exechosts, i) + ""
         print("EVENT_JOB_FORCE jobid<%d>, execHost<%s>, username<%s>" %(jobid, hoststr, username))
-
+    elif eventrec.type == lsf.EVENT_JOB_RUN_RUSAGE:
+        jobid = eventrec.eventLog.jobRunRusageLog.jobid;
+        numpgids = eventrec.eventLog.jobRunRusageLog.jrusage.npgids;
+        for i in range(0,numpgids):
+            pgids = str(lsf.intArray_getitem(eventrec.eventLog.jobRunRusageLog.jrusage.pgid, i)) + " "
+        pgids = pgids[:-1]
+        numpids = eventrec.eventLog.jobRunRusageLog.jrusage.npids;
+        for i in range(0,numpids):
+            pids = str(lsf.pidInfoArray_getitem(eventrec.eventLog.jobRunRusageLog.jrusage.pidInfo, i).pid) + " ";
+        pids = pids[:-1]
+        print("EVENT_JOB_RUN_RUSAGE jobid<%d> pgids<%s> pids<%s>" %(jobid, pgids, pids))
     else:
         print("event type is %d" %(eventrec.type))
 

pythonlsf/lsf.i

@@ -53,6 +53,7 @@ typedef long off_t;
 %array_functions(struct gpuTaskData, gpuTaskDataArray)
 %array_functions(struct gpuData *, gpuDataArray)
 %array_functions(struct migData, migDataArray)
+%array_functions(struct pidInfo, pidInfoArray)
 #endif
 %array_functions(LS_LONG_INT, LS_LONG_INTArray)
 %array_functions(guaranteedResourcePoolEnt, guaranteedResourcePoolEntArray)