Revise unix-agent (processes section) to use dbBulkInsert.

This commit is contained in:
Louis Rossouw
2015-07-17 06:08:03 +02:00
parent 54dd165917
commit 650369603d
+4 -8
View File
@@ -112,20 +112,16 @@ if ($device['os_group'] == 'unix') {
if (!empty($agent_data['ps'])) { if (!empty($agent_data['ps'])) {
echo 'Processes: '; echo 'Processes: ';
dbDelete('processes', 'device_id = ?', array($device['device_id'])); dbDelete('processes', 'device_id = ?', array($device['device_id']));
$query = "INSERT INTO `processes` (`device_id`,`pid`,`user`,`vsz`,`rss`,`cputime`,`command`) VALUES "; $data=array();
$values = "";
foreach (explode("\n", $agent_data['ps']) as $process) { foreach (explode("\n", $agent_data['ps']) as $process) {
$process = preg_replace('/\((.*),([0-9]*),([0-9]*),([0-9\:]*),([0-9]*)\)\ (.*)/', '\\1|\\2|\\3|\\4|\\5|\\6', $process); $process = preg_replace('/\((.*),([0-9]*),([0-9]*),([0-9\:]*),([0-9]*)\)\ (.*)/', '\\1|\\2|\\3|\\4|\\5|\\6', $process);
list($user, $vsz, $rss, $cputime, $pid, $command) = explode('|', $process, 6); list($user, $vsz, $rss, $cputime, $pid, $command) = explode('|', $process, 6);
if (!empty($command)) { if (!empty($command)) {
if ($values != "") { $data[]=array('device_id' => $device['device_id'], 'pid' => $pid, 'user' => $user, 'vsz' => $vsz, 'rss' => $rss, 'cputime' => $cputime, 'command' => $command);
$values .= ",";
}
$values .= "('".mres($device['device_id'])."','".mres($pid)."','".mres($user)."','".mres($vsz)."','".mres($rss)."','".mres($cputime)."','".mres($command)."')";
} }
} }
if ($values != "") { if (count($data) > 0) {
dbQuery($query.$values); dbBulkInsert('processes',$data);
} }
echo "\n"; echo "\n";
} }