wikimedia /
mediawiki
| @@ 1536-1545 (lines=10) @@ | ||
| 1533 | * @param callable $callback |
|
| 1534 | * @param array $params |
|
| 1535 | */ |
|
| 1536 | public function forEachOpenConnection( $callback, array $params = [] ) { |
|
| 1537 | foreach ( $this->mConns as $connsByServer ) { |
|
| 1538 | foreach ( $connsByServer as $serverConns ) { |
|
| 1539 | foreach ( $serverConns as $conn ) { |
|
| 1540 | $mergedParams = array_merge( [ $conn ], $params ); |
|
| 1541 | call_user_func_array( $callback, $mergedParams ); |
|
| 1542 | } |
|
| 1543 | } |
|
| 1544 | } |
|
| 1545 | } |
|
| 1546 | ||
| 1547 | /** |
|
| 1548 | * Call a function with each open connection object to a master |
|
| @@ 1572-1584 (lines=13) @@ | ||
| 1569 | * @param array $params |
|
| 1570 | * @since 1.28 |
|
| 1571 | */ |
|
| 1572 | public function forEachOpenReplicaConnection( $callback, array $params = [] ) { |
|
| 1573 | foreach ( $this->mConns as $connsByServer ) { |
|
| 1574 | foreach ( $connsByServer as $i => $serverConns ) { |
|
| 1575 | if ( $i === $this->getWriterIndex() ) { |
|
| 1576 | continue; // skip master |
|
| 1577 | } |
|
| 1578 | foreach ( $serverConns as $conn ) { |
|
| 1579 | $mergedParams = array_merge( [ $conn ], $params ); |
|
| 1580 | call_user_func_array( $callback, $mergedParams ); |
|
| 1581 | } |
|
| 1582 | } |
|
| 1583 | } |
|
| 1584 | } |
|
| 1585 | ||
| 1586 | /** |
|
| 1587 | * Get the hostname and lag time of the most-lagged replica DB |
|
