@@ -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 |
|
NO CONTENT: modified file, binary diff hidden |
@@ -32,10 +32,12 | |||||
32 | <Reference Include="System" /> |
|
32 | <Reference Include="System" /> | |
33 | </ItemGroup> |
|
33 | </ItemGroup> | |
34 | <ItemGroup> |
|
34 | <ItemGroup> | |
35 |
<Compile Include="Diagnostics\ |
|
35 | <Compile Include="Diagnostics\ConsoleTraceListener.cs" /> | |
|
36 | <Compile Include="Diagnostics\LogChannel.cs" /> | |||
36 | <Compile Include="Diagnostics\LogicalOperation.cs" /> |
|
37 | <Compile Include="Diagnostics\LogicalOperation.cs" /> | |
37 | <Compile Include="Diagnostics\Log.cs" /> |
|
38 | <Compile Include="Diagnostics\TraceLog.cs" /> | |
38 |
<Compile Include="Diagnostics\ |
|
39 | <Compile Include="Diagnostics\TraceContext.cs" /> | |
|
40 | <Compile Include="Diagnostics\TraceEvent.cs" /> | |||
39 | <Compile Include="Diagnostics\TraceEventType.cs" /> |
|
41 | <Compile Include="Diagnostics\TraceEventType.cs" /> | |
40 | <Compile Include="ICancellable.cs" /> |
|
42 | <Compile Include="ICancellable.cs" /> | |
41 | <Compile Include="IProgressHandler.cs" /> |
|
43 | <Compile Include="IProgressHandler.cs" /> |
@@ -14,10 +14,10 namespace Implab.Parallels { | |||||
14 |
|
14 | |||
15 | public static Promise<T> Invoke<T>(Func<T> func) { |
|
15 | public static Promise<T> Invoke<T>(Func<T> func) { | |
16 | var p = new Promise<T>(); |
|
16 | var p = new Promise<T>(); | |
17 |
var caller = |
|
17 | var caller = TraceContext.Current; | |
18 |
|
18 | |||
19 | ThreadPool.QueueUserWorkItem(param => { |
|
19 | ThreadPool.QueueUserWorkItem(param => { | |
20 | Log.Transfer(caller); |
|
20 | TraceLog.Transfer(caller); | |
21 | try { |
|
21 | try { | |
22 | p.Resolve(func()); |
|
22 | p.Resolve(func()); | |
23 | } catch(Exception e) { |
|
23 | } catch(Exception e) { | |
@@ -31,10 +31,10 namespace Implab.Parallels { | |||||
31 | public static Promise<T> InvokeNewThread<T>(Func<T> func) { |
|
31 | public static Promise<T> InvokeNewThread<T>(Func<T> func) { | |
32 | var p = new Promise<T>(); |
|
32 | var p = new Promise<T>(); | |
33 |
|
33 | |||
34 |
var caller = |
|
34 | var caller = TraceContext.Current; | |
35 |
|
35 | |||
36 | var worker = new Thread(() => { |
|
36 | var worker = new Thread(() => { | |
37 | Log.Transfer(caller); |
|
37 | TraceLog.Transfer(caller); | |
38 | try { |
|
38 | try { | |
39 | p.Resolve(func()); |
|
39 | p.Resolve(func()); | |
40 | } catch (Exception e) { |
|
40 | } catch (Exception e) { |
@@ -42,10 +42,10 namespace Implab.Parallels { | |||||
42 |
|
42 | |||
43 | var promise = new Promise<T>(); |
|
43 | var promise = new Promise<T>(); | |
44 |
|
44 | |||
45 |
var caller = |
|
45 | var caller = TraceContext.Current; | |
46 |
|
46 | |||
47 | EnqueueTask(delegate() { |
|
47 | EnqueueTask(delegate() { | |
48 | Log.Transfer(caller); |
|
48 | TraceLog.Transfer(caller); | |
49 | try { |
|
49 | try { | |
50 | promise.Resolve(task()); |
|
50 | promise.Resolve(task()); | |
51 | } catch (Exception e) { |
|
51 | } catch (Exception e) { |
1 | NO CONTENT: file was removed |
|
NO CONTENT: file was removed |
1 | NO CONTENT: file was removed |
|
NO CONTENT: file was removed |
1 | NO CONTENT: file was removed |
|
NO CONTENT: file was removed |
General Comments 0
You need to be logged in to leave comments.
Login now