childNode adjustments
parent
054a53719d
commit
c011477531
|
@ -67,7 +67,7 @@ module.exports = function(s,config,lang,app,io){
|
||||||
})
|
})
|
||||||
}else{
|
}else{
|
||||||
s.debugLog('Child Node Force Disconnected!',new Date(),ipAddress)
|
s.debugLog('Child Node Force Disconnected!',new Date(),ipAddress)
|
||||||
client.destroy()
|
client.disconnect()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
client.on('message',onAuthenticate)
|
client.on('message',onAuthenticate)
|
||||||
|
|
|
@ -8,6 +8,7 @@ const spawn = require('child_process').spawn;
|
||||||
const connectionTester = require('connection-tester')
|
const connectionTester = require('connection-tester')
|
||||||
const SoundDetection = require('shinobi-sound-detection')
|
const SoundDetection = require('shinobi-sound-detection')
|
||||||
const streamViewerCountTimeouts = {}
|
const streamViewerCountTimeouts = {}
|
||||||
|
const { createQueueAwaited } = require('../common.js')
|
||||||
module.exports = (s,config,lang) => {
|
module.exports = (s,config,lang) => {
|
||||||
const {
|
const {
|
||||||
applyPartialToConfiguration,
|
applyPartialToConfiguration,
|
||||||
|
@ -1431,6 +1432,9 @@ module.exports = (s,config,lang) => {
|
||||||
const typeIsLocal = e.type === 'local'
|
const typeIsLocal = e.type === 'local'
|
||||||
const monitorConfig = theGroup.rawMonitorConfigurations[monitorId]
|
const monitorConfig = theGroup.rawMonitorConfigurations[monitorId]
|
||||||
const doPingTest = e.type !== 'socket' && e.type !== 'dashcam' && e.protocol !== 'udp' && e.type !== 'local' && e.details.skip_ping !== '1';
|
const doPingTest = e.type !== 'socket' && e.type !== 'dashcam' && e.protocol !== 'udp' && e.type !== 'local' && e.details.skip_ping !== '1';
|
||||||
|
if(!theGroup.startMonitorInQueue){
|
||||||
|
theGroup.startMonitorInQueue = createQueueAwaited(0.5, 1)
|
||||||
|
}
|
||||||
const startMonitorInQueue = theGroup.startMonitorInQueue
|
const startMonitorInQueue = theGroup.startMonitorInQueue
|
||||||
if(!activeMonitor.isStarted)return;
|
if(!activeMonitor.isStarted)return;
|
||||||
// e = monitor object
|
// e = monitor object
|
||||||
|
|
Loading…
Reference in New Issue