X-Git-Url: https://git.heureux-cyclage.org/?a=blobdiff_plain;ds=sidebyside;f=maintenance%2FrefreshFileHeaders.php;h=bca1c964353bd35fed8d1746450cb4bc26aaccd9;hb=f5b9af121a07ecc674a63cbc65c3a01e9fa7d785;hp=b9b418cb2b9702b90cd46595c58976594b17eec6;hpb=dce93c060464edc62bafa05e9cd9da8e249626d3;p=lhc%2Fweb%2Fwiklou.git diff --git a/maintenance/refreshFileHeaders.php b/maintenance/refreshFileHeaders.php index b9b418cb2b..bca1c96435 100644 --- a/maintenance/refreshFileHeaders.php +++ b/maintenance/refreshFileHeaders.php @@ -20,7 +20,6 @@ * http://www.gnu.org/copyleft/gpl.html * * @file - * @author Aaron Schulz * @ingroup Maintenance */ @@ -48,11 +47,14 @@ class RefreshFileHeaders extends Maintenance { $count = 0; $dbr = $this->getDB( DB_REPLICA ); + do { $conds = [ "img_name > {$dbr->addQuotes( $start )}" ]; + if ( strlen( $end ) ) { $conds[] = "img_name <= {$dbr->addQuotes( $end )}"; } + $res = $dbr->select( 'image', '*', $conds, __METHOD__, [ 'LIMIT' => $this->mBatchSize, 'ORDER BY' => 'img_name ASC' ] ); @@ -62,34 +64,48 @@ class RefreshFileHeaders extends Maintenance { $res->rewind(); } + $backendOperations = []; + foreach ( $res as $row ) { $file = $repo->newFileFromRow( $row ); $headers = $file->getContentHeaders(); + if ( count( $headers ) ) { - $this->updateFileHeaders( $file, $headers ); + $backendOperations[] = [ + 'op' => 'describe', 'src' => $file->getPath(), 'headers' => $headers + ]; } + // Do all of the older file versions... foreach ( $file->getHistory() as $oldFile ) { $headers = $oldFile->getContentHeaders(); if ( count( $headers ) ) { - $this->updateFileHeaders( $oldFile, $headers ); + $backendOperations[] = [ + 'op' => 'describe', 'src' => $oldFile->getPath(), 'headers' => $headers + ]; } } + if ( $this->hasOption( 'verbose' ) ) { - $this->output( "Updated headers for file '{$row->img_name}'.\n" ); + $this->output( "Queued headers update for file '{$row->img_name}'.\n" ); } - ++$count; + $start = $row->img_name; // advance } + + $backendOperationsCount = count( $backendOperations ); + $count += $backendOperationsCount; + + $this->output( "Updating headers for {$backendOperationsCount} file(s).\n" ); + $this->updateFileHeaders( $repo, $backendOperations ); } while ( $res->numRows() === $this->mBatchSize ); $this->output( "Done. Updated headers for $count file(s).\n" ); } - protected function updateFileHeaders( File $file, array $headers ) { - $status = $file->getRepo()->getBackend()->describe( [ - 'src' => $file->getPath(), 'headers' => $headers - ] ); + protected function updateFileHeaders( $repo, $backendOperations ) { + $status = $repo->getBackend()->doQuickOperations( $backendOperations ); + if ( !$status->isGood() ) { $this->error( "Encountered error: " . print_r( $status, true ) ); }