File MysqlReplicationReporter.php has 364 lines of code (exceeds 250 allowed). Consider refactoring.

Open

<?php
/**
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or

Method primaryPosWait has 107 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function primaryPosWait( IDatabase $conn, DBPrimaryPos $pos, $timeout ) {
        if ( !( $pos instanceof MySQLPrimaryPos ) ) {
            throw new InvalidArgumentException( "Position not an instance of MySQLPrimaryPos" );
        }

Function primaryPosWait has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

    public function primaryPosWait( IDatabase $conn, DBPrimaryPos $pos, $timeout ) {
        if ( !( $pos instanceof MySQLPrimaryPos ) ) {
            throw new InvalidArgumentException( "Position not an instance of MySQLPrimaryPos" );
        }

• Read up
  Read up

Function getPrimaryPos has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

    public function getPrimaryPos( IDatabase $conn ) {
        $now = microtime( true ); // as-of-time *before* fetching GTID variables

        $pos = false;
        if ( $this->useGTIDs() ) {

• Read up
  Read up

Method getLagFromPtHeartbeat has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    protected function getLagFromPtHeartbeat( IDatabase $conn ) {
        $currentTrxInfo = $this->getRecordedTransactionLagStatus( $conn );
        if ( $currentTrxInfo ) {
            // There is an active transaction and the initial lag was already queried
            $staleness = microtime( true ) - $currentTrxInfo['since'];

Method __construct has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

        $topologyRole,
        $logger,
        $srvCache,
        $lagDetectionMethod,
        $lagDetectionOptions,

Function getReplicaPos has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

    public function getReplicaPos( IDatabase $conn ) {
        $now = microtime( true ); // as-of-time *before* fetching GTID variables

        if ( $this->useGTIDs() ) {
            // Try to use GTIDs, fallbacking to binlog positions if not possible

• Read up
  Read up

Avoid too many return statements within this method.

Open

        return $status;