implab/ImplabNet Commit - r39:6498078ae368

Слияние с diagnostics

cin -

r39:6498078ae368 default

parent child

Context file:

r39:6498078ae368

Collapse all files

Implab/Diagnostics/ConsoleTraceListener.cs created 644 +37 0

@@ -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	}

Implab/Diagnostics/LogChannel.cs created 644 +30 0

@@ -0,0 +1,30
	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	public void LogEvent(TraceContext context,TEvent data) {
	25	var t = Events;
	26	if (t != null)
	27	t(context, new ValueEventArgs<TEvent>(data));
	28	}
	29	}
	30	}

Implab/Diagnostics/LogicalOperation.cs created 644 +47 0

@@ -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	}

Implab/Diagnostics/TraceContext.cs created 644 +97 0

@@ -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, "FORK {0}", context.ThreadId);
	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(this, TraceEvent.Create(type, format, args));
	95	}
	96	}
	97	}

Implab/Diagnostics/TraceEvent.cs created 644 +27 0

@@ -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	}

Implab/Diagnostics/TraceEventType.cs created 644 +16 0

@@ -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	}

Implab/Diagnostics/TraceLog.cs created 644 +53 0

@@ -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	}

Implab.v11.suo binary modified 0 0

NO CONTENT: modified file, binary diff hidden

Implab/Implab.csproj +8 -2

             <?xml version="1.0" encoding="utf-8"?>
             <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
               <PropertyGroup>
                 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
                 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
                 <ProductVersion>10.0.0</ProductVersion>
                 <SchemaVersion>2.0</SchemaVersion>
                 <ProjectGuid>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</ProjectGuid>
                 <OutputType>Library</OutputType>
                 <RootNamespace>Implab</RootNamespace>
                 <AssemblyName>Implab</AssemblyName>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug</OutputPath>
-                <DefineConstants>DEBUG;</DefineConstants>
+                <DefineConstants>TRACE;DEBUG;</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
                 <DebugType>full</DebugType>
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release</OutputPath>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <ItemGroup>
                 <Reference Include="System" />
               </ItemGroup>
               <ItemGroup>
+                <Compile Include="Diagnostics\ConsoleTraceListener.cs" />
+                <Compile Include="Diagnostics\LogChannel.cs" />
+                <Compile Include="Diagnostics\LogicalOperation.cs" />
+                <Compile Include="Diagnostics\TraceLog.cs" />
+                <Compile Include="Diagnostics\TraceContext.cs" />
+                <Compile Include="Diagnostics\TraceEvent.cs" />
+                <Compile Include="Diagnostics\TraceEventType.cs" />
                 <Compile Include="ICancellable.cs" />
                 <Compile Include="IProgressHandler.cs" />
                 <Compile Include="IProgressNotifier.cs" />
                 <Compile Include="IPromise.cs" />
                 <Compile Include="IPromiseBase.cs" />
                 <Compile Include="ITaskController.cs" />
                 <Compile Include="ManagedPromise.cs" />
                 <Compile Include="Parallels\DispatchPool.cs" />
                 <Compile Include="Parallels\ArrayTraits.cs" />
                 <Compile Include="Parallels\MTQueue.cs" />
                 <Compile Include="Parallels\WorkerPool.cs" />
-                <Compile Include="PromiseState.cs" />
                 <Compile Include="TaskController.cs" />
                 <Compile Include="ProgressInitEventArgs.cs" />
                 <Compile Include="Properties\AssemblyInfo.cs" />
                 <Compile Include="Promise.cs" />
                 <Compile Include="Parallels\AsyncPool.cs" />
                 <Compile Include="Safe.cs" />
                 <Compile Include="ValueEventArgs.cs" />
               </ItemGroup>
               <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
               <ItemGroup />
             </Project>

Implab/Parallels/AsyncPool.cs +6 0

+            using Implab.Diagnostics;
             using System;
             using System.Threading;
             namespace Implab.Parallels {
             	/// <summary>
             	/// Класс для распаралеливания задач.
             	/// </summary>
             	/// <remarks>
             	/// Используя данный класс и лямда выражения можно распараллелить
             	/// вычисления, для этого используется концепция обещаний.
             	/// </remarks>
             	public static class AsyncPool {
             		public static Promise<T> Invoke<T>(Func<T> func) {
             			var p = new Promise<T>();
+                        var caller = TraceContext.Current;
             			ThreadPool.QueueUserWorkItem(param => {
+                            TraceLog.Transfer(caller);
             				try {
             					p.Resolve(func());
             				} catch(Exception e) {
             					p.Reject(e);
             				}
             			});
             			return p;
             		}
                     public static Promise<T> InvokeNewThread<T>(Func<T> func) {
                         var p = new Promise<T>();
+                        var caller = TraceContext.Current;
                         var worker = new Thread(() => {
+                            TraceLog.Transfer(caller);
                             try {
                                 p.Resolve(func());
                             } catch (Exception e) {
                                 p.Reject(e);
                             }
                         });
                         worker.IsBackground = true;
                         worker.Start();
                         return p;
                     }
             	}
             }

Implab/Parallels/WorkerPool.cs +4 0

             using System;
             using System.Collections.Generic;
             using System.Linq;
             using System.Text;
             using System.Threading;
             using System.Diagnostics;
+            using Implab.Diagnostics;
             namespace Implab.Parallels {
                 public class WorkerPool : DispatchPool<Action> {
                     MTQueue<Action> m_queue = new MTQueue<Action>();
                     int m_queueLength = 0;
                     readonly int m_threshold = 1;
                     public WorkerPool(int minThreads, int maxThreads, int threshold)
                         : base(minThreads, maxThreads) {
                         m_threshold = threshold;
                         InitPool();
                     }
                     public WorkerPool(int minThreads, int maxThreads) :
                         base(minThreads, maxThreads) {
                         InitPool();
                     }
                     public WorkerPool(int threads)
                         : base(threads) {
                         InitPool();
                     }
                     public WorkerPool()
                         : base() {
                         InitPool();
                     }
                     public Promise<T> Invoke<T>(Func<T> task) {
                         if (task == null)
                             throw new ArgumentNullException("task");
                         if (IsDisposed)
                             throw new ObjectDisposedException(ToString());
                         var promise = new Promise<T>();
+                        var caller = TraceContext.Current;
                         EnqueueTask(delegate() {
+                            TraceLog.Transfer(caller);
                             try {
                                 promise.Resolve(task());
                             } catch (Exception e) {
                                 promise.Reject(e);
                             }
                         });
                         return promise;
                     }
                     protected void EnqueueTask(Action unit) {
                         Debug.Assert(unit != null);
                         var len = Interlocked.Increment(ref m_queueLength);
                         m_queue.Enqueue(unit);
                         if (len > m_threshold*ActiveThreads)
                             GrowPool();
                     }
                     protected override bool TryDequeue(out Action unit) {
                         if (m_queue.TryDequeue(out unit)) {
                             Interlocked.Decrement(ref m_queueLength);
                             return true;
                         }
                         return false;
                     }
                     protected override bool Suspend() {
                         // This override solves race condition
                         // WORKER                   CLIENT
                         // ---------------------------------------
                         // TryDeque == false
                         //                          Enqueue(unit), queueLen++
                         //                          GrowPool? == NO
                         // ActiveThreads--
                         // Suspend
                         //    queueLength > 0
                         // continue
                         if (m_queueLength > 0)
                             return true;
                         return base.Suspend();
                     }
                     protected override void InvokeUnit(Action unit) {
                         unit();
                     }
                 }
             }

Implab/PromiseState.cs removed 0 -15

NO CONTENT: file was removed

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages