##// END OF EJS Templates
implab » ImplabNet
RSS
initial log capabilities
cin -
r35:2880242f987a diagnostics
parent child
Show More
Show file before | Show file after | Hide comments
@@ -0,0 +1,11
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5 using System.Threading.Tasks;
6
7 namespace Implab.Diagnostics {
8 public interface IEventListener {
9 void TraceEvent(LogContext context, TraceEventType type, string format, params object[] args);
10 }
11 }
Show file before | Show file after | Hide comments
@@ -0,0 +1,50
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 public static class Log {
10 [Conditional("TRACE")]
11 public static void Transfer(LogContext from) {
12 LogContext.Transfer(from);
13 }
14
15 [Conditional("TRACE")]
16 public static void StartLogicalOperation() {
17 LogContext.Current.StartLogicalOperation();
18 }
19
20 [Conditional("TRACE")]
21 public static void StartLogicalOperation(string name) {
22 LogContext.Current.StartLogicalOperation(name);
23 }
24
25 [Conditional("TRACE")]
26 public static void EndLogicalOperation() {
27 LogContext.Current.EndLogicalOperation();
28 }
29
30 [Conditional("TRACE")]
31 public static void TraceInformation(string format, params object[] arguments) {
32 LogContext.Current.TraceEvent(TraceEventType.Information, format, arguments);
33 }
34
35 [Conditional("TRACE")]
36 public static void TraceWarning(string format, params object[] arguments) {
37 LogContext.Current.TraceEvent(TraceEventType.Warning, format, arguments);
38 }
39
40 [Conditional("TRACE")]
41 public static void TraceError(string format, params object[] arguments) {
42 LogContext.Current.TraceEvent(TraceEventType.Error, format, arguments);
43 }
44
45 [Conditional("TRACE")]
46 public static void TraceError(Exception err) {
47 TraceError("{0}", err);
48 }
49 }
50 }
Show file before | Show file after | Hide comments
@@ -0,0 +1,107
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 LogContext {
10 LogicalOperation m_currentOperation;
11 readonly LogicalOperation m_traceBound;
12 readonly int m_threadId;
13 readonly LogContext m_parent;
14
15 readonly static object _consoleLock = new object();
16
17 [ThreadStatic]
18 static LogContext _current;
19
20 public static LogContext Current {
21 get {
22 if (_current == null)
23 _current = new LogContext();
24 return _current;
25 }
26 }
27
28 LogContext(LogContext 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 TraceEvent(TraceEventType.Transfer, String.Empty);
38 }
39
40 LogContext() {
41 m_currentOperation = new LogicalOperation();
42 m_traceBound = m_currentOperation;
43 m_threadId = Thread.CurrentThread.ManagedThreadId;
44 }
45
46 public static void Transfer(LogContext from) {
47 _current = from == null ? new LogContext() : new LogContext(from);
48 }
49
50 public LogContext 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 TraceEvent(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 TraceEvent(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 TraceEvent(TraceEventType.OperationCompleted, "{0} {1} ms", op.Name, op.Duration);
90 }
91 }
92
93 public void TraceEvent(TraceEventType type, string format, params object[] args) {
94 /*var msg = new StringBuilder();
95 for (int i = 0; i < CurrentOperation.Level; i++)
96 msg.Append(" ");
97 msg.Append(type);
98 msg.AppendFormat("[{0}]: ",m_threadId);
99 msg.AppendFormat(format, args);
100
101 lock (_consoleLock) {
102 Console.ForegroundColor = (ConsoleColor)(m_threadId % 15 + 1);
103 Console.WriteLine(msg.ToString());
104 }*/
105 }
106 }
107 }
Show file before | Show file after | Hide comments
@@ -0,0 +1,47
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5 using System.Threading.Tasks;
6
7 namespace Implab.Diagnostics {
8 public class LogicalOperation {
9 readonly LogicalOperation m_parent;
10 readonly string m_name;
11 readonly int m_level;
12 readonly int m_timestamp;
13
14 public LogicalOperation()
15 : this(null, null) {
16 }
17
18 public LogicalOperation(string name, LogicalOperation parent) {
19 m_name = name ?? String.Empty;
20 m_parent = parent;
21
22 m_level = parent == null ? 0 : parent.Level + 1;
23 m_timestamp = Environment.TickCount;
24 }
25
26 public int Duration {
27 get {
28 var dt = Environment.TickCount - m_timestamp;
29 return dt < 0 ? int.MaxValue + dt : dt; // handle overflow
30 }
31 }
32
33 public LogicalOperation Parent {
34 get {
35 return m_parent;
36 }
37 }
38
39 public int Level {
40 get { return m_level; }
41 }
42
43 public string Name {
44 get { return m_name; }
45 }
46 }
47 }
Show file before | Show file after | Hide comments
@@ -0,0 +1,16
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5 using System.Threading.Tasks;
6
7 namespace Implab.Diagnostics {
8 public enum TraceEventType {
9 Information = 1,
10 Warning,
11 Error,
12 OperationStarted,
13 OperationCompleted,
14 Transfer
15 }
16 }
Show file before | Show file after | Hide comments
1 NO CONTENT: modified file, binary diff hidden
NO CONTENT: modified file, binary diff hidden
Show file before | Show file after | Hide comments
@@ -1,57 +1,61
1 <?xml version="1.0" encoding="utf-8"?>
1 <?xml version="1.0" encoding="utf-8"?>
2 <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
2 <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
3 <PropertyGroup>
3 <PropertyGroup>
4 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
4 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
5 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
5 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
6 <ProductVersion>10.0.0</ProductVersion>
6 <ProductVersion>10.0.0</ProductVersion>
7 <SchemaVersion>2.0</SchemaVersion>
7 <SchemaVersion>2.0</SchemaVersion>
8 <ProjectGuid>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</ProjectGuid>
8 <ProjectGuid>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</ProjectGuid>
9 <OutputType>Library</OutputType>
9 <OutputType>Library</OutputType>
10 <RootNamespace>Implab</RootNamespace>
10 <RootNamespace>Implab</RootNamespace>
11 <AssemblyName>Implab</AssemblyName>
11 <AssemblyName>Implab</AssemblyName>
12 </PropertyGroup>
12 </PropertyGroup>
13 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
13 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
14 <DebugSymbols>true</DebugSymbols>
14 <DebugSymbols>true</DebugSymbols>
15 <DebugType>full</DebugType>
15 <DebugType>full</DebugType>
16 <Optimize>false</Optimize>
16 <Optimize>false</Optimize>
17 <OutputPath>bin\Debug</OutputPath>
17 <OutputPath>bin\Debug</OutputPath>
18 <DefineConstants>DEBUG;</DefineConstants>
18 <DefineConstants>TRACE;DEBUG;</DefineConstants>
19 <ErrorReport>prompt</ErrorReport>
19 <ErrorReport>prompt</ErrorReport>
20 <WarningLevel>4</WarningLevel>
20 <WarningLevel>4</WarningLevel>
21 <ConsolePause>false</ConsolePause>
21 <ConsolePause>false</ConsolePause>
22 </PropertyGroup>
22 </PropertyGroup>
23 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
23 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
24 <DebugType>full</DebugType>
24 <DebugType>full</DebugType>
25 <Optimize>true</Optimize>
25 <Optimize>true</Optimize>
26 <OutputPath>bin\Release</OutputPath>
26 <OutputPath>bin\Release</OutputPath>
27 <ErrorReport>prompt</ErrorReport>
27 <ErrorReport>prompt</ErrorReport>
28 <WarningLevel>4</WarningLevel>
28 <WarningLevel>4</WarningLevel>
29 <ConsolePause>false</ConsolePause>
29 <ConsolePause>false</ConsolePause>
30 </PropertyGroup>
30 </PropertyGroup>
31 <ItemGroup>
31 <ItemGroup>
32 <Reference Include="System" />
32 <Reference Include="System" />
33 </ItemGroup>
33 </ItemGroup>
34 <ItemGroup>
34 <ItemGroup>
35 <Compile Include="Diagnostics\IEventListener.cs" />
36 <Compile Include="Diagnostics\LogicalOperation.cs" />
37 <Compile Include="Diagnostics\Log.cs" />
38 <Compile Include="Diagnostics\LogContext.cs" />
39 <Compile Include="Diagnostics\TraceEventType.cs" />
35 <Compile Include="ICancellable.cs" />
40 <Compile Include="ICancellable.cs" />
36 <Compile Include="IProgressHandler.cs" />
41 <Compile Include="IProgressHandler.cs" />
37 <Compile Include="IProgressNotifier.cs" />
42 <Compile Include="IProgressNotifier.cs" />
38 <Compile Include="IPromise.cs" />
43 <Compile Include="IPromise.cs" />
39 <Compile Include="IPromiseBase.cs" />
44 <Compile Include="IPromiseBase.cs" />
40 <Compile Include="ITaskController.cs" />
45 <Compile Include="ITaskController.cs" />
41 <Compile Include="ManagedPromise.cs" />
46 <Compile Include="ManagedPromise.cs" />
42 <Compile Include="Parallels\DispatchPool.cs" />
47 <Compile Include="Parallels\DispatchPool.cs" />
43 <Compile Include="Parallels\ArrayTraits.cs" />
48 <Compile Include="Parallels\ArrayTraits.cs" />
44 <Compile Include="Parallels\MTQueue.cs" />
49 <Compile Include="Parallels\MTQueue.cs" />
45 <Compile Include="Parallels\WorkerPool.cs" />
50 <Compile Include="Parallels\WorkerPool.cs" />
46 <Compile Include="PromiseState.cs" />
47 <Compile Include="TaskController.cs" />
51 <Compile Include="TaskController.cs" />
48 <Compile Include="ProgressInitEventArgs.cs" />
52 <Compile Include="ProgressInitEventArgs.cs" />
49 <Compile Include="Properties\AssemblyInfo.cs" />
53 <Compile Include="Properties\AssemblyInfo.cs" />
50 <Compile Include="Promise.cs" />
54 <Compile Include="Promise.cs" />
51 <Compile Include="Parallels\AsyncPool.cs" />
55 <Compile Include="Parallels\AsyncPool.cs" />
52 <Compile Include="Safe.cs" />
56 <Compile Include="Safe.cs" />
53 <Compile Include="ValueEventArgs.cs" />
57 <Compile Include="ValueEventArgs.cs" />
54 </ItemGroup>
58 </ItemGroup>
55 <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
59 <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
56 <ItemGroup />
60 <ItemGroup />
57 </Project> No newline at end of file
61 </Project>
Show file before | Show file after | Hide comments
@@ -1,44 +1,50
1 using Implab.Diagnostics;
1 using System;
2 using System;
2 using System.Threading;
3 using System.Threading;
3
4
4 namespace Implab.Parallels {
5 namespace Implab.Parallels {
5 /// <summary>
6 /// <summary>
6 /// Класс для распаралеливания задач.
7 /// Класс для распаралеливания задач.
7 /// </summary>
8 /// </summary>
8 /// <remarks>
9 /// <remarks>
9 /// Используя данный класс и лямда выражения можно распараллелить
10 /// Используя данный класс и лямда выражения можно распараллелить
10 /// вычисления, для этого используется концепция обещаний.
11 /// вычисления, для этого используется концепция обещаний.
11 /// </remarks>
12 /// </remarks>
12 public static class AsyncPool {
13 public static class AsyncPool {
13
14
14 public static Promise<T> Invoke<T>(Func<T> func) {
15 public static Promise<T> Invoke<T>(Func<T> func) {
15 var p = new Promise<T>();
16 var p = new Promise<T>();
17 var caller = LogContext.Current;
16
18
17 ThreadPool.QueueUserWorkItem(param => {
19 ThreadPool.QueueUserWorkItem(param => {
20 Log.Transfer(caller);
18 try {
21 try {
19 p.Resolve(func());
22 p.Resolve(func());
20 } catch(Exception e) {
23 } catch(Exception e) {
21 p.Reject(e);
24 p.Reject(e);
22 }
25 }
23 });
26 });
24
27
25 return p;
28 return p;
26 }
29 }
27
30
28 public static Promise<T> InvokeNewThread<T>(Func<T> func) {
31 public static Promise<T> InvokeNewThread<T>(Func<T> func) {
29 var p = new Promise<T>();
32 var p = new Promise<T>();
30
33
34 var caller = LogContext.Current;
35
31 var worker = new Thread(() => {
36 var worker = new Thread(() => {
37 Log.Transfer(caller);
32 try {
38 try {
33 p.Resolve(func());
39 p.Resolve(func());
34 } catch (Exception e) {
40 } catch (Exception e) {
35 p.Reject(e);
41 p.Reject(e);
36 }
42 }
37 });
43 });
38 worker.IsBackground = true;
44 worker.IsBackground = true;
39 worker.Start();
45 worker.Start();
40
46
41 return p;
47 return p;
42 }
48 }
43 }
49 }
44 }
50 }
Show file before | Show file after | Hide comments
@@ -1,93 +1,97
1 using System;
1 using System;
2 using System.Collections.Generic;
2 using System.Collections.Generic;
3 using System.Linq;
3 using System.Linq;
4 using System.Text;
4 using System.Text;
5 using System.Threading;
5 using System.Threading;
6 using System.Diagnostics;
6 using System.Diagnostics;
7 using Implab.Diagnostics;
7
8
8 namespace Implab.Parallels {
9 namespace Implab.Parallels {
9 public class WorkerPool : DispatchPool<Action> {
10 public class WorkerPool : DispatchPool<Action> {
10
11
11 MTQueue<Action> m_queue = new MTQueue<Action>();
12 MTQueue<Action> m_queue = new MTQueue<Action>();
12 int m_queueLength = 0;
13 int m_queueLength = 0;
13 readonly int m_threshold = 1;
14 readonly int m_threshold = 1;
14
15
15 public WorkerPool(int minThreads, int maxThreads, int threshold)
16 public WorkerPool(int minThreads, int maxThreads, int threshold)
16 : base(minThreads, maxThreads) {
17 : base(minThreads, maxThreads) {
17 m_threshold = threshold;
18 m_threshold = threshold;
18 InitPool();
19 InitPool();
19 }
20 }
20
21
21 public WorkerPool(int minThreads, int maxThreads) :
22 public WorkerPool(int minThreads, int maxThreads) :
22 base(minThreads, maxThreads) {
23 base(minThreads, maxThreads) {
23 InitPool();
24 InitPool();
24 }
25 }
25
26
26 public WorkerPool(int threads)
27 public WorkerPool(int threads)
27 : base(threads) {
28 : base(threads) {
28 InitPool();
29 InitPool();
29 }
30 }
30
31
31 public WorkerPool()
32 public WorkerPool()
32 : base() {
33 : base() {
33 InitPool();
34 InitPool();
34 }
35 }
35
36
36 public Promise<T> Invoke<T>(Func<T> task) {
37 public Promise<T> Invoke<T>(Func<T> task) {
37 if (task == null)
38 if (task == null)
38 throw new ArgumentNullException("task");
39 throw new ArgumentNullException("task");
39 if (IsDisposed)
40 if (IsDisposed)
40 throw new ObjectDisposedException(ToString());
41 throw new ObjectDisposedException(ToString());
41
42
42 var promise = new Promise<T>();
43 var promise = new Promise<T>();
43
44
45 var caller = LogContext.Current;
46
44 EnqueueTask(delegate() {
47 EnqueueTask(delegate() {
48 Log.Transfer(caller);
45 try {
49 try {
46 promise.Resolve(task());
50 promise.Resolve(task());
47 } catch (Exception e) {
51 } catch (Exception e) {
48 promise.Reject(e);
52 promise.Reject(e);
49 }
53 }
50 });
54 });
51
55
52 return promise;
56 return promise;
53 }
57 }
54
58
55 protected void EnqueueTask(Action unit) {
59 protected void EnqueueTask(Action unit) {
56 Debug.Assert(unit != null);
60 Debug.Assert(unit != null);
57 var len = Interlocked.Increment(ref m_queueLength);
61 var len = Interlocked.Increment(ref m_queueLength);
58 m_queue.Enqueue(unit);
62 m_queue.Enqueue(unit);
59
63
60 if (len > m_threshold*ActiveThreads)
64 if (len > m_threshold*ActiveThreads)
61 GrowPool();
65 GrowPool();
62 }
66 }
63
67
64 protected override bool TryDequeue(out Action unit) {
68 protected override bool TryDequeue(out Action unit) {
65 if (m_queue.TryDequeue(out unit)) {
69 if (m_queue.TryDequeue(out unit)) {
66 Interlocked.Decrement(ref m_queueLength);
70 Interlocked.Decrement(ref m_queueLength);
67 return true;
71 return true;
68 }
72 }
69 return false;
73 return false;
70 }
74 }
71
75
72 protected override bool Suspend() {
76 protected override bool Suspend() {
73 // This override solves race condition
77 // This override solves race condition
74 // WORKER CLIENT
78 // WORKER CLIENT
75 // ---------------------------------------
79 // ---------------------------------------
76 // TryDeque == false
80 // TryDeque == false
77 // Enqueue(unit), queueLen++
81 // Enqueue(unit), queueLen++
78 // GrowPool? == NO
82 // GrowPool? == NO
79 // ActiveThreads--
83 // ActiveThreads--
80 // Suspend
84 // Suspend
81 // queueLength > 0
85 // queueLength > 0
82 // continue
86 // continue
83 if (m_queueLength > 0)
87 if (m_queueLength > 0)
84 return true;
88 return true;
85 return base.Suspend();
89 return base.Suspend();
86 }
90 }
87
91
88 protected override void InvokeUnit(Action unit) {
92 protected override void InvokeUnit(Action unit) {
89 unit();
93 unit();
90 }
94 }
91
95
92 }
96 }
93 }
97 }
Show file before | Show file after | Hide comments
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