1

当我传递一个包含 1 个元素的数组时,一切正常,当我传递一个与两个(我们的用例最大)时,我收到以下错误:

该文件描述符没有写入队列(写入后)!

这是我的代码:

exports.triggerPhysical = function(state, alerts) {

console.dir("IN PHYSICAL");
console.dir(alerts);

  SerialPort.list(function(err, ports) {

      var port = {};

      for(var i = 0; i < ports.length; i++) {
        try {
          if(typeof ports[i].manufacturer != 'undefined' && ports[i].manufacturer.includes("Numato")) {
            port = ports[i];
          }
        } catch(err) {
          console.dir(err);
        }
      }

      var numato = new SerialPort(port.comName, {baudrate : 19200}, function(err) {
        if(err) {
          return console.dir(err);
        }

        console.dir('calling write');       

        for(var j = 0; j < alerts.length; j++) {
            numato.write('relay ' + state + ' ' + alerts[j].index + '\r', function(err) {
              if(err) {
                console.dir('error writing');
                console.dir(err);
              }
              console.dir('serial message written');              
          });           
        }

      numato.close();

      return true;

    });
  });
}

第一次写很好,第二次失败。我猜有一个明显的解决方案,但我没有找到它。任何见解将不胜感激。

4

1 回答 1

0

我最终做了两件事来解决这个问题。首先,我升级到 node-serialport 库的 5.x 版。

其次,我将代码更改为以下内容:

exports.triggerPhysical = function(state, alerts) {

    var port = new SerialPort('/dev/ttyACM0');

    port.on("open", function() {
        alerts.forEach(function(alert, idx) {
            str = 'relay ' + state + ' ' + alert.index + '\r';
            port.write(str, function(err, results) {
                if(err) {
                    console.dir("err writing");
                    console.dir(err);
                } else {
                    console.dir(results);
                }
            });
        });     
    })

    port.drain(writeDone);      


    function writeDone() {
        console.dir("In writeDone");
        port.close();
    }
}

我现在能够连续写入而不会导致任何错误,并且端口不会最终处于奇怪的锁定状态。

于 2017-09-11T19:23:23.040 回答