Rev 878 | Rev 882 | Go to most recent revision | Only display areas with differences | Regard whitespace | Details | Blame | Last modification | View Log | SVN | RSS feed
| Rev 878 | Rev 879 | ||
|---|---|---|---|
| 1 | using System; |
1 | using System; |
| 2 | using System.Collections.Generic; |
2 | using System.Collections.Generic; |
| 3 | using System.Text; |
3 | using System.Text; |
| 4 | using System.Threading; |
4 | using System.Threading; |
| 5 | 5 | ||
| 6 | //this class should probably be integrated into canNMT instead |
6 | //this class should probably be integrated into canNMT instead |
| 7 | 7 | ||
| 8 | public class Downloader { |
8 | public class Downloader { |
| 9 | private HexFile hf; |
9 | private HexFile hf; |
| 10 | private DaemonConnection dc; |
10 | private DaemonConnection dc; |
| 11 | private bool isBiosUpdate; |
11 | private bool isBiosUpdate; |
| 12 | private ulong dlOffset = 0; |
12 | private ulong dlOffset = 0; |
| 13 | //private Thread down; |
13 | //private Thread down; |
| 14 | private byte receiveID; |
14 | private byte receiveID; |
| 15 | private uint hwid; |
15 | private uint hwid; |
| 16 | private bool HWID_INUSE; |
16 | private bool HWID_INUSE; |
| 17 | 17 | ||
| 18 | private enum dState { SEND_START, WAIT_ACK_PRG, SEND_PGM_DATA, WAIT_ACK_DATA, RESEND_ADDR, WAIT_DONE, SEND_DONE, SEND_BIOS_UPDATE, SEND_RESET, DONE, DEBUG_STATE2, WAIT_BOOT, SEND_EMPTY_START, WAIT_ACK_PRG_EMPTY, SEND_EMPTY_DATA, WAIT_ACK_EMPTY_DATA, SEND_DONE_EMPTY, WAIT_DONE_EMPTY}; |
18 | private enum dState { SEND_START, WAIT_ACK_PRG, SEND_PGM_DATA, WAIT_ACK_DATA, RESEND_ADDR, WAIT_DONE, SEND_DONE, SEND_BIOS_UPDATE, SEND_RESET, DONE, DEBUG_STATE2, WAIT_BOOT, SEND_EMPTY_START, WAIT_ACK_PRG_EMPTY, SEND_EMPTY_DATA, WAIT_ACK_EMPTY_DATA, SEND_DONE_EMPTY, WAIT_DONE_EMPTY}; |
| 19 | 19 | ||
| 20 | private const byte CAN_NMT = 0x00; |
20 | private const byte CAN_NMT = 0x00; |
| 21 | 21 | ||
| 22 | private const byte CAN_NMT_RESET = 0x04; |
22 | private const byte CAN_NMT_RESET = 0x04; |
| 23 | private const byte CAN_NMT_BIOS_START = 0x08; |
23 | private const byte CAN_NMT_BIOS_START = 0x08; |
| 24 | private const byte CAN_NMT_PGM_START = 0x0C; |
24 | private const byte CAN_NMT_PGM_START = 0x0C; |
| 25 | private const byte CAN_NMT_PGM_DATA = 0x10; |
25 | private const byte CAN_NMT_PGM_DATA = 0x10; |
| 26 | private const byte CAN_NMT_PGM_END = 0x14; |
26 | private const byte CAN_NMT_PGM_END = 0x14; |
| 27 | private const byte CAN_NMT_PGM_COPY = 0x18; |
27 | private const byte CAN_NMT_PGM_COPY = 0x18; |
| 28 | private const byte CAN_NMT_PGM_ACK = 0x1C; |
28 | private const byte CAN_NMT_PGM_ACK = 0x1C; |
| 29 | private const byte CAN_NMT_PGM_NACK = 0x20; |
29 | private const byte CAN_NMT_PGM_NACK = 0x20; |
| 30 | private const byte CAN_NMT_START_APP = 0x24; |
30 | private const byte CAN_NMT_START_APP = 0x24; |
| 31 | private const byte CAN_NMT_APP_START = 0x28; |
31 | private const byte CAN_NMT_APP_START = 0x28; |
| 32 | private const byte CAN_NMT_HEARTBEAT = 0x2C; |
32 | private const byte CAN_NMT_HEARTBEAT = 0x2C; |
| 33 | 33 | ||
| 34 | private const byte MY_ID = 0x00; |
34 | private const byte MY_ID = 0x00; |
| 35 | //private const byte TARGET_ID = 0x78; |
35 | //private const byte TARGET_ID = 0x78; |
| 36 | private const byte MY_NID = 0x0; |
36 | private const byte MY_NID = 0x0; |
| 37 | private const byte ADDR0_INDEX = 0; |
37 | private const byte ADDR0_INDEX = 0; |
| 38 | private const byte ADDR1_INDEX = 1; |
38 | private const byte ADDR1_INDEX = 1; |
| 39 | private const byte ADDR2_INDEX = 2; |
39 | private const byte ADDR2_INDEX = 2; |
| 40 | private const byte ADDR3_INDEX = 3; |
40 | private const byte ADDR3_INDEX = 3; |
| 41 | 41 | ||
| 42 | private const byte HWID0_INDEX = 4; |
42 | private const byte HWID0_INDEX = 4; |
| 43 | private const byte HWID1_INDEX = 5; |
43 | private const byte HWID1_INDEX = 5; |
| 44 | private const byte HWID2_INDEX = 6; |
44 | private const byte HWID2_INDEX = 6; |
| 45 | private const byte HWID3_INDEX = 7; |
45 | private const byte HWID3_INDEX = 7; |
| 46 | 46 | ||
| 47 | private const int TIMEOUT_MS = 1000; |
47 | private const int TIMEOUT_MS = 1000; |
| 48 | private const int TIMEOUT_SHORT_MS = 200; |
48 | private const int TIMEOUT_SHORT_MS = 200; |
| 49 | 49 | ||
| 50 | private long timeStart = 0; |
50 | private long timeStart = 0; |
| 51 | 51 | ||
| 52 | public Downloader(HexFile hf, DaemonConnection dc, byte receiveID, bool isBiosUpdate, bool HWID_INUSE, uint hwid) { |
52 | public Downloader(HexFile hf, DaemonConnection dc, byte receiveID, bool isBiosUpdate, bool HWID_INUSE, uint hwid) { |
| 53 | this.hf = hf; |
53 | this.hf = hf; |
| 54 | this.dc = dc; |
54 | this.dc = dc; |
| 55 | this.receiveID = receiveID; |
55 | this.receiveID = receiveID; |
| 56 | this.isBiosUpdate = isBiosUpdate; |
56 | this.isBiosUpdate = isBiosUpdate; |
| 57 | this.hwid = hwid; |
57 | this.hwid = hwid; |
| 58 | this.HWID_INUSE = HWID_INUSE; |
58 | this.HWID_INUSE = HWID_INUSE; |
| 59 | } |
59 | } |
| 60 | 60 | ||
| 61 | public int calcCRC(HexFile hf) { |
61 | public int calcCRC(HexFile hf) { |
| 62 | int crc=0; |
62 | int crc=0; |
| 63 | for (ulong i=hf.getAddrLower(); i <= hf.getAddrUpper(); i++) { |
63 | for (ulong i=hf.getAddrLower(); i <= hf.getAddrUpper(); i++) { |
| 64 | crc = crc16_update(crc, hf.getByte(i)); |
64 | crc = crc16_update(crc, hf.getByte(i)); |
| 65 | } |
65 | } |
| 66 | return crc; |
66 | return crc; |
| 67 | } |
67 | } |
| 68 | 68 | ||
| 69 | public int crc16_update(int crc, byte a) { |
69 | public int crc16_update(int crc, byte a) { |
| 70 | int i; |
70 | int i; |
| 71 | crc ^= a; |
71 | crc ^= a; |
| 72 | for (i = 0; i < 8; ++i) { |
72 | for (i = 0; i < 8; ++i) { |
| 73 | if ((crc & 1) != 0) |
73 | if ((crc & 1) != 0) |
| 74 | crc = (crc >> 1) ^ 0xA001; |
74 | crc = (crc >> 1) ^ 0xA001; |
| 75 | else |
75 | else |
| 76 | crc = (crc >> 1); |
76 | crc = (crc >> 1); |
| 77 | } |
77 | } |
| 78 | return crc; |
78 | return crc; |
| 79 | } |
79 | } |
| 80 | 80 | ||
| 81 | public bool go() { |
81 | public bool go() { |
| 82 | if (dc==null || hf==null || hf.getLength()==0) return false; |
82 | if (dc==null || hf==null || hf.getLength()==0) return false; |
| 83 | return downloader(); |
83 | return downloader(); |
| 84 | } |
84 | } |
| 85 | 85 | ||
| 86 | public void abort() { |
86 | public void abort() { |
| 87 | //if (down != null && down.IsAlive) down.Abort(); |
87 | //if (down != null && down.IsAlive) down.Abort(); |
| 88 | } |
88 | } |
| 89 | 89 | ||
| 90 | public bool downloader() { |
90 | public bool downloader() { |
| 91 | dState pgs = dState.SEND_START; |
91 | dState pgs = dState.SEND_START; |
| 92 | int t = 0; |
92 | int t = 0; |
| 93 | int t2 = 0; |
93 | int t2 = 0; |
| 94 | CanPacket outCm = null; |
94 | CanPacket outCm = null; |
| 95 | CanPacket cm = null; |
95 | CanPacket cm = null; |
| 96 | byte[] data = new byte[8]; |
96 | byte[] data = new byte[8]; |
| 97 | uint byteSent = 0; |
97 | uint byteSent = 0; |
| 98 | ulong currentAddress = 0; |
98 | ulong currentAddress = 0; |
| 99 | bool done = false; |
99 | bool done = false; |
| 100 | bool errorOccured = false; |
100 | bool errorOccured = false; |
| 101 | 101 | ||
| 102 | //int rotstate=0; |
102 | //int rotstate=0; |
| 103 | //int dldisplaystate=0; |
103 | //int dldisplaystate=0; |
| 104 | double lastpercent=0; |
104 | double lastpercent=0; |
| 105 | double lasttenpercent=0; |
105 | double lasttenpercent=0; |
| 106 | int nrOfTicks=0; |
106 | int nrOfTicks=0; |
| 107 | 107 | ||
| 108 | try { |
108 | try { |
| 109 | if (isBiosUpdate) { |
109 | if (isBiosUpdate) { |
| 110 | dlOffset = hf.getAddrLower(); |
110 | dlOffset = hf.getAddrLower(); |
| 111 | //Console.WriteLine(dlOffset); |
111 | //Console.WriteLine(dlOffset); |
| 112 | //dlOffset = 200; |
112 | //dlOffset = 200; |
| 113 | } |
113 | } |
| 114 | 114 | ||
| 115 | CanNMT cpn = new CanNMT(HWID_INUSE); |
115 | CanNMT cpn = new CanNMT(HWID_INUSE); |
| 116 | cpn.setReceiver(receiveID); |
116 | cpn.setReceiver(receiveID); |
| 117 | bool hasMessage = false; |
117 | bool hasMessage = false; |
| 118 | 118 | ||
| 119 | while (!done) { |
119 | while (!done) { |
| 120 | Thread.Sleep(1); |
120 | Thread.Sleep(1); |
| 121 | 121 | ||
| 122 | switch (pgs) { |
122 | switch (pgs) { |
| 123 | case dState.SEND_START: |
123 | case dState.SEND_START: |
| 124 | // Send boot start packet to target. |
124 | // Send boot start packet to target. |
| 125 | // and wait for ack. |
125 | // and wait for ack. |
| 126 | currentAddress = hf.getAddrLower(); |
126 | currentAddress = hf.getAddrLower(); |
| 127 | //data[RID_INDEX] = TARGET_ID; |
127 | //data[RID_INDEX] = TARGET_ID; |
| 128 | data[ADDR0_INDEX] = (byte)((currentAddress-dlOffset) & 0x0000FF); |
128 | data[ADDR0_INDEX] = (byte)((currentAddress-dlOffset) & 0x0000FF); |
| 129 | data[ADDR1_INDEX] = (byte)(((currentAddress-dlOffset) & 0x00FF00) >> 8); |
129 | data[ADDR1_INDEX] = (byte)(((currentAddress-dlOffset) & 0x00FF00) >> 8); |
| 130 | data[ADDR2_INDEX] = (byte)(((currentAddress-dlOffset) & 0xFF0000) >> 16); |
130 | data[ADDR2_INDEX] = (byte)(((currentAddress-dlOffset) & 0xFF0000) >> 16); |
| 131 | data[ADDR3_INDEX] = 0; |
131 | data[ADDR3_INDEX] = 0; |
| 132 | if (HWID_INUSE) { |
132 | if (HWID_INUSE) { |
| 133 | data[HWID0_INDEX] = (byte)((hwid) & 0xFF); |
133 | data[HWID0_INDEX] = (byte)((hwid) & 0xFF); |
| 134 | data[HWID1_INDEX] = (byte)((hwid>>8) & 0xFF); |
134 | data[HWID1_INDEX] = (byte)((hwid>>8) & 0xFF); |
| 135 | data[HWID2_INDEX] = (byte)((hwid>>16) & 0xFF); |
135 | data[HWID2_INDEX] = (byte)((hwid>>16) & 0xFF); |
| 136 | data[HWID3_INDEX] = (byte)((hwid>>24) & 0xFF); |
136 | data[HWID3_INDEX] = (byte)((hwid>>24) & 0xFF); |
| 137 | } |
137 | } |
| 138 | //outCm = new CanPacket(CAN_NMT, CAN_NMT_PGM_START, MY_ID, receiveID, 4, data); |
138 | //outCm = new CanPacket(CAN_NMT, CAN_NMT_PGM_START, MY_ID, receiveID, 4, data); |
| 139 | outCm = cpn.getPgmStartPacket(data); |
139 | outCm = cpn.getPgmStartPacket(data); |
| 140 | dc.sendCanPacket(outCm); |
140 | dc.sendCanPacket(outCm); |
| 141 | t = Environment.TickCount; |
141 | t = Environment.TickCount; |
| 142 | t2 = Environment.TickCount; |
142 | t2 = Environment.TickCount; |
| 143 | pgs = dState.WAIT_ACK_PRG; |
143 | pgs = dState.WAIT_ACK_PRG; |
| 144 | timeStart = Environment.TickCount; |
144 | timeStart = Environment.TickCount; |
| 145 | Console.WriteLine("Downloading..."); |
145 | Console.WriteLine("Downloading..."); |
| 146 | Console.Write(" 0% [ ]\r"); |
146 | Console.Write(" 0% [ ]\r"); |
| 147 | Console.Write(" 0% ["); |
147 | Console.Write(" 0% ["); |
| 148 | break; |
148 | break; |
| 149 | 149 | ||
| 150 | 150 | ||
| 151 | case dState.WAIT_ACK_PRG: |
151 | case dState.WAIT_ACK_PRG: |
| 152 | // Check for timeout, resend start packet in that case.. |
152 | // Check for timeout, resend start packet in that case.. |
| 153 | if ((Environment.TickCount - t) > TIMEOUT_MS) { |
153 | if ((Environment.TickCount - t) > TIMEOUT_MS) { |
| 154 | Console.WriteLine("Timeout while waiting for start prg ack."); |
154 | Console.WriteLine("Timeout while waiting for start prg ack."); |
| 155 | errorOccured = true; |
155 | errorOccured = true; |
| 156 | pgs = dState.SEND_RESET; |
156 | pgs = dState.SEND_RESET; |
| 157 | } |
157 | } |
| 158 | //Thread.Sleep(1); |
158 | //Thread.Sleep(1); |
| 159 | // If received ack. |
159 | // If received ack. |
| 160 | hasMessage = dc.getData(out cm); |
160 | hasMessage = dc.getData(out cm); |
| 161 | if (hasMessage) { |
161 | if (hasMessage) { |
| 162 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
162 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
| 163 | if (cpnin.isNMTPacket()) { |
163 | if (cpnin.isNMTPacket()) { |
| 164 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
164 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
| 165 | // If no error |
165 | // If no error |
| 166 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
166 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
| 167 | // Start sending program data.. |
167 | // Start sending program data.. |
| 168 | byteSent = 0; |
168 | byteSent = 0; |
| 169 | pgs = dState.SEND_PGM_DATA; |
169 | pgs = dState.SEND_PGM_DATA; |
| 170 | } |
170 | } |
| 171 | else if (cpnin.getType() == CAN_NMT_PGM_NACK ) { |
171 | else if (cpnin.getType() == CAN_NMT_PGM_NACK ) { |
| 172 | // else .. |
172 | // else .. |
| 173 | Console.WriteLine("Nack on CAN_NMT_PGM_START."); |
173 | Console.WriteLine("Nack on CAN_NMT_PGM_START."); |
| 174 | errorOccured = true; |
174 | errorOccured = true; |
| 175 | pgs = dState.SEND_RESET; |
175 | pgs = dState.SEND_RESET; |
| 176 | } |
176 | } |
| 177 | } |
177 | } |
| 178 | } |
178 | } |
| 179 | break; |
179 | break; |
| 180 | 180 | ||
| 181 | case dState.SEND_PGM_DATA: |
181 | case dState.SEND_PGM_DATA: |
| 182 | 182 | ||
| 183 | double percent = (double)byteSent*100/((double)hf.getAddrUpper()-(double)currentAddress); |
183 | double percent = (double)byteSent*100/((double)hf.getAddrUpper()-(double)currentAddress); |
| 184 | //Console.Write(" 0% [ ]"); |
184 | //Console.Write(" 0% [ ]"); |
| 185 | 185 | ||
| 186 | if (percent >= lastpercent+2.5) { |
186 | if (percent >= lastpercent+2.5) { |
| 187 | //Console.WriteLine(percent); |
187 | //Console.WriteLine(percent); |
| 188 | Console.Write("="); |
188 | Console.Write("="); |
| 189 | nrOfTicks++; |
189 | nrOfTicks++; |
| 190 | lastpercent = lastpercent+2.5; |
190 | lastpercent = lastpercent+2.5; |
| 191 | } |
191 | } |
| 192 | if (percent > lasttenpercent+10) { |
192 | if (percent > lasttenpercent+10) { |
| - | 193 | for (int i=nrOfTicks; i<40; i++) { |
|
| - | 194 | Console.Write(" "); |
|
| - | 195 | } |
|
| - | 196 | Console.Write("]"); |
|
| 193 | Console.Write("\r"); |
197 | Console.Write("\r"); |
| 194 | Console.Write(" "+Math.Round(percent,0)+"% ["); |
198 | Console.Write(" "+Math.Round(percent,0)+"% ["); |
| 195 | 199 | ||
| 196 | lasttenpercent = percent; |
200 | lasttenpercent = percent; |
| 197 | for (int i=0; i<nrOfTicks; i++) { |
201 | for (int i=0; i<nrOfTicks; i++) { |
| 198 | Console.Write("="); |
202 | Console.Write("="); |
| 199 | } |
203 | } |
| 200 | } |
204 | } |
| 201 | 205 | ||
| 202 | 206 | ||
| 203 | // Send program data. |
207 | // Send program data. |
| 204 | byte datalength = 2; |
208 | byte datalength = 2; |
| 205 | for (ulong i = 0; i < 6; i++) { |
209 | for (ulong i = 0; i < 6; i++) { |
| 206 | // Populate data. |
210 | // Populate data. |
| 207 | data[i+2] = hf.getByte(currentAddress + i + byteSent); |
211 | data[i+2] = hf.getByte(currentAddress + i + byteSent); |
| 208 | if (currentAddress + i + byteSent > hf.getAddrUpper()) { |
212 | if (currentAddress + i + byteSent > hf.getAddrUpper()) { |
| 209 | break; //then done |
213 | break; //then done |
| 210 | } |
214 | } |
| 211 | datalength++; |
215 | datalength++; |
| 212 | } |
216 | } |
| 213 | data[0] = (byte)(byteSent & 0x00FF); |
217 | data[0] = (byte)(byteSent & 0x00FF); |
| 214 | data[1] = (byte)((byteSent & 0xFF00) >> 8); |
218 | data[1] = (byte)((byteSent & 0xFF00) >> 8); |
| 215 | 219 | ||
| 216 | outCm = cpn.getPgmDataPacket(data, datalength); |
220 | outCm = cpn.getPgmDataPacket(data, datalength); |
| 217 | dc.sendCanPacket(outCm); |
221 | dc.sendCanPacket(outCm); |
| 218 | 222 | ||
| 219 | t = Environment.TickCount; |
223 | t = Environment.TickCount; |
| 220 | t2 = Environment.TickCount; |
224 | t2 = Environment.TickCount; |
| 221 | byteSent += 6; |
225 | byteSent += 6; |
| 222 | pgs = dState.WAIT_ACK_DATA; |
226 | pgs = dState.WAIT_ACK_DATA; |
| 223 | break; |
227 | break; |
| 224 | 228 | ||
| 225 | 229 | ||
| 226 | case dState.WAIT_ACK_DATA: |
230 | case dState.WAIT_ACK_DATA: |
| 227 | // Wait for pgm ack. |
231 | // Wait for pgm ack. |
| 228 | if ((Environment.TickCount - t) > TIMEOUT_MS) { |
232 | if ((Environment.TickCount - t) > TIMEOUT_MS) { |
| 229 | // Woops, error. |
233 | // Woops, error. |
| 230 | Console.WriteLine("Timeout while waiting for data ack."); |
234 | Console.WriteLine("Timeout while waiting for data ack."); |
| 231 | errorOccured = true; |
235 | errorOccured = true; |
| 232 | pgs = dState.SEND_RESET; |
236 | pgs = dState.SEND_RESET; |
| 233 | } |
237 | } |
| 234 | else if ((Environment.TickCount - t2) > TIMEOUT_SHORT_MS) { |
238 | else if ((Environment.TickCount - t2) > TIMEOUT_SHORT_MS) { |
| 235 | // Woops, error. |
239 | // Woops, error. |
| 236 | //disable Console.Write(":"); |
240 | //disable Console.Write(":"); |
| 237 | byteSent -= 6; |
241 | byteSent -= 6; |
| 238 | pgs = dState.SEND_PGM_DATA; |
242 | pgs = dState.SEND_PGM_DATA; |
| 239 | break; |
243 | break; |
| 240 | } |
244 | } |
| 241 | //Thread.Sleep(1); |
245 | //Thread.Sleep(1); |
| 242 | // If received ack. |
246 | // If received ack. |
| 243 | hasMessage = dc.getData(out cm); |
247 | hasMessage = dc.getData(out cm); |
| 244 | if (hasMessage) { |
248 | if (hasMessage) { |
| 245 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
249 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
| 246 | if (cpnin.isNMTPacket()) { |
250 | if (cpnin.isNMTPacket()) { |
| 247 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
251 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
| 248 | // If no error |
252 | // If no error |
| 249 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
253 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
| 250 | //currentAddress += 2; |
254 | //currentAddress += 2; |
| 251 | // Check if end. |
255 | // Check if end. |
| 252 | if (currentAddress + byteSent > hf.getAddrUpper()) { |
256 | if (currentAddress + byteSent > hf.getAddrUpper()) { |
| 253 | // Yes, we are done, send done. |
257 | // Yes, we are done, send done. |
| 254 | pgs = dState.SEND_DONE; |
258 | pgs = dState.SEND_DONE; |
| 255 | } |
259 | } |
| 256 | else { |
260 | else { |
| 257 | // More to write. |
261 | // More to write. |
| 258 | //byteSent = 0; |
262 | //byteSent = 0; |
| 259 | pgs = dState.SEND_PGM_DATA; |
263 | pgs = dState.SEND_PGM_DATA; |
| 260 | } |
264 | } |
| 261 | } |
265 | } |
| 262 | else if (cpnin.getType() == CAN_NMT_PGM_NACK ) { |
266 | else if (cpnin.getType() == CAN_NMT_PGM_NACK ) { |
| 263 | // else .. |
267 | // else .. |
| 264 | Console.WriteLine("Nack on CAN_NMT_PGM_DATA."); |
268 | Console.WriteLine("Nack on CAN_NMT_PGM_DATA."); |
| 265 | errorOccured = true; |
269 | errorOccured = true; |
| 266 | pgs = dState.SEND_RESET; |
270 | pgs = dState.SEND_RESET; |
| 267 | } |
271 | } |
| 268 | } |
272 | } |
| 269 | } |
273 | } |
| 270 | break; |
274 | break; |
| 271 | 275 | ||
| 272 | case dState.SEND_DONE: |
276 | case dState.SEND_DONE: |
| - | 277 | for (int i=nrOfTicks; i<40; i++) { |
|
| - | 278 | Console.Write(" "); |
|
| - | 279 | } |
|
| - | 280 | Console.Write("]"); |
|
| 273 | Console.Write("\r"); |
281 | Console.Write("\r"); |
| 274 | Console.Write("100% [========================================] "); |
282 | Console.Write("100% [========================================]"); |
| 275 | // Send done |
283 | // Send done |
| 276 | outCm = cpn.getPgmEndPacket(); |
284 | outCm = cpn.getPgmEndPacket(); |
| 277 | dc.sendCanPacket(outCm); |
285 | dc.sendCanPacket(outCm); |
| 278 | 286 | ||
| 279 | t = Environment.TickCount; |
287 | t = Environment.TickCount; |
| 280 | t2 = Environment.TickCount; |
288 | t2 = Environment.TickCount; |
| 281 | pgs = dState.WAIT_DONE; |
289 | pgs = dState.WAIT_DONE; |
| 282 | break; |
290 | break; |
| 283 | 291 | ||
| 284 | 292 | ||
| 285 | case dState.WAIT_DONE: |
293 | case dState.WAIT_DONE: |
| 286 | // Check for timeout, resend done packet in that case.. |
294 | // Check for timeout, resend done packet in that case.. |
| 287 | if ((Environment.TickCount - t) > TIMEOUT_MS) { |
295 | if ((Environment.TickCount - t) > TIMEOUT_MS) { |
| 288 | Console.WriteLine("Timeout while waiting for end prg ack."); |
296 | Console.WriteLine("Timeout while waiting for end prg ack."); |
| 289 | errorOccured = true; |
297 | errorOccured = true; |
| 290 | pgs = dState.SEND_RESET; |
298 | pgs = dState.SEND_RESET; |
| 291 | } |
299 | } |
| 292 | //Thread.Sleep(1); |
300 | //Thread.Sleep(1); |
| 293 | 301 | ||
| 294 | hasMessage = dc.getData(out cm); |
302 | hasMessage = dc.getData(out cm); |
| 295 | if (hasMessage) { |
303 | if (hasMessage) { |
| 296 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
304 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
| 297 | if (cpnin.isNMTPacket()) { |
305 | if (cpnin.isNMTPacket()) { |
| 298 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
306 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
| 299 | // If no error |
307 | // If no error |
| 300 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
308 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
| 301 | Console.WriteLine(""); |
309 | Console.WriteLine(""); |
| 302 | // |
310 | // |
| 303 | int crc = calcCRC(hf); |
311 | int crc = calcCRC(hf); |
| 304 | 312 | ||
| 305 | if (cm.getDataLength() == 2) { |
313 | if (cm.getDataLength() == 2) { |
| 306 | byte[] cmdata = cm.getData(); |
314 | byte[] cmdata = cm.getData(); |
| 307 | if ((cmdata[0] == (crc & 0xFF)) && (cmdata[1] == (crc>>8))) { |
315 | if ((cmdata[0] == (crc & 0xFF)) && (cmdata[1] == (crc>>8))) { |
| 308 | if (!isBiosUpdate) { |
316 | if (!isBiosUpdate) { |
| 309 | Console.WriteLine("Done, successfully programmed application."); |
317 | Console.WriteLine("Done, successfully programmed application."); |
| 310 | pgs = dState.SEND_RESET; |
318 | pgs = dState.SEND_RESET; |
| 311 | } else { |
319 | } else { |
| 312 | Console.WriteLine("Done, successfully programmed bios to application space."); |
320 | Console.WriteLine("Done, successfully programmed bios to application space."); |
| 313 | pgs = dState.SEND_BIOS_UPDATE; |
321 | pgs = dState.SEND_BIOS_UPDATE; |
| 314 | } |
322 | } |
| 315 | } else { |
323 | } else { |
| 316 | string nodecrc = String.Format("{0:x4}", (int)cmdata[0] + (int)(cmdata[1]<<8)); |
324 | string nodecrc = String.Format("{0:x4}", (int)cmdata[0] + (int)(cmdata[1]<<8)); |
| 317 | nodecrc = "0x"+nodecrc; |
325 | nodecrc = "0x"+nodecrc; |
| 318 | string realcrc = String.Format("{0:x4}", (int)(crc & 0xFF) + (int)(crc & 0xFF00)); |
326 | string realcrc = String.Format("{0:x4}", (int)(crc & 0xFF) + (int)(crc & 0xFF00)); |
| 319 | realcrc = "0x"+realcrc; |
327 | realcrc = "0x"+realcrc; |
| 320 | Console.WriteLine("CRC failed. Node sent CRC "+nodecrc+" but should be "+realcrc+"."); |
328 | Console.WriteLine("CRC failed. Node sent CRC "+nodecrc+" but should be "+realcrc+"."); |
| 321 | errorOccured = true; |
329 | errorOccured = true; |
| 322 | pgs = dState.SEND_RESET; |
330 | pgs = dState.SEND_RESET; |
| 323 | } |
331 | } |
| 324 | 332 | ||
| 325 | byteSent = 0; |
333 | byteSent = 0; |
| 326 | } |
334 | } |
| 327 | //Console.WriteLine("crc: " + crc + " " + (crc>>8) + " " + (crc & 0xFF)); |
335 | //Console.WriteLine("crc: " + crc + " " + (crc>>8) + " " + (crc & 0xFF)); |
| 328 | //Console.WriteLine("ACKpkg with CRC: " + cm.ToString()); |
336 | //Console.WriteLine("ACKpkg with CRC: " + cm.ToString()); |
| 329 | // |
337 | // |
| 330 | } |
338 | } |
| 331 | else if (cpnin.getType() == CAN_NMT_PGM_NACK) { |
339 | else if (cpnin.getType() == CAN_NMT_PGM_NACK) { |
| 332 | // else resend addr.. |
340 | // else resend addr.. |
| 333 | Console.WriteLine("Nack on CAN_NMT_PGM_END."); |
341 | Console.WriteLine("Nack on CAN_NMT_PGM_END."); |
| 334 | errorOccured = true; |
342 | errorOccured = true; |
| 335 | pgs = dState.SEND_RESET; |
343 | pgs = dState.SEND_RESET; |
| 336 | } |
344 | } |
| 337 | } |
345 | } |
| 338 | } |
346 | } |
| 339 | break; |
347 | break; |
| 340 | 348 | ||
| 341 | case dState.SEND_BIOS_UPDATE: |
349 | case dState.SEND_BIOS_UPDATE: |
| 342 | data[0] = (byte)(0 & 0x00FF); |
350 | data[0] = (byte)(0 & 0x00FF); |
| 343 | data[1] = (byte)((0 & 0xFF00) >> 8); |
351 | data[1] = (byte)((0 & 0xFF00) >> 8); |
| 344 | data[2] = (byte)(dlOffset & 0x00FF); |
352 | data[2] = (byte)(dlOffset & 0x00FF); |
| 345 | data[3] = (byte)((dlOffset & 0xFF00) >> 8); |
353 | data[3] = (byte)((dlOffset & 0xFF00) >> 8); |
| 346 | data[4] = (byte)((hf.getAddrUpper()-hf.getAddrLower()+1) & 0x00FF); |
354 | data[4] = (byte)((hf.getAddrUpper()-hf.getAddrLower()+1) & 0x00FF); |
| 347 | data[5] = (byte)(((hf.getAddrUpper()-hf.getAddrLower()+1) & 0xFF00) >> 8); |
355 | data[5] = (byte)(((hf.getAddrUpper()-hf.getAddrLower()+1) & 0xFF00) >> 8); |
| 348 | 356 | ||
| 349 | outCm = cpn.getPgmCopyPacket(data); |
357 | outCm = cpn.getPgmCopyPacket(data); |
| 350 | Console.WriteLine("Now say a prayer, moving bios"); |
358 | Console.WriteLine("Now say a prayer, moving bios"); |
| 351 | dc.sendCanPacket(outCm); |
359 | dc.sendCanPacket(outCm); |
| 352 | t = Environment.TickCount; |
360 | t = Environment.TickCount; |
| 353 | t2 = Environment.TickCount; |
361 | t2 = Environment.TickCount; |
| 354 | pgs = dState.WAIT_BOOT; |
362 | pgs = dState.WAIT_BOOT; |
| 355 | //pgs = dState.DONE; |
363 | //pgs = dState.DONE; |
| 356 | break; |
364 | break; |
| 357 | 365 | ||
| 358 | case dState.WAIT_BOOT: |
366 | case dState.WAIT_BOOT: |
| 359 | // Wait for node reset answer (boot msg). |
367 | // Wait for node reset answer (boot msg). |
| 360 | if ((Environment.TickCount - t) > 3*TIMEOUT_MS) { |
368 | if ((Environment.TickCount - t) > 3*TIMEOUT_MS) { |
| 361 | // Woops, error. |
369 | // Woops, error. |
| 362 | Console.WriteLine("Timeout while waiting for node to boot."); |
370 | Console.WriteLine("Timeout while waiting for node to boot."); |
| 363 | errorOccured = true; |
371 | errorOccured = true; |
| 364 | pgs = dState.SEND_DONE; |
372 | pgs = dState.SEND_DONE; |
| 365 | } |
373 | } |
| 366 | //Thread.Sleep(1); |
374 | //Thread.Sleep(1); |
| 367 | // If received boot msg. |
375 | // If received boot msg. |
| 368 | hasMessage = dc.getData(out cm); |
376 | hasMessage = dc.getData(out cm); |
| 369 | if (hasMessage) { |
377 | if (hasMessage) { |
| 370 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
378 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
| 371 | if (cpnin.isNMTPacket()) { |
379 | if (cpnin.isNMTPacket()) { |
| 372 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
380 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
| 373 | // If no error |
381 | // If no error |
| 374 | if (cpnin.getType() == CAN_NMT_BIOS_START) { |
382 | if (cpnin.getType() == CAN_NMT_BIOS_START) { |
| 375 | pgs = dState.SEND_EMPTY_START; |
383 | pgs = dState.SEND_EMPTY_START; |
| 376 | } |
384 | } |
| 377 | else { |
385 | else { |
| 378 | // else .. |
386 | // else .. |
| 379 | } |
387 | } |
| 380 | } |
388 | } |
| 381 | } |
389 | } |
| 382 | break; |
390 | break; |
| 383 | 391 | ||
| 384 | case dState.SEND_EMPTY_START: |
392 | case dState.SEND_EMPTY_START: |
| 385 | // Send boot start packet to target. |
393 | // Send boot start packet to target. |
| 386 | // and wait for ack. |
394 | // and wait for ack. |
| 387 | 395 | ||
| 388 | //data[RID_INDEX] = TARGET_ID; |
396 | //data[RID_INDEX] = TARGET_ID; |
| 389 | data[ADDR0_INDEX] = (byte)((0) & 0x0000FF); |
397 | data[ADDR0_INDEX] = (byte)((0) & 0x0000FF); |
| 390 | data[ADDR1_INDEX] = (byte)(((0) & 0x00FF00) >> 8); |
398 | data[ADDR1_INDEX] = (byte)(((0) & 0x00FF00) >> 8); |
| 391 | data[ADDR2_INDEX] = (byte)(((0) & 0xFF0000) >> 16); |
399 | data[ADDR2_INDEX] = (byte)(((0) & 0xFF0000) >> 16); |
| 392 | data[ADDR3_INDEX] = 0; |
400 | data[ADDR3_INDEX] = 0; |
| 393 | if (HWID_INUSE) { |
401 | if (HWID_INUSE) { |
| 394 | data[HWID0_INDEX] = (byte)((hwid) & 0xFF); |
402 | data[HWID0_INDEX] = (byte)((hwid) & 0xFF); |
| 395 | data[HWID1_INDEX] = (byte)((hwid>>8) & 0xFF); |
403 | data[HWID1_INDEX] = (byte)((hwid>>8) & 0xFF); |
| 396 | data[HWID2_INDEX] = (byte)((hwid>>16) & 0xFF); |
404 | data[HWID2_INDEX] = (byte)((hwid>>16) & 0xFF); |
| 397 | data[HWID3_INDEX] = (byte)((hwid>>24) & 0xFF); |
405 | data[HWID3_INDEX] = (byte)((hwid>>24) & 0xFF); |
| 398 | } |
406 | } |
| 399 | //outCm = new CanPacket(CAN_NMT, CAN_NMT_PGM_START, MY_ID, receiveID, 4, data); |
407 | //outCm = new CanPacket(CAN_NMT, CAN_NMT_PGM_START, MY_ID, receiveID, 4, data); |
| 400 | outCm = cpn.getPgmStartPacket(data); |
408 | outCm = cpn.getPgmStartPacket(data); |
| 401 | dc.sendCanPacket(outCm); |
409 | dc.sendCanPacket(outCm); |
| 402 | t = Environment.TickCount; |
410 | t = Environment.TickCount; |
| 403 | t2 = Environment.TickCount; |
411 | t2 = Environment.TickCount; |
| 404 | pgs = dState.WAIT_ACK_PRG_EMPTY; |
412 | pgs = dState.WAIT_ACK_PRG_EMPTY; |
| 405 | break; |
413 | break; |
| 406 | 414 | ||
| 407 | 415 | ||
| 408 | case dState.WAIT_ACK_PRG_EMPTY: |
416 | case dState.WAIT_ACK_PRG_EMPTY: |
| 409 | // Check for timeout, resend start packet in that case.. |
417 | // Check for timeout, resend start packet in that case.. |
| 410 | if ((Environment.TickCount - t) > 3*TIMEOUT_MS) { |
418 | if ((Environment.TickCount - t) > 3*TIMEOUT_MS) { |
| 411 | Console.WriteLine("Timeout while waiting for start prg ack during empty-first-block-cycle."); |
419 | Console.WriteLine("Timeout while waiting for start prg ack during empty-first-block-cycle."); |
| 412 | errorOccured = true; |
420 | errorOccured = true; |
| 413 | pgs = dState.SEND_RESET; |
421 | pgs = dState.SEND_RESET; |
| 414 | } |
422 | } |
| 415 | //Thread.Sleep(1); |
423 | //Thread.Sleep(1); |
| 416 | // If received ack. |
424 | // If received ack. |
| 417 | hasMessage = dc.getData(out cm); |
425 | hasMessage = dc.getData(out cm); |
| 418 | if (hasMessage) { |
426 | if (hasMessage) { |
| 419 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
427 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
| 420 | if (cpnin.isNMTPacket()) { |
428 | if (cpnin.isNMTPacket()) { |
| 421 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
429 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
| 422 | // If no error |
430 | // If no error |
| 423 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
431 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
| 424 | // Start sending program data.. |
432 | // Start sending program data.. |
| 425 | byteSent = 0; |
433 | byteSent = 0; |
| 426 | pgs = dState.SEND_EMPTY_DATA; |
434 | pgs = dState.SEND_EMPTY_DATA; |
| 427 | } |
435 | } |
| 428 | else if (cpnin.getType() == CAN_NMT_PGM_NACK ) { |
436 | else if (cpnin.getType() == CAN_NMT_PGM_NACK ) { |
| 429 | // else .. |
437 | // else .. |
| 430 | Console.WriteLine("Nack on CAN_NMT_PGM_START."); |
438 | Console.WriteLine("Nack on CAN_NMT_PGM_START."); |
| 431 | errorOccured = true; |
439 | errorOccured = true; |
| 432 | pgs = dState.SEND_RESET; |
440 | pgs = dState.SEND_RESET; |
| 433 | } |
441 | } |
| 434 | } |
442 | } |
| 435 | } |
443 | } |
| 436 | break; |
444 | break; |
| 437 | 445 | ||
| 438 | case dState.SEND_EMPTY_DATA: |
446 | case dState.SEND_EMPTY_DATA: |
| 439 | // Send program data. |
447 | // Send program data. |
| 440 | data[0] = 0; |
448 | data[0] = 0; |
| 441 | data[1] = 0; |
449 | data[1] = 0; |
| 442 | data[2] = 0xff; |
450 | data[2] = 0xff; |
| 443 | data[3] = 0xff; |
451 | data[3] = 0xff; |
| 444 | 452 | ||
| 445 | outCm = cpn.getPgmDataPacket(data, 4); |
453 | outCm = cpn.getPgmDataPacket(data, 4); |
| 446 | dc.sendCanPacket(outCm); |
454 | dc.sendCanPacket(outCm); |
| 447 | 455 | ||
| 448 | t = Environment.TickCount; |
456 | t = Environment.TickCount; |
| 449 | t2 = Environment.TickCount; |
457 | t2 = Environment.TickCount; |
| 450 | byteSent += 6; |
458 | byteSent += 6; |
| 451 | pgs = dState.WAIT_ACK_EMPTY_DATA; |
459 | pgs = dState.WAIT_ACK_EMPTY_DATA; |
| 452 | break; |
460 | break; |
| 453 | 461 | ||
| 454 | 462 | ||
| 455 | case dState.WAIT_ACK_EMPTY_DATA: |
463 | case dState.WAIT_ACK_EMPTY_DATA: |
| 456 | // Wait for pgm ack. |
464 | // Wait for pgm ack. |
| 457 | if ((Environment.TickCount - t) > 2*TIMEOUT_MS) { |
465 | if ((Environment.TickCount - t) > 2*TIMEOUT_MS) { |
| 458 | // Woops, error. |
466 | // Woops, error. |
| 459 | Console.WriteLine("Timeout while waiting for data ack."); |
467 | Console.WriteLine("Timeout while waiting for data ack."); |
| 460 | errorOccured = true; |
468 | errorOccured = true; |
| 461 | pgs = dState.SEND_RESET; |
469 | pgs = dState.SEND_RESET; |
| 462 | } |
470 | } |
| 463 | //Thread.Sleep(1); |
471 | //Thread.Sleep(1); |
| 464 | // If received ack. |
472 | // If received ack. |
| 465 | hasMessage = dc.getData(out cm); |
473 | hasMessage = dc.getData(out cm); |
| 466 | if (hasMessage) { |
474 | if (hasMessage) { |
| 467 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
475 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
| 468 | if (cpnin.isNMTPacket()) { |
476 | if (cpnin.isNMTPacket()) { |
| 469 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
477 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
| 470 | // If no error |
478 | // If no error |
| 471 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
479 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
| 472 | pgs = dState.SEND_DONE_EMPTY; |
480 | pgs = dState.SEND_DONE_EMPTY; |
| 473 | } |
481 | } |
| 474 | else if (cpnin.getType() == CAN_NMT_PGM_NACK ) { |
482 | else if (cpnin.getType() == CAN_NMT_PGM_NACK ) { |
| 475 | // else .. |
483 | // else .. |
| 476 | Console.WriteLine("Nack on CAN_NMT_PGM_DATA."); |
484 | Console.WriteLine("Nack on CAN_NMT_PGM_DATA."); |
| 477 | errorOccured = true; |
485 | errorOccured = true; |
| 478 | pgs = dState.SEND_RESET; |
486 | pgs = dState.SEND_RESET; |
| 479 | } |
487 | } |
| 480 | } |
488 | } |
| 481 | } |
489 | } |
| 482 | break; |
490 | break; |
| 483 | 491 | ||
| 484 | case dState.SEND_DONE_EMPTY: |
492 | case dState.SEND_DONE_EMPTY: |
| 485 | // Send done |
493 | // Send done |
| 486 | outCm = cpn.getPgmEndPacket(); |
494 | outCm = cpn.getPgmEndPacket(); |
| 487 | dc.sendCanPacket(outCm); |
495 | dc.sendCanPacket(outCm); |
| 488 | 496 | ||
| 489 | t = Environment.TickCount; |
497 | t = Environment.TickCount; |
| 490 | t2 = Environment.TickCount; |
498 | t2 = Environment.TickCount; |
| 491 | pgs = dState.WAIT_DONE_EMPTY; |
499 | pgs = dState.WAIT_DONE_EMPTY; |
| 492 | break; |
500 | break; |
| 493 | 501 | ||
| 494 | 502 | ||
| 495 | case dState.WAIT_DONE_EMPTY: |
503 | case dState.WAIT_DONE_EMPTY: |
| 496 | // Check for timeout, resend done packet in that case.. |
504 | // Check for timeout, resend done packet in that case.. |
| 497 | if ((Environment.TickCount - t) > TIMEOUT_MS) { |
505 | if ((Environment.TickCount - t) > TIMEOUT_MS) { |
| 498 | Console.WriteLine("Timeout while waiting for end prg ack."); |
506 | Console.WriteLine("Timeout while waiting for end prg ack."); |
| 499 | errorOccured = true; |
507 | errorOccured = true; |
| 500 | pgs = dState.SEND_RESET; |
508 | pgs = dState.SEND_RESET; |
| 501 | } |
509 | } |
| 502 | //Thread.Sleep(1); |
510 | //Thread.Sleep(1); |
| 503 | 511 | ||
| 504 | hasMessage = dc.getData(out cm); |
512 | hasMessage = dc.getData(out cm); |
| 505 | if (hasMessage) { |
513 | if (hasMessage) { |
| 506 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
514 | CanNMT cpnin = new CanNMT(cm, HWID_INUSE); |
| 507 | if (cpnin.isNMTPacket()) { |
515 | if (cpnin.isNMTPacket()) { |
| 508 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
516 | //if (cpnin.isNMTPacket() && (cpnin.getSender() == receiveID)) { |
| 509 | // If no error |
517 | // If no error |
| 510 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
518 | if (cpnin.getType() == CAN_NMT_PGM_ACK) { |
| 511 | Console.WriteLine(""); |
519 | Console.WriteLine(""); |
| 512 | // |
520 | // |
| 513 | Console.WriteLine("Done, successfully cleaned application flash."); |
521 | Console.WriteLine("Done, successfully cleaned application flash."); |
| 514 | pgs = dState.SEND_RESET; |
522 | pgs = dState.SEND_RESET; |
| 515 | } |
523 | } |
| 516 | else if (cpnin.getType() == CAN_NMT_PGM_NACK) { |
524 | else if (cpnin.getType() == CAN_NMT_PGM_NACK) { |
| 517 | // else resend addr.. |
525 | // else resend addr.. |
| 518 | Console.WriteLine("Nack on CAN_NMT_PGM_END."); |
526 | Console.WriteLine("Nack on CAN_NMT_PGM_END."); |
| 519 | errorOccured = true; |
527 | errorOccured = true; |
| 520 | pgs = dState.SEND_RESET; |
528 | pgs = dState.SEND_RESET; |
| 521 | } |
529 | } |
| 522 | } |
530 | } |
| 523 | } |
531 | } |
| 524 | break; |
532 | break; |
| 525 | case dState.SEND_RESET: |
533 | case dState.SEND_RESET: |
| 526 | // Send reset |
534 | // Send reset |
| 527 | cpn.doReset(dc, receiveID, hwid); |
535 | cpn.doReset(dc, receiveID, hwid); |
| 528 | t = Environment.TickCount; |
536 | t = Environment.TickCount; |
| 529 | t2 = Environment.TickCount; |
537 | t2 = Environment.TickCount; |
| 530 | pgs = dState.DONE; |
538 | pgs = dState.DONE; |
| 531 | break; |
539 | break; |
| 532 | 540 | ||
| 533 | 541 | ||
| 534 | case dState.DONE: |
542 | case dState.DONE: |
| 535 | done = true; |
543 | done = true; |
| 536 | //down.Abort(); |
544 | //down.Abort(); |
| 537 | if (!errorOccured) { |
545 | if (!errorOccured) { |
| 538 | long tsecs = ((Environment.TickCount - timeStart) / 1000); |
546 | long tsecs = ((Environment.TickCount - timeStart) / 1000); |
| 539 | double bitRate = hf.getLength() / ((double)(Environment.TickCount - timeStart) / 1000.0); |
547 | double bitRate = hf.getLength() / ((double)(Environment.TickCount - timeStart) / 1000.0); |
| 540 | 548 | ||
| 541 | if (tsecs <= 0) tsecs = 1; |
549 | if (tsecs <= 0) tsecs = 1; |
| 542 | long mins = tsecs / 60; |
550 | long mins = tsecs / 60; |
| 543 | long secs = tsecs % 60; |
551 | long secs = tsecs % 60; |
| 544 | string pad = ""; |
552 | string pad = ""; |
| 545 | if (secs < 10) { |
553 | if (secs < 10) { |
| 546 | pad = "0"; |
554 | pad = "0"; |
| 547 | } |
555 | } |
| 548 | Console.WriteLine("Time spent: " + mins + ":" + pad + secs + ", " + Math.Round(bitRate, 2) + " bytes/s"); |
556 | Console.WriteLine("Time spent: " + mins + ":" + pad + secs + ", " + Math.Round(bitRate, 2) + " bytes/s"); |
| 549 | } |
557 | } |
| 550 | //Console.Write("> "); |
558 | //Console.Write("> "); |
| 551 | break; |
559 | break; |
| 552 | } |
560 | } |
| 553 | } |
561 | } |
| 554 | 562 | ||
| 555 | } catch(Exception) { |
563 | } catch(Exception) { |
| 556 | Console.WriteLine("Exception occured"); |
564 | Console.WriteLine("Exception occured"); |
| 557 | //Console.WriteLine(e); |
565 | //Console.WriteLine(e); |
| 558 | //skriva ut antal bytes skrivna vore bra här, kanske nån annan form av hjälp för debug, något gick snett liksom |
566 | //skriva ut antal bytes skrivna vore bra här, kanske nån annan form av hjälp för debug, något gick snett liksom |
| 559 | 567 | ||
| 560 | } |
568 | } |
| 561 | 569 | ||
| 562 | return !errorOccured; |
570 | return !errorOccured; |
| 563 | } |
571 | } |
| 564 | } |
572 | } |
| 565 | 573 | ||