|
36
|
1 using System;
|
|
|
2 using System.Collections.Generic;
|
|
|
3 using System.Linq;
|
|
|
4 using System.Text;
|
|
|
5 using System.Threading;
|
|
|
6 using System.Threading.Tasks;
|
|
|
7
|
|
|
8 namespace Implab.Diagnostics {
|
|
40
|
9 /// <summary>
|
|
|
10 /// Контекст трассировки, привязывается к потоку и содержит в себе информацию о стеке логических операций.
|
|
|
11 /// </summary>
|
|
|
12 /// <remarks>
|
|
|
13 /// Контекст трассировки передается слушателям событий для определения места, где возникло событие.
|
|
|
14 /// </remarks>
|
|
36
|
15 public class TraceContext {
|
|
|
16 LogicalOperation m_currentOperation;
|
|
40
|
17 readonly LogicalOperation m_bound;
|
|
36
|
18 readonly int m_threadId;
|
|
|
19
|
|
|
20 [ThreadStatic]
|
|
|
21 static TraceContext _current;
|
|
|
22
|
|
40
|
23 /// <summary>
|
|
|
24 /// Текущий контекст трассировки для потока, создается астоматически при первом обращении.
|
|
|
25 /// </summary>
|
|
36
|
26 public static TraceContext Current {
|
|
|
27 get {
|
|
|
28 if (_current == null)
|
|
|
29 _current = new TraceContext();
|
|
|
30 return _current;
|
|
|
31 }
|
|
|
32 }
|
|
|
33
|
|
|
34 TraceContext(TraceContext context) {
|
|
|
35 if (context == null)
|
|
|
36 throw new ArgumentNullException("context");
|
|
|
37
|
|
|
38 m_currentOperation = context.CurrentOperation;
|
|
40
|
39 m_bound = context.CurrentOperation;
|
|
36
|
40 m_threadId = Thread.CurrentThread.ManagedThreadId;
|
|
|
41 }
|
|
|
42
|
|
|
43 TraceContext() {
|
|
|
44 m_currentOperation = new LogicalOperation();
|
|
40
|
45 m_bound = m_currentOperation;
|
|
36
|
46 m_threadId = Thread.CurrentThread.ManagedThreadId;
|
|
|
47 }
|
|
|
48
|
|
40
|
49 /// <summary>
|
|
|
50 /// При необходимости копирует состояние контекста трассивровки в текущий поток.
|
|
|
51 /// </summary>
|
|
|
52 /// <param name="from">Исходный контекст трассировки, который передается.</param>
|
|
|
53 /// <remarks>
|
|
|
54 /// <para>
|
|
|
55 /// Копирование происходит за счет создания нового контекста трассировки и заполнением его
|
|
|
56 /// состояния из переданного контекста. При этом копируется стек операций, однако в новом
|
|
|
57 /// контексте ранее начатые логические операции не могут быть завершены.
|
|
|
58 /// </para>
|
|
|
59 /// <para>
|
|
|
60 /// Если передача состояния состоялась, то вызывается событие трассировки <see cref="TraceEventType.Transfer"/>.
|
|
|
61 /// </para>
|
|
|
62 /// </remarks>
|
|
36
|
63 public static void Transfer(TraceContext from) {
|
|
40
|
64 if (_current == from)
|
|
|
65 return;
|
|
|
66 if (from != null) {
|
|
|
67 var context = new TraceContext(from);
|
|
|
68 context.LogEvent(TraceEventType.Transfer, "[{0}]-->[{1}]",from.ThreadId, context.ThreadId);
|
|
|
69 _current = context;
|
|
|
70 } else {
|
|
|
71 _current = new TraceContext();
|
|
36
|
72 }
|
|
|
73 }
|
|
|
74
|
|
40
|
75 /// <summary>
|
|
|
76 /// Создает постоянную копию текущего контекста, данную копию можно хранить и использовать для передачи через <see cref="Transfer(TraceContext)"/>
|
|
|
77 /// </summary>
|
|
|
78 /// <returns>Копия текущего контекста трассировки или <c>null</c> если таковой не был создан.</returns>
|
|
|
79 public static TraceContext Snapshot() {
|
|
|
80 return _current == null ? null : new TraceContext(_current);
|
|
|
81 }
|
|
|
82
|
|
|
83 /// <summary>
|
|
|
84 /// Выполняет переданное действие в указанном контексте трассировки, по окончании восстанавливает предыдущий контекст трассировки потока.
|
|
|
85 /// </summary>
|
|
|
86 /// <param name="action"></param>
|
|
|
87 public void Invoke(Action action) {
|
|
|
88 if (action == null)
|
|
|
89 throw new ArgumentNullException("action");
|
|
|
90 var old = _current;
|
|
|
91 Transfer(this);
|
|
|
92 try {
|
|
|
93 action();
|
|
|
94 } finally {
|
|
|
95 _current = old;
|
|
|
96 }
|
|
|
97 }
|
|
|
98
|
|
|
99 /// <summary>
|
|
|
100 /// Текущая логическая операция.
|
|
|
101 /// </summary>
|
|
36
|
102 public LogicalOperation CurrentOperation {
|
|
|
103 get {
|
|
|
104 return m_currentOperation;
|
|
|
105 }
|
|
|
106 }
|
|
|
107
|
|
40
|
108 /// <summary>
|
|
|
109 /// Операция ниже которой нельзя опускаться в стеке логических операций, т.е. она не может быть завершена в текущем контексте.
|
|
|
110 /// </summary>
|
|
|
111 public LogicalOperation BoundOperation {
|
|
36
|
112 get {
|
|
40
|
113 return m_bound;
|
|
36
|
114 }
|
|
|
115 }
|
|
|
116
|
|
40
|
117 /// <summary>
|
|
|
118 /// Поток, в котором создан контекст трассировки.
|
|
|
119 /// </summary>
|
|
36
|
120 public int ThreadId {
|
|
|
121 get {
|
|
|
122 return m_threadId;
|
|
|
123 }
|
|
|
124 }
|
|
|
125
|
|
40
|
126 /// <summary>
|
|
|
127 /// Начинает безымянную логическую операцию.
|
|
|
128 /// </summary>
|
|
36
|
129 public void StartLogicalOperation() {
|
|
|
130 StartLogicalOperation(null);
|
|
|
131 }
|
|
|
132
|
|
40
|
133 /// <summary>
|
|
|
134 /// Начинает логическую операцию с указанным именем. Созданная операция будет добвалена в стек логических операций контекста, затем будет создано соответсвующее событие.
|
|
|
135 /// </summary>
|
|
|
136 /// <param name="name">Имя начинаемой операции.</param>
|
|
36
|
137 public void StartLogicalOperation(string name) {
|
|
|
138 m_currentOperation = new LogicalOperation(name, m_currentOperation);
|
|
40
|
139 LogEvent(TraceEventType.OperationStarted, name);
|
|
36
|
140 }
|
|
|
141
|
|
40
|
142 /// <summary>
|
|
|
143 /// Заканчивает логическую операцию начатую в текущем контексте. Операции, начатые в других контекстах не могут быть закончены в текущем контексте.
|
|
|
144 /// </summary>
|
|
|
145 /// <remarks>
|
|
|
146 /// При вызове данного метода создается событие журнала трассировки, либо о завершении операции, либо об ошибки, поскольку данная операция
|
|
|
147 /// начата в другом контексте.
|
|
|
148 /// </remarks>
|
|
36
|
149 public void EndLogicalOperation() {
|
|
40
|
150 if (m_bound == m_currentOperation) {
|
|
36
|
151 LogEvent(TraceEventType.Error, "Trying to end the operation which isn't belongs to current trace");
|
|
|
152 } else {
|
|
|
153 var op = m_currentOperation;
|
|
40
|
154 LogEvent(TraceEventType.OperationCompleted, "{0} {1} ms", op.Name, op.Duration);
|
|
36
|
155 m_currentOperation = m_currentOperation.Parent;
|
|
|
156 }
|
|
|
157 }
|
|
|
158
|
|
|
159 void LogEvent(TraceEventType type, string format, params object[] args) {
|
|
37
|
160 LogChannel<TraceEvent>.Default.LogEvent(this, TraceEvent.Create(type, format, args));
|
|
36
|
161 }
|
|
|
162 }
|
|
|
163 }
|
