serial drain implemented

HilscherAutomation · Jul 5, 2019 · 6d171d9 · 6d171d9
1 parent 2e2b409
commit 6d171d9
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/node-red-contrib-npix-rs485/25-serial-rs485.js b/node-red-contrib-npix-rs485/25-serial-rs485.js
@@ -74,13 +74,14 @@ module.exports = function(RED) {
                                      if (err) {
                                          var errmsg = err.toString().replace("Serialport","Serialport "+node.port.serial.path);
                                          node.error(errmsg,msg);
+                                         mutex.unlock();
                                      } else {
                                          // !!!!!Modification!!!! Wait till all data has been transmitted
                                          node.port.drain(function(err) {
                                               // set RS485 TX enable to low
                                               gpio.write(11, false, function(err){
-                                                   // unlock mutex  
-                                                   mutex.unlock();             
+                                                   // unlock mutex
+                                                   mutex.unlock();
                                               });
                                          });
                                      }
@@ -268,6 +269,7 @@ module.exports = function(RED) {
                         queue: [],
                         on: function(a,b) { this._emitter.on(a,b); },
                         close: function(cb) { this.serial.close(cb); },
+                        drain: function(cb) { this.serial.drain(cb); },
                         encodePayload: function (payload) {
                             if (!Buffer.isBuffer(payload)) {
                                 if (typeof payload === "object") {