Distribute spinwait to local funciton

Author: HowardWhile

EasyModbus/ModbusClient.cs

@@ -75,7 +75,6 @@ public enum RegisterOrder { LowHigh = 0, HighLow = 1 };
 
         NetworkStream stream;
 
-        private SpinWait sw_delay = new SpinWait();
 		/// <summary>
 		/// Constructor which determines the Master ip-address and the Master Port.
 		/// </summary>
@@ -943,11 +942,11 @@ public bool[] ReadDiscreteInputs(int startingAddress, int quantity)
                 DateTime dateTimeSend = DateTime.Now;
                 byte receivedUnitIdentifier = 0xFF;
 
-
+                SpinWait sw_delay = new SpinWait();
                 while (receivedUnitIdentifier != this.unitIdentifier & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
                 {
                     while (dataReceived == false & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
-                        this.sw_delay.SpinOnce();  
+                        sw_delay.SpinOnce();  
 
                 	data = new byte[2100];
                 	Array.Copy(readBuffer, 0, data, 6, readBuffer.Length);
@@ -1138,10 +1137,12 @@ public bool[] ReadCoils(int startingAddress, int quantity)
                 readBuffer = new byte[256];
                 DateTime dateTimeSend = DateTime.Now;
                 byte receivedUnitIdentifier = 0xFF;
+
+                SpinWait sw_delay = new SpinWait();
                 while (receivedUnitIdentifier != this.unitIdentifier & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
                 {
                     while (dataReceived == false & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
-                        this.sw_delay.SpinOnce();
+                        sw_delay.SpinOnce();
 
                 	data = new byte[2100];
 
@@ -1330,10 +1331,12 @@ public int[] ReadHoldingRegisters(int startingAddress, int quantity)
 
                 DateTime dateTimeSend = DateTime.Now;
                 byte receivedUnitIdentifier = 0xFF;
+
+                SpinWait sw_delay = new SpinWait();
                 while (receivedUnitIdentifier != this.unitIdentifier & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
                 {
                 	while (dataReceived == false & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
-                        this.sw_delay.SpinOnce();
+                        sw_delay.SpinOnce();
 
                     data = new byte[2100];
                 	Array.Copy(readBuffer, 0, data, 6, readBuffer.Length);
@@ -1533,11 +1536,12 @@ public int[] ReadInputRegisters(int startingAddress, int quantity)
                 readBuffer = new byte[256];
                 DateTime dateTimeSend = DateTime.Now;
                 byte receivedUnitIdentifier = 0xFF;
-                
+
+                SpinWait sw_delay = new SpinWait();
                 while (receivedUnitIdentifier != this.unitIdentifier & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
                 {
                 	while (dataReceived == false & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
-                        this.sw_delay.SpinOnce();
+                        sw_delay.SpinOnce();
 
                     data = new byte[2100];
                 	Array.Copy(readBuffer, 0, data, 6, readBuffer.Length);
@@ -1735,10 +1739,12 @@ public void WriteSingleCoil(int startingAddress, bool value)
                 readBuffer = new byte[256];
                 DateTime dateTimeSend = DateTime.Now;
                 byte receivedUnitIdentifier = 0xFF;
+
+                SpinWait sw_delay = new SpinWait();
                 while (receivedUnitIdentifier != this.unitIdentifier & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
                 {
                 	while (dataReceived == false & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
-                        this.sw_delay.SpinOnce();
+                        sw_delay.SpinOnce();
 
                     data = new byte[2100];
                 	Array.Copy(readBuffer, 0, data, 6, readBuffer.Length);
@@ -1915,10 +1921,12 @@ public void WriteSingleRegister(int startingAddress, int value)
                 readBuffer = new byte[256];
                 DateTime dateTimeSend = DateTime.Now;
                 byte receivedUnitIdentifier = 0xFF;
+
+                SpinWait sw_delay = new SpinWait();
                 while (receivedUnitIdentifier != this.unitIdentifier & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
                 {
                 	while (dataReceived == false & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
-                        this.sw_delay.SpinOnce();
+                        sw_delay.SpinOnce();
 
                     data = new byte[2100];
                 	Array.Copy(readBuffer, 0, data, 6, readBuffer.Length);
@@ -2112,10 +2120,12 @@ public void WriteMultipleCoils(int startingAddress, bool[] values)
                 readBuffer = new byte[256];
                 DateTime dateTimeSend = DateTime.Now;
                 byte receivedUnitIdentifier = 0xFF;
+
+                SpinWait sw_delay = new SpinWait();
                 while (receivedUnitIdentifier != this.unitIdentifier & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
                 {
                 	while (dataReceived == false & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
-                        this.sw_delay.SpinOnce();
+                        sw_delay.SpinOnce();
 
                     data = new byte[2100];
                 	Array.Copy(readBuffer, 0, data, 6, readBuffer.Length);
@@ -2298,10 +2308,12 @@ public void WriteMultipleRegisters(int startingAddress, int[] values)
                 readBuffer = new byte[256];
                 DateTime dateTimeSend = DateTime.Now;
                 byte receivedUnitIdentifier = 0xFF;
+
+                SpinWait sw_delay = new SpinWait();
                 while (receivedUnitIdentifier != this.unitIdentifier & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
                 {
                 	while (dataReceived == false & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
-                        this.sw_delay.SpinOnce();
+                        sw_delay.SpinOnce();
 
                     data = new byte[2100];
                 	Array.Copy(readBuffer, 0, data, 6, readBuffer.Length);
@@ -2502,10 +2514,12 @@ public int[] ReadWriteMultipleRegisters(int startingAddressRead, int quantityRea
                 readBuffer = new byte[256];
                 DateTime dateTimeSend = DateTime.Now;
                 byte receivedUnitIdentifier = 0xFF;
+
+                SpinWait sw_delay = new SpinWait();
                 while (receivedUnitIdentifier != this.unitIdentifier & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
                 {
                 	while (dataReceived == false & !((DateTime.Now.Ticks - dateTimeSend.Ticks) > TimeSpan.TicksPerMillisecond * this.connectTimeout))
-                        this.sw_delay.SpinOnce();
+                        sw_delay.SpinOnce();
 
                     data = new byte[2100];
                 	Array.Copy(readBuffer, 0, data, 6, readBuffer.Length);