Returns all job ID's if queried without ID.

JIRA: STORPERF-184

Change-Id: I631b4adbd830420a3b502e4f2a86a66824c87fcd
Signed-off-by: Taseer Ahmed <taseer94@gmail.com>

2 files changed, 16 insertions, 0 deletions

diff --git a/docker/storperf-master/storperf/db/job_db.py b/docker/storperf-master/storperf/db/job_db.py
index 3308fa8..eb35cac 100644
--- a/docker/storperf-master/storperf/db/job_db.py
+++ b/docker/storperf-master/storperf/db/job_db.py
@@ -233,6 +233,19 @@ class JobDB(object):
             db.commit()
             db.close()
 
+    def fetch_jobs(self):
+        jobs = []
+        db = sqlite3.connect(JobDB.db_name)
+        cursor = db.cursor()
+        cursor.execute("select distinct job_id from jobs")
+        while (True):
+            row = cursor.fetchone()
+            if row is None:
+                break
+            jobs.append(row[0])
+        db.close()
+        return jobs
+
     def fetch_workload_params(self, job_id):
         """
         """
diff --git a/docker/storperf-master/storperf/storperf_master.py b/docker/storperf-master/storperf/storperf_master.py
index 054d2a7..b30d266 100644
--- a/docker/storperf-master/storperf/storperf_master.py
+++ b/docker/storperf-master/storperf/storperf_master.py
@@ -346,6 +346,9 @@ class StorPerfMaster(object):
     def fetch_job_status(self, job_id):
         return self._test_executor.execution_status(job_id)
 
+    def fetch_all_jobs(self):
+        return self.job_db.fetch_jobs()
+
     def _setup_slave(self, slave):
         logger = logging.getLogger(__name__ + ":" + slave)