Changeset 11222 for branches/HiveStatistics/sources/HeuristicLab.Services.Hive.Statistics/3.3/Controllers/AdminDataController.cs

Timestamp:

07/24/14 09:16:42 (10 years ago)

Author:

mroscoe

Message:

 

File:

• branches/HiveStatistics/sources/HeuristicLab.Services.Hive.Statistics/3.3/Controllers/AdminDataController.cs (modified) (3 diffs)

branches/HiveStatistics/sources/HeuristicLab.Services.Hive.Statistics/3.3/Controllers/AdminDataController.cs

@@ -24 +24 @@
     }
 
-    public JsonResult TaskStats(DateTime start, DateTime end, string userName=null)
-    {
-      using (var db = new HiveDataContext(Settings.Default.HeuristicLab_Hive_LinqConnectionString))
-      {
+    public JsonResult TaskStats(DateTime start, DateTime end, string userName=null) {
+      using (var db = new HiveDataContext(Settings.Default.HeuristicLab_Hive_LinqConnectionString)) {
         var taskStats = (from tasks in db.FactTasks
                         join jobs in db.DimJobs
@@ -35 +33 @@
                         (string.IsNullOrEmpty(userName) || jobs.UserName == userName)
                         select new { tasks.TotalWaitingTime, tasks.TotalTransferTime, tasks.TotalRuntime, tasks.NumCalculationRuns, 
-                          tasks.CoresRequired, tasks.MemoryRequired, tasks.TaskSize, tasks.ResultSize})
+                          tasks.CoresRequired, tasks.MemoryRequired})
                           .ToList();
 
@@ -45 +43 @@
         FullStats.Add(new KeyValuePair<string, double>("Cores Required", taskStats.Sum(c => c.CoresRequired)));
         FullStats.Add(new KeyValuePair<string, double>("Memory Required", taskStats.Sum(m => m.MemoryRequired)));
-        FullStats.Add(new KeyValuePair<string, double>("Task Size", taskStats.Sum(ts => ts.TaskSize)));
-        FullStats.Add(new KeyValuePair<string, double>("Result Size", taskStats.Sum(rs => Convert.ToDouble(rs.ResultSize))));
 
         return Json(FullStats, JsonRequestBehavior.AllowGet);
       }
     }
+
+    public JsonResult MoreTaskInfo(string taskId) {
+      using (var db = new HiveDataContext(Settings.Default.HeuristicLab_Hive_LinqConnectionString))
+      {
+        var moreInfo = (from tasks in db.FactTasks
+                         where tasks.TaskId.ToString() == taskId
+                         select new
+                         {
+                           tasks.TotalWaitingTime,
+                           tasks.TotalTransferTime,
+                           tasks.TotalRuntime,
+                           tasks.NumCalculationRuns,
+                           tasks.CoresRequired,
+                           tasks.MemoryRequired,
+                         })
+                          .ToList();
+
+        List<KeyValuePair<string, double>> AllInfo = new List<KeyValuePair<string, double>>();
+        AllInfo.Add(new KeyValuePair<string, double>("Number Calculation Runs", moreInfo.Sum(n => n.NumCalculationRuns)));
+        AllInfo.Add(new KeyValuePair<string, double>("Cores Required", moreInfo.Sum(c => c.CoresRequired)));
+        AllInfo.Add(new KeyValuePair<string, double>("Memory Required", moreInfo.Sum(m => m.MemoryRequired)));
+
+        return Json(AllInfo, JsonRequestBehavior.AllowGet);
+      }
+    }
+
+    public JsonResult MoreSlaveInfo(string slaveId) {
+      using (var db = new HiveDataContext(Settings.Default.HeuristicLab_Hive_LinqConnectionString))
+      {
+        var moreInfo = (from slaves in db.FactClientInfos
+                        where slaves.ClientId.ToString() == slaveId
+                        select new
+                        {
+                          slaves.Time,
+                          slaves.TotalTimeIdle,
+                          slaves.TotalTimeCalculating,
+                          slaves.TotalTimeTransferring,
+                          slaves.TotalTimeOffline,
+                          slaves.TotalTimeUnavailable
+                        }).ToList();
+
+        List<List<KeyValuePair<string, string>>> AllInfo = new List<List<KeyValuePair<string, string>>>();
+        List<List<KeyValuePair<string, string>>> DistinctInfo = new List<List<KeyValuePair<string, string>>>();
+        for(var i=0; i < moreInfo.Count; i++) {
+          List<KeyValuePair<string, string>> newRow = new List<KeyValuePair<string, string>>();
+          newRow.Add(new KeyValuePair<string, string>("Time", moreInfo.ElementAt(i).Time.ToShortDateString() + " " + moreInfo.ElementAt(i).Time.ToShortTimeString()));
+          newRow.Add(new KeyValuePair<string, string>("Time Idle", moreInfo.ElementAt(i).TotalTimeIdle.ToString()));
+          newRow.Add(new KeyValuePair<string, string>("Time Calculating", moreInfo.ElementAt(i).TotalTimeCalculating.ToString()));
+          newRow.Add(new KeyValuePair<string, string>("Time Transferring", moreInfo.ElementAt(i).TotalTimeTransferring.ToString()));
+          newRow.Add(new KeyValuePair<string, string>("Time Offline", moreInfo.ElementAt(i).TotalTimeOffline.ToString()));
+          newRow.Add(new KeyValuePair<string, string>("Time Unavailable", moreInfo.ElementAt(i).TotalTimeUnavailable.ToString()));
+          AllInfo.Add(newRow);
+        }
+
+        //Ensures that only records with changes in Traffic or Time fields are included
+        List<KeyValuePair<string, string>> lastRecord = null;
+        //Initilized to true to ensure first record is automatically included
+        bool isDistinct = true;
+        foreach (List<KeyValuePair<string, string>> row in AllInfo) {
+          //Ignores check for first row
+          if (lastRecord != null) {
+            isDistinct = false;
+            //Cycles through values of current row and lastRecord
+            for (var j=0; j < row.Count; j++) {
+              //Disregards time field from distinct checks
+              if (row.ElementAt(j).Key != "Time") {
+                //If values differ then row is distinct, break loop
+                if (row.ElementAt(j).Value != lastRecord.ElementAt(j).Value) {
+                  isDistinct = true;
+                  break;
+                }
+              }
+            }
+          }
+          lastRecord = row;
+          if (isDistinct) {
+            DistinctInfo.Add(row);
+          }
+        }
+
+        return Json(DistinctInfo, JsonRequestBehavior.AllowGet);
+      }
+    }
   }
 }