From a0ca1882d80bc78223d1d4452593a1106560cf4b Mon Sep 17 00:00:00 2001 From: sta Date: Sun, 16 Mar 2014 04:25:19 +0900 Subject: [PATCH] Fix a few --- Example/Notifier.cs | 5 +++-- Example/Program.cs | 16 ++++++++-------- Example1/Notifier.cs | 5 +++-- Example1/Program.cs | 2 +- 4 files changed, 15 insertions(+), 13 deletions(-) diff --git a/Example/Notifier.cs b/Example/Notifier.cs index dff2bb81..4a25cc5a 100644 --- a/Example/Notifier.cs +++ b/Example/Notifier.cs @@ -10,7 +10,7 @@ namespace Example { internal class Notifier : IDisposable { - private bool _enabled; + private volatile bool _enabled; private Queue _queue; private ManualResetEvent _waitHandle; @@ -65,7 +65,8 @@ namespace Example public void Notify (NotificationMessage message) { lock (((ICollection) _queue).SyncRoot) { - _queue.Enqueue (message); + if (_enabled) + _queue.Enqueue (message); } } diff --git a/Example/Program.cs b/Example/Program.cs index d76e0f9f..0d76fcf3 100644 --- a/Example/Program.cs +++ b/Example/Program.cs @@ -11,7 +11,7 @@ namespace Example { using (var nf = new Notifier ()) using (var ws = new WebSocket ("ws://echo.websocket.org")) - //using (var ws = new WebSocket ("wss://echo.websocket.org")) + //using (var ws = new WebSocket ("wss://echo.websocket.org")) // For Secure Connection //using (var ws = new WebSocket ("ws://localhost:4649/Echo")) //using (var ws = new WebSocket ("wss://localhost:4649/Echo")) //using (var ws = new WebSocket ("ws://localhost:4649/Echo?name=nobita")) @@ -21,7 +21,7 @@ namespace Example //using (var ws = new WebSocket ("ws://localhost:4649/Chat?name=nobita")) //using (var ws = new WebSocket ("ws://localhost:4649/チャット?name=のび太")) { - /* WebSocket events */ + /* Setting WebSocket events */ ws.OnOpen += (sender, e) => ws.Send ("Hi, there!"); ws.OnMessage += (sender, e) => @@ -51,23 +51,23 @@ namespace Example #if DEBUG ws.Log.Level = LogLevel.Trace; #endif - // Per-message Compression + // Setting Per-message Compression //ws.Compression = CompressionMethod.Deflate; - /* Secure Connection + /* For Secure Connection ws.ServerCertificateValidationCallback = (sender, certificate, chain, sslPolicyErrors) => { ws.Log.Debug (String.Format ("\n{0}\n{1}", certificate.Issuer, certificate.Subject)); return true; // If the server cert is valid }; */ - // HTTP Authentication (Basic/Digest) + // For HTTP Authentication (Basic/Digest) //ws.SetCredentials ("nobita", "password", false); // Digest - // Origin + // Setting Origin //ws.Origin = "http://echo.websocket.org"; - // Cookies + // Setting Cookies //ws.SetCookie (new Cookie ("nobita", "\"idiot, gunfighter\"")); //ws.SetCookie (new Cookie ("dora", "tanuki")); @@ -76,7 +76,7 @@ namespace Example Console.WriteLine ("\nType \"exit\" to exit.\n"); while (true) { - Thread.Sleep (500); + Thread.Sleep (1000); Console.Write ("> "); var msg = Console.ReadLine (); if (msg == "exit") diff --git a/Example1/Notifier.cs b/Example1/Notifier.cs index a4ca5d44..f291e8c5 100644 --- a/Example1/Notifier.cs +++ b/Example1/Notifier.cs @@ -10,7 +10,7 @@ namespace Example1 { internal class Notifier : IDisposable { - private bool _enabled; + private volatile bool _enabled; private Queue _queue; private ManualResetEvent _waitHandle; @@ -65,7 +65,8 @@ namespace Example1 public void Notify (NotificationMessage message) { lock (((ICollection) _queue).SyncRoot) { - _queue.Enqueue (message); + if (_enabled) + _queue.Enqueue (message); } } diff --git a/Example1/Program.cs b/Example1/Program.cs index 5ddf351d..30776db3 100644 --- a/Example1/Program.cs +++ b/Example1/Program.cs @@ -21,7 +21,7 @@ namespace Example1 Console.WriteLine ("\nType \"exit\" to exit.\n"); while (true) { - Thread.Sleep (500); + Thread.Sleep (1000); Console.Write ("> "); var msg = Console.ReadLine (); if (msg == "exit")