| | |
| | | <?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 |
| | |
| | | $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"); |