Changeset 3586

Timestamp:

10/30/2009 08:34:12 AM (3 weeks ago)

Author:

brian

Message:

Fix for VOView providers in release branch; set free_slots=0 if waiting jobs.

Files:

• gip/branches/1_1_x_release/gip/lib/python/gip/providers/condor.py (modified) (2 diffs)
• gip/branches/1_1_x_release/gip/lib/python/gip/providers/lsf.py (modified) (2 diffs)
• gip/branches/1_1_x_release/gip/lib/python/gip/providers/pbs.py (modified) (2 diffs)

gip/branches/1_1_x_release/gip/lib/python/gip/providers/condor.py

@@ -314 +314 @@
-            free = min(unclaimed, assigned-myrunning,
-                assigned-int(info['running']))
+            free = int(free)
+
+            waiting = int(info["idle"]) + int(info["held"])
+            if waiting > 0:
+                free = 0
-
-            info = {"vo"      : vo,
@@ -325 +330 @@
-                # Held jobs are included as "waiting" since the definition is:
-                #    Number of jobs that are in a state different than running
-info["idle"] + info["held"]
+waiting
-                "total"       : info["running"] + info["idle"] + info["held"],
-int(free)
+free
-                "job_slots"   : int(total_nodes),
-                "ert"         : ert,

gip/branches/1_1_x_release/gip/lib/python/gip/providers/lsf.py

@@ -146 +146 @@
-            max_job_time=my_queue_info.get("max_wall", 0))
-
+        free_slots = my_queue_info.get('free_slots', 0)
+        waiting = info2.get('waiting', 0)
+        if waiting > 0:
+            free_slots = 0
+
-        info = {
-            'ceUniqueID'  : ce_unique_id,
-            'job_slots'   : my_queue_info.get('job_slots', 0),
-my_queue_info.get('free_slots', 0)
+free_slots
-            'ce_name'     : ce_name,
-            'queue'       : queue,
@@ -158 +163 @@
-            'max_running' : info2.get('max_running', 0),
-            'priority'    : queue_info.get(queue, {}).get('priority', 0),
-info2.get('waiting', 0)
+waiting
-            'data'        : cp.get("osg_dirs", "data"),
-            'app'         : cp.get("osg_dirs", "app"),

gip/branches/1_1_x_release/gip/lib/python/gip/providers/pbs.py

@@ -130 +130 @@
-            max_job_time=my_queue_info.get("max_wall", 0))
-
+        free_slots = my_queue_info.get('free_slots', 0)
+        waiting = info2.get('wait', 0)
+        if waiting > 0:
+            free_slots = 0
+
-        info = {
-            'ceUniqueID'  : ce_unique_id,
-            'job_slots'   : my_queue_info.get('job_slots', 0),
-my_queue_info.get('free_slots', 0)
+free_slots
-            'ce_name'     : ce_name,
-            'queue'       : queue,
@@ -142 +147 @@
-            'max_running' : info2.get('max_running', 0),
-            'priority'    : queue_info.get(queue, {}).get('priority', 0),
-info2.get('wait', 0)
+waiting
-            'data'        : cp_get(cp, "osg_dirs", "data", "UNKNOWN_DATA"),
-            'app'         : cp_get(cp, "osg_dirs", "app", "UNKNOWN_APP"),