##// END OF EJS Templates
implab » ImplabNet
RSS
Bound promise to CancellationToken...
Bound promise to CancellationToken Added new states to ExecutionSate enum. Added Safe.Guard() method to handle cleanup of the result of the promise
cin - - Load All Authors

File last commit:

r204:cbb0bd8fc0d1 v2
r209:a867536c68fc v2
Show More
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
Fixed broken Implab.Diagnostics.Interactive
 r204 Channel = args.Channel.ToString(),
cin
Interactive tracing...
 r48 Timestamp = Environment.TickCount
};
Enqueue(item);
}
cin
refactoring, interactive tarce log almost complete
 r47 }
}