@@ -328,7 +328,7 @@ |
||
| 328 | 328 | /** |
| 329 | 329 | * @param DatabaseBase $db |
| 330 | 330 | * @param string $error |
| 331 | - * @param int|string $errno |
|
| 331 | + * @param integer $errno |
|
| 332 | 332 | * @param string $sql |
| 333 | 333 | * @param string $fname |
| 334 | 334 | */ |
@@ -753,7 +753,7 @@ discard block |
||
| 753 | 753 | /** |
| 754 | 754 | * @see FileBackendStore::getFileSha1Base36() |
| 755 | 755 | * @param array $params |
| 756 | - * @return bool|string |
|
| 756 | + * @return false|string |
|
| 757 | 757 | */ |
| 758 | 758 | protected function doGetFileSha1Base36( array $params ) { |
| 759 | 759 | $fsFile = $this->getLocalReference( $params ); |
@@ -1031,7 +1031,7 @@ discard block |
||
| 1031 | 1031 | * to a list of storage paths to be locked. All returned paths are |
| 1032 | 1032 | * normalized. |
| 1033 | 1033 | * |
| 1034 | - * @param array $performOps List of FileOp objects |
|
| 1034 | + * @param FileOp[] $performOps List of FileOp objects |
|
| 1035 | 1035 | * @return array (LockManager::LOCK_UW => path list, LockManager::LOCK_EX => path list) |
| 1036 | 1036 | */ |
| 1037 | 1037 | final public function getPathsToLockForOpsInternal( array $performOps ) { |
@@ -128,7 +128,7 @@ |
||
| 128 | 128 | * Get the value of the parameter with the given name |
| 129 | 129 | * |
| 130 | 130 | * @param string $name |
| 131 | - * @return mixed Returns null if the parameter is not set |
|
| 131 | + * @return string Returns null if the parameter is not set |
|
| 132 | 132 | */ |
| 133 | 133 | final public function getParam( $name ) { |
| 134 | 134 | return isset( $this->params[$name] ) ? $this->params[$name] : null; |
@@ -470,6 +470,10 @@ |
||
| 470 | 470 | return $status; |
| 471 | 471 | } |
| 472 | 472 | |
| 473 | + /** |
|
| 474 | + * @param string $fullCont |
|
| 475 | + * @param string $dirRel |
|
| 476 | + */ |
|
| 473 | 477 | protected function doSecureInternal( $fullCont, $dirRel, array $params ) { |
| 474 | 478 | $status = Status::newGood(); |
| 475 | 479 | list( , $shortCont, ) = FileBackend::splitStoragePath( $params['dir'] ); |
@@ -644,7 +644,7 @@ discard block |
||
| 644 | 644 | } |
| 645 | 645 | |
| 646 | 646 | /** |
| 647 | - * @return bool|string |
|
| 647 | + * @return string|false |
|
| 648 | 648 | */ |
| 649 | 649 | protected function restoreErrorHandler() { |
| 650 | 650 | restore_error_handler(); |
@@ -756,7 +756,7 @@ discard block |
||
| 756 | 756 | } |
| 757 | 757 | |
| 758 | 758 | /** |
| 759 | - * @param $sql |
|
| 759 | + * @param string $sql |
|
| 760 | 760 | * @return string|null |
| 761 | 761 | */ |
| 762 | 762 | protected function getQueryVerb( $sql ) { |
@@ -900,6 +900,12 @@ discard block |
||
| 900 | 900 | return $res; |
| 901 | 901 | } |
| 902 | 902 | |
| 903 | + /** |
|
| 904 | + * @param string $sql |
|
| 905 | + * @param string $commentedSql |
|
| 906 | + * @param boolean $isWrite |
|
| 907 | + * @param string $fname |
|
| 908 | + */ |
|
| 903 | 909 | private function doProfiledQuery( $sql, $commentedSql, $isWrite, $fname ) { |
| 904 | 910 | $isMaster = !is_null( $this->getLBInfo( 'master' ) ); |
| 905 | 911 | # generalizeSQL() will probably cut down the query to reasonable |
@@ -981,6 +987,10 @@ discard block |
||
| 981 | 987 | } |
| 982 | 988 | } |
| 983 | 989 | |
| 990 | + /** |
|
| 991 | + * @param string $sql |
|
| 992 | + * @param boolean $priorWritesPending |
|
| 993 | + */ |
|
| 984 | 994 | private function canRecoverFromDisconnect( $sql, $priorWritesPending ) { |
| 985 | 995 | # Transaction dropped; this can mean lost writes, or REPEATABLE-READ snapshots. |
| 986 | 996 | # Dropped connections also mean that named locks are automatically released. |
@@ -1100,7 +1110,7 @@ discard block |
||
| 1100 | 1110 | * |
| 1101 | 1111 | * @param array $options Associative array of options to be turned into |
| 1102 | 1112 | * an SQL query, valid keys are listed in the function. |
| 1103 | - * @return array |
|
| 1113 | + * @return string[] |
|
| 1104 | 1114 | * @see DatabaseBase::select() |
| 1105 | 1115 | */ |
| 1106 | 1116 | protected function makeSelectOptions( $options ) { |
@@ -2271,6 +2281,9 @@ discard block |
||
| 2271 | 2281 | return $this->insert( $destTable, $rows, $fname, $insertOptions ); |
| 2272 | 2282 | } |
| 2273 | 2283 | |
| 2284 | + /** |
|
| 2285 | + * @param string $destTable |
|
| 2286 | + */ |
|
| 2274 | 2287 | protected function nativeInsertSelect( $destTable, $srcTable, $varMap, $conds, |
| 2275 | 2288 | $fname = __METHOD__, |
| 2276 | 2289 | $insertOptions = [], $selectOptions = [] |
@@ -3345,7 +3358,7 @@ discard block |
||
| 3345 | 3358 | } |
| 3346 | 3359 | |
| 3347 | 3360 | /** |
| 3348 | - * @return string|bool Reason this DB is read-only or false if it is not |
|
| 3361 | + * @return string|false Reason this DB is read-only or false if it is not |
|
| 3349 | 3362 | */ |
| 3350 | 3363 | protected function getReadOnlyReason() { |
| 3351 | 3364 | $reason = $this->getLBInfo( 'readOnlyReason' ); |
@@ -36,22 +36,8 @@ discard block |
||
| 36 | 36 | * |
| 37 | 37 | * Sub-classes will extend the required keys in $conf with additional parameters |
| 38 | 38 | * |
| 39 | - * @param $conf $params Array with keys: |
|
| 40 | - * - localDomain: A DatabaseDomain or domain ID string. |
|
| 41 | - * - readOnlyReason : Reason the master DB is read-only if so [optional] |
|
| 42 | - * - srvCache : BagOStuff object for server cache [optional] |
|
| 43 | - * - memCache : BagOStuff object for cluster memory cache [optional] |
|
| 44 | - * - wanCache : WANObjectCache object [optional] |
|
| 45 | - * - hostname : The name of the current server [optional] |
|
| 46 | - * - cliMode: Whether the execution context is a CLI script. [optional] |
|
| 47 | - * - profiler : Class name or instance with profileIn()/profileOut() methods. [optional] |
|
| 48 | - * - trxProfiler: TransactionProfiler instance. [optional] |
|
| 49 | - * - replLogger: PSR-3 logger instance. [optional] |
|
| 50 | - * - connLogger: PSR-3 logger instance. [optional] |
|
| 51 | - * - queryLogger: PSR-3 logger instance. [optional] |
|
| 52 | - * - perfLogger: PSR-3 logger instance. [optional] |
|
| 53 | - * - errorLogger : Callback that takes an Exception and logs it. [optional] |
|
| 54 | 39 | * @throws InvalidArgumentException |
| 40 | + * @return void |
|
| 55 | 41 | */ |
| 56 | 42 | public function __construct( array $conf ); |
| 57 | 43 | |
@@ -59,6 +45,7 @@ discard block |
||
| 59 | 45 | * Disables all load balancers. All connections are closed, and any attempt to |
| 60 | 46 | * open a new connection will result in a DBAccessError. |
| 61 | 47 | * @see ILoadBalancer::disable() |
| 48 | + * @return void |
|
| 62 | 49 | */ |
| 63 | 50 | public function destroy(); |
| 64 | 51 | |
@@ -123,6 +110,7 @@ discard block |
||
| 123 | 110 | * Prepare all tracked load balancers for shutdown |
| 124 | 111 | * @param integer $mode One of the class SHUTDOWN_* constants |
| 125 | 112 | * @param callable|null $workCallback Work to mask ChronologyProtector writes |
| 113 | + * @return void |
|
| 126 | 114 | */ |
| 127 | 115 | public function shutdown( |
| 128 | 116 | $mode = self::SHUTDOWN_CHRONPROT_SYNC, callable $workCallback = null |
@@ -132,6 +120,7 @@ discard block |
||
| 132 | 120 | * Commit all replica DB transactions so as to flush any REPEATABLE-READ or SSI snapshot |
| 133 | 121 | * |
| 134 | 122 | * @param string $fname Caller name |
| 123 | + * @return void |
|
| 135 | 124 | */ |
| 136 | 125 | public function flushReplicaSnapshots( $fname = __METHOD__ ); |
| 137 | 126 | |
@@ -142,6 +131,7 @@ discard block |
||
| 142 | 131 | * @param string $fname Caller name |
| 143 | 132 | * @param array $options Options map: |
| 144 | 133 | * - maxWriteDuration: abort if more than this much time was spent in write queries |
| 134 | + * @return void |
|
| 145 | 135 | */ |
| 146 | 136 | public function commitAll( $fname = __METHOD__, array $options = [] ); |
| 147 | 137 | |
@@ -157,6 +147,7 @@ discard block |
||
| 157 | 147 | * |
| 158 | 148 | * @param string $fname |
| 159 | 149 | * @throws DBTransactionError |
| 150 | + * @return void |
|
| 160 | 151 | */ |
| 161 | 152 | public function beginMasterChanges( $fname = __METHOD__ ); |
| 162 | 153 | |
@@ -166,12 +157,14 @@ discard block |
||
| 166 | 157 | * @param array $options Options map: |
| 167 | 158 | * - maxWriteDuration: abort if more than this much time was spent in write queries |
| 168 | 159 | * @throws Exception |
| 160 | + * @return void |
|
| 169 | 161 | */ |
| 170 | 162 | public function commitMasterChanges( $fname = __METHOD__, array $options = [] ); |
| 171 | 163 | |
| 172 | 164 | /** |
| 173 | 165 | * Rollback changes on all master connections |
| 174 | 166 | * @param string $fname Caller name |
| 167 | + * @return void |
|
| 175 | 168 | */ |
| 176 | 169 | public function rollbackMasterChanges( $fname = __METHOD__ ); |
| 177 | 170 | |
@@ -216,6 +209,7 @@ discard block |
||
| 216 | 209 | * - timeout : Max wait time. Default: ~60 seconds |
| 217 | 210 | * - ifWritesSince: Only wait if writes were done since this UNIX timestamp |
| 218 | 211 | * @throws DBReplicationWaitError If a timeout or error occured waiting on a DB cluster |
| 212 | + * @return void |
|
| 219 | 213 | */ |
| 220 | 214 | public function waitForReplication( array $opts = [] ); |
| 221 | 215 | |
@@ -226,6 +220,7 @@ discard block |
||
| 226 | 220 | * |
| 227 | 221 | * @param string $name Callback name |
| 228 | 222 | * @param callable|null $callback Use null to unset a callback |
| 223 | + * @return void |
|
| 229 | 224 | */ |
| 230 | 225 | public function setWaitForReplicationListener( $name, callable $callback = null ); |
| 231 | 226 | |
@@ -246,6 +241,7 @@ discard block |
||
| 246 | 241 | * @param mixed $ticket Result of getEmptyTransactionTicket() |
| 247 | 242 | * @param array $opts Options to waitForReplication() |
| 248 | 243 | * @throws DBReplicationWaitError |
| 244 | + * @return void |
|
| 249 | 245 | */ |
| 250 | 246 | public function commitAndWaitForReplication( $fname, $ticket, array $opts = [] ); |
| 251 | 247 | |
@@ -259,6 +255,7 @@ discard block |
||
| 259 | 255 | * Disable the ChronologyProtector for all load balancers |
| 260 | 256 | * |
| 261 | 257 | * This can be called at the start of special API entry points |
| 258 | + * @return void |
|
| 262 | 259 | */ |
| 263 | 260 | public function disableChronologyProtection(); |
| 264 | 261 | |
@@ -266,16 +263,19 @@ discard block |
||
| 266 | 263 | * Set a new table prefix for the existing local domain ID for testing |
| 267 | 264 | * |
| 268 | 265 | * @param string $prefix |
| 266 | + * @return void |
|
| 269 | 267 | */ |
| 270 | 268 | public function setDomainPrefix( $prefix ); |
| 271 | 269 | |
| 272 | 270 | /** |
| 273 | 271 | * Close all open database connections on all open load balancers. |
| 272 | + * @return void |
|
| 274 | 273 | */ |
| 275 | 274 | public function closeAll(); |
| 276 | 275 | |
| 277 | 276 | /** |
| 278 | 277 | * @param string $agent Agent name for query profiling |
| 278 | + * @return void |
|
| 279 | 279 | */ |
| 280 | 280 | public function setAgentName( $agent ); |
| 281 | 281 | |
@@ -295,6 +295,7 @@ discard block |
||
| 295 | 295 | * - IPAddress : IP address |
| 296 | 296 | * - UserAgent : User-Agent HTTP header |
| 297 | 297 | * - ChronologyProtection : cookie/header value specifying ChronologyProtector usage |
| 298 | + * @return void |
|
| 298 | 299 | */ |
| 299 | 300 | public function setRequestInfo( array $info ); |
| 300 | 301 | } |
@@ -436,7 +436,7 @@ discard block |
||
| 436 | 436 | /** |
| 437 | 437 | * Return the list of revision fields that should be selected to create |
| 438 | 438 | * a new revision. |
| 439 | - * @return array |
|
| 439 | + * @return string[] |
|
| 440 | 440 | */ |
| 441 | 441 | public static function selectFields() { |
| 442 | 442 | global $wgContentHandlerUseDB; |
@@ -467,7 +467,7 @@ discard block |
||
| 467 | 467 | /** |
| 468 | 468 | * Return the list of revision fields that should be selected to create |
| 469 | 469 | * a new revision from an archive row. |
| 470 | - * @return array |
|
| 470 | + * @return string[] |
|
| 471 | 471 | */ |
| 472 | 472 | public static function selectArchiveFields() { |
| 473 | 473 | global $wgContentHandlerUseDB; |
@@ -498,7 +498,7 @@ discard block |
||
| 498 | 498 | /** |
| 499 | 499 | * Return the list of text fields that should be selected to read the |
| 500 | 500 | * revision text |
| 501 | - * @return array |
|
| 501 | + * @return string[] |
|
| 502 | 502 | */ |
| 503 | 503 | public static function selectTextFields() { |
| 504 | 504 | return [ |
@@ -509,7 +509,7 @@ discard block |
||
| 509 | 509 | |
| 510 | 510 | /** |
| 511 | 511 | * Return the list of page fields that should be selected from page table |
| 512 | - * @return array |
|
| 512 | + * @return string[] |
|
| 513 | 513 | */ |
| 514 | 514 | public static function selectPageFields() { |
| 515 | 515 | return [ |
@@ -524,7 +524,7 @@ discard block |
||
| 524 | 524 | |
| 525 | 525 | /** |
| 526 | 526 | * Return the list of user fields that should be selected from user table |
| 527 | - * @return array |
|
| 527 | + * @return string[] |
|
| 528 | 528 | */ |
| 529 | 529 | public static function selectUserFields() { |
| 530 | 530 | return [ 'user_name' ]; |
@@ -872,7 +872,7 @@ discard block |
||
| 872 | 872 | /** |
| 873 | 873 | * Fetch revision's user id without regard for the current user's permissions |
| 874 | 874 | * |
| 875 | - * @return string |
|
| 875 | + * @return integer |
|
| 876 | 876 | * @deprecated since 1.25, use getUser( Revision::RAW ) |
| 877 | 877 | */ |
| 878 | 878 | public function getRawUser() { |
@@ -1795,7 +1795,7 @@ discard block |
||
| 1795 | 1795 | * |
| 1796 | 1796 | * @param Title $title |
| 1797 | 1797 | * @param int $id |
| 1798 | - * @return string|bool False if not found |
|
| 1798 | + * @return string|false False if not found |
|
| 1799 | 1799 | */ |
| 1800 | 1800 | static function getTimestampFromId( $title, $id, $flags = 0 ) { |
| 1801 | 1801 | $db = ( $flags & self::READ_LATEST ) |
@@ -1894,7 +1894,7 @@ discard block |
||
| 1894 | 1894 | * @param IDatabase $db |
| 1895 | 1895 | * @param int $pageId Page ID |
| 1896 | 1896 | * @param int $revId Known current revision of this page |
| 1897 | - * @return Revision|bool Returns false if missing |
|
| 1897 | + * @return Revision Returns false if missing |
|
| 1898 | 1898 | * @since 1.28 |
| 1899 | 1899 | */ |
| 1900 | 1900 | public static function newKnownCurrent( IDatabase $db, $pageId, $revId ) { |
@@ -126,16 +126,27 @@ |
||
| 126 | 126 | return true; |
| 127 | 127 | } |
| 128 | 128 | |
| 129 | + /** |
|
| 130 | + * @param string $field |
|
| 131 | + * @param string $op |
|
| 132 | + * @param null|IDatabase $dbw |
|
| 133 | + */ |
|
| 129 | 134 | private static function buildSetBitDeletedField( $field, $op, $value, $dbw ) { |
| 130 | 135 | return $field . ' = ' . ( $op === '&' |
| 131 | 136 | ? $dbw->bitAnd( $field, $value ) |
| 132 | 137 | : $dbw->bitOr( $field, $value ) ); |
| 133 | 138 | } |
| 134 | 139 | |
| 140 | + /** |
|
| 141 | + * @param integer $userId |
|
| 142 | + */ |
|
| 135 | 143 | public static function suppressUserName( $name, $userId, $dbw = null ) { |
| 136 | 144 | return self::setUsernameBitfields( $name, $userId, '|', $dbw ); |
| 137 | 145 | } |
| 138 | 146 | |
| 147 | + /** |
|
| 148 | + * @param integer|null $userId |
|
| 149 | + */ |
|
| 139 | 150 | public static function unsuppressUserName( $name, $userId, $dbw = null ) { |
| 140 | 151 | return self::setUsernameBitfields( $name, $userId, '&', $dbw ); |
| 141 | 152 | } |
@@ -117,10 +117,16 @@ |
||
| 117 | 117 | return $this->repo->getRootDirectory() . '/' . $this->repo->getHashPath( $name ) . $name; |
| 118 | 118 | } |
| 119 | 119 | |
| 120 | + /** |
|
| 121 | + * @param Database|null $db |
|
| 122 | + */ |
|
| 120 | 123 | private function imageExists( $name, $db ) { |
| 121 | 124 | return $db->selectField( 'image', '1', [ 'img_name' => $name ], __METHOD__ ); |
| 122 | 125 | } |
| 123 | 126 | |
| 127 | + /** |
|
| 128 | + * @param Database|null $db |
|
| 129 | + */ |
|
| 124 | 130 | private function pageExists( $name, $db ) { |
| 125 | 131 | return $db->selectField( |
| 126 | 132 | 'page', |