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