Public_Tools/wavelog
2
0
Fork 0
mirror of https://github.com/wavelog/wavelog.git synced 2026-03-22 02:14:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

lock mig process with lock file in cache folder to avoid raceconds

Browse Source
This commit is contained in:
HB9HIL
2024-06-25 13:05:24 +02:00
parent 1baede673a
commit 4e723e7bbf
1 changed files with 32 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
system/libraries/Migration.php
View File

@@ -86,6 +86,13 @@ class CI_Migration {
*/
protected $_migration_table = 'migrations';
/**
* Name and Path of the migration lockfile
*
* @var string
*/
protected $_migration_lockfile = APPPATH . 'cache/.migration_running';
/**
* Whether to automatically run migrations
*
@@ -297,15 +304,32 @@ class CI_Migration {
$pending[$number] = array($class, $method);
}
// Now just run the necessary migrations
foreach ($pending as $number => $migration)
{
log_message('debug', 'Migrating '.$method.' from version '.$current_version.' to version '.$number);
// Let's check if a migration is currently running
if (!file_exists($this->_migration_lockfile)) {
$migration[0] = new $migration[0];
call_user_func($migration);
$current_version = $number;
$this->_update_version($current_version);
// Create the lockfile
if (touch($this->_migration_lockfile)) {
// Now just run the necessary migrations
foreach ($pending as $number => $migration)
{
log_message('debug', 'Migrating '.$method.' from version '.$current_version.' to version '.$number);
$migration[0] = new $migration[0];
call_user_func($migration);
$current_version = $number;
$this->_update_version($current_version);
}
// After the migrations we can remove the lockfile
unlink($this->_migration_lockfile);
} else {
log_message('error', 'Failed to create Migration Lockfile. Check directory permissions.');
}
} else {
log_message('debug', 'Migration process is currently locked. Second migration attempt ignored.');
}
// This is necessary when moving down, since the the last migration applied