Server IP : 104.21.38.3 / Your IP : 172.70.143.252 Web Server : Apache System : Linux krdc-ubuntu-s-2vcpu-4gb-amd-blr1-01.localdomain 5.15.0-142-generic #152-Ubuntu SMP Mon May 19 10:54:31 UTC 2025 x86_64 User : www ( 1000) PHP Version : 7.4.33 Disable Function : passthru,exec,system,putenv,chroot,chgrp,chown,shell_exec,popen,proc_open,pcntl_exec,ini_alter,ini_restore,dl,openlog,syslog,readlink,symlink,popepassthru,pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,imap_open,apache_setenv MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /www/server/mysql/src/rapid/plugin/group_replication/include/ |
Upload File : |
/* Copyright (c) 2017, 2023, 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 also distributed 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 included with MySQL. 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, 51 Franklin Street, Suite 500, Boston, MA 02110-1335 USA */ #ifndef GROUP_PARTITION_HANDLING_INCLUDE #define GROUP_PARTITION_HANDLING_INCLUDE #include "read_mode_handler.h" #include "plugin_utils.h" class Group_partition_handling { public: Group_partition_handling(Shared_writelock *shared_stop_write_lock, ulong unreachable_timeout); /** The class destructor */ virtual ~Group_partition_handling(); /** The thread handler. @return @retval 0 OK @retval !=0 Error */ int partition_thread_handler(); /** Launch the partition thread handler @return the operation status @retval 0 OK @retval !=0 Error */ int launch_partition_handler_thread(); /** Terminate the partition thread handler @return the operation status @retval 0 OK @retval !=0 Error */ int terminate_partition_handler_thread(); /** Is the member currently/or was on a partition? @note this flag is set to true whenever the partition handler is launched and set to false whenever someone tries to abort it. @return is member on partition, or was on one @retval true yes @retval false no */ bool is_member_on_partition(); /** Is the partition handler thread running @return true if running, false otherwise */ bool is_partition_handler_running(); /** Updates the timeout when the member becomes unreachable. @param unreachable_timeout The timeout before going into error */ void update_timeout_on_unreachable(ulong unreachable_timeout); /** @return the configured timeout @retval 0 The partition thread wont run or timeout. @retval >0 After this seconds the plugin will move to ERROR in a minority */ ulong get_timeout_on_unreachable(); /** Signals the thread to abort the waiting process. @return the operation status @retval true It already killed pending transactions and left the group @retval false The thread was not running, or was aborted in time. */ bool abort_partition_handler_if_running(); /** @return is the process finished @retval true It already killed pending transactions and left the group @retval false The thread was not running, or was aborted. */ bool is_partition_handling_terminated(); private: /** Internal method that contains the logic for leaving and killing transactions */ void kill_transactions_and_leave(); //Group_partition_handling variables /** Is member in partition */ bool member_in_partition; /** Is the thread running */ bool thread_running; /** Should we abort the process that will kill pending transaction */ bool partition_handling_aborted; /** Did the partition handler terminate and killed pending transactions */ bool partition_handling_terminated; /** The number of seconds until the member goes into error state*/ ulong timeout_on_unreachable; /** The stop lock used when killing transaction/stopping server*/ Shared_writelock *shared_stop_write_lock; /* Thread related structures */ my_thread_handle partition_trx_handler_pthd; //run conditions and locks mysql_mutex_t run_lock; mysql_cond_t run_cond; mysql_mutex_t trx_termination_aborted_lock; mysql_cond_t trx_termination_aborted_cond; }; #endif /* GROUP_PARTITION_HANDLING_INCLUDE */