@@ -0,0 +1,37 | |||
|
1 | using System; | |
|
2 | using System.Collections.Generic; | |
|
3 | using System.Linq; | |
|
4 | using System.Text; | |
|
5 | ||
|
6 | namespace Implab.Diagnostics { | |
|
7 | public class ConsoleTraceListener { | |
|
8 | ||
|
9 | static readonly object _consoleLock = new object(); | |
|
10 | ||
|
11 | public void Subscribe() { | |
|
12 | LogChannel<TraceEvent>.Default.Events += Default_Events; | |
|
13 | } | |
|
14 | ||
|
15 | public void Unsubscribe() { | |
|
16 | LogChannel<TraceEvent>.Default.Events -= Default_Events; | |
|
17 | } | |
|
18 | ||
|
19 | void Default_Events(object sender, ValueEventArgs<TraceEvent> e) { | |
|
20 | LogEvent((TraceContext)sender, e.Value); | |
|
21 | } | |
|
22 | ||
|
23 | void LogEvent(TraceContext context, TraceEvent evt) { | |
|
24 | var msg = new StringBuilder(); | |
|
25 | for (int i = 0; i < context.CurrentOperation.Level; i++) | |
|
26 | msg.Append(" "); | |
|
27 | msg.Append(evt.EventType); | |
|
28 | msg.AppendFormat("[{0}]: ",context.ThreadId); | |
|
29 | msg.Append(evt.Message); | |
|
30 | ||
|
31 | lock (_consoleLock) { | |
|
32 | Console.ForegroundColor = (ConsoleColor)(context.ThreadId % 15 + 1); | |
|
33 | Console.WriteLine(msg.ToString()); | |
|
34 | } | |
|
35 | } | |
|
36 | } | |
|
37 | } |
@@ -0,0 +1,24 | |||
|
1 | using System; | |
|
2 | using System.Collections.Generic; | |
|
3 | using System.Linq; | |
|
4 | using System.Text; | |
|
5 | ||
|
6 | namespace Implab.Diagnostics { | |
|
7 | public class LogChannel<TEvent> { | |
|
8 | static LogChannel<TEvent> _default = new LogChannel<TEvent>(); | |
|
9 | ||
|
10 | public static LogChannel<TEvent> Default { | |
|
11 | get { | |
|
12 | return _default; | |
|
13 | } | |
|
14 | } | |
|
15 | ||
|
16 | public event EventHandler<ValueEventArgs<TEvent>> Events; | |
|
17 | ||
|
18 | public void LogEvent(TEvent data) { | |
|
19 | var t = Events; | |
|
20 | if (t!= null) | |
|
21 | t(TraceContext.Current,new ValueEventArgs<TEvent>(data)); | |
|
22 | } | |
|
23 | } | |
|
24 | } |
@@ -0,0 +1,97 | |||
|
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 { | |
|
9 | public class TraceContext { | |
|
10 | LogicalOperation m_currentOperation; | |
|
11 | readonly LogicalOperation m_traceBound; | |
|
12 | readonly int m_threadId; | |
|
13 | readonly TraceContext m_parent; | |
|
14 | ||
|
15 | readonly static object _consoleLock = new object(); | |
|
16 | ||
|
17 | [ThreadStatic] | |
|
18 | static TraceContext _current; | |
|
19 | ||
|
20 | public static TraceContext Current { | |
|
21 | get { | |
|
22 | if (_current == null) | |
|
23 | _current = new TraceContext(); | |
|
24 | return _current; | |
|
25 | } | |
|
26 | } | |
|
27 | ||
|
28 | TraceContext(TraceContext context) { | |
|
29 | if (context == null) | |
|
30 | throw new ArgumentNullException("context"); | |
|
31 | ||
|
32 | m_parent = context; | |
|
33 | m_currentOperation = context.CurrentOperation; | |
|
34 | m_traceBound = context.CurrentOperation; | |
|
35 | m_threadId = Thread.CurrentThread.ManagedThreadId; | |
|
36 | ||
|
37 | LogEvent(TraceEventType.Transfer, String.Empty); | |
|
38 | } | |
|
39 | ||
|
40 | TraceContext() { | |
|
41 | m_currentOperation = new LogicalOperation(); | |
|
42 | m_traceBound = m_currentOperation; | |
|
43 | m_threadId = Thread.CurrentThread.ManagedThreadId; | |
|
44 | } | |
|
45 | ||
|
46 | public static void Transfer(TraceContext from) { | |
|
47 | _current = from == null ? new TraceContext() : new TraceContext(from); | |
|
48 | } | |
|
49 | ||
|
50 | public TraceContext ParentContext { | |
|
51 | get { | |
|
52 | return m_parent; | |
|
53 | } | |
|
54 | } | |
|
55 | ||
|
56 | public LogicalOperation CurrentOperation { | |
|
57 | get { | |
|
58 | return m_currentOperation; | |
|
59 | } | |
|
60 | } | |
|
61 | ||
|
62 | public LogicalOperation TraceBound { | |
|
63 | get { | |
|
64 | return m_traceBound; | |
|
65 | } | |
|
66 | } | |
|
67 | ||
|
68 | public int ThreadId { | |
|
69 | get { | |
|
70 | return m_threadId; | |
|
71 | } | |
|
72 | } | |
|
73 | ||
|
74 | public void StartLogicalOperation() { | |
|
75 | StartLogicalOperation(null); | |
|
76 | } | |
|
77 | ||
|
78 | public void StartLogicalOperation(string name) { | |
|
79 | LogEvent(TraceEventType.OperationStarted, "{0}", name); | |
|
80 | m_currentOperation = new LogicalOperation(name, m_currentOperation); | |
|
81 | } | |
|
82 | ||
|
83 | public void EndLogicalOperation() { | |
|
84 | if (m_traceBound == m_currentOperation) { | |
|
85 | LogEvent(TraceEventType.Error, "Trying to end the operation which isn't belongs to current trace"); | |
|
86 | } else { | |
|
87 | var op = m_currentOperation; | |
|
88 | m_currentOperation = m_currentOperation.Parent; | |
|
89 | LogEvent(TraceEventType.OperationCompleted, "{0} {1} ms", op.Name, op.Duration); | |
|
90 | } | |
|
91 | } | |
|
92 | ||
|
93 | void LogEvent(TraceEventType type, string format, params object[] args) { | |
|
94 | LogChannel<TraceEvent>.Default.LogEvent(TraceEvent.Create(type, format, args)); | |
|
95 | } | |
|
96 | } | |
|
97 | } |
@@ -0,0 +1,27 | |||
|
1 | using System; | |
|
2 | using System.Collections.Generic; | |
|
3 | using System.Linq; | |
|
4 | using System.Text; | |
|
5 | ||
|
6 | namespace Implab.Diagnostics { | |
|
7 | public class TraceEvent { | |
|
8 | public string Message { | |
|
9 | get; | |
|
10 | private set; | |
|
11 | } | |
|
12 | ||
|
13 | public TraceEventType EventType { | |
|
14 | get; | |
|
15 | private set; | |
|
16 | } | |
|
17 | ||
|
18 | public TraceEvent(TraceEventType type, string message) { | |
|
19 | EventType = type; | |
|
20 | Message = message; | |
|
21 | } | |
|
22 | ||
|
23 | public static TraceEvent Create(TraceEventType type, string format, params object[] args) { | |
|
24 | return new TraceEvent(type, String.Format(format, args)); | |
|
25 | } | |
|
26 | } | |
|
27 | } |
@@ -0,0 +1,53 | |||
|
1 | using System; | |
|
2 | using System.Collections.Generic; | |
|
3 | using System.Diagnostics; | |
|
4 | using System.Linq; | |
|
5 | using System.Text; | |
|
6 | using System.Threading.Tasks; | |
|
7 | ||
|
8 | namespace Implab.Diagnostics { | |
|
9 | /// <summary> | |
|
10 | /// Класс для публикации событий выполнения программы, события публикуются через <see cref="LogChannel{TraceEvent}"/> | |
|
11 | /// </summary> | |
|
12 | public static class TraceLog { | |
|
13 | [Conditional("TRACE")] | |
|
14 | public static void Transfer(TraceContext from) { | |
|
15 | TraceContext.Transfer(from); | |
|
16 | } | |
|
17 | ||
|
18 | [Conditional("TRACE")] | |
|
19 | public static void StartLogicalOperation() { | |
|
20 | TraceContext.Current.StartLogicalOperation(); | |
|
21 | } | |
|
22 | ||
|
23 | [Conditional("TRACE")] | |
|
24 | public static void StartLogicalOperation(string name) { | |
|
25 | TraceContext.Current.StartLogicalOperation(name); | |
|
26 | } | |
|
27 | ||
|
28 | [Conditional("TRACE")] | |
|
29 | public static void EndLogicalOperation() { | |
|
30 | TraceContext.Current.EndLogicalOperation(); | |
|
31 | } | |
|
32 | ||
|
33 | [Conditional("TRACE")] | |
|
34 | public static void TraceInformation(string format, params object[] arguments) { | |
|
35 | LogChannel<TraceEvent>.Default.LogEvent(TraceEvent.Create(TraceEventType.Information, format, arguments)); | |
|
36 | } | |
|
37 | ||
|
38 | [Conditional("TRACE")] | |
|
39 | public static void TraceWarning(string format, params object[] arguments) { | |
|
40 | LogChannel<TraceEvent>.Default.LogEvent(TraceEvent.Create(TraceEventType.Warning, format, arguments)); | |
|
41 | } | |
|
42 | ||
|
43 | [Conditional("TRACE")] | |
|
44 | public static void TraceError(string format, params object[] arguments) { | |
|
45 | LogChannel<TraceEvent>.Default.LogEvent(TraceEvent.Create(TraceEventType.Error, format, arguments)); | |
|
46 | } | |
|
47 | ||
|
48 | [Conditional("TRACE")] | |
|
49 | public static void TraceError(Exception err) { | |
|
50 | TraceError("{0}", err); | |
|
51 | } | |
|
52 | } | |
|
53 | } |
|
1 | NO CONTENT: modified file, binary diff hidden |
@@ -32,10 +32,12 | |||
|
32 | 32 | <Reference Include="System" /> |
|
33 | 33 | </ItemGroup> |
|
34 | 34 | <ItemGroup> |
|
35 |
<Compile Include="Diagnostics\ |
|
|
35 | <Compile Include="Diagnostics\ConsoleTraceListener.cs" /> | |
|
36 | <Compile Include="Diagnostics\LogChannel.cs" /> | |
|
36 | 37 | <Compile Include="Diagnostics\LogicalOperation.cs" /> |
|
37 | <Compile Include="Diagnostics\Log.cs" /> | |
|
38 |
<Compile Include="Diagnostics\ |
|
|
38 | <Compile Include="Diagnostics\TraceLog.cs" /> | |
|
39 | <Compile Include="Diagnostics\TraceContext.cs" /> | |
|
40 | <Compile Include="Diagnostics\TraceEvent.cs" /> | |
|
39 | 41 | <Compile Include="Diagnostics\TraceEventType.cs" /> |
|
40 | 42 | <Compile Include="ICancellable.cs" /> |
|
41 | 43 | <Compile Include="IProgressHandler.cs" /> |
@@ -14,10 +14,10 namespace Implab.Parallels { | |||
|
14 | 14 | |
|
15 | 15 | public static Promise<T> Invoke<T>(Func<T> func) { |
|
16 | 16 | var p = new Promise<T>(); |
|
17 |
var caller = |
|
|
17 | var caller = TraceContext.Current; | |
|
18 | 18 | |
|
19 | 19 | ThreadPool.QueueUserWorkItem(param => { |
|
20 | Log.Transfer(caller); | |
|
20 | TraceLog.Transfer(caller); | |
|
21 | 21 | try { |
|
22 | 22 | p.Resolve(func()); |
|
23 | 23 | } catch(Exception e) { |
@@ -31,10 +31,10 namespace Implab.Parallels { | |||
|
31 | 31 | public static Promise<T> InvokeNewThread<T>(Func<T> func) { |
|
32 | 32 | var p = new Promise<T>(); |
|
33 | 33 | |
|
34 |
var caller = |
|
|
34 | var caller = TraceContext.Current; | |
|
35 | 35 | |
|
36 | 36 | var worker = new Thread(() => { |
|
37 | Log.Transfer(caller); | |
|
37 | TraceLog.Transfer(caller); | |
|
38 | 38 | try { |
|
39 | 39 | p.Resolve(func()); |
|
40 | 40 | } catch (Exception e) { |
@@ -42,10 +42,10 namespace Implab.Parallels { | |||
|
42 | 42 | |
|
43 | 43 | var promise = new Promise<T>(); |
|
44 | 44 | |
|
45 |
var caller = |
|
|
45 | var caller = TraceContext.Current; | |
|
46 | 46 | |
|
47 | 47 | EnqueueTask(delegate() { |
|
48 | Log.Transfer(caller); | |
|
48 | TraceLog.Transfer(caller); | |
|
49 | 49 | try { |
|
50 | 50 | promise.Resolve(task()); |
|
51 | 51 | } catch (Exception e) { |
|
1 | NO CONTENT: file was removed |
|
1 | NO CONTENT: file was removed |
|
1 | NO CONTENT: file was removed |
General Comments 0
You need to be logged in to leave comments.
Login now