Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/Atom/Services/System/CanNode.js @ 1663 – Rev 1028 → 1034

Rev 1028 | Rev 1037 | Go to most recent revision | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | SVN | RSS feed

 CanNode.prototype.myProgrammingHexAddress = null;
 CanNode.prototype.myProgrammingOffset = null;
 CanNode.prototype.myProgrammingCallback = null;
 CanNode.prototype.myProgrammingWantAck = null;
 CanNode.prototype.myProgrammingState = null;
+CanNode.prototype.myProgrammingLastPercent = null;
+CanNode.prototype.myProgrammingLastTenPercent = null;
+CanNode.prototype.myProgrammingnrOfTicks = null;
+CanNode.prototype.myProgrammingTimeout = null;
+CanNode.prototype.myProgrammingResend = null;
+CanNode.prototype.myProgrammingLastPacket = null;
 CanNode.prototype.isOnline = function()
+{
     return this.myIsOnline;
+}
     this.myProgrammingHex = hexData;
     this.myProgrammingCallback = progressCallback;
     CanProgrammingNode = this;
+    var self = this;
+    this.myProgrammingTimeout = new Interval(function() { self.programmingTimeout() }, 6000);
+    this.myProgrammingTimeout.start();
+    this.myProgrammingState = "RESET";
+    this.reset();
+}
+CanNode.prototype.programmingTimeout = function()
+{
+    switch (this.myProgrammingState)
+    {
+    case "RESET":
+        this.stopProgramming(true, "Timeout while waiting for node to reset");
+        this.reset();
+        break;
+    case "DATA":
+        this.stopProgramming(true, "Timeout while waiting for node to ack data packet");
+        this.reset();
+        break;
+    case "END":
+        this.stopProgramming(true, "Timeout while waiting for node to ack data packet*");
+        this.reset();
+        break;
+    case "CRC":
+        this.stopProgramming(true, "Timeout while waiting for node to send crc");
-    this.reset();
+        this.reset();
+        break;
+    case "COPY":
+        //this will never occur, bios does not send ack for copy command, it just moves data in flash then reset itself
+        break;
+    default:
+        break;
+    }
 }
+CanNode.prototype.programmingResend = function()
+{
+    this.myProgrammingResend.setTimeout(200);
+    //if we did not got ack then try to resend the data
+    this.myProgrammingLastPacket.send();
+}
 CanNode.prototype.handleBiosStart = function(biosVersion, hasApplication)
+{
 //print("node was reset and bios just started, ver:" + biosVersion);
     if (this.myProgramming)
         canMessage.setData("Address1", (this.myProgrammingHexAddress>>8)&0xff);
         canMessage.setData("Address3", (this.myProgrammingHexAddress>>16)&0xff);
         canMessage.setData("Address4", (this.myProgrammingHexAddress>>24)&0xff);
         canMessage.send();
         this.myProgrammingState = "DATA";
+        var self = this;
+        this.myProgrammingTimeout.setTimeout(1000);
+        //this.myProgrammingResend = new Interval(function() { self.programmingResend() }, 1100);
+        //this.myProgrammingResend.start();
-        this.myProgrammingCallback(true, "START", "Started programming of node");
+        this.myProgrammingCallback(true, "START", "Started programming of node", false);
+        this.myProgrammingCallback(true, "", "  0% [", true);
     }
 }
 CanNode.prototype.handleNack = function(data)
 {
     stopProgramming(true, "Failed, got NACK, sending reset");
     this.reset();
     if (false)
     {
     }
+}
 CanNode.prototype.handleAck = function(data)
+{
-//this.myProgrammingCallback(true, "DBG", "data: "+data+", myProgrammingWantAck: "+this.myProgrammingWantAck+"");
+    this.myProgrammingTimeout.setTimeout(1000);
     if (data == this.myProgrammingWantAck)
+    {
         switch (this.myProgrammingState)
+        {
         case "DATA":
             var offset = this.myProgrammingHexOffset;
+            //this.myProgrammingResend.setTimeout(100);
             this.myProgrammingWantAck = ((offset<<8)|(offset>>8))&0xffff;
             //var bytesLeft = this.myProgrammingHex.getAddrUpper() - (this.myProgrammingHexAddress+this.myProgrammingHexOffset);
             var bytesLeft = this.myProgrammingHex.getLength() - this.myProgrammingHexOffset;
             case 4:
                 canMessage = new CanNMTMessage("nmt", "Pgm_Data_32");
                 break;
             case 5:
                 canMessage = new CanNMTMessage("nmt", "Pgm_Data_40");
                 break;
             }
             canMessage.setData("Offset0", offset&0xff);
             canMessage.setData("Offset1", (offset>>8)&0xff);
             for (var i=0; i<bytesLeft && i<6; i++)
+            {
                 case 3:
                     canMessage.setData("Data3", this.myProgrammingHex.getByte(offset));
                     break;
                 case 4:
                     canMessage.setData("Data4", this.myProgrammingHex.getByte(offset));
                     break;
                 case 5:
                     canMessage.setData("Data5", this.myProgrammingHex.getByte(offset));
                     break;
+                }
                 offset++;
             }
             canMessage.send();
             this.myProgrammingHexOffset = offset;
             if (this.myProgrammingHexOffset >= this.myProgrammingHex.getLength()) {
                 this.myProgrammingState = "END";
+            }
-            this.myProgrammingCallback(true, "PROGRESS", this.myProgrammingHexOffset + ":" + this.myProgrammingHex.getLength());
+            //this.myProgrammingCallback(true, "PROGRESS", this.myProgrammingHexOffset + ":" + this.myProgrammingHex.getLength(), false);
+            var percent = 100*this.myProgrammingHexOffset / this.myProgrammingHex.getLength();
+            if (percent >= this.myProgrammingLastPercent+2.5)
+            {
+                this.myProgrammingCallback(true, "", "=", true);
+                this.myProgrammingLastPercent+=2.5;
+                this.myProgrammingnrOfTicks++;
+            }
+            if (percent > this.myProgrammingLastTenPercent+10)
+            {
+                for (var i=this.myProgrammingnrOfTicks; i<40; i++) this.myProgrammingCallback(true, "", " ", true);
+                this.myProgrammingCallback(true, "", "]", true);
+                this.myProgrammingCallback(true, "", "\r", true);
+                this.myProgrammingCallback(true, "", " "+Math.round(percent)+"% [", true);
+                this.myProgrammingLastTenPercent+=10;
+                for (var i=0; i<this.myProgrammingnrOfTicks; i++) this.myProgrammingCallback(true, "", "=", true);
+            }
+            this.myProgrammingLastPacket = canMessage;
             break;
         case "END":
             this.myProgrammingWantAck = ((this.myProgrammingHex.getCRC16()<<8)|(this.myProgrammingHex.getCRC16()>>8))&0xffff;
             var canMessage = new CanNMTMessage("nmt", "Pgm_End");
             canMessage.send();
             this.myProgrammingState = "CRC";
+            for (var i=this.myProgrammingnrOfTicks; i<40; i++) this.myProgrammingCallback(true, "", " ", true);
+            this.myProgrammingCallback(true, "", "]", true);
+            this.myProgrammingCallback(true, "", "\r", true);
+            this.myProgrammingCallback(true, "", "100% [========================================]", true);
+            if (this.myProgrammingResend != null)
+            {
+                /* Stop the interval */
+                this.myProgrammingResend.stop();
+            }
             break;
         case "CRC":
             //is this a bios programming?
             if (false)
+            {
                 this.myProgrammingState = "COPY";
-                this.myProgrammingCallback(true, "PROGRESS", "Start to copy bios to new location");
+                this.myProgrammingCallback(true, "PROGRESS", "Start to copy bios to new location", false);
                 var canMessage = new CanNMTMessage("nmt", "Pgm_Copy");
                 canMessage.setData("Source0", source);
                 canMessage.setData("Source1", source);
                 canMessage.setData("Destination0", destination);
                 canMessage.setData("Destination1", destination);
                 canMessage.setData("Length0", length);
                 canMessage.setData("Length1", length);
                 canMessage.send();
                 this.stopProgramming();
             }
             else
             {
-                this.stopProgramming(true, "Done, sucessful");
+                this.stopProgramming(true, "Done, successful");
                 this.reset();
             }
             break;
         case "COPY":    //this will never occur, bios does not send ack for copy command, it just moves data in flash then reset itself
             break;
         default:
             break;
         }
+    }
     else
     {
         switch (this.myProgrammingState)
+        {
         case "DATA":
             //Fall through
         case "END":
             ///TODO: We got something that was not correct... we should abort
             this.stopProgramming(true, "Failed to program, ack had wrong offset, expected data: "+this.myProgrammingWantAck+" got: "+data);
             this.reset();
             break;
         case "CRC":
             this.stopProgramming(true, "Failed to program, CRC not matching, expected data: "+this.myProgrammingWantAck+" got: "+data);
             this.reset();
             break;
         case "COPY":    //this will never occur, bios does not send ack for copy command, it just moves data in flash then reset itself
             break;
         default:
             break;
+        }
     }
 }
 CanNode.prototype.stopProgramming = function(status, text)
+{
     if (status && text)
     {
-        this.myProgrammingCallback(status, "STOP", text);
+        this.myProgrammingCallback(status, "\nSTOP", text, false);
     }
     this.myProgrammingIsBios = false;
     this.myProgramming = false;
     this.myProgrammingHex = new Array();
     this.myProgrammingHexAddress = 0;
     this.myProgrammingHexOffset = 0;
     this.myProgrammingCallback = function() {};
     this.myProgrammingWantAck = null;
     this.myProgrammingState = "";
+    this.myProgrammingLastPercent = 0;
+    this.myProgrammingLastTenPercent = 0;
+    this.myProgrammingnrOfTicks = 0;
+    if (this.myProgrammingTimeout != null)
+    {
+        /* Stop the interval */
+        this.myProgrammingTimeout.stop();
+    }
+    if (this.myProgrammingResend != null)
+    {
+        /* Stop the interval */
+        this.myProgrammingResend.stop();
+    }
     CanProgrammingNode = null;
+}