Я пытаюсь настроить межпроцессное взаимодействие между простой программой на C и Node.js. Приведенный ниже код работает в основном нормально, однако через некоторое время (~ 5-10 минут) приложение Node.js вылетает со следующим сообщением об ошибке:
TypeError: Unsupported fd type: UNKNOWN
at createHandle (net.js:70:9)
at new Socket (net.js:209:20)
at fs.open (/home/pi/src/components/named_pipe_receiver.ts:22:23)
at FSReqWrap.oncomplete (fs.js:135:15)
C:
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>
#include <time.h>
#include <stdlib.h>
int main() {
int fd;
char * fifo_name = "/tmp/fifo";
mkfifo(fifo_name, 0666);
char buff[20];
time_t my_time;
while (1) {
fd = open(fifo_name, O_WRONLY);
time(& my_time);
strftime(buff, 20, "%Y-%m-%d %H:%M:%S", localtime(& my_time));
write(fd, buff, sizeof(buff));
close(fd);
usleep(10000);
}
return 0;
}
Node.js (v8.9.4):
const C = require('constants');
const fs = require('fs');
const net = require('net');
function listen() {
const fd = fs.openSync('/tmp/fifo', C.O_NONBLOCK | C.O_RDONLY);
const socket = new net.Socket({ fd, readable: true, writable: false });
socket.on('data', (data) => {
console.info(data.toString());
});
socket.on('close', () => {
fs.closeSync(fd);
socket.end();
socket.destroy();
listen();
});
socket.on('error', () => {
process.exit(1);
});
}
listen();
Обе программы переписаны для публикации здесь, но они отражают суть того, что я пытаюсь достичь.
Вопрос 1: Как я могу исправить свой код, чтобы сообщение об ошибке больше не появлялось?
Вопрос 2: Я чувствую, что есть лучший способ связи между двумя процессами. Какие-либо предложения?





Я не видел, чтобы эта ошибка повторялась снова после удаления строк, закрывающих файл и завершающих сокет:
socket.on('close', () => {
// fs.closeSync(fd);
// socket.end();
// socket.destroy();
listen();
});
Кажется, это исправило!
Небольшое обновление, теперь оно работает без сбоев в течение 2 часов после удаления вызовов
fs.close,socket.endиsocket.destroy.