mirror of
https://github.com/librenms/librenms.git
synced 2024-10-07 16:52:45 +00:00
Zane C. Bowers-Hadley
1b5f5cee37
* checkpoint work for now * polling should be good now * re-work php-fpm some more * re-work the php-fpm app page * add php-fpm_v1_combined.inc.php * add more graphs * more work * add last request cpu * fix stats for pools * more graph work * update the docs for php-fpm * more graph work * more graph stuff * graph stuff now done * some style fixes * another style fix * remove a unneeded use line * add new tests * add some missing items to the test * json fix * remove start time and add data
136 lines
4.6 KiB
PHP
136 lines
4.6 KiB
PHP
<?php
|
|
|
|
use LibreNMS\Exceptions\JsonAppParsingFailedException;
|
|
use LibreNMS\RRD\RrdDefinition;
|
|
|
|
$name = 'php-fpm';
|
|
|
|
try {
|
|
// phpfpmsp is the original name and being kept for compatbility purposes... sp stood for single pool
|
|
$extend_return = json_app_get($device, 'phpfpmsp');
|
|
} catch (JsonAppParsingFailedException $e) {
|
|
// Legacy script, build compatible array
|
|
$phpfpm = $e->getOutput();
|
|
|
|
[$pool,$start_time,$start_since,$accepted_conn,$listen_queue,$max_listen_queue,$listen_queue_len,$idle_processes,
|
|
$active_processes,$total_processes,$max_active_processes,$max_children_reached,$slow_requests] = explode("\n", $phpfpm);
|
|
|
|
$rrd_name = ['app', $name, $app->app_id];
|
|
$rrd_def = RrdDefinition::make()
|
|
->addDataset('lq', 'GAUGE', 0)
|
|
->addDataset('mlq', 'GAUGE', 0)
|
|
->addDataset('ip', 'GAUGE', 0)
|
|
->addDataset('ap', 'GAUGE', 0)
|
|
->addDataset('tp', 'GAUGE', 0)
|
|
->addDataset('map', 'GAUGE', 0)
|
|
->addDataset('mcr', 'GAUGE', 0)
|
|
->addDataset('sr', 'GAUGE', 0);
|
|
|
|
$fields = [
|
|
'lq' => $listen_queue,
|
|
'mlq' => $max_listen_queue,
|
|
'ip' => $idle_processes,
|
|
'ap' => $active_processes,
|
|
'tp' => $total_processes,
|
|
'map' => $max_active_processes,
|
|
'mcr' => $max_children_reached,
|
|
'sr' => $slow_requests,
|
|
];
|
|
|
|
$app->data = ['version' => 'legacy'];
|
|
|
|
$tags = ['name' => $name, 'app_id' => $app->app_id, 'rrd_def' => $rrd_def, 'rrd_name' => $rrd_name];
|
|
data_update($device, 'app', $tags, $fields);
|
|
|
|
update_application($app, 'OK', $fields);
|
|
|
|
return;
|
|
}
|
|
|
|
$var_mappings = [
|
|
'accepted_conn' => 'accepted conn',
|
|
'active_processes' => 'active processes',
|
|
'idle_processes' => 'idle processes',
|
|
'listen_queue' => 'listen queue',
|
|
'listen_queue_len' => 'listen queue len',
|
|
'max_active_processes' => 'max active processes',
|
|
'max_children_reached' => 'max children reached',
|
|
'max_listen_queue' => 'max listen queue',
|
|
'slow_requests' => 'slow requests',
|
|
'start_since' => 'start since',
|
|
'total_processes' => 'total processes',
|
|
'last_request_cpu' => 'last request cpu',
|
|
];
|
|
|
|
$new_app_data = [
|
|
'version' => $extend_return['version'],
|
|
'pools' => [],
|
|
];
|
|
|
|
$metrics = [
|
|
'errored' => $extend_return['data']['errored'],
|
|
];
|
|
|
|
$old_app_data = $app->data;
|
|
|
|
$counter_rrd_def = RrdDefinition::make()
|
|
->addDataset('data', 'DERIVE', 0);
|
|
|
|
$gauge_rrd_def = RrdDefinition::make()
|
|
->addDataset('data', 'GAUGE', 0);
|
|
|
|
// process pools
|
|
foreach ($extend_return['data']['pools'] as $pool => $pool_stats) {
|
|
$new_app_data['pools'][] = $pool;
|
|
foreach ($var_mappings as $stat => $stat_key) {
|
|
$rrd_name = ['app', $name, $app->app_id, 'pools___' . $pool . '___' . $stat];
|
|
$fields = ['data' => $extend_return['data']['pools'][$pool][$stat_key]];
|
|
|
|
$metrics['pools___' . $pool . '___' . $stat] = $extend_return['data']['pools'][$pool][$stat_key];
|
|
|
|
if ($stat == 'accepted_conn' || $stat == 'slow_requests' || $stat == 'max_children_reached') {
|
|
$rrd_def = $counter_rrd_def;
|
|
} else {
|
|
$rrd_def = $gauge_rrd_def;
|
|
}
|
|
|
|
$tags = ['name' => $name, 'app_id' => $app->app_id, 'rrd_def' => $rrd_def, 'rrd_name' => $rrd_name];
|
|
data_update($device, 'app', $tags, $fields);
|
|
}
|
|
}
|
|
|
|
// process totals
|
|
foreach ($var_mappings as $stat => $stat_key) {
|
|
$rrd_name = ['app', $name, $app->app_id, 'totals___' . $stat];
|
|
$fields = ['data' => $extend_return['data']['totals'][$stat_key]];
|
|
|
|
$metrics['totals_' . $stat] = $extend_return['data']['totals'][$stat_key];
|
|
|
|
if ($stat == 'accepted_conn' || $stat == 'slow_requests' || $stat == 'max_children_reached') {
|
|
$rrd_def = $counter_rrd_def;
|
|
} else {
|
|
$rrd_def = $gauge_rrd_def;
|
|
}
|
|
|
|
$tags = ['name' => $name, 'app_id' => $app->app_id, 'rrd_def' => $rrd_def, 'rrd_name' => $rrd_name];
|
|
data_update($device, 'app', $tags, $fields);
|
|
}
|
|
|
|
// check for added or removed pools
|
|
$old_pools = $old_app_data['pools'] ?? [];
|
|
$new_pools = $new_app_data['pools'] ?? [];
|
|
$added_pools = array_diff($new_pools, $old_pools);
|
|
$removed_pools = array_diff($old_pools, $new_pools);
|
|
|
|
// if we have any changes in pools, log it
|
|
if (count($added_pools) > 0 || count($removed_pools) > 0) {
|
|
$log_message = 'Suricata Instance Change:';
|
|
$log_message .= count($added_pools) > 0 ? ' Added ' . implode(',', $added_pools) : '';
|
|
$log_message .= count($removed_pools) > 0 ? ' Removed ' . implode(',', $added_pools) : '';
|
|
log_event($log_message, $device, 'application');
|
|
}
|
|
|
|
$app->data = $new_app_data;
|
|
|
|
update_application($app, 'OK', $metrics);
|