Updating C# Examples

examples/C#/asyncsrv.cs

@@ -48,7 +48,7 @@ static void AsyncSrv_Client(ZContext context, int i)
 						{
 							if (error == ZError.EAGAIN)
 							{
-								error = ZError.None;
+								Thread.Sleep(1);
 								continue;
 							}
 							if (error == ZError.ETERM)

examples/C#/eagain.cs

@@ -40,10 +40,8 @@ public static void EAgain(IDictionary<string, string> dict, string[] args)
 								Console.WriteLine(new ZException(error));
 								break;
 
-								/* Usually, when reaching EAGAIN you would do
-								error = ZError.None; // = default(ZError); // = null;
+								/* Usually when reaching EAGAIN, I would do
 								Thread.Sleep(1);
-
 								continue; /**/
 							}
 							if (error == ZError.ETERM)

examples/C#/interrupt.cs

@@ -51,17 +51,15 @@ public static void Interrupt(IDictionary<string, string> dict, string[] args)
 						{
 							context.Shutdown();
 						}
-					} /**/
+					}
 
 					if (null == (request = responder.ReceiveFrame(ZSocketFlags.DontWait, out error)))
 					{
 						if (error == ZError.EAGAIN)
 						{
-							error = ZError.None;
 							Thread.Sleep(1);
-
 							continue;
-						} /**/
+						}
 						if (error == ZError.ETERM)
 							break;	// Interrupted
 						throw new ZException(error);

examples/C#/mtrelay.cs

@@ -19,13 +19,12 @@ public static void MTRelay(IDictionary<string, string> dict, string[] args)
 			//
 
 			// Bind inproc socket before starting step2
-			using (var context = new ZContext())
-			using (var receiver = new ZSocket(context, ZSocketType.PAIR))
+			using (var ctx = new ZContext())
+			using (var receiver = new ZSocket(ctx, ZSocketType.PAIR))
 			{
 				receiver.Bind("inproc://step3");
 
-				var thread = new Thread(() => MTRelay_step2(context));
-				thread.Start();
+				new Thread(() => MTRelay_step2(ctx)).Start();
 
 				// Wait for signal
 				receiver.ReceiveFrame();
@@ -34,22 +33,21 @@ public static void MTRelay(IDictionary<string, string> dict, string[] args)
 			}
 		}
 
-		static void MTRelay_step2(ZContext context)
+		static void MTRelay_step2(ZContext ctx)
 		{
 			// Bind inproc socket before starting step1
-			using (var receiver = new ZSocket(context, ZSocketType.PAIR))
+			using (var receiver = new ZSocket(ctx, ZSocketType.PAIR))
 			{
 				receiver.Bind("inproc://step2");
 
-				var thread = new Thread(() => MTRelay_step1(context));
-				thread.Start();
+				new Thread(() => MTRelay_step1(ctx)).Start();
 
 				// Wait for signal and pass it on
 				receiver.ReceiveFrame();
 			}
 
 			// Connect to step3 and tell it we're ready
-			using (var xmitter = new ZSocket(context, ZSocketType.PAIR))
+			using (var xmitter = new ZSocket(ctx, ZSocketType.PAIR))
 			{
 				xmitter.Connect("inproc://step3");
 
@@ -58,10 +56,10 @@ static void MTRelay_step2(ZContext context)
 			}
 		}
 
-		static void MTRelay_step1(ZContext context) 
+		static void MTRelay_step1(ZContext ctx) 
 		{
 			// Connect to step2 and tell it we're ready
-			using (var xmitter = new ZSocket(context, ZSocketType.PAIR))
+			using (var xmitter = new ZSocket(ctx, ZSocketType.PAIR))
 			{
 				xmitter.Connect("inproc://step2");
 

examples/C#/mtserver.cs

@@ -38,10 +38,10 @@ public static void MTServer(IDictionary<string, string> dict, string[] args)
 			}
 		}
 
-		static void MTServer_Worker(ZContext context) 
+		static void MTServer_Worker(ZContext ctx) 
 		{
 			// Socket to talk to dispatcher
-			using (var server = new ZSocket(context, ZSocketType.REP))
+			using (var server = new ZSocket(ctx, ZSocketType.REP))
 			{
 				server.Connect("inproc://workers");
 

examples/C#/peering1.cs

@@ -65,8 +65,6 @@ public static void Peering1(IDictionary<string, string> dict, string[] args)
 					{
 						if (error == ZError.EAGAIN)
 						{
-							error = ZError.None;
-
 							using (var output = new ZMessage())
 							{
 								output.Add(new ZFrame(self));

examples/C#/rrbroker.cs

@@ -19,9 +19,9 @@ public static void RRBroker(IDictionary<string, string> dict, string[] args)
 			//
 
 			// Prepare our context and sockets
-			using (var context = new ZContext())
-			using (var frontend = new ZSocket(context, ZSocketType.ROUTER))
-			using (var backend = new ZSocket(context, ZSocketType.DEALER))
+			using (var ctx = new ZContext())
+			using (var frontend = new ZSocket(ctx, ZSocketType.ROUTER))
+			using (var backend = new ZSocket(ctx, ZSocketType.DEALER))
 			{
 				frontend.Bind("tcp://*:5559");
 				backend.Bind("tcp://*:5560");

examples/C#/rtdealer.cs

@@ -32,8 +32,7 @@ public static void RTDealer(IDictionary<string, string> dict, string[] args)
 
 				for (int i = 0; i < RTDealer_Workers; ++i)
 				{
-					int j = i;
-					new Thread(() => RTDealer_Worker(j)).Start();
+					int j = i; new Thread(() => RTDealer_Worker(j)).Start();
 				}
 
 				var stopwatch = new Stopwatch();
@@ -84,14 +83,14 @@ static void RTDealer_Worker(int i)
 					worker.Send(new ZFrame("Hi Boss"));	
 
 					// Get workload from broker, until finished
-					bool finished;
 					using (ZMessage msg = worker.ReceiveMessage())
 					{
-						finished = (msg[2].ReadString() == "Fired!");
-					}
-					if (finished)
-					{
-						break;
+						bool finished = (msg[2].ReadString() == "Fired!");
+
+						if (finished)
+						{
+							break;
+						}
 					}
 
 					total++;

examples/C#/rtreq.cs

@@ -82,15 +82,15 @@ static void RTReq_Worker(int i)
 					worker.Send(new ZFrame("Hi Boss"));
 
 					// Get workload from broker, until finished
-					bool finished;
 					using (ZFrame frame = worker.ReceiveFrame())
 					{
-						finished = (frame.ReadString() == "Fired!");
-					}
-					if (finished)
-					{
-						break;
+						bool finished = (frame.ReadString() == "Fired!");
+						if (finished)
+						{
+							break;
+						}
 					}
+
 					total++;
 
 					// Do some random work

examples/C#/suisnail.cs

@@ -91,9 +91,7 @@ static void SuiSnail_Publisher(ZContext context, ZSocket backend, CancellationTo
 					{
 						if (error == ZError.EAGAIN)
 						{
-							error = ZError.None;
 							Thread.Sleep(1);	// wait 1 ms
-
 							continue;
 						}
 						if (error == ZError.ETERM)