}
$masterName = $lb->getServerName( $lb->getWriterIndex() );
- if ( $lb->getServerCount() > 1 ) {
- $pos = $lb->getMasterPos();
+ if ( $lb->hasStreamingReplicaServers() ) {
+ $pos = $lb->getReplicaResumePos();
if ( $pos ) {
$this->logger->debug( __METHOD__ . ": LB for '$masterName' has pos $pos\n" );
$this->shutdownPositions[$masterName] = $pos;