implab/ImplabNet Commit - r256:c52691faaf21

Removed obsolete App, ComponentContainer...

cin -

r256:c52691faaf21 v3

parent child

Context file:

r256:c52691faaf21

Collapse all files

Implab/Components/IAsyncComponent.cs created 644 +37 0

@@ -0,0 +1,37
	1	using System;
	2	using System.Threading.Tasks;
	3
	4	namespace Implab.Components {
	5	/// <summary>
	6	/// An interface for asynchronous components.
	7	/// </summary>
	8	/// <remarks>
	9	/// <para>
	10	/// Асинхронные компоненты не предназначены для одновременного использования несколькими клиентами,
	11	/// однако существуют внутренние процессы, изменяющее состояние компонент без участия клиента.
	12	/// Данный интерфейс определяет протокол взаимодействия с компонентой, при которм компоненте
	13	/// посылаются сигналы от клиента, в ответ на которые компонента меняет свойство <see cref="Completion"/>,
	14	/// данное свойство содержит в себе новую задачу, выполняемую компонентой и данное свойство
	15	/// может измениться только при получении нового сигнала от клиента.
	16	/// </para>
	17	/// <para>
	18	/// В дополнение к <see cref="Completion"/> компонента может определять другие свойства, в
	19	/// которых будет передаваться информация о результате выполнения операции.
	20	/// </para>
	21	/// <para>
	22	/// Особое внимание следует уделить реализации <see cref="IDisposable"/>, который по своей природе
	23	/// синхронный, данное правило безусловно можно нарушить, но тогда могут возникнуть проблемы с
	24	/// тем, что ресурсы еще не освободились, а ход программы продолжается, что приведет к ошибкам,
	25	/// например при попытке получить ресуср другим объектом, либо при заврешении программы.
	26	/// </para>
	27	/// <seealso href="https://blog.stephencleary.com/2013/01/async-oop-0-introduction.html"/>
	28	/// </remarks>
	29	public interface IAsyncComponent {
	30	/// <summary>
	31	/// The result of the last started operation. This property reflects
	32	/// only the result of the last started operation and therefore should
	33	/// change only if a new operation is initiated.
	34	/// </summary>
	35	Task Completion { get; }
	36	}
	37	} No newline at end of file

Implab.Test/Implab.Test.csproj +1 -1

               <PropertyGroup>
                 <TargetFramework>net46</TargetFramework>
-                <FrameworkPathOverride Condition="'$(TargetFramework)'=='net45' and '$(OSTYPE)'=='linux'">/usr/lib/mono/4.5/</FrameworkPathOverride>
+                <FrameworkPathOverride Condition="'$(TargetFramework)'=='net46' and '$(OSTYPE)'=='linux'">/usr/lib/mono/4.5/</FrameworkPathOverride>
                 <IsPackable>false</IsPackable>
               </PropertyGroup>

Implab.Test/UnitTest1.cs +16 -5

             using System.Diagnostics;
             using System.Threading;
             using Implab.Diagnostics;
+            using System.Linq;
             using Xunit;
             namespace Implab.Test {
                     [Fact]
                     public async Task Test1() {
                         var listener = new SimpleTraceListener(Console.Out);
+                        listener.TraceOutputOptions |= TraceOptions.ThreadId;
                         var source = TraceSource;
                         source.Switch.Level = SourceLevels.All;
                         source.Listeners.Add(listener);
-                        using (var op = LogicalOperation(nameof(Test1)))
+                        using (LogicalOperation("Test1")){
-                        using (LogicalOperation("InnerOperation")){
                             await Task.Yield();
-                            Log("Inner");
+                            Log(String.Join(", ", Trace.CorrelationManager.LogicalOperationStack.Cast<object>().Select(x => x.ToString())));
-                            await Task.Yield();
+                            await AsyncDummy();
-                            Log("source event");
+                            Log(String.Join(", ", Trace.CorrelationManager.LogicalOperationStack.Cast<object>().Select(x => x.ToString())));
                         }
                     }
+                    async Task AsyncDummy() {
+                        using(LogicalOperation("OuterDummy"))
+                        using(LogicalOperation("InnerDummy")) {
+                            Log(String.Join(", ", Trace.CorrelationManager.LogicalOperationStack.Cast<object>().Select(x => x.ToString())));
+                            await Task.Delay(1);
+                            Log(String.Join(", ", Trace.CorrelationManager.LogicalOperationStack.Cast<object>().Select(x => x.ToString())));
+                        }
+                        Log(String.Join(", ", Trace.CorrelationManager.LogicalOperationStack.Cast<object>().Select(x => x.ToString())));
+                    }
                 }
             }

Implab/Components/DisposablePool.cs +2 -2

             namespace Implab.Components {
                 /// <summary>
-                /// The base class for implementing pools of disposable objects.
+                /// The base class for implementing thread-safe pools of disposable objects.
                 /// </summary>
                 /// <remarks>
-                /// <para>This class maintains a set of pre-created objects and which are frequently allocated and released
+                /// <para>This class maintains a set of pre-created objects which are frequently allocated and released
                 /// by clients. The pool maintains maximum number of unsued object, any object above this limit is disposed,
                 /// if the pool is empty it will create new objects on demand.</para>
                 /// <para>Instances of this class are thread-safe.</para>

Implab/Components/IRunnable.cs +1 -8

                     void Stop(CancellationToken ct);
                     /// <summary>
-                    /// The result of the last started operation. This property reflects
+                    /// Current state of the componenet, dynamically reflects the current state.
-                    /// only the result of the last started operation and therefore should
-                    /// change only if a new operation is initiated.
-                    /// </summary>
-                    Task Completion { get; }
-                    /// <summary>
-                    /// Current state of the componenet
                     /// </summary>
                     ExecutionState State { get; }

Implab/Components/RunnableComponent.cs +28 -11

                 /// This class provides a basic lifecycle from the creation to the
                 /// termination of the component.
                 /// </remarks>
-                public class RunnableComponent : IRunnable, IInitializable, IDisposable {
+                public class RunnableComponent : IAsyncComponent, IRunnable, IInitializable, IDisposable {
                     /// <summary>
                     /// This class bounds <see cref="CancellationTokenSource"/> lifetime to the task,
                     }
                     // this lock is used to synchronize state flow of the component during
-                    // completions or the operations.
+                    // processing calls from a client and internal processes.
                     readonly object m_lock = new object();
                     // current operation cookie, used to check wheather a call to
                     // operation, if cookies didn't match ignore completion result.
                     object m_cookie;
+                    // AsyncOperationDscriptor aggregates a task and it's cancellation token
                     AsyncOperationDescriptor m_current = AsyncOperationDescriptor.None;
                     ExecutionState m_state;
                         var cookie = new object();
                         if (MoveInitialize(cookie))
                             ScheduleTask(InitializeInternalAsync, CancellationToken.None, cookie);
+                        else
+                            throw new InvalidOperationException();
                     }
                     /// <summary>
                         var cookie = new object();
                         if (MoveStart(cookie))
                             ScheduleTask(StartInternalAsync, ct, cookie);
+                        else
+                            throw new InvalidOperationException();
                     }
                     protected virtual Task StartInternalAsync(CancellationToken ct) {
                         var cookie = new object();
                         if (MoveStop(cookie))
                             ScheduleTask(StopAsync, ct, cookie);
+                        else
+                            throw new InvalidOperationException();
                     }
                     async Task StopAsync(CancellationToken ct) {
                         return Task.CompletedTask;
                     }
+                    protected void Fail(Exception err) {
+                        lock(m_lock) {
+                            if (m_state != ExecutionState.Running)
+                                return;
+                            m_cookie = new object();
+                            LastError = err;
+                            State = ExecutionState.Failed;
+                        }
+                    }
                     #region state management
                         }
                     }
+                    void ScheduleTask(Func<CancellationToken, Task> next, CancellationToken ct, object cookie) {
-                    protected async void ScheduleTask(Func<CancellationToken, Task> next, CancellationToken ct, object cookie) {
+                        m_current = AsyncOperationDescriptor.Create(async (x) => {
-                        try {
+                            try {
-                            m_current = AsyncOperationDescriptor.Create(next, ct);
+                                await next(x);
-                            await m_current.Task;
+                                MoveSuccess(cookie);
-                            MoveSuccess(cookie);
+                            } catch (Exception e) {
-                        } catch (Exception e) {
+                                MoveFailed(e, cookie);
-                            MoveFailed(e, cookie);
+                        }, ct);
                     }
                     #endregion

Implab/Components/App.cs removed 0 -25

NO CONTENT: file was removed

Implab/Components/ComponentContainer.cs removed 0 -130

NO CONTENT: file was removed

General Comments 3

sergey

|

Auto status change to "Under Review"

sergey

|

ok, latest stable version should be in default

Write
Preview

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

	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