public function __construct() {
parent::__construct();
- $this->mDescription = "Clean up abandoned files in temporary uploaded file stash";
+ $this->addDescription( 'Clean up abandoned files in temporary uploaded file stash' );
$this->setBatchSize( 50 );
}
$repo = RepoGroup::singleton()->getLocalRepo();
$tempRepo = $repo->getTempRepo();
- $dbr = $repo->getSlaveDb();
+ $dbr = $repo->getReplicaDB();
// how far back should this look for files to delete?
$cutoff = time() - $wgUploadStashMaxAge;
$this->output( "No stashed files to cleanup according to the DB.\n" );
} else {
// finish the read before starting writes.
- $keys = array();
+ $keys = [];
foreach ( $res as $row ) {
array_push( $keys, $row->us_key );
}
// Delete all the corresponding thumbnails...
$dir = $tempRepo->getZonePath( 'thumb' );
- $iterator = $tempRepo->getBackend()->getFileList( array( 'dir' => $dir, 'adviseStat' => 1 ) );
+ $iterator = $tempRepo->getBackend()->getFileList( [ 'dir' => $dir, 'adviseStat' => 1 ] );
$this->output( "Deleting old thumbnails...\n" );
$i = 0;
- $batch = array(); // operation batch
+ $batch = []; // operation batch
foreach ( $iterator as $file ) {
if ( wfTimestamp( TS_UNIX, $tempRepo->getFileTimestamp( "$dir/$file" ) ) < $cutoff ) {
- $batch[] = array( 'op' => 'delete', 'src' => "$dir/$file" );
- if ( count( $batch ) >= $this->mBatchSize ) {
+ $batch[] = [ 'op' => 'delete', 'src' => "$dir/$file" ];
+ if ( count( $batch ) >= $this->getBatchSize() ) {
$this->doOperations( $tempRepo, $batch );
$i += count( $batch );
- $batch = array();
+ $batch = [];
$this->output( "$i\n" );
}
}
// Apparently lots of stash files are not registered in the DB...
$dir = $tempRepo->getZonePath( 'public' );
- $iterator = $tempRepo->getBackend()->getFileList( array( 'dir' => $dir, 'adviseStat' => 1 ) );
+ $iterator = $tempRepo->getBackend()->getFileList( [ 'dir' => $dir, 'adviseStat' => 1 ] );
$this->output( "Deleting orphaned temp files...\n" );
if ( strpos( $dir, '/local-temp' ) === false ) { // sanity check
$this->error( "Temp repo is not using the temp container.", 1 ); // die
}
$i = 0;
- $batch = array(); // operation batch
+ $batch = []; // operation batch
foreach ( $iterator as $file ) {
if ( wfTimestamp( TS_UNIX, $tempRepo->getFileTimestamp( "$dir/$file" ) ) < $cutoff ) {
- $batch[] = array( 'op' => 'delete', 'src' => "$dir/$file" );
- if ( count( $batch ) >= $this->mBatchSize ) {
+ $batch[] = [ 'op' => 'delete', 'src' => "$dir/$file" ];
+ if ( count( $batch ) >= $this->getBatchSize() ) {
$this->doOperations( $tempRepo, $batch );
$i += count( $batch );
- $batch = array();
+ $batch = [];
$this->output( "$i\n" );
}
}