logsource.cs

   1 using System;
   2 using System.IO;
   3 using System.Web;
   4 using System.Collections;
   5 using Wv;
   6 using Wv.Schedulator;
   7
   8 namespace Wv.Schedulator
   9 {
  10     public class LogSource : Source
  11     {
  12         string logstr;
  13
  14         public LogSource(Schedulator s, string name, string logstr)
  15             : base(s, name)
  16         {
  17             this.logstr = logstr;
  18         }
  19
  20         public static Source create(Schedulator s, string name,
  21                                     string prefix, string suffix)
  22         {
  23             return new LogSource(s, name, suffix);
  24         }
  25
  26         static string clean_filename(string s)
  27         {
  28             string s2 = "";
  29             foreach (char c in s)
  30             {
  31                 if (Char.IsLetterOrDigit(c))
  32                     s2 += c;
  33                 else
  34                     s2 += "_";
  35             }
  36             return s2;
  37         }
  38
  39         static string get_file_from_id(string id)
  40         {
  41             try
  42             {
  43                 StreamReader r = File.OpenText(
  44                                String.Format("schedules/{0}.sched.log",
  45                                              clean_filename(id)));
  46                 return r.ReadToEnd();
  47             }
  48             catch (IOException)
  49             {
  50                 // nothing
  51             }
  52             return "";
  53         }
  54
  55         public static Source create_from_file_id(Schedulator s, string name,
  56                                               string prefix, string suffix)
  57         {
  58             string id = wv.isempty(suffix) ? s.name : suffix;
  59             return new LogSource(s, name, get_file_from_id(id));
  60         }
  61
  62         class Values
  63         {
  64             public TimeSpan
  65                 origest = TimeSpan.Zero,
  66                 currest = TimeSpan.Zero;
  67             public DateTime date;
  68         }
  69
  70         public override void cleanup_tasks()
  71         {
  72             Hashtable changes = new Hashtable();
  73
  74             string[] lines = logstr.Split("\n".ToCharArray());
  75             foreach (string line in lines)
  76             {
  77                 string[] words = line.Split(" ".ToCharArray());
  78                 if (words.Length < 2) continue;
  79                 string key = HttpUtility.UrlDecode(words[0]);
  80                 string value = HttpUtility.UrlDecode(words[1]);
  81                 DateTime date;
  82                 if (words.Length >= 3)
  83                     date = DateTime.Parse(words[2]);
  84                 else
  85                     date = DateTime.Parse("1999-01-01");
  86
  87                 Values v;
  88                 if (changes[key] != null)
  89                     v = (Values)changes[key];
  90                 else
  91                 {
  92                     v = new Values();
  93                     changes.Add(key, v);
  94                 }
  95                 if (wv.isempty(v.origest) && !wv.isempty(v.currest))
  96                     v.origest = v.currest;
  97                 v.currest = StringSource.parse_estimate(0, value);
  98                 if (wv.isempty(v.origest))
  99                     v.origest = v.currest;
 100                 v.date = date;
 101             }
 102
 103             foreach (string key in changes.Keys)
 104             {
 105                 string[] words = key.Split("_".ToCharArray(), 3);
 106                 if (words.Length < 3) continue; // invalid
 107
 108                 Task t = s.tasks.FindById(words[1] + ":" + words[2]);
 109                 if (t == null)
 110                     continue; // no longer exists, ignore
 111
 112                 Values v = (Values)changes[key];
 113
 114                 switch (words[0])
 115                 {
 116                 case "currest":
 117                     t.currest = v.currest;
 118                     t.origest = v.origest;
 119                     break;
 120                 case "elapsed":
 121                     t.elapsed = v.currest;
 122                     break;
 123                 }
 124
 125                 t.done = (!wv.isempty(t.currest) && t.currest == t.elapsed);
 126                 if (t.done) t.donedate = v.date;
 127             }
 128         }
 129     }
 130 }