| | |
| | | //MainPage.AddTip (Language.StringByID (SimpleControl.R.MyInternationalizationString.OperationFailed)); |
| | | } |
| | | } |
| | | } |
| | | return; |
| | | //if (Shared.SimpleControl.CommonPage.IsRemote && !isLocal) { |
| | | // System.Console.WriteLine ("远程发送数据:" + SendFlag); |
| | | // SmartHome.MqttCommon.MqttRemoteSend (Packet.Bytes); |
| | | // Packet.FlagDateTime = DateTime.Now; |
| | | // Packet.HaveSendCount--; |
| | | // //这里是重发两次 |
| | | // while (Packet.HaveSendCount < 3) { |
| | | // if (Packet.FlagDateTime.AddMilliseconds (1000).Ticks <= System.DateTime.Now.Ticks) { |
| | | // SmartHome.MqttCommon.MqttRemoteSend (Packet.Bytes); |
| | | // System.Console.WriteLine ("重发远程发送数据:" + SendFlag); |
| | | // Packet.FlagDateTime = DateTime.Now; |
| | | // Packet.HaveSendCount++; |
| | | // } |
| | | // System.Threading.Thread.Sleep (100); |
| | | // }
// allDone.Set ();
//} else { |
| | | // try { |
| | | // System.Console.WriteLine ("发送数据:" + SendFlag); |
| | | // BusSocket.AsyncBeginSend (Packet); |
| | | // Packet.HaveSendCount--; |
| | | |
| | | // //这里是重发两次 |
| | | // while (Packet.HaveSendCount < 3) { |
| | | // if (Packet.FlagDateTime.AddMilliseconds (1000).Ticks <= System.DateTime.Now.Ticks) { |
| | | // System.Console.WriteLine ("重发数据:" + SendFlag); |
| | | // BusSocket.AsyncBeginSend (Packet); |
| | | // } |
| | | // System.Threading.Thread.Sleep (100); |
| | | // } |
| | | |
| | | // } catch (Exception ex) { |
| | | // Console.WriteLine ("managerSendCount:" + ex.ToString ()); |
| | | // } finally { |
| | | // allDone.Set (); |
| | | // } |
| | | //} |
| | | } |
| | | /// <summary> |
| | | /// 当前数据包 |
| | | /// </summary> |
| | |
| | | /// </summary> |
| | | /// <param name="target">发送对象</param> |
| | | /// <param name="sendCount">重发次数</param> |
| | | public void Send (Target target, SendCount sendCount, bool isWait) |
| | | public void Send (Target target, SendCount sendCount, bool isWait, bool needLocal = false) |
| | | { |
| | | isLocal = needLocal; |
| | | Packet = new Packet (target.SendBytes, target.IPEndPoint); |
| | | Packet.HaveSendCount = 3 - (int)sendCount; |
| | | |
| | |
| | | this.wait (); |
| | | } |
| | | } |
| | | bool isLocal = false; |
| | | } |
| | | } |