// Super doesn't open when $user is false, but we can work with $dbName,
// which is derived from the file path in this case.
$this->openFile( $p['dbFilePath'] );
+ $lockDomain = md5( $p['dbFilePath'] );
} else {
$this->mDBname = $p['dbname'];
+ $lockDomain = $this->mDBname;
// Stock wiki mode using standard file names per DB.
parent::__construct( $p );
// Super doesn't open when $user is false, but we can work with $dbName
wfWarn( "Invalid SQLite transaction mode provided." );
}
- $this->lockMgr = new FSLockManager( [ 'lockDirectory' => "{$this->dbDir}/locks" ] );
+ $this->lockMgr = new FSLockManager( [
+ 'domain' => $lockDomain,
+ 'lockDirectory' => "{$this->dbDir}/locks"
+ ] );
}
/**
self::LOCK_EX => self::LOCK_EX
];
- protected $lockDir; // global dir for all servers
+ /** @var string Global dir for all servers */
+ protected $lockDir;
/** @var array Map of (locked key => lock file handle) */
protected $handles = [];
+ /** @var bool */
+ protected $isWindows;
+
/**
* Construct a new instance from configuration.
*
parent::__construct( $config );
$this->lockDir = $config['lockDirectory'];
+ $this->isWindows = ( strtoupper( substr( PHP_OS, 0, 3 ) ) === 'WIN' );
}
/**
} else {
MediaWiki\suppressWarnings();
$handle = fopen( $this->getLockPath( $path ), 'a+' );
- MediaWiki\restoreWarnings();
if ( !$handle ) { // lock dir missing?
- wfMkdirParents( $this->lockDir );
+ mkdir( $this->lockDir, 0777, true );
$handle = fopen( $this->getLockPath( $path ), 'a+' ); // try again
}
+ MediaWiki\restoreWarnings();
}
if ( $handle ) {
// Either a shared or exclusive lock
}
// Unlock handles to release locks and delete
// any lock files that end up with no locks on them...
- if ( wfIsWindows() ) {
+ if ( $this->isWindows ) {
// Windows: for any process, including this one,
// calling unlink() on a locked file will fail
$status->merge( $this->closeLockHandles( $path, $handlesToClose ) );
* This only applies if locks are not tied to a connection/process.
*/
public function __construct( array $config ) {
- $this->domain = isset( $config['domain'] ) ? $config['domain'] : wfWikiID();
+ $this->domain = isset( $config['domain'] ) ? $config['domain'] : 'global';
if ( isset( $config['lockTTL'] ) ) {
$this->lockTTL = max( 5, $config['lockTTL'] );
} elseif ( PHP_SAPI === 'cli' ) {