Changeset 4904 for branches/HeuristicLab.DebugEngine/DebugEngine.cs

Timestamp:

11/22/10 17:06:12 (13 years ago)

Author:

epitzer

Message:

Add operator trace view (#47)

File:

• branches/HeuristicLab.DebugEngine/DebugEngine.cs (modified) (11 diffs)

branches/HeuristicLab.DebugEngine/DebugEngine.cs

@@ -21 +21 @@
 
 using System;
+using System.Collections.Generic;
 using System.Linq;
 using System.Threading;
@@ -48 +49 @@
       Log = cloner.Clone(original.Log);
       ExecutionStack = cloner.Clone(original.ExecutionStack);
+      OperatorTrace = new ItemList<IOperator>(original.OperatorTrace.Select(op => cloner.Clone(op)));
+      operatorParents = original.operatorParents.ToDictionary(kvp => cloner.Clone(kvp.Key), kvp => cloner.Clone(kvp.Value));
       pausePending = original.pausePending;
       stopPending = original.stopPending;
@@ -60 +63 @@
       Log = new Log();
       ExecutionStack = new ExecutionStack();
+      OperatorTrace = new ItemList<IOperator>();
+      operatorParents = new Dictionary<IAtomicOperation, IAtomicOperation>();
       pausePending = stopPending = false;
       timer = new System.Timers.Timer(100);
@@ -110 +115 @@
     }
 
+    [Storable]
+    public ItemList<IOperator> OperatorTrace { get; private set; }
+
+    [Storable]
+    private Dictionary<IAtomicOperation, IAtomicOperation> operatorParents;
+
     #endregion
 
@@ -131 +142 @@
       ignoreNextBreakpoint = false;
       CurrentOperation = null;
+      OperatorTrace.Clear();
+      operatorParents.Clear();
       OnPrepared();
     }
@@ -140 +153 @@
       ignoreNextBreakpoint = false;
       CurrentOperation = null;
+      OperatorTrace.Clear();
+      operatorParents.Clear();
       OnPrepared();
     }
@@ -161 +176 @@
     public override void Start() {
       base.Start();
-      CurrentOperation = null;
       ThreadPool.QueueUserWorkItem(new WaitCallback(Run), null);
     }
@@ -250 +264 @@
           ExpandOperationCollection(operations);
         } else if (ExecutionStack.Count > 0) {
-          Log.LogMessage("Poping execution stack");
+          Log.LogMessage("Popping execution stack");
           CurrentOperation = ExecutionStack.Last();
           ExecutionStack.RemoveAt(ExecutionStack.Count - 1);
@@ -256 +270 @@
           Log.LogMessage("Nothing to do");
         }
+        GenerateOperationTrace();
       } catch (Exception x) {
         OnExceptionOccurred(x);
+      }
+    }
+
+    private void GenerateOperationTrace() {
+      var operation = CurrentOperation as IAtomicOperation;
+      if (operation != null) {
+        List<IOperator> trace = new List<IOperator>();
+        while (operation != null) {
+          trace.Add(operation.Operator);
+          IAtomicOperation parent = null;
+          operatorParents.TryGetValue(operation, out parent);
+          operation = parent;
+        }
+        trace.Reverse();
+        OperatorTrace.Clear();
+        OperatorTrace.AddRange(trace);
       }
     }
@@ -276 +307 @@
           currentOperator = operation.Operator;
           IOperation successor = operation.Operator.Execute((IExecutionContext)operation);
-          CurrentOperation = null;
-          currentOperator = null;
           if (successor != null) {
+            AssignParents(operation, successor);
             ExecutionStack.Add(successor);
           }
+          currentOperator = null;
+          CurrentOperation = null;
         } catch (Exception ex) {
           OnExceptionOccurred(new OperatorExecutionException(operation.Operator, ex));
@@ -288 +320 @@
     }
 
+    private void AssignParents(IAtomicOperation parent, IOperation successor) {
+      OperationCollection operations = successor as OperationCollection;
+      if (operations != null)
+        foreach (var op in operations)
+          AssignParents(parent, op);
+      IAtomicOperation atomicOperation = successor as IAtomicOperation;
+      if (atomicOperation != null && atomicOperation.Operator != null && !operatorParents.ContainsKey(atomicOperation))
+        operatorParents[atomicOperation] = parent;
+    }
+
     protected virtual void ExpandOperationCollection(OperationCollection operations) {
       ExecutionStack.AddRange(operations.Reverse());