implab/ImplabNet Files · Implab/Diagnostics/ListenerBase.cs

Added ResetState to RunnableComponent to reset in case of failure...

Added ResetState to RunnableComponent to reset in case of failure Added StateChanged event to IRunnable Renamed Promise.SUCCESS -> Promise.Success Added Promise.FromException Renamed Bundle -> PromiseAll in PromiseExtensions

cin - - Load All Authors

File last commit:

r194:d45bdf510514 v2


                r205:8200ab154c8a

Download file

             ListenerBase.cs
        
                    86 lines
            
             | 2.7 KiB
            
                | text/x-csharp
            
             |
                CSharpLexer
            
             / Implab / Diagnostics / ListenerBase.cs
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        cin
    
Improved logging

              r134
            
      using System;

      using System.Collections.Generic;

        cin
    
component model refactoring

              r152
            
      using Implab.Components;

        cin
    
Improved logging

              r134
            
      namespace Implab.Diagnostics {

          public abstract class ListenerBase : ServiceLocator, ILogWriter<object>, ILogWriter<TraceEvent> {

              readonly Dictionary<object, Action> m_subscriptions = new Dictionary<object, Action>();

              protected ListenerBase() {

                  Register(this);

              }

              public void Subscribe(Type eventType) {

                  if (eventType == null)

                      throw new ArgumentNullException("eventType");

                  GetType().GetMethod("Subscribe", new Type[0]).MakeGenericMethod(eventType).Invoke(this, null);

              }

              public void Subscribe<TEvent>() {

                  Subscribe<TEvent>(LogChannel<TEvent>.Default);

              }

              public void Subscribe<TEvent>(LogChannel<TEvent> channel) {

                  if (channel == null)

                      throw new ArgumentNullException("channel");

                  lock (m_subscriptions) {

                      AssertNotDisposed();

                      if (m_subscriptions.ContainsKey(channel))

                          return;

                      var writer = GetService<ILogWriter<TEvent>>();

                      EventHandler<LogEventArgs<TEvent>> handler = (sender, args) => writer.Write(args,args.Value);

                      channel.Events += handler;

                      Action unsubscribe = () => {

                          channel.Events -= handler;

                      };

                      m_subscriptions.Add(channel, unsubscribe);

                  }

              }

              public void Unsubscribe<TEvent>(LogChannel<TEvent> channel) {

                  if (channel == null)

                      throw new ArgumentNullException("channel");

                  lock (m_subscriptions) {

                      Action subscription;

                      if (m_subscriptions.TryGetValue(channel, out subscription)) {

                          subscription();

                          m_subscriptions.Remove(channel);

                      }

                  }

              }

              public void UnsubscribeAll() {

                  lock (m_subscriptions) {

        cin
    
working on diagnostics

              r194
            
                      foreach (var remove in m_subscriptions.Values)

                          remove();

        cin
    
Improved logging

              r134
            
                      m_subscriptions.Clear();

                  }

              }

              #region ILogWriter implementation

              public abstract void Write(LogEventArgs args, object entry);

              #endregion

              #region ILogWriter implementation

              public virtual void Write(LogEventArgs args, TraceEvent entry) {

                  Write(args, (object)entry);

              }

              #endregion

              protected override void Dispose(bool disposing) {

                  base.Dispose(disposing);

                  if (disposing) {

                      UnsubscribeAll();

                  }

              }

          }

      }

	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

cin Improved logging	r134	using System;
		using System.Collections.Generic;
cin component model refactoring	r152	using Implab.Components;
cin Improved logging	r134
		namespace Implab.Diagnostics {
		public abstract class ListenerBase : ServiceLocator, ILogWriter<object>, ILogWriter<TraceEvent> {

		readonly Dictionary<object, Action> m_subscriptions = new Dictionary<object, Action>();

		protected ListenerBase() {
		Register(this);
		}

		public void Subscribe(Type eventType) {
		if (eventType == null)
		throw new ArgumentNullException("eventType");
		GetType().GetMethod("Subscribe", new Type[0]).MakeGenericMethod(eventType).Invoke(this, null);
		}

		public void Subscribe<TEvent>() {
		Subscribe<TEvent>(LogChannel<TEvent>.Default);
		}

		public void Subscribe<TEvent>(LogChannel<TEvent> channel) {
		if (channel == null)
		throw new ArgumentNullException("channel");

		lock (m_subscriptions) {
		AssertNotDisposed();
		if (m_subscriptions.ContainsKey(channel))
		return;

		var writer = GetService<ILogWriter<TEvent>>();

		EventHandler<LogEventArgs<TEvent>> handler = (sender, args) => writer.Write(args,args.Value);

		channel.Events += handler;

		Action unsubscribe = () => {
		channel.Events -= handler;
		};

		m_subscriptions.Add(channel, unsubscribe);
		}
		}

		public void Unsubscribe<TEvent>(LogChannel<TEvent> channel) {
		if (channel == null)
		throw new ArgumentNullException("channel");

		lock (m_subscriptions) {
		Action subscription;
		if (m_subscriptions.TryGetValue(channel, out subscription)) {
		subscription();
		m_subscriptions.Remove(channel);
		}
		}
		}

		public void UnsubscribeAll() {
		lock (m_subscriptions) {
cin working on diagnostics	r194	foreach (var remove in m_subscriptions.Values)
		remove();
cin Improved logging	r134	m_subscriptions.Clear();
		}
		}

		#region ILogWriter implementation
		public abstract void Write(LogEventArgs args, object entry);
		#endregion

		#region ILogWriter implementation
		public virtual void Write(LogEventArgs args, TraceEvent entry) {
		Write(args, (object)entry);
		}
		#endregion


		protected override void Dispose(bool disposing) {
		base.Dispose(disposing);
		if (disposing) {
		UnsubscribeAll();
		}
		}
		}
		}