wikimedia /
mediawiki
| @@ 343-347 (lines=5) @@ | ||
| 340 | if ( $i !== false ) { |
|
| 341 | # Slave connection successful |
|
| 342 | # Wait for the session master pos for a short time |
|
| 343 | if ( $this->mWaitForPos && $i > 0 ) { |
|
| 344 | if ( !$this->doWait( $i ) ) { |
|
| 345 | $this->mServers[$i]['slave pos'] = $conn->getSlavePos(); |
|
| 346 | } |
|
| 347 | } |
|
| 348 | if ( $this->mReadIndex <= 0 && $this->mLoads[$i] > 0 && $group === false ) { |
|
| 349 | $this->mReadIndex = $i; |
|
| 350 | # Record if the generic reader index is in "lagged slave" mode |
|
| @@ 373-378 (lines=6) @@ | ||
| 370 | $this->mWaitForPos = $pos; |
|
| 371 | $i = $this->mReadIndex; |
|
| 372 | ||
| 373 | if ( $i > 0 ) { |
|
| 374 | if ( !$this->doWait( $i ) ) { |
|
| 375 | $this->mServers[$i]['slave pos'] = $this->getAnyOpenConnection( $i )->getSlavePos(); |
|
| 376 | $this->laggedSlaveMode = true; |
|
| 377 | } |
|
| 378 | } |
|
| 379 | } |
|
| 380 | ||
| 381 | /** |
|
