From eed6b3c6f189fcb318a38ef70c66d1501123f342 Mon Sep 17 00:00:00 2001
From: vogelor <vogelor@ispconfig3>
Date: Mon, 28 Mar 2011 15:53:05 -0400
Subject: [PATCH] the new rescue-module is now able to rescue (restart) mysql

---
 server/server.php |  194 ++++++++++++++++++++++++++++--------------------
 1 files changed, 112 insertions(+), 82 deletions(-)

diff --git a/server/server.php b/server/server.php
index 537176c..6a3499f 100644
--- a/server/server.php
+++ b/server/server.php
@@ -1,110 +1,132 @@
 <?php
 
 /*
-Copyright (c) 2007, Till Brehm, projektfarm Gmbh
-All rights reserved.
+  Copyright (c) 2007, Till Brehm, projektfarm Gmbh
+  All rights reserved.
 
-Redistribution and use in source and binary forms, with or without modification,
-are permitted provided that the following conditions are met:
+  Redistribution and use in source and binary forms, with or without modification,
+  are permitted provided that the following conditions are met:
 
-    * Redistributions of source code must retain the above copyright notice,
-      this list of conditions and the following disclaimer.
-    * Redistributions in binary form must reproduce the above copyright notice,
-      this list of conditions and the following disclaimer in the documentation
-      and/or other materials provided with the distribution.
-    * Neither the name of ISPConfig nor the names of its contributors
-      may be used to endorse or promote products derived from this software without
-      specific prior written permission.
+ * Redistributions of source code must retain the above copyright notice,
+  this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright notice,
+  this list of conditions and the following disclaimer in the documentation
+  and/or other materials provided with the distribution.
+ * Neither the name of ISPConfig nor the names of its contributors
+  may be used to endorse or promote products derived from this software without
+  specific prior written permission.
 
-THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
-ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
-WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
-IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
-INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
-BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
-DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
-OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
-NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,
-EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-*/
+  THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+  ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+  WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
+  IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
+  INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
+  BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+  DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
+  OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
+  NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,
+  EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
 
 require('lib/config.inc.php');
 require('lib/app.inc.php');
 
 set_time_limit(0);
-ini_set('error_reporting',E_ALL & ~E_NOTICE);
+ini_set('error_reporting', E_ALL & ~E_NOTICE);
 
 // make sure server_id is always an int
 $conf['server_id'] = intval($conf['server_id']);
 
 /*
-// Get server record, if updates where available for this server
-$server_db_record = $app->db->queryOneRecord("SELECT * FROM server WHERE update = 1 AND server_id = ".$conf['server_id']);
-if($server_db_record == false) {
-	$app->log('Nothing to update for server_id '.$conf['server_id']);
-	die();
-} else {
-	// Set update status to 0, so we dont start the update process twice
-	$app->db->query("UPDATE server SET update = 0 WHERE server_id = ".$conf['server_id']);
-	$app->log('Begin update.');
-}
-*/
+  // Get server record, if updates where available for this server
+  $server_db_record = $app->db->queryOneRecord("SELECT * FROM server WHERE update = 1 AND server_id = ".$conf['server_id']);
+  if($server_db_record == false) {
+  $app->log('Nothing to update for server_id '.$conf['server_id']);
+  die();
+  } else {
+  // Set update status to 0, so we dont start the update process twice
+  $app->db->query("UPDATE server SET update = 0 WHERE server_id = ".$conf['server_id']);
+  $app->log('Begin update.');
+  }
+ */
 
-//* Load the server configuration
-if($app->dbmaster->connect()) {
+/*
+ * Try to Load the server configuration from the master-db
+ */
+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'];
+	$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);
+} else {
+	/*
+	 * The master-db is not available.
+	 * Problem: because we need to start the rescue-module (to rescue the DB if this IS the
+	 * server, the master-db is running at) we have to initialize some config...
+	 */
+	$conf['last_datalog_id'] = intval('9223372036854775807'); // maxint at 32 and 64 bit systems
+	$conf['mirror_server_id'] = 0; // no mirror
+	// Set the loglevel to warning
+	$conf['log_priority'] = LOGLEVEL_WARN;
+	/*
+	 * Set the configuration to rescue the database
+	 */
+	$conf['serverconfig']['rescue']['try_rescue'] = 'y';
+	$conf['serverconfig']['rescue']['do_not_try_rescue_mysql'] = 'n';
 }
 
 
 // Check whether another instance of this script is already running
-if(is_file($conf['temppath'].$conf['fs_div'].'.ispconfig_lock')){
-  clearstatcache();
-  for($i=0;$i<120;$i++){ // Wait max. 1200 sec, then retry
-    if(is_file($conf['temppath'].$conf['fs_div'].'.ispconfig_lock')){
-      exec("ps aux | grep '/usr/local/ispconfig/server/[s]erver.php' | 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();
-    }
-  }
+if (is_file($conf['temppath'] . $conf['fs_div'] . '.ispconfig_lock')) {
+	clearstatcache();
+	for ($i = 0; $i < 120; $i++) { // Wait max. 1200 sec, then retry
+		if (is_file($conf['temppath'] . $conf['fs_div'] . '.ispconfig_lock')) {
+			exec("ps aux | grep '/usr/local/ispconfig/server/[s]erver.php' | 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();
+		}
+	}
 }
 
 // Set Lockfile
-@touch($conf['temppath'].$conf['fs_div'].'.ispconfig_lock');
-$app->log('Set Lock: '.$conf['temppath'].$conf['fs_div'].'.ispconfig_lock', LOGLEVEL_DEBUG);
+@touch($conf['temppath'] . $conf['fs_div'] . '.ispconfig_lock');
+$app->log('Set Lock: ' . $conf['temppath'] . $conf['fs_div'] . '.ispconfig_lock', LOGLEVEL_DEBUG);
 
+/** Do we need to start the core-modules */
+$needStartCore = true;
 
-if($app->db->connect() && $app->dbmaster->connect()) {
+/*
+ * Next we try to process the datalog
+ */
+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)");
+	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)");
+		$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)");
 	}
-	
+
 	$tmp_num_records = $tmp_rec['number'];
 	unset($tmp_rec);
 
-	if($tmp_num_records > 0) {
+	if ($tmp_num_records > 0) {
 		/*
-	 	There is something to do, triggert by the database -> do it!
-		*/
+		  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
@@ -118,30 +140,38 @@
 		$app->modules->processDatalog();
 		// Restart services that need to 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');
+		// All modules are already loaded and processed, so there is NO NEED to load the core once again...
+		$needStartCore = false;
 	}
 } else {
-	if(!$app->db->connect()) {
-		$app->log('Unable to connect to local server.'.$app->db->errorMessage,LOGLEVEL_WARN);
+	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);
+		$app->log('Unable to connect to master server.' . $app->dbmaster->errorMessage, LOGLEVEL_WARN);
 	}
 }
 
+/*
+ * Under normal circumstances the system was loaded and all updates are done.
+ * but if we do not have to update anything or if the database is not accessible, then we
+ * have to start the core-system (if the database is accessible, we need the core because of the
+ * monitoring. If the databse is NOT accessible, we need the core because of rescue the db...
+ */
+if ($needStartCore) {
+	// 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');
+}
+
+
 // Remove lock
-@unlink($conf['temppath'].$conf['fs_div'].'.ispconfig_lock');
-$app->log('Remove Lock: '.$conf['temppath'].$conf['fs_div'].'.ispconfig_lock',LOGLEVEL_DEBUG);
+@unlink($conf['temppath'] . $conf['fs_div'] . '.ispconfig_lock');
+$app->log('Remove Lock: ' . $conf['temppath'] . $conf['fs_div'] . '.ispconfig_lock', LOGLEVEL_DEBUG);
 
 
 die("finished.\n");

--
Gitblit v1.9.1