wikimedia /
mediawiki
| @@ 1553-1562 (lines=10) @@ | ||
| 1550 | * @param callable $callback |
|
| 1551 | * @param array $params |
|
| 1552 | */ |
|
| 1553 | public function forEachOpenConnection( $callback, array $params = [] ) { |
|
| 1554 | foreach ( $this->mConns as $connsByServer ) { |
|
| 1555 | foreach ( $connsByServer as $serverConns ) { |
|
| 1556 | foreach ( $serverConns as $conn ) { |
|
| 1557 | $mergedParams = array_merge( [ $conn ], $params ); |
|
| 1558 | call_user_func_array( $callback, $mergedParams ); |
|
| 1559 | } |
|
| 1560 | } |
|
| 1561 | } |
|
| 1562 | } |
|
| 1563 | ||
| 1564 | /** |
|
| 1565 | * Call a function with each open connection object to a master |
|
| @@ 1589-1601 (lines=13) @@ | ||
| 1586 | * @param array $params |
|
| 1587 | * @since 1.28 |
|
| 1588 | */ |
|
| 1589 | public function forEachOpenReplicaConnection( $callback, array $params = [] ) { |
|
| 1590 | foreach ( $this->mConns as $connsByServer ) { |
|
| 1591 | foreach ( $connsByServer as $i => $serverConns ) { |
|
| 1592 | if ( $i === $this->getWriterIndex() ) { |
|
| 1593 | continue; // skip master |
|
| 1594 | } |
|
| 1595 | foreach ( $serverConns as $conn ) { |
|
| 1596 | $mergedParams = array_merge( [ $conn ], $params ); |
|
| 1597 | call_user_func_array( $callback, $mergedParams ); |
|
| 1598 | } |
|
| 1599 | } |
|
| 1600 | } |
|
| 1601 | } |
|
| 1602 | ||
| 1603 | /** |
|
| 1604 | * Get the hostname and lag time of the most-lagged replica DB |
|
