Briq
/
red-briq-nodes
6
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

problema di timeout?

master
Pietro Brenna 2022-01-03 18:48:52 +01:00
parent e5bed926b5
commit 6a953cfcdc
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
red/s7/s7-briq.js
View File

@ -86,7 +86,8 @@ function s7node_from_plc(plc) {
host: plc.ip, host: plc.ip,
port: plc.port, port: plc.port,
rack: plc.rack, rack: plc.rack,
slot: plc.slot slot: plc.slot,
timeout: 10000
}; };
let nuovo = new NodeS7({ let nuovo = new NodeS7({
silent: false, silent: false,
@ -147,7 +148,8 @@ function s7_read_write_loop(ip, obj) {
s7write_lock[ip] = true; s7write_lock[ip] = true;
let item = q.shift(); let item = q.shift();
if (item.action == "write") { if (item.action == "write") {
obj.writeItems(item.variable, item.value, (e) => { let timeout_id = null;
let callback = (e) => {
if (e) { if (e) {
// questa scrittura è fallita // questa scrittura è fallita
item.reject(e); item.reject(e);
@ -155,13 +157,19 @@ function s7_read_write_loop(ip, obj) {
// questa scrittura è riuscita // questa scrittura è riuscita
item.resolve(); item.resolve();
} }
try {
clearTimeout(timeout_id);
} catch (e) { }
s7write_lock[ip] = false; s7write_lock[ip] = false;
s7_read_write_loop(ip, obj); s7_read_write_loop(ip, obj);
}) };
timeout_id = setTimeout(() => callback('timeout error'), 60000);
obj.writeItems(item.variable, item.value, callback)
} else if (item.action == "read") { } else if (item.action == "read") {
obj.removeItems(undefined); // questo elimina tutte obj.removeItems(undefined); // questo elimina tutte
obj.addItems(item.variable); obj.addItems(item.variable);
obj.readAllItems((anyBadQualities, dataObject) => { let timeout_id = null;
let callback = (anyBadQualities, dataObject) => {
if (anyBadQualities) { if (anyBadQualities) {
console.error("Can't read variables (" + ip + "): bad qualities", anyBadQualities) console.error("Can't read variables (" + ip + "): bad qualities", anyBadQualities)
item.reject(anyBadQualities); item.reject(anyBadQualities);
@ -169,9 +177,14 @@ function s7_read_write_loop(ip, obj) {
// console.log("letti", dataObject); // console.log("letti", dataObject);
item.resolve(dataObject[item.variable]); item.resolve(dataObject[item.variable]);
} }
try {
clearTimeout(timeout_id);
} catch (e) { }
s7write_lock[ip] = false; s7write_lock[ip] = false;
s7_read_write_loop(ip, obj); s7_read_write_loop(ip, obj);
}) };
timeout_id = setTimeout(() => callback('timeout error', null), 60000);
obj.readAllItems(callback)
} }
} else { } else {
// è già lockato o vuoto // è già lockato o vuoto