latham
2011-05-05 7cd9971f543f12a5fb60b67631190712d0d9788e
server/lib/classes/monitor_tools.inc.php
@@ -149,35 +149,69 @@
      return array('name' => $distname, 'version' => $distver, 'id' => $distid, 'baseid' => $distbaseid);
   }
/*
    //** Email Quota
    public function monitorEmailQuota() {
        global $conf;
      //* Initialize data array
      $data = array();
      //* the id of the server as int
      $server_id = intval($conf['server_id']);
      //* The type of the data
      $type = 'email_quota';
      //* The state of the email_quota.
      $state = 'ok';
        //* Dovecot quota check Courier in progress lathama@gmail.com
        if($dir = opendir("/var/vmail")){
            while (($quotafiles = readdir($dir)) !== false){
                if(preg_match('/.\_quota$/', $quotafiles)){
                    $quotafile = (file("/var/vmail/" . $quotafiles));
                    $emailaddress = preg_replace('/_quota/',"", $quotafiles);
                    $emailaddress = preg_replace('/_/',"@", $emailaddress);
                    $data[$emailaddress]['used'] = trim($quotafile['1']);
                }
            }
            closedir($dir);
        }
      $res['server_id'] = $server_id;
      $res['type'] = $type;
      $res['data'] = $data;
      $res['state'] = $state;
        return $res;
    }
*/
    //** Filesystem Quota
   public function monitorHDQuota() {
      global $conf;
      /* Initialize data array */
      //* Initialize data array
      $data = array();
      /* the id of the server as int */
      //* the id of the server as int
      $server_id = intval($conf['server_id']);
      /** The type of the data */
      //* The type of the data
      $type = 'harddisk_quota';
      /** The state of the harddisk_quota. */
      //* The state of the harddisk_quota.
      $state = 'ok';
      /** Fetch the data for all users */
      //* Fetch the data for all users
      $dfData = shell_exec('repquota -au');
      // split into array
      //* Split into array
      $df = explode("\n", $dfData);
      /*
       * ignore the first 5 lines, process the rest
       */
      //* ignore the first 5 lines, process the rest
      for ($i = 5; $i <= sizeof($df); $i++) {
         if ($df[$i] != '') {
            /*
             * Make a array of the data
             */
            //* Make a array of the data
            $s = preg_split('/[\s]+/', $df[$i]);
            $username = $s[0];
            if (substr($username, 0, 3) == 'web') {
@@ -194,20 +228,16 @@
         }
      }
      /** Fetch the data for all users */
      //** Fetch the data for all users
      $dfData = shell_exec('repquota -ag');
      // split into array
      //* split into array
      $df = explode("\n", $dfData);
      /*
       * ignore the first 5 lines, process the rest
       */
      //* ignore the first 5 lines, process the rest
      for ($i = 5; $i <= sizeof($df); $i++) {
         if ($df[$i] != '') {
            /*
             * Make a array of the data
             */
            //* Make a array of the data
            $s = preg_split('/[\s]+/', $df[$i]);
            $groupname = $s[0];
            if (substr($groupname, 0, 6) == 'client') {
@@ -224,9 +254,7 @@
         }
      }
      /*
       * Return the Result
       */
      //* Return the Result
      $res['server_id'] = $server_id;
      $res['type'] = $type;
      $res['data'] = $data;
@@ -597,7 +625,7 @@
      /* Monitor BIND-Server */
      $data['bindserver'] = -1; // unknown - not needed
      if ($services['dns_server'] == 1) {
         if ($this->_checkTcp('localhost', 53)) {
         if ($this->_checkUdp('localhost', 53)) {
            $data['bindserver'] = 1;
         } else {
            $data['bindserver'] = 0;
@@ -1539,26 +1567,36 @@
   }
   private function _checkTcp($host, $port) {
      /* Try to open a connection */
      $fp = @fsockopen($host, $port, $errno, $errstr, 2);
      if ($fp) {
         /*
          * We got a connection, but maybe apache is not able to send data over this
          * connection?
          * We got a connection, this means, everything is O.K.
          * But maybe we are able to do more deep testing?
          */
         fwrite($fp, "GET / HTTP/1.0\r\n\r\n");
         stream_set_timeout($fp, 2);
         $res = fread($fp, 10);
         $info = stream_get_meta_data($fp);
         fclose($fp);
         if ($info['timed_out']) {
            return false; // Apache was not able to send data over this connection
         } else {
            return true; // Apache was able to send data over this connection
         if ($port == 80) {
            /*
             * Port 80 means, testing APACHE
             * So we can do a deepter test and try to get data over this connection.
             * (if apache hangs, we get a connection but a timeout by trying to GET the data!)
             */
            fwrite($fp, "GET / HTTP/1.0\r\n\r\n");
            stream_set_timeout($fp, 5); // Timeout after 5 seconds
            $res = fread($fp, 10);  // try to get 10 bytes (enough to test!)
            $info = stream_get_meta_data($fp);
            if ($info['timed_out']) {
               return false; // Apache was not able to send data over this connection
            }
         }
         /* The connection is no longer needed */
         fclose($fp);
         /* We are able to establish a connection */
         return true;
      } else {
         return false; // Apache was not able to establish a connection
         /* We are NOT able to establish a connection */
         return false;
      }
   }
@@ -1585,67 +1623,64 @@
         return false;
      }
   }
    /*
     * Set the state to the given level (or higher, but not lesser).
     * * If the actual state is critical and you call the method with ok,
     *   then the state is critical.
     *
     * * If the actual state is critical and you call the method with error,
     *   then the state is error.
     */
    private function _setState($oldState, $newState)
    {
        /*
         * Calculate the weight of the old state
         */
        switch ($oldState) {
            case 'no_state': $oldInt = 0;
                break;
            case 'ok': $oldInt = 1;
                break;
            case 'unknown': $oldInt = 2;
                break;
            case 'info': $oldInt = 3;
                break;
            case 'warning': $oldInt = 4;
                break;
            case 'critical': $oldInt = 5;
                break;
            case 'error': $oldInt = 6;
                break;
        }
        /*
         * Calculate the weight of the new state
         */
        switch ($newState) {
            case 'no_state': $newInt = 0 ;
                break;
            case 'ok': $newInt = 1 ;
                break;
            case 'unknown': $newInt = 2 ;
                break;
            case 'info': $newInt = 3 ;
                break;
            case 'warning': $newInt = 4 ;
                break;
            case 'critical': $newInt = 5 ;
                break;
            case 'error': $newInt = 6 ;
                break;
        }
        /*
         * Set to the higher level
         */
        if ($newInt > $oldInt){
            return $newState;
        }
        else
        {
            return $oldState;
        }
    }
   /**
    * Set the state to the given level (or higher, but not lesser).
    * * If the actual state is critical and you call the method with ok,
    *   then the state is critical.
    *
    * * If the actual state is critical and you call the method with error,
    *   then the state is error.
    */
   private function _setState($oldState, $newState) {
      /*
       * Calculate the weight of the old state
       */
      switch ($oldState) {
         case 'no_state': $oldInt = 0;
            break;
         case 'ok': $oldInt = 1;
            break;
         case 'unknown': $oldInt = 2;
            break;
         case 'info': $oldInt = 3;
            break;
         case 'warning': $oldInt = 4;
            break;
         case 'critical': $oldInt = 5;
            break;
         case 'error': $oldInt = 6;
            break;
      }
      /*
       * Calculate the weight of the new state
       */
      switch ($newState) {
         case 'no_state': $newInt = 0;
            break;
         case 'ok': $newInt = 1;
            break;
         case 'unknown': $newInt = 2;
            break;
         case 'info': $newInt = 3;
            break;
         case 'warning': $newInt = 4;
            break;
         case 'critical': $newInt = 5;
            break;
         case 'error': $newInt = 6;
            break;
      }
      /*
       * Set to the higher level
       */
      if ($newInt > $oldInt) {
         return $newState;
      } else {
         return $oldState;
      }
   }
   private function _getIntArray($line) {
      /** The array of float found */
@@ -1663,4 +1698,4 @@
}
?>
?>