Changeset 818 for trunk/Modules/NetworkConfigLinux/Generators/CheckPorts.php

Timestamp:

Mar 16, 2016, 10:01:02 PM (9 years ago)

Author:

chronos

Message:

• Added: UpDown history for network ports.

File:

• trunk/Modules/NetworkConfigLinux/Generators/CheckPorts.php (modified) (4 diffs)

trunk/Modules/NetworkConfigLinux/Generators/CheckPorts.php

@@ -3 +3 @@
 class ConfigCheckPorts extends NetworkConfigItem
 {
-  function CheckPortStatus($IP, $Port)
+  function CheckPortStatus($IP, $Port, $Protocol = 'tcp')
   {
     $Timeout = 1;
     $State = 0;
-    if($Socket = @fsockopen($IP, $Port, $ErrorNumber, $ErrorString, $Timeout))
+    if($Protocol = 'tcp') $Prefix = '';
+      else if($Protocol = 'udp') $Prefix = 'udp://';
+      else throw new Exception('Unsupported protocol "'.$Protocol.'"');
+    if($Socket = @fsockopen($Prefix.$IP, $Port, $ErrorNumber, $ErrorString, $Timeout))
     {
       fclose($Socket);
@@ -21 +24 @@
     // Load all ports to memory
     $Ports = array();
-    $DbResult = $this->Database->query('SELECT `NetworkPort`.`Id`, `NetworkPort`.`Number`, '.
+    $DbResult = $this->Database->query('SELECT `NetworkPort`.`Id`, `NetworkPort`.`Number`, `NetworkPort`.`Protocol`, '.
       '`NetworkPort`.`Online`, 0 AS `NewOnline`, `NetworkInterface`.`LocalIP` AS `LocalIP` '.
       'FROM `NetworkPort` '.
@@ -31 +34 @@
     foreach($Ports as $Index => $Port)
     {
-      $Port['NewOnline'] = $this->CheckPortStatus($Port['LocalIP'], $Port['Number']);
+      if($Port['Protocol'] == 0) $Port['Protocol'] = 'tcp';
+      if($Port['Protocol'] == 1) $Port['Protocol'] = 'udp';
+      $Port['NewOnline'] = $this->CheckPortStatus($Port['LocalIP'], $Port['Number'], $Port['Protocol']);
 
       // Update last online time if still online
@@ -37 +42 @@
       {
         $DbResult = $this->Database->update('NetworkPort', '`Id` = "'.$Port['Id'].'"',
-        array('LastOnline' => TimeToMysqlDateTime($StartTime)));
+          array('Online' => 1, 'LastOnline' => TimeToMysqlDateTime($StartTime)));
+      }
+
+      // Update UpDown table
+      if($Port['Online'] != $Port['NewOnline'])
+      {
+        // Online state changed
+        $DbResult = $this->Database->query('INSERT INTO `NetworkPortUpDown` (`Port`,
+         `State`, `Time`, `Duration`) VALUES ('.$Port['Id'].', '.$Port['NewOnline'].', "'.
+          TimeToMysqlDateTime($StartTime).'", NULL)');
+        // Update previous record duration in UpDown table
+        $this->Database->query('UPDATE `NetworkPortUpDown` AS `TM` SET `Duration` = TIMESTAMPDIFF(SECOND, '.
+          '`TM`.`Time`, (SELECT `Time` FROM (SELECT * FROM `NetworkPortUpDown`) AS `TA` WHERE (`TA`.`Time` > `TM`.`Time`) '.
+          'AND (`TA`.`Port`=`TM`.`Port`) ORDER BY `TA`.`Time` ASC LIMIT 1)) '.
+          'WHERE (`TM`.`Duration` IS NULL) AND (`TM`.`Interface` ='.$Port['Id'].')');
       }
     }
-  
+    $DbResult = $this->Database->update('NetworkDevice', '`LastOnline` < "'.TimeToMysqlDateTime($StartTime).'"', array('Online' => 0));
+
     // Set offline all ports which were not updated as online
     $DbResult = $this->Database->select('NetworkPort', '*', '(`Online` = 1) AND '.