implab/ImplabNet Files · Implab.Diagnostics.Interactive/InteractiveListener.cs

Added 'Fail' method to RunnableComponent which allows component to move from...

Added 'Fail' method to RunnableComponent which allows component to move from Running to Failed state. Added PollingComponent a timer based runnable component More tests Added FailPromise a thin class to wrap exceptions Fixed error handling in SuccessPromise classes.

cin - - Load All Authors

File last commit:

r134:04d4c92d0f28 v2


                r203:4d9830a9bbb8

Download file

             InteractiveListener.cs
        
                    122 lines
            
             | 3.7 KiB
            
                | text/x-csharp
            
             |
                CSharpLexer
            
             / Implab.Diagnostics.Interactive / InteractiveListener.cs
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        cin
    
refactoring, interactive tarce log almost complete

              r47
            
      using Implab.Parallels;

      using System;

      using System.Collections.Generic;

      using System.Linq;

      using System.Text;

      using System.Threading;

      using System.Threading.Tasks;

      using System.Windows.Forms;

      namespace Implab.Diagnostics.Interactive

      {

        cin
    
Improved logging

              r134
            
          public class InteractiveListener: ListenerBase

        cin
    
refactoring, interactive tarce log almost complete

              r47
            
          {

              TraceForm m_form;

              SynchronizationContext m_syncGuiThread;

        cin
    
fixed Resove method bug when calling it on already cancelled promise

              r130
            
              readonly Promise m_guiStarted = new Promise();

        cin
    
refactoring, interactive tarce log almost complete

              r47
            
        cin
    
Refactoring

              r66
            
              readonly IPromise m_guiFinished;

        cin
    
fixed JSONXmlReader disposing under ugly mono...

              r85
            
              //        readonly IPromise m_workerFinished = new Promise<object>();

        cin
    
refactoring, interactive tarce log almost complete

              r47
            
              readonly MTQueue<TraceViewItem> m_queue = new MTQueue<TraceViewItem>();

              readonly AutoResetEvent m_queueEvent = new AutoResetEvent(false);

              int m_queueLength;

              bool m_exitPending;

              readonly object m_pauseLock = new object();

              bool m_paused;

              readonly ManualResetEvent m_pauseEvent = new ManualResetEvent(true);

        cin
    
Improved logging

              r134
            
              public InteractiveListener() {

        cin
    
fixed Resove method bug when calling it on already cancelled promise

              r130
            
                  m_guiFinished = AsyncPool.RunThread(GuiThread);

                  /*m_workerFinished = */AsyncPool.RunThread(QueueThread);

        cin
    
refactoring, interactive tarce log almost complete

              r47
            
                  m_guiStarted.Join();

              }

              void GuiThread() {

                  m_form = new TraceForm(); // will create SynchronizationContext

        cin
    
Interactive tracing...

              r48
            
                  m_form.PauseEvents += (s,a) => Pause();

                  m_form.ResumeEvents += (s, a) => Resume();

        cin
    
refactoring, interactive tarce log almost complete

              r47
            
                  m_syncGuiThread = SynchronizationContext.Current;

                  m_guiStarted.Resolve();

                  Application.Run();

              }

              void QueueThread() {

                  while (!m_exitPending) {

                      if (m_paused)

                          m_pauseEvent.WaitOne();

                      TraceViewItem item;

                      if (m_queue.TryDequeue(out item)) {

                          Interlocked.Decrement(ref m_queueLength);

                          m_syncGuiThread.Send(x => m_form.AddTraceEvent(item),null);

                      } else {

                          m_queueEvent.WaitOne();

                      }

                  }

              }

              public void Pause() {

                  // for consistency we need to set this properties atomically

                  lock (m_pauseLock) {

                      m_pauseEvent.Reset();

                      m_paused = true;

                  }

              }

              public void Resume() {

                  // for consistency we need to set this properties atomically

                  lock (m_pauseLock) {

                      m_paused = false;

                      m_pauseEvent.Set();

                  }

              }

              void Enqueue(TraceViewItem item) {

                  m_queue.Enqueue(item);

                  if (Interlocked.Increment(ref m_queueLength) == 1)

                      m_queueEvent.Set();

              }

              public void ShowForm() {

                  m_syncGuiThread.Post(x => m_form.Show(), null);

              }

              public void HideForm() {

                  m_syncGuiThread.Post(x => m_form.Hide(), null);

              }

              void Terminate() {

        cin
    
Interactive tracing...

              r48
            
                  m_exitPending = true;

                  Resume();            

        cin
    
refactoring, interactive tarce log almost complete

              r47
            
                  m_syncGuiThread.Post(x => Application.ExitThread(), null);

              }

              protected override void Dispose(bool disposing) {

                  if (disposing) {

                      Terminate();

                      m_guiFinished.Join();

                  }

                  base.Dispose(disposing);

              }

        cin
    
Interactive tracing...

              r48
            
        cin
    
Improved logging

              r134
            
              public override void Write(LogEventArgs args, object entry) {

        cin
    
Interactive tracing...

              r48
            
                  var item = new TraceViewItem {

        cin
    
Improved logging

              r134
            
                      Indent = args.Operation.Level,

                      Message = entry.ToString(),

        cin
    
rewritten tracing

              r92
            
                      Thread = args.ThreadId,

        cin
    
Improved logging

              r134
            
                      Channel = args.ChannelName,

        cin
    
Interactive tracing...

              r48
            
                      Timestamp = Environment.TickCount

                  };

                  Enqueue(item);

              }

        cin
    
refactoring, interactive tarce log almost complete

              r47
            
          }

      }

	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 refactoring, interactive tarce log almost complete	r47	using Implab.Parallels;
		using System;
		using System.Collections.Generic;
		using System.Linq;
		using System.Text;
		using System.Threading;
		using System.Threading.Tasks;
		using System.Windows.Forms;

		namespace Implab.Diagnostics.Interactive
		{
cin Improved logging	r134	public class InteractiveListener: ListenerBase
cin refactoring, interactive tarce log almost complete	r47	{
		TraceForm m_form;

		SynchronizationContext m_syncGuiThread;
cin fixed Resove method bug when calling it on already cancelled promise	r130	readonly Promise m_guiStarted = new Promise();
cin refactoring, interactive tarce log almost complete	r47
cin Refactoring	r66	readonly IPromise m_guiFinished;
cin fixed JSONXmlReader disposing under ugly mono...	r85	// readonly IPromise m_workerFinished = new Promise<object>();
cin refactoring, interactive tarce log almost complete	r47
		readonly MTQueue<TraceViewItem> m_queue = new MTQueue<TraceViewItem>();
		readonly AutoResetEvent m_queueEvent = new AutoResetEvent(false);

		int m_queueLength;
		bool m_exitPending;

		readonly object m_pauseLock = new object();
		bool m_paused;
		readonly ManualResetEvent m_pauseEvent = new ManualResetEvent(true);

cin Improved logging	r134	public InteractiveListener() {
cin fixed Resove method bug when calling it on already cancelled promise	r130	m_guiFinished = AsyncPool.RunThread(GuiThread);
		/m_workerFinished = /AsyncPool.RunThread(QueueThread);
cin refactoring, interactive tarce log almost complete	r47
		m_guiStarted.Join();
		}

		void GuiThread() {
		m_form = new TraceForm(); // will create SynchronizationContext
cin Interactive tracing...	r48
		m_form.PauseEvents += (s,a) => Pause();
		m_form.ResumeEvents += (s, a) => Resume();

cin refactoring, interactive tarce log almost complete	r47	m_syncGuiThread = SynchronizationContext.Current;
		m_guiStarted.Resolve();
		Application.Run();
		}

		void QueueThread() {
		while (!m_exitPending) {
		if (m_paused)
		m_pauseEvent.WaitOne();

		TraceViewItem item;
		if (m_queue.TryDequeue(out item)) {
		Interlocked.Decrement(ref m_queueLength);

		m_syncGuiThread.Send(x => m_form.AddTraceEvent(item),null);
		} else {
		m_queueEvent.WaitOne();
		}
		}
		}

		public void Pause() {
		// for consistency we need to set this properties atomically
		lock (m_pauseLock) {
		m_pauseEvent.Reset();
		m_paused = true;
		}
		}

		public void Resume() {
		// for consistency we need to set this properties atomically
		lock (m_pauseLock) {
		m_paused = false;
		m_pauseEvent.Set();
		}
		}

		void Enqueue(TraceViewItem item) {
		m_queue.Enqueue(item);
		if (Interlocked.Increment(ref m_queueLength) == 1)
		m_queueEvent.Set();
		}

		public void ShowForm() {
		m_syncGuiThread.Post(x => m_form.Show(), null);
		}

		public void HideForm() {
		m_syncGuiThread.Post(x => m_form.Hide(), null);
		}

		void Terminate() {
cin Interactive tracing...	r48	m_exitPending = true;
		Resume();
cin refactoring, interactive tarce log almost complete	r47	m_syncGuiThread.Post(x => Application.ExitThread(), null);
		}

		protected override void Dispose(bool disposing) {
		if (disposing) {
		Terminate();
		m_guiFinished.Join();
		}
		base.Dispose(disposing);
		}
cin Interactive tracing...	r48
cin Improved logging	r134	public override void Write(LogEventArgs args, object entry) {
cin Interactive tracing...	r48	var item = new TraceViewItem {
cin Improved logging	r134	Indent = args.Operation.Level,
		Message = entry.ToString(),
cin rewritten tracing	r92	Thread = args.ThreadId,
cin Improved logging	r134	Channel = args.ChannelName,
cin Interactive tracing...	r48	Timestamp = Environment.TickCount
		};

		Enqueue(item);
		}
cin refactoring, interactive tarce log almost complete	r47	}
		}