Mercurial > pub > ImplabNet
annotate Implab/Diagnostics/TraceContext.cs @ 209:a867536c68fc v2
Bound promise to CancellationToken
Added new states to ExecutionSate enum.
Added Safe.Guard() method to handle cleanup of the result of the promise
| author | cin |
|---|---|
| date | Wed, 16 Nov 2016 03:06:08 +0300 |
| parents | 71e543dbe65a |
| children | babe55c34931 |
| rev | line source |
|---|---|
| 92 | 1 using System; |
| 2 using System.Collections.Generic; | |
| 3 using System.Threading; | |
| 4 | |
| 5 namespace Implab.Diagnostics { | |
| 6 /// <summary> | |
| 7 /// Trace context is bound to the specific thread, each thread has it's own ThreadContext. | |
| 8 /// </summary> | |
| 9 /// <remarks> | |
| 10 /// ThreadContext manages relations between logical operations and threads. | |
| 11 /// </remarks> | |
| 12 public class TraceContext { | |
| 13 | |
| 14 [ThreadStatic] | |
| 15 static TraceContext _instance; | |
| 16 | |
| 17 OperationContext m_current = OperationContext.EMPTY; | |
| 18 readonly Stack<OperationContext> m_stack = new Stack<OperationContext>(); | |
| 19 readonly int m_threadId; | |
| 20 | |
| 21 public static TraceContext Instance { | |
| 22 get { | |
| 23 if (_instance == null) | |
| 24 _instance = new TraceContext(); | |
| 25 return _instance; | |
| 26 } | |
| 27 } | |
| 28 | |
| 29 public TraceContext() { | |
| 30 m_threadId = Thread.CurrentThread.ManagedThreadId; | |
| 31 } | |
| 32 | |
| 33 public int ThreadId { | |
| 34 get { return m_threadId; } | |
| 35 } | |
| 36 | |
| 37 public LogicalOperation CurrentOperation { | |
| 38 get { | |
| 39 return m_current.CurrentOperation; | |
| 40 } | |
| 41 } | |
| 42 | |
| 43 public void EnterLogicalOperation(LogicalOperation operation, bool takeOwnership) { | |
| 133 | 44 //var prev = CurrentOperation; |
| 134 | 45 //LogChannel<TraceEvent>.Default.LogEvent(new TraceEvent(takeOwnership ? TraceEventType.Attach : TraceEventType.Enter, String.Format("{0} -> {1}",prev.Name, operation.Name))); |
| 92 | 46 m_stack.Push(m_current); |
| 47 m_current = new OperationContext(operation, takeOwnership); | |
| 48 } | |
| 49 | |
| 50 public void StartLogicalOperation(string name) { | |
| 200 | 51 LogChannel<TraceEvent>.Default.LogEvent(new TraceEvent(TraceContext.Instance.CurrentOperation, TraceEventType.OperationStarted, name)); |
| 92 | 52 m_current.BeginLogicalOperation(name); |
| 53 } | |
| 54 | |
| 55 public void StartLogicalOperation() { | |
| 93 | 56 StartLogicalOperation(String.Empty); |
| 92 | 57 } |
| 58 | |
| 195 | 59 public LogicalOperation EndLogicalOperation() { |
| 60 return m_current.EndLogicalOperation(); | |
| 92 | 61 } |
| 62 | |
| 63 public LogicalOperation DetachLogicalOperation() { | |
| 94 | 64 var prev = m_current.DetachLogicalOperation(); |
| 133 | 65 //LogChannel<TraceEvent>.Default.LogEvent(new TraceEvent(TraceEventType.Detach, String.Format("{0} -> {1}",prev.Name, CurrentOperation.Name))); |
| 94 | 66 return prev; |
| 92 | 67 } |
| 68 | |
| 69 public void Leave() { | |
| 93 | 70 if (m_stack.Count > 0) { |
| 71 m_current.Leave(); | |
| 133 | 72 //var prev = CurrentOperation; |
| 92 | 73 m_current = m_stack.Pop(); |
| 133 | 74 //LogChannel<TraceEvent>.Default.LogEvent(new TraceEvent(TraceEventType.Leave, String.Format("{0} -> {1}", prev.Name, CurrentOperation.Name))); |
| 93 | 75 } else { |
|
119
2573b562e328
Promises rewritten, added improved version of AsyncQueue
cin
parents:
94
diff
changeset
|
76 TraceLog.TraceWarning("Attempt to leave the last operation context"); |
| 92 | 77 m_current = OperationContext.EMPTY; |
| 78 } | |
| 79 } | |
| 80 } | |
| 81 } | |
| 82 |