|
@@ 156-161 (lines=6) @@
|
| 153 |
|
// Scale from 10% to 100% of nominal weight |
| 154 |
|
$weightScales[$i] = max( $newWeight, .10 ); |
| 155 |
|
|
| 156 |
|
if ( !$conn ) { |
| 157 |
|
$lagTimes[$i] = false; |
| 158 |
|
$host = $this->parent->getServerName( $i ); |
| 159 |
|
$this->replLogger->error( __METHOD__ . ": host $host is unreachable" ); |
| 160 |
|
continue; |
| 161 |
|
} |
| 162 |
|
|
| 163 |
|
$lagTimes[$i] = $conn->getLag(); |
| 164 |
|
if ( $lagTimes[$i] === false ) { |
|
@@ 164-167 (lines=4) @@
|
| 161 |
|
} |
| 162 |
|
|
| 163 |
|
$lagTimes[$i] = $conn->getLag(); |
| 164 |
|
if ( $lagTimes[$i] === false ) { |
| 165 |
|
$host = $this->parent->getServerName( $i ); |
| 166 |
|
$this->replLogger->error( __METHOD__ . ": host $host is not replicating?" ); |
| 167 |
|
} |
| 168 |
|
|
| 169 |
|
if ( $close ) { |
| 170 |
|
# Close the connection to avoid sleeper connections piling up. |