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("InnerOperation")){
+                         using (LogicalOperation("Test1")){
                              await Task.Yield();
-                             Log("Inner");
-                             await Task.Yield();
-                             Log("source event");
+                             Log(String.Join(", ", Trace.CorrelationManager.LogicalOperationStack.Cast<object>().Select(x => x.ToString())));
+                             await AsyncDummy();
+                             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
-                     /// 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
+                     /// Current state of the componenet, dynamically reflects the current state.
                      /// </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) {
-                         try {
-                             m_current = AsyncOperationDescriptor.Create(next, ct);
-                             await m_current.Task;
-                             MoveSuccess(cookie);
-                         } catch (Exception e) {
-                             MoveFailed(e, cookie);
+                         }
+                         m_current = AsyncOperationDescriptor.Create(async (x) => {
+                             try {
+                                 await next(x);
+                                 MoveSuccess(cookie);
+                             } catch (Exception e) {
+                                 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