From f1919c3c6a9dafb73722538f566c724b7ecfb09b Mon Sep 17 00:00:00 2001
From: fsaintma <frederic.saint-marcel@inria.fr>
Date: Mon, 8 Jun 2015 10:41:11 +0200
Subject: [PATCH] add ASAP mgt and fix start_time with ASAP jobs

---
 sfa/iotlab/iotlabaggregate.py | 2 --
 sfa/iotlab/iotlabdriver.py    | 4 +++-
 sfa/iotlab/iotlabshell.py     | 7 +++++--
 3 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/sfa/iotlab/iotlabaggregate.py b/sfa/iotlab/iotlabaggregate.py
index 2b496152..ee95299b 100644
--- a/sfa/iotlab/iotlabaggregate.py
+++ b/sfa/iotlab/iotlabaggregate.py
@@ -187,8 +187,6 @@ class IotLABAggregate(object):
                 leases.append(reserved_nodes[lease_id])
 
             rspec_leases = self.leases_to_rspec_leases(leases)
-            logger.warning("iotlabaggregate list_resources rspec_leases  %s" %
-                           rspec_leases)
             rspec.version.add_leases(rspec_leases)
         return rspec.toxml()
 
diff --git a/sfa/iotlab/iotlabdriver.py b/sfa/iotlab/iotlabdriver.py
index 8a52ee6a..231ed06a 100644
--- a/sfa/iotlab/iotlabdriver.py
+++ b/sfa/iotlab/iotlabdriver.py
@@ -63,7 +63,6 @@ class IotLabDriver(Driver):
         return geni_slivers
 
     def aggregate_version(self):
-        logger.warning("iotlabdriver aggregate_version")
         version_manager = VersionManager()
         ad_rspec_versions = []
         request_rspec_versions = []
@@ -145,6 +144,9 @@ class IotLabDriver(Driver):
         leases = rspec.version.get_leases()
         start_time = min([int(lease['start_time'])
                          for lease in leases])
+        # ASAP Jobs
+        if start_time == 0:
+            start_time = None
         end_time = max([int(lease['start_time']) +
                        int(lease['duration'])*60
                        for lease in leases])
diff --git a/sfa/iotlab/iotlabshell.py b/sfa/iotlab/iotlabshell.py
index f1fb1db0..becdbf50 100644
--- a/sfa/iotlab/iotlabshell.py
+++ b/sfa/iotlab/iotlabshell.py
@@ -137,10 +137,13 @@ class IotLABShell(object):
             return {'error': err.reason}
         for exp in experiments['items']:
             # BUG IN OAR REST API : job with reservation didn't return
-            # resources attribute list
-            # we use another request for finding job resources
+            # resources attribute list. We use another request for
+            # finding job resources
             exp_nodes = self.api.method('admin/experiments/%d' % exp['id'])
             exp['resources'] = exp_nodes['nodes']
+            # BUG ASAP jobs without date information
+            if exp['date'] == "as soon as possible":
+                exp['date'] = 0
             reserved_nodes_dict[exp['id']] = exp
         return reserved_nodes_dict
 
-- 
2.43.0