mirror/librenms-librenms
1
0
Fork 0
mirror of https://github.com/librenms/librenms.git synced 2024-10-07 16:52:45 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Pause polling and discovery if there's an update-lock

Browse Source
This commit is contained in:
f0o
2015-09-01 14:14:50 +01:00
parent ccfdddeae6
commit e11f613bdd
3 changed files with 16 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
discovery.php
View File

@@ -105,6 +105,13 @@ if ($config['distributed_poller'] === true) {
$where .= ' AND poller_group IN('.$config['distributed_poller_group'].')';
}
echo 'Checking for MySQL Locks:';
while (!dbCheckLock('schema_update')) {
echo '.';
sleep(1);
}
echo PHP_EOL;
foreach (dbFetch("SELECT * FROM `devices` WHERE status = 1 AND disabled = 0 $where ORDER BY device_id DESC") as $device) {
if (dbGetLock('discovering.' . $device['device_id'])) {
discover_device($device, $options);

6
includes/sql-schema/update.php
View File

@@ -98,10 +98,6 @@ if (!dbGetLock('schema_update')) {
register_shutdown_function('dbReleaseLock','schema_update');
do {
sleep(1);
} while (@dbFetchCell('SELECT COUNT(*) FROM `devices` WHERE NOT IS_FREE_LOCK(CONCAT("polling.", device_id)) OR NOT IS_FREE_LOCK(CONCAT("queued.", device_id)) OR NOT IS_FREE_LOCK(CONCAT("discovering.", device_id))') > 0);
foreach ($filelist as $file) {
list($filename,$extension) = explode('.', $file, 2);
if ($filename > $db_rev) {
@@ -171,3 +167,5 @@ if ($updating) {
echo "-- Done\n";
}
dbReleaseLock('schema_update');

7
poller.php
View File

@@ -100,6 +100,13 @@ if (isset($options['r'])) {
$config['norrd'] = true;
}
echo 'Checking for MySQL Locks:';
while (!dbCheckLock('schema_update')) {
echo '.';
sleep(1);
}
echo PHP_EOL;
rrdtool_pipe_open($rrd_process, $rrd_pipes);
echo "Starting polling run:\n\n";