Added better error handling to vlogger script in case that the mysql databa...

tbrehm

2010-05-20 d65d4f57d58749da096fe5097853746975cdeb6c

 server/server.php

@@ -32,6 +32,7 @@
require("lib/app.inc.php");

set_time_limit(0);
ini_set('error_reporting','E_ALL & ~E_NOTICE');

// make sure server_id is always an int
$conf["server_id"] = intval($conf["server_id"]);
@@ -49,13 +50,35 @@
}
*/

/*
//* Load the server configuration
if($app->dbmaster->connect()) {
   // get the dalaog_id of the last performed record
   $server_db_record = $app->dbmaster->queryOneRecord("SELECT * FROM server WHERE server_id = ".$conf["server_id"]);
   $conf['last_datalog_id'] = (int)$server_db_record['updated'];
   $conf["mirror_server_id"] = (int)$server_db_record['mirror_server_id'];
   // Load the ini_parser
   $app->uses('ini_parser');
   // Get server configuration
   $conf["serverconfig"] = $app->ini_parser->parse_ini_string(stripslashes($server_db_record["config"]));
   // Set the loglevel
   $conf["log_priority"] = intval($conf["serverconfig"]["server"]["loglevel"]);
	
   unset($server_db_record);
}


// Check if another process is running
if(is_file($conf["temppath"].$conf["fs_div"].".ispconfig_lock")){
  clearstatcache();
  for($i=0;$i<120;$i++){ // Wait max. 120 sec, then proceed
  for($i=0;$i<120;$i++){ // Wait max. 1200 sec, then proceed
    if(is_file($conf["temppath"].$conf["fs_div"].".ispconfig_lock")){
      sleep(1);
      exec("ps aux | grep '/usr/local/ispconfig/server/server.php' | grep -v 'grep' | wc -l", $check);
      if(intval($check[0]) > 1) { // 1 because this is 2nd instance!
          $app->log("There is already an instance of server.php running. Exiting.", LOGLEVEL_DEBUG);
          exit;
      }
     $app->log("There is already a lockfile set. Waiting another 10 seconds...", LOGLEVEL_DEBUG);
      sleep(10);
      clearstatcache();
    }
  }
@@ -64,50 +87,62 @@
// Set Lockfile
@touch($conf["temppath"].$conf["fs_div"].".ispconfig_lock");
$app->log("Set Lock: ".$conf["temppath"].$conf["fs_div"].".ispconfig_lock", LOGLEVEL_DEBUG);
*/

// Check if there is anything to update
$tmp_rec = $app->db->queryOneRecord("SELECT count(server_id) as number from sys_datalog WHERE server_id = ".$conf["server_id"]);
$tmp_num_records = $tmp_rec["number"];
unset($tmp_rec);

if($tmp_num_records > 0) {
if($app->db->connect() && $app->dbmaster->connect()) {

   // Check if there is anything to update
   if($conf["mirror_server_id"] > 0) {
      $tmp_rec = $app->dbmaster->queryOneRecord("SELECT count(server_id) as number from sys_datalog WHERE datalog_id > ".$conf['last_datalog_id']." AND (server_id = ".$conf["server_id"]." OR server_id = ".$conf["mirror_server_id"]." OR server_id = 0)");
   } else {
      $tmp_rec = $app->dbmaster->queryOneRecord("SELECT count(server_id) as number from sys_datalog WHERE datalog_id > ".$conf['last_datalog_id']." AND (server_id = ".$conf["server_id"]." OR server_id = 0)");
   }
   
   $app->log("Found $tmp_num_records changes, starting update process.",LOGLEVEL_DEBUG);
	
   // Load required base-classes
   $app->uses('ini_parser,modules,plugins');
	
	
   // Get server configuration
   $conf["serverconfig"] = $app->ini_parser->parse_ini_string(stripslashes($server_db_record["config"]));
   $tmp_num_records = $tmp_rec["number"];
   unset($tmp_rec);

   /*
    Load the modules that are im the mods-enabled folder
   */

   $app->modules->loadModules();

   /*
    Load the plugins that are in the plugins-enabled folder
   */

   $app->plugins->loadPlugins();

   /*
    Go trough the sys_datalog table and call the processing functions
    in the modules that are hooked on to the table actions
   */
   $app->modules->processDatalog();
   if($tmp_num_records > 0) {
      /*
       There is something to do, triggert by the database -> do it!
      */
      // Write the Log
      $app->log("Found $tmp_num_records changes, starting update process.", LOGLEVEL_DEBUG);
      // Load required base-classes
      $app->uses('modules,plugins,file,services');
      // Load the modules that are im the mods-enabled folder
      $app->modules->loadModules('all');
      // Load the plugins that are in the plugins-enabled folder
      $app->plugins->loadPlugins('all');
      // Go trough the sys_datalog table and call the processing functions
      // in the modules that are hooked on to the table actions
      $app->modules->processDatalog();
      // Restart services that need to be restarted after configuration
      $app->services->processDelayedActions();
   } else {
      /*
       There is no trigger inside the database -> load only the core, maybe they have to do something
      */
      // Write the log
      $app->log('No Updated records found, starting only the core.', LOGLEVEL_DEBUG);
      // Load required base-classes
      $app->uses('modules,plugins,file,services');
      // Load the modules that are im the mods-core folder
      $app->modules->loadModules('core');
      // Load the plugins that are in the plugins-core folder
      $app->plugins->loadPlugins('core');
   }
} else {
   $app->log('Nothing to Update.',LOGLEVEL_DEBUG);
   if(!$app->db->connect()) {
      $app->log("Unable to connect to local server.".$app->db->errorMessage,LOGLEVEL_WARN);
   } else {
      $app->log("Unable to connect to master server.".$app->dbmaster->errorMessage,LOGLEVEL_WARN);
   }
}

/*
// Remove lock
@unlink($conf["temppath"].$conf["fs_div"].".ispconfig_lock");
$app->log("Remove Lock: ".$conf["temppath"].$conf["fs_div"].".ispconfig_lock",LOGLEVEL_DEBUG);
*/

die('finished.');
?>

die("finished.\n");
?>