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