Important changes to repositories hosted on mbed.com
Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.
To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.
It is also possible to export all your personal repositories from the account settings page.
hspguisourcev301/HspGuiSourceV301/GuiDLLs/RPCSupport/Pipelines/Pipeline.cs@3:36de8b9e4b1a, 2021-04-10 (annotated)
- Committer:
- darienf
- Date:
- Sat Apr 10 03:05:42 2021 +0000
- Revision:
- 3:36de8b9e4b1a
ayoooo
Who changed what in which revision?
| User | Revision | Line number | New contents of line |
|---|---|---|---|
| darienf | 3:36de8b9e4b1a | 1 | /******************************************************************************* |
| darienf | 3:36de8b9e4b1a | 2 | * Copyright (C) 2016 Maxim Integrated Products, Inc., All rights Reserved. |
| darienf | 3:36de8b9e4b1a | 3 | * |
| darienf | 3:36de8b9e4b1a | 4 | * This software is protected by copyright laws of the United States and |
| darienf | 3:36de8b9e4b1a | 5 | * of foreign countries. This material may also be protected by patent laws |
| darienf | 3:36de8b9e4b1a | 6 | * and technology transfer regulations of the United States and of foreign |
| darienf | 3:36de8b9e4b1a | 7 | * countries. This software is furnished under a license agreement and/or a |
| darienf | 3:36de8b9e4b1a | 8 | * nondisclosure agreement and may only be used or reproduced in accordance |
| darienf | 3:36de8b9e4b1a | 9 | * with the terms of those agreements. Dissemination of this information to |
| darienf | 3:36de8b9e4b1a | 10 | * any party or parties not specified in the license agreement and/or |
| darienf | 3:36de8b9e4b1a | 11 | * nondisclosure agreement is expressly prohibited. |
| darienf | 3:36de8b9e4b1a | 12 | * |
| darienf | 3:36de8b9e4b1a | 13 | * The above copyright notice and this permission notice shall be included |
| darienf | 3:36de8b9e4b1a | 14 | * in all copies or substantial portions of the Software. |
| darienf | 3:36de8b9e4b1a | 15 | * |
| darienf | 3:36de8b9e4b1a | 16 | * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS |
| darienf | 3:36de8b9e4b1a | 17 | * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF |
| darienf | 3:36de8b9e4b1a | 18 | * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. |
| darienf | 3:36de8b9e4b1a | 19 | * IN NO EVENT SHALL MAXIM INTEGRATED BE LIABLE FOR ANY CLAIM, DAMAGES |
| darienf | 3:36de8b9e4b1a | 20 | * OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, |
| darienf | 3:36de8b9e4b1a | 21 | * ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR |
| darienf | 3:36de8b9e4b1a | 22 | * OTHER DEALINGS IN THE SOFTWARE. |
| darienf | 3:36de8b9e4b1a | 23 | * |
| darienf | 3:36de8b9e4b1a | 24 | * Except as contained in this notice, the name of Maxim Integrated |
| darienf | 3:36de8b9e4b1a | 25 | * Products, Inc. shall not be used except as stated in the Maxim Integrated |
| darienf | 3:36de8b9e4b1a | 26 | * Products, Inc. Branding Policy. |
| darienf | 3:36de8b9e4b1a | 27 | * |
| darienf | 3:36de8b9e4b1a | 28 | * The mere transfer of this software does not imply any licenses |
| darienf | 3:36de8b9e4b1a | 29 | * of trade secrets, proprietary technology, copyrights, patents, |
| darienf | 3:36de8b9e4b1a | 30 | * trademarks, maskwork rights, or any other form of intellectual |
| darienf | 3:36de8b9e4b1a | 31 | * property whatsoever. Maxim Integrated Products, Inc. retains all |
| darienf | 3:36de8b9e4b1a | 32 | * ownership rights. |
| darienf | 3:36de8b9e4b1a | 33 | ******************************************************************************* |
| darienf | 3:36de8b9e4b1a | 34 | */ |
| darienf | 3:36de8b9e4b1a | 35 | |
| darienf | 3:36de8b9e4b1a | 36 | using System; |
| darienf | 3:36de8b9e4b1a | 37 | using System.Collections.Generic; |
| darienf | 3:36de8b9e4b1a | 38 | using System.Linq; |
| darienf | 3:36de8b9e4b1a | 39 | using System.Text; |
| darienf | 3:36de8b9e4b1a | 40 | using System.Globalization; |
| darienf | 3:36de8b9e4b1a | 41 | using System.Collections; |
| darienf | 3:36de8b9e4b1a | 42 | |
| darienf | 3:36de8b9e4b1a | 43 | namespace RPCSupport.Pipelines |
| darienf | 3:36de8b9e4b1a | 44 | { |
| darienf | 3:36de8b9e4b1a | 45 | public abstract class Pipeline |
| darienf | 3:36de8b9e4b1a | 46 | { |
| darienf | 3:36de8b9e4b1a | 47 | public delegate void RawRpcRequest(string s); |
| darienf | 3:36de8b9e4b1a | 48 | public delegate void RawRpcReply(string s); |
| darienf | 3:36de8b9e4b1a | 49 | public delegate void RawRpcStream(string s); |
| darienf | 3:36de8b9e4b1a | 50 | internal RawRpcRequest rawRpcRequest; |
| darienf | 3:36de8b9e4b1a | 51 | internal RawRpcReply rawRpcReply; |
| darienf | 3:36de8b9e4b1a | 52 | internal RawRpcStream rawRpcStream; |
| darienf | 3:36de8b9e4b1a | 53 | public virtual bool Init() |
| darienf | 3:36de8b9e4b1a | 54 | { |
| darienf | 3:36de8b9e4b1a | 55 | return true; |
| darienf | 3:36de8b9e4b1a | 56 | } |
| darienf | 3:36de8b9e4b1a | 57 | |
| darienf | 3:36de8b9e4b1a | 58 | public abstract string RawRpcCall(string request, bool reply); |
| darienf | 3:36de8b9e4b1a | 59 | public abstract void SendSingleByte(char ch); |
| darienf | 3:36de8b9e4b1a | 60 | public abstract void Discard(); |
| darienf | 3:36de8b9e4b1a | 61 | public abstract string RawRpcCallBinary(string request, bool reply, out bool allOnes); |
| darienf | 3:36de8b9e4b1a | 62 | |
| darienf | 3:36de8b9e4b1a | 63 | public void LogStream(string stream) |
| darienf | 3:36de8b9e4b1a | 64 | { |
| darienf | 3:36de8b9e4b1a | 65 | if (rawRpcStream != null) |
| darienf | 3:36de8b9e4b1a | 66 | { |
| darienf | 3:36de8b9e4b1a | 67 | rawRpcStream(stream); |
| darienf | 3:36de8b9e4b1a | 68 | } |
| darienf | 3:36de8b9e4b1a | 69 | } |
| darienf | 3:36de8b9e4b1a | 70 | |
| darienf | 3:36de8b9e4b1a | 71 | /*public virtual bool IsConnected() |
| darienf | 3:36de8b9e4b1a | 72 | { |
| darienf | 3:36de8b9e4b1a | 73 | return false; |
| darienf | 3:36de8b9e4b1a | 74 | }*/ |
| darienf | 3:36de8b9e4b1a | 75 | public abstract bool IsConnected(); |
| darienf | 3:36de8b9e4b1a | 76 | |
| darienf | 3:36de8b9e4b1a | 77 | public void LogCallback(RawRpcRequest request, RawRpcReply reply, RawRpcStream stream) |
| darienf | 3:36de8b9e4b1a | 78 | { |
| darienf | 3:36de8b9e4b1a | 79 | rawRpcRequest = request; |
| darienf | 3:36de8b9e4b1a | 80 | rawRpcReply = reply; |
| darienf | 3:36de8b9e4b1a | 81 | rawRpcStream = stream; |
| darienf | 3:36de8b9e4b1a | 82 | } |
| darienf | 3:36de8b9e4b1a | 83 | |
| darienf | 3:36de8b9e4b1a | 84 | public String Call(string name, string method, params string[] args) |
| darienf | 3:36de8b9e4b1a | 85 | { |
| darienf | 3:36de8b9e4b1a | 86 | return SendRPC(name, method, args); |
| darienf | 3:36de8b9e4b1a | 87 | } |
| darienf | 3:36de8b9e4b1a | 88 | |
| darienf | 3:36de8b9e4b1a | 89 | public String CallBinary(string name, string method, out bool allOnes, params string[] args) |
| darienf | 3:36de8b9e4b1a | 90 | { |
| darienf | 3:36de8b9e4b1a | 91 | return SendRPCBinary(name, method, out allOnes, args); |
| darienf | 3:36de8b9e4b1a | 92 | } |
| darienf | 3:36de8b9e4b1a | 93 | |
| darienf | 3:36de8b9e4b1a | 94 | public String CallNoReply(string name, string method, params string[] args) |
| darienf | 3:36de8b9e4b1a | 95 | { |
| darienf | 3:36de8b9e4b1a | 96 | return SendRPCNoReply(name, method, args); |
| darienf | 3:36de8b9e4b1a | 97 | } |
| darienf | 3:36de8b9e4b1a | 98 | |
| darienf | 3:36de8b9e4b1a | 99 | public virtual void Connect(string name) |
| darienf | 3:36de8b9e4b1a | 100 | { |
| darienf | 3:36de8b9e4b1a | 101 | } |
| darienf | 3:36de8b9e4b1a | 102 | |
| darienf | 3:36de8b9e4b1a | 103 | public virtual void Disconnect() |
| darienf | 3:36de8b9e4b1a | 104 | { |
| darienf | 3:36de8b9e4b1a | 105 | } |
| darienf | 3:36de8b9e4b1a | 106 | |
| darienf | 3:36de8b9e4b1a | 107 | public virtual String[] ScanAvailablePortNames() |
| darienf | 3:36de8b9e4b1a | 108 | { |
| darienf | 3:36de8b9e4b1a | 109 | return null; |
| darienf | 3:36de8b9e4b1a | 110 | } |
| darienf | 3:36de8b9e4b1a | 111 | |
| darienf | 3:36de8b9e4b1a | 112 | public byte GetReturnValue_Byte() |
| darienf | 3:36de8b9e4b1a | 113 | { |
| darienf | 3:36de8b9e4b1a | 114 | return 0; |
| darienf | 3:36de8b9e4b1a | 115 | } |
| darienf | 3:36de8b9e4b1a | 116 | |
| darienf | 3:36de8b9e4b1a | 117 | public String GetReturnValue() |
| darienf | 3:36de8b9e4b1a | 118 | { |
| darienf | 3:36de8b9e4b1a | 119 | return ""; |
| darienf | 3:36de8b9e4b1a | 120 | } |
| darienf | 3:36de8b9e4b1a | 121 | |
| darienf | 3:36de8b9e4b1a | 122 | private String TrimArgument(String str) |
| darienf | 3:36de8b9e4b1a | 123 | { |
| darienf | 3:36de8b9e4b1a | 124 | String strOut = "0"; |
| darienf | 3:36de8b9e4b1a | 125 | String strIn = str.TrimStart(new char[] { '0' }); |
| darienf | 3:36de8b9e4b1a | 126 | if (String.IsNullOrEmpty(strIn) == false) |
| darienf | 3:36de8b9e4b1a | 127 | { |
| darienf | 3:36de8b9e4b1a | 128 | strOut = strIn; |
| darienf | 3:36de8b9e4b1a | 129 | } |
| darienf | 3:36de8b9e4b1a | 130 | return strOut; |
| darienf | 3:36de8b9e4b1a | 131 | } |
| darienf | 3:36de8b9e4b1a | 132 | |
| darienf | 3:36de8b9e4b1a | 133 | public String SendRPC(String Name, String Method, params String[] Args) |
| darienf | 3:36de8b9e4b1a | 134 | { |
| darienf | 3:36de8b9e4b1a | 135 | //write to serial port and receive result |
| darienf | 3:36de8b9e4b1a | 136 | String Arguments = ""; |
| darienf | 3:36de8b9e4b1a | 137 | |
| darienf | 3:36de8b9e4b1a | 138 | if (Args != null) |
| darienf | 3:36de8b9e4b1a | 139 | { |
| darienf | 3:36de8b9e4b1a | 140 | for (int i = 0; i < Args.Length; i++) |
| darienf | 3:36de8b9e4b1a | 141 | { |
| darienf | 3:36de8b9e4b1a | 142 | Arguments = Arguments + " " + TrimArgument(Args[i]); |
| darienf | 3:36de8b9e4b1a | 143 | } |
| darienf | 3:36de8b9e4b1a | 144 | } |
| darienf | 3:36de8b9e4b1a | 145 | |
| darienf | 3:36de8b9e4b1a | 146 | String request = "/" + Name + "/" + Method + Arguments + "\r\n"; |
| darienf | 3:36de8b9e4b1a | 147 | Console.WriteLine(request); |
| darienf | 3:36de8b9e4b1a | 148 | String reply = RawRpcCall(request, true); |
| darienf | 3:36de8b9e4b1a | 149 | |
| darienf | 3:36de8b9e4b1a | 150 | return reply; |
| darienf | 3:36de8b9e4b1a | 151 | } |
| darienf | 3:36de8b9e4b1a | 152 | |
| darienf | 3:36de8b9e4b1a | 153 | public String SendRPCNoReply(String Name, String Method, params String[] Args) |
| darienf | 3:36de8b9e4b1a | 154 | { |
| darienf | 3:36de8b9e4b1a | 155 | //write to serial port and receive result |
| darienf | 3:36de8b9e4b1a | 156 | String Arguments = ""; |
| darienf | 3:36de8b9e4b1a | 157 | |
| darienf | 3:36de8b9e4b1a | 158 | if (Args != null) |
| darienf | 3:36de8b9e4b1a | 159 | { |
| darienf | 3:36de8b9e4b1a | 160 | for (int i = 0; i < Args.Length; i++) |
| darienf | 3:36de8b9e4b1a | 161 | { |
| darienf | 3:36de8b9e4b1a | 162 | Arguments = Arguments + " " + Args[i]; |
| darienf | 3:36de8b9e4b1a | 163 | } |
| darienf | 3:36de8b9e4b1a | 164 | } |
| darienf | 3:36de8b9e4b1a | 165 | |
| darienf | 3:36de8b9e4b1a | 166 | String request = "/" + Name + "/" + Method + Arguments + "\r\n"; |
| darienf | 3:36de8b9e4b1a | 167 | String reply = RawRpcCall(request, false); |
| darienf | 3:36de8b9e4b1a | 168 | |
| darienf | 3:36de8b9e4b1a | 169 | return reply; |
| darienf | 3:36de8b9e4b1a | 170 | } |
| darienf | 3:36de8b9e4b1a | 171 | |
| darienf | 3:36de8b9e4b1a | 172 | public String SendRPCBinary(String Name, String Method, out bool allOnes, params String[] Args) |
| darienf | 3:36de8b9e4b1a | 173 | { |
| darienf | 3:36de8b9e4b1a | 174 | //write to serial port and receive result |
| darienf | 3:36de8b9e4b1a | 175 | String Arguments = ""; |
| darienf | 3:36de8b9e4b1a | 176 | |
| darienf | 3:36de8b9e4b1a | 177 | if (Args != null) |
| darienf | 3:36de8b9e4b1a | 178 | { |
| darienf | 3:36de8b9e4b1a | 179 | for (int i = 0; i < Args.Length; i++) |
| darienf | 3:36de8b9e4b1a | 180 | { |
| darienf | 3:36de8b9e4b1a | 181 | Arguments = Arguments + " " + Args[i]; |
| darienf | 3:36de8b9e4b1a | 182 | } |
| darienf | 3:36de8b9e4b1a | 183 | } |
| darienf | 3:36de8b9e4b1a | 184 | |
| darienf | 3:36de8b9e4b1a | 185 | String request = "/" + Name + "/" + Method + Arguments + "\r\n"; |
| darienf | 3:36de8b9e4b1a | 186 | String reply = RawRpcCallBinary(request, false, out allOnes); |
| darienf | 3:36de8b9e4b1a | 187 | |
| darienf | 3:36de8b9e4b1a | 188 | return reply; |
| darienf | 3:36de8b9e4b1a | 189 | } |
| darienf | 3:36de8b9e4b1a | 190 | |
| darienf | 3:36de8b9e4b1a | 191 | |
| darienf | 3:36de8b9e4b1a | 192 | public byte StringToByte(String reply) |
| darienf | 3:36de8b9e4b1a | 193 | { |
| darienf | 3:36de8b9e4b1a | 194 | byte val = 0xFF; |
| darienf | 3:36de8b9e4b1a | 195 | if (byte.TryParse(reply, NumberStyles.HexNumber, CultureInfo.CurrentCulture, out val)) |
| darienf | 3:36de8b9e4b1a | 196 | { |
| darienf | 3:36de8b9e4b1a | 197 | } |
| darienf | 3:36de8b9e4b1a | 198 | return val; |
| darienf | 3:36de8b9e4b1a | 199 | } |
| darienf | 3:36de8b9e4b1a | 200 | |
| darienf | 3:36de8b9e4b1a | 201 | |
| darienf | 3:36de8b9e4b1a | 202 | internal byte[] StringToMultiBytes(string reply, byte numBytes) |
| darienf | 3:36de8b9e4b1a | 203 | { |
| darienf | 3:36de8b9e4b1a | 204 | byte[] data = new Byte[numBytes]; |
| darienf | 3:36de8b9e4b1a | 205 | string[] strings = reply.Split(new char[] { ' ' }); |
| darienf | 3:36de8b9e4b1a | 206 | for (int i = 0; i < numBytes; i++) |
| darienf | 3:36de8b9e4b1a | 207 | { |
| darienf | 3:36de8b9e4b1a | 208 | data[i] = StringToByte(strings[i]); |
| darienf | 3:36de8b9e4b1a | 209 | } |
| darienf | 3:36de8b9e4b1a | 210 | return data; |
| darienf | 3:36de8b9e4b1a | 211 | } |
| darienf | 3:36de8b9e4b1a | 212 | |
| darienf | 3:36de8b9e4b1a | 213 | public abstract string ReadString(); |
| darienf | 3:36de8b9e4b1a | 214 | public abstract int Read(char[] buffer, int offset, int count); |
| darienf | 3:36de8b9e4b1a | 215 | } |
| darienf | 3:36de8b9e4b1a | 216 | } |