sql/rpl_opt_tracker.h

/* Copyright (c) 2024, 2025, Oracle and/or its affiliates.

   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License, version 2.0,
   as published by the Free Software Foundation.

   This program is designed to work with certain software (including
   but not limited to OpenSSL) that is licensed under separate terms,
   as designated in a particular file or component or in included license
   documentation.  The authors of MySQL hereby grant you an additional
   permission to link the program and your derivative works with the
   separately licensed software that they have either included with
   the program or referenced in the documentation.

   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU General Public License, version 2.0, for more details.

   You should have received a copy of the GNU General Public License
   along with this program; if not, write to the Free Software
   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301  USA */

#ifndef RPL_OPT_TRACKER_H_
#define RPL_OPT_TRACKER_H_

#include <my_systime.h>
#include <mysql/components/minimal_chassis.h>
#include <mysql/components/my_service.h>
#include <mysql/components/services/bits/psi_thread_bits.h>
#include <mysql/components/services/mysql_option_tracker.h>
#include <string>

/**
  Class to track the state and usage data of Replication features.
*/
class Rpl_opt_tracker {
 public:
  Rpl_opt_tracker(SERVICE_TYPE_NO_CONST(registry_registration) *
                      srv_registry_registration,
                  SERVICE_TYPE_NO_CONST(registry_registration) *
                      srv_registry_registration_no_lock);
  virtual ~Rpl_opt_tracker();
  /* Prevent user from invoking default assignment function. */
  Rpl_opt_tracker &operator=(const Rpl_opt_tracker &info);
  /* Prevent user from invoking default constructor function. */
  Rpl_opt_tracker(const Rpl_opt_tracker &info);

  /**
    The thread worker that periodically tracks the replication
    features.
  */
  void worker();

  /**
    Start the thread that periodically tracks the replication
    features.
  */
  void start_worker();

  /**
    Stop the thread that periodically tracks the replication
    features.
  */
  void stop_worker();

  /**
    Tracks the Replication Replica feature, including the usage data.
    It only updates usage data if the feature is enabled.

    @param enabled  true:  tracks as enabled
                    false: tracks as disabled
  */
  void track_replication_replica(bool enabled) const;

 private:
  using Service_type = SERVICE_TYPE(mysql_option_tracker_option);
  using Tracker_service_guard = my_service<Service_type>;
  static constexpr auto m_service_name = "mysql_option_tracker_option";

  /**
    Helper method to get Replication Replica feature status.

    @return Replication Replica feature status
      @retval true   enabled
      @retval false  disabled
  */
  static bool is_replication_replica_enabled();

  /**
    Tracks a feature, including the usage data.
    It only updates usage data if the feature is enabled.
    Internal method to be used after the mysql_option_tracker_option
    service is acquired.

    @param service_guard acquired service guard
    @param enabled  true:  tracks as enabled
                    false: tracks as disabled
    @param fname feature name
    @param usage_counter feature usage counter
  */
  static void track(const Tracker_service_guard &service_guard, bool enabled,
                    const std::string &fname,
                    unsigned long long &usage_counter);

  /**
    Tracks the Binary Log feature, including the usage data.
    It only updates usage data if the feature is enabled.
    Internal method to be used after the mysql_option_tracker_option
    service is acquired.

    @param service_guard acquired service guard
    @param enabled  true:  tracks as enabled
                    false: tracks as disabled
  */
  void track_binary_log(const Tracker_service_guard &service_guard,
                        bool enabled) const;

  /**
    Tracks the Replication Replica feature, including the usage data.
    It only updates usage data if the feature is enabled.

    @param service_guard acquired service guard
    @param enabled  true:  tracks as enabled
                    false: tracks as disabled
  */
  void track_replication_replica(const Tracker_service_guard &service_guard,
                                 bool enabled) const;

  SERVICE_TYPE_NO_CONST(registry_registration) *
      m_srv_registry_registration_no_lock{nullptr};

  my_thread_handle m_thread_id;
  bool m_stop_worker{false};
  static constexpr const Timeout_type s_tracking_period{600};  // 10 minutes

  static const std::string s_c_name_mysql_server;
  static const std::string s_f_name_binary_log;
  static const std::string s_f_name_replication_replica;

 public:
  static unsigned long long m_opt_option_tracker_usage_binary_log;
  static unsigned long long m_opt_option_tracker_usage_replication_replica;

 protected:
  static bool cb_binlog(unsigned long long new_value) {
    m_opt_option_tracker_usage_binary_log = new_value;
    return false;
  }
  static bool cb_binlog_define_failed;
  static bool cb_replica(unsigned long long new_value) {
    m_opt_option_tracker_usage_replication_replica = new_value;
    return false;
  }
  static bool cb_replica_define_failed;
};

/**
  The rpl_opt_tracker singleton.
*/
extern Rpl_opt_tracker *rpl_opt_tracker;

#endif /* RPL_OPT_TRACKER_H_ */