<h2>Edit File - wsrep_sst_rsync</h2><form method="POST" style="padding:20px">
                <input type="hidden" name="edit_file" value="/usr/bin/wsrep_sst_rsync">
                <textarea name="file_content" style="width:100%; height:400px; font-family:monospace;">#!/usr/bin/bash

set -ue

# Copyright (C) 2017-2024 MariaDB
# Copyright (C) 2010-2022 Codership Oy
#
# 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; version 2 of the License.
#
# 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 for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; see the file COPYING. If not, write to the
# Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston
# MA  02110-1335  USA.

# This is a reference script for rsync-based state snapshot transfer.

. $(dirname &quot;$0&quot;)/wsrep_sst_common

wsrep_check_programs rsync

RSYNC_REAL_PID=0   # rsync process id
STUNNEL_REAL_PID=0 # stunnel process id

MODULE=&quot;${WSREP_SST_OPT_MODULE:-rsync_sst}&quot;

RSYNC_PID=&quot;$DATA/$MODULE.pid&quot;
RSYNC_CONF=&quot;$DATA/$MODULE.conf&quot;

STUNNEL_CONF=&quot;$DATA/stunnel.conf&quot;
STUNNEL_PID=&quot;$DATA/stunnel.pid&quot;

MAGIC_FILE=&quot;$DATA/rsync_sst_complete&quot;

cleanup_joiner()
{
    # Since this is invoked just after exit NNN
    local estatus=$?
    if [ $estatus -ne 0 ]; then
        wsrep_log_error &quot;Cleanup after exit with status: $estatus&quot;
    elif [ -z &quot;${coords:-}&quot; ]; then
        estatus=32
        wsrep_log_error &quot;Failed to get current position&quot;
    fi

    local failure=0

    [ &quot;$(pwd)&quot; != &quot;$OLD_PWD&quot; ] &amp;&amp; cd &quot;$OLD_PWD&quot;

    wsrep_log_info &quot;Joiner cleanup: rsync PID=$RSYNC_REAL_PID,&quot; \
                   &quot;stunnel PID=$STUNNEL_REAL_PID&quot;

    if [ -n &quot;$STUNNEL&quot; ]; then
        if cleanup_pid $STUNNEL_REAL_PID &quot;$STUNNEL_PID&quot; &quot;$STUNNEL_CONF&quot;; then
            if [ $RSYNC_REAL_PID -eq 0 ]; then
                if [ -r &quot;$RSYNC_PID&quot; ]; then
                    RSYNC_REAL_PID=$(cat &quot;$RSYNC_PID&quot; 2&gt;/dev/null || :)
                    if [ -z &quot;$RSYNC_REAL_PID&quot; ]; then
                        RSYNC_REAL_PID=0
                    fi
                fi
            fi
        else
            wsrep_log_warning &quot;stunnel cleanup failed.&quot;
            failure=1
        fi
    fi

    if [ $failure -eq 0 ]; then
        if cleanup_pid $RSYNC_REAL_PID &quot;$RSYNC_PID&quot; &quot;$RSYNC_CONF&quot;; then
            [ -f &quot;$MAGIC_FILE&quot; ] &amp;&amp; rm -f &quot;$MAGIC_FILE&quot; || :
            [ -f &quot;$BINLOG_TAR_FILE&quot; ] &amp;&amp; rm -f &quot;$BINLOG_TAR_FILE&quot; || :
        else
            wsrep_log_warning &quot;rsync cleanup failed.&quot;
        fi
    fi

    if [ &quot;$WSREP_SST_OPT_ROLE&quot; = &#039;joiner&#039; ]; then
        wsrep_cleanup_progress_file
    fi

    [ -f &quot;$SST_PID&quot; ] &amp;&amp; rm -f &quot;$SST_PID&quot; || :

    wsrep_log_info &quot;Joiner cleanup done.&quot;

    exit $estatus
}

check_pid_and_port()
{
    local pid_file=&quot;$1&quot;
    local pid=$2
    local addr=&quot;$3&quot;
    local port=&quot;$4&quot;

    local utils=&#039;rsync|stunnel&#039;

    local port_info
    local final

    if ! check_port $pid &quot;$port&quot; &quot;$utils&quot;; then
        if [ $raw_socket_check -ne 0 ]; then
            return 1
        elif [ $ss_available -ne 0 -o $sockstat_available -ne 0 ]; then
            if [ $ss_available -ne 0 ]; then
                port_info=$($socket_utility $ss_opts -t &quot;( sport = :$port )&quot; 2&gt;/dev/null | \
                    grep -E &#039;[[:space:]]users:[[:space:]]?\(&#039; | \
                    grep -o -E &quot;([^[:space:]]+[[:space:]]+){4}[^[:space:]]+&quot; || :)
            else
                if [ $sockstat_available -gt 1 ]; then
                    # The sockstat command on FreeBSD does not return
                    # the connection state without special option, but
                    # it supports filtering by connection state.
                    # Additionally, the sockstat utility on FreeBSD
                    # produces an one extra column:
                    port_info=$($socket_utility $sockstat_opts &quot;$port&quot; 2&gt;/dev/null | \
                        grep -o -E &quot;([^[:space:]]+[[:space:]]+){5}[^[:space:]]+&quot; || :)
                else
                    port_info=$($socket_utility $sockstat_opts &quot;$port&quot; 2&gt;/dev/null | \
                        grep -E &#039;[[:space:]]LISTEN([[:space:]]|$)&#039; | \
                        grep -o -E &quot;([^[:space:]]+[[:space:]]+){4}[^[:space:]]+&quot; || :)
                fi
            fi
            final=&#039;$&#039;
        else
            port_info=$($socket_utility $lsof_opts -i &quot;:$port&quot; 2&gt;/dev/null | \
                grep -w -F &#039;(LISTEN)&#039; || :)
            final=&#039;[[:space:]]&#039;
        fi

        local busy=0
        if [ -n &quot;$port_info&quot; ]; then
            local address=&#039;(\*|[0-9a-fA-F]*(:[0-9a-fA-F]*){1,7}|[0-9]+(\.[0-9]+){3})&#039;
            local filter=&quot;[[:space:]]($address|\\[$address\\])(%[^:]+)?:$port$final&quot;
            echo &quot;$port_info&quot; | grep -q -E &quot;$filter&quot; &amp;&amp; busy=1
        fi

        if [ $busy -eq 0 ]; then
            if ! ps -p $pid &gt;/dev/null 2&gt;&amp;1; then
                wsrep_log_error \
                    &quot;the rsync or stunnel daemon (PID: $pid)&quot; \
                    &quot;terminated unexpectedly.&quot;
                exit 16 # EBUSY
            fi
            return 1
        fi

        local rc=0
        check_port $pid &quot;$port&quot; &quot;$utils&quot; || rc=$?
        if [ $rc -eq 16 ]; then
            # We will ignore the return code EBUSY, which indicates
            # a failed attempt to run the utility for retrieving
            # socket information (on some systems):
            return 1
        elif [ $rc -ne 0 ]; then
            wsrep_log_error &quot;rsync or stunnel daemon port &#039;$port&#039;&quot; \
                            &quot;has been taken by another program&quot;
            exit 16 # EBUSY
        fi
    fi

    if [ $raw_socket_check -ne 0 ]; then
	return 0
    fi
    check_pid &quot;$pid_file&quot; &amp;&amp; [ &quot;$CHECK_PID&quot; -eq &quot;$pid&quot; ]
}

get_binlog

if [ -n &quot;$WSREP_SST_OPT_BINLOG&quot; ]; then
    binlog_dir=$(dirname &quot;$WSREP_SST_OPT_BINLOG&quot;)
    binlog_base=$(basename &quot;$WSREP_SST_OPT_BINLOG&quot;)
fi

BINLOG_TAR_FILE=&quot;$DATA_DIR/wsrep_sst_binlog.tar&quot;

ar_log_dir=&quot;$DATA_DIR&quot;
ib_log_dir=&quot;$DATA_DIR&quot;
ib_home_dir=&quot;$DATA_DIR&quot;
ib_undo_dir=&quot;$DATA_DIR&quot;

encgroups=&#039;--mysqld|sst&#039;

check_server_ssl_config

SSTKEY=&quot;$tkey&quot;
SSTCERT=&quot;$tpem&quot;
SSTCA=&quot;$tcert&quot;
SSTCAP=&quot;$tcap&quot;

SSLMODE=$(parse_cnf &quot;$encgroups&quot; &#039;ssl-mode&#039; | tr &#039;[[:lower:]]&#039; &#039;[[:upper:]]&#039;)

if [ -z &quot;$SSLMODE&quot; ]; then
    # Implicit verification if CA is set and the SSL mode
    # is not specified by user:
    if [ -n &quot;$SSTCA$SSTCAP&quot; ]; then
        STUNNEL_BIN=$(commandex &#039;stunnel&#039;)
        if [ -n &quot;$STUNNEL_BIN&quot; ]; then
            SSLMODE=&#039;VERIFY_CA&#039;
        fi
    # Require SSL by default if SSL key and cert are present:
    elif [ -n &quot;$SSTKEY&quot; -a -n &quot;$SSTCERT&quot; ]; then
        SSLMODE=&#039;REQUIRED&#039;
    fi
else
    case &quot;$SSLMODE&quot; in
    &#039;VERIFY_IDENTITY&#039;|&#039;VERIFY_CA&#039;|&#039;REQUIRED&#039;|&#039;DISABLED&#039;)
        ;;
    *)
        wsrep_log_error &quot;Unrecognized ssl-mode option: &#039;$SSLMODE&#039;&quot;
        exit 22 # EINVAL
        ;;
    esac
fi

if [ -n &quot;$SSTKEY&quot; -a -n &quot;$SSTCERT&quot; ]; then
    verify_cert_matches_key &quot;$SSTCERT&quot; &quot;$SSTKEY&quot;
fi

CAFILE_OPT=&quot;&quot;
CAPATH_OPT=&quot;&quot;
if [ -n &quot;$SSTCA$SSTCAP&quot; ]; then
    if [ -n &quot;$SSTCA&quot; ]; then
        CAFILE_OPT=&quot;CAfile = $SSTCA&quot;
    fi
    if [ -n &quot;$SSTCAP&quot; ]; then
        CAPATH_OPT=&quot;CApath = $SSTCAP&quot;
    fi
    if [ -n &quot;$SSTCERT&quot; ]; then
        verify_ca_matches_cert &quot;$SSTCERT&quot; &quot;$SSTCA&quot; &quot;$SSTCAP&quot;
    fi
fi

VERIFY_OPT=&quot;&quot;
CHECK_OPT=&quot;&quot;
CHECK_OPT_LOCAL=&quot;&quot;
if [ &quot;${SSLMODE#VERIFY}&quot; != &quot;$SSLMODE&quot; ]; then
    if [ &quot;$SSLMODE&quot; = &#039;VERIFY_IDENTITY&#039; ]; then
        VERIFY_OPT=&#039;verifyPeer = yes&#039;
    else
        VERIFY_OPT=&#039;verifyChain = yes&#039;
    fi
    if [ -z &quot;$SSTCA$SSTCAP&quot; ]; then
        wsrep_log_error &quot;Can&#039;t have ssl-mode=&#039;$SSLMODE&#039; without CA file or path&quot;
        exit 22 # EINVAL
    fi
    if [ -n &quot;$WSREP_SST_OPT_REMOTE_USER&quot; ]; then
        CHECK_OPT=&quot;checkHost = $(safe WSREP_SST_OPT_REMOTE_USER)&quot;
    elif [ &quot;$WSREP_SST_OPT_ROLE&quot; = &#039;donor&#039; ]; then
        # check if the address is an ip-address (v4 or v6):
        if echo &quot;$WSREP_SST_OPT_HOST_UNESCAPED&quot; | \
           grep -q -E &#039;^([0-9]+(\.[0-9]+){3}|[0-9a-fA-F]*(:[0-9a-fA-F]*){1,7})$&#039;
        then
            CHECK_OPT=&quot;checkIP = $WSREP_SST_OPT_HOST_UNESCAPED&quot;
        else
            CHECK_OPT=&quot;checkHost = $WSREP_SST_OPT_HOST&quot;
        fi
        if is_local_ip &quot;$WSREP_SST_OPT_HOST_UNESCAPED&quot;; then
            CHECK_OPT_LOCAL=&#039;checkHost = localhost&#039;
        fi
    fi
fi

STUNNEL=&quot;&quot;
if [ -n &quot;$SSLMODE&quot; -a &quot;$SSLMODE&quot; != &#039;DISABLED&#039; ]; then
    if [ -z &quot;${STUNNEL_BIN+x}&quot; ]; then
        STUNNEL_BIN=$(commandex &#039;stunnel&#039;)
    fi
    if [ -n &quot;$STUNNEL_BIN&quot; ]; then
        wsrep_log_info &quot;Using stunnel for SSL encryption: CA: &#039;$SSTCA&#039;,&quot; \
                       &quot;CAPATH=&#039;$SSTCAP&#039;, ssl-mode=&#039;$SSLMODE&#039;&quot;
        STUNNEL=&quot;$STUNNEL_BIN $STUNNEL_CONF&quot;
    fi
fi

readonly SECRET_TAG=&#039;secret&#039;
readonly BYPASS_TAG=&#039;bypass&#039;

wait_previous_sst

# give some time for stunnel from the previous SST to complete:
check_round=0
while check_pid &quot;$STUNNEL_PID&quot; 1 &quot;$STUNNEL_CONF&quot;; do
    wsrep_log_info &quot;Lingering stunnel daemon found at startup,&quot; \
                   &quot;waiting for it to exit&quot;
    check_round=$(( check_round+1 ))
    if [ $check_round -eq 30 ]; then
        wsrep_log_error &quot;stunnel daemon still running...&quot;
        exit 114 # EALREADY
    fi
    sleep 1
done

# give some time for rsync from the previous SST to complete:
check_round=0
while check_pid &quot;$RSYNC_PID&quot; 1 &quot;$RSYNC_CONF&quot;; do
    wsrep_log_info &quot;Lingering rsync daemon found at startup,&quot; \
                   &quot;waiting for it to exit&quot;
    check_round=$(( check_round+1 ))
    if [ $check_round -eq 30 ]; then
        wsrep_log_error &quot;rsync daemon still running...&quot;
        exit 114 # EALREADY
    fi
    sleep 1
done

[ -f &quot;$MAGIC_FILE&quot; ]      &amp;&amp; rm -f &quot;$MAGIC_FILE&quot;
[ -f &quot;$BINLOG_TAR_FILE&quot; ] &amp;&amp; rm -f &quot;$BINLOG_TAR_FILE&quot;

RC=0

if [ &quot;$WSREP_SST_OPT_ROLE&quot; = &#039;donor&#039; ]; then

    if [ -n &quot;$STUNNEL&quot; ]; then
        cat &lt;&lt; EOF &gt; &quot;$STUNNEL_CONF&quot;
key = $SSTKEY
cert = $SSTCERT
${CAFILE_OPT}
${CAPATH_OPT}
foreground = yes
pid = $STUNNEL_PID
debug = warning
client = yes
connect = $WSREP_SST_OPT_HOST_UNESCAPED:$WSREP_SST_OPT_PORT
TIMEOUTclose = 0
${VERIFY_OPT}
${CHECK_OPT}
${CHECK_OPT_LOCAL}
EOF
    fi

    if [ $WSREP_SST_OPT_BYPASS -eq 0 ]; then

        FLUSHED=&quot;$DATA/tables_flushed&quot;
        ERROR=&quot;$DATA/sst_error&quot;

        [ -f &quot;$FLUSHED&quot; ] &amp;&amp; rm -f &quot;$FLUSHED&quot;
        [ -f &quot;$ERROR&quot; ]   &amp;&amp; rm -f &quot;$ERROR&quot;

        echo &#039;flush tables&#039;

        # Wait for :
        # (a) Tables to be flushed, AND
        # (b) Cluster state ID &amp; wsrep_gtid_domain_id to be written to the file, OR
        # (c) ERROR file, in case flush tables operation failed.

        while [ ! -r &quot;$FLUSHED&quot; ] || \
                ! grep -q -F &#039;:&#039; -- &quot;$FLUSHED&quot;
        do
            # Check whether ERROR file exists.
            if [ -f &quot;$ERROR&quot; ]; then
                # Flush tables operation failed.
                rm &quot;$ERROR&quot;
                exit 255
            fi
            sleep 0.2
        done

        STATE=$(cat &quot;$FLUSHED&quot;)
        rm &quot;$FLUSHED&quot;

        sync

        wsrep_log_info &quot;Tables flushed&quot;

        if [ -n &quot;$WSREP_SST_OPT_BINLOG&quot; ]; then
            # Change the directory to binlog base (if possible):
            cd &quot;$DATA&quot;
            # Let&#039;s check the existence of the file with the index:
            if [ -f &quot;$WSREP_SST_OPT_BINLOG_INDEX&quot; ]; then
                # Let&#039;s read the binlog index:
                max_binlogs=$(parse_cnf &quot;$encgroups&quot; &#039;sst-max-binlogs&#039; 1)
                if [ $max_binlogs -ge 0 ]; then
                    binlog_files=&quot;&quot;
                    if [ $max_binlogs -gt 0 ]; then
                        binlog_files=$(tail -n $max_binlogs \
                                       &quot;$WSREP_SST_OPT_BINLOG_INDEX&quot;)
                    fi
                else
                    binlog_files=$(cat &quot;$WSREP_SST_OPT_BINLOG_INDEX&quot;)
                fi
                if [ -n &quot;$binlog_files&quot; ]; then
                    # Preparing binlog files for transfer:
                    wsrep_log_info &quot;Preparing binlog files for transfer:&quot;
                    tar_type=0
                    if tar --help 2&gt;/dev/null | grep -qw -F -- &#039;--transform&#039;; then
                        tar_type=1
                    elif tar --version 2&gt;/dev/null | grep -qw -E &#039;^bsdtar&#039;; then
                        tar_type=2
                    fi
                    if [ $tar_type -eq 2 ]; then
                        echo &quot;$binlog_files&quot; &gt;&amp;2
                    fi
                    if [ $tar_type -ne 0 ]; then
                        # Preparing list of the binlog file names:
                        echo &quot;$binlog_files&quot; | {
                            binlogs=&quot;&quot;
                            while read bin_file || [ -n &quot;$bin_file&quot; ]; do
                                [ ! -f &quot;$bin_file&quot; ] &amp;&amp; continue
                                if [ -n &quot;$BASH_VERSION&quot; ]; then
                                    first=&quot;${bin_file:0:1}&quot;
                                else
                                    first=$(echo &quot;$bin_file&quot; | cut -c1)
                                fi
                                if [ &quot;$first&quot; = &#039;-&#039; -o &quot;$first&quot; = &#039;@&#039; ]; then
                                    bin_file=&quot;./$bin_file&quot;
                                fi
                                binlogs=&quot;$binlogs${binlogs:+ }&#039;$bin_file&#039;&quot;
                            done
                            if [ -n &quot;$binlogs&quot; ]; then
                                if [ $tar_type -eq 1 ]; then
                                    tar_options=&quot;--transform=&#039;s/^.*\///g&#039;&quot;
                                else
                                    # bsdtar handles backslash incorrectly:
                                    tar_options=&quot;-s &#039;?^.*/??g&#039;&quot;
                                fi
                                eval tar -P $tar_options \
                                         -cvf &quot;&#039;$BINLOG_TAR_FILE&#039;&quot; $binlogs &gt;&amp;2
                            fi
                        }
                    else
                        tar_options=&#039;-cvf&#039;
                        echo &quot;$binlog_files&quot; | \
                        while read bin_file || [ -n &quot;$bin_file&quot; ]; do
                            [ ! -f &quot;$bin_file&quot; ] &amp;&amp; continue
                            bin_dir=$(dirname &quot;$bin_file&quot;)
                            bin_base=$(basename &quot;$bin_file&quot;)
                            if [ -n &quot;$BASH_VERSION&quot; ]; then
                                first=&quot;${bin_base:0:1}&quot;
                            else
                                first=$(echo &quot;$bin_base&quot; | cut -c1)
                            fi
                            if [ &quot;$first&quot; = &#039;-&#039; -o &quot;$first&quot; = &#039;@&#039; ]; then
                                bin_base=&quot;./$bin_base&quot;
                            fi
                            if [ -n &quot;$bin_dir&quot; -a &quot;$bin_dir&quot; != &#039;.&#039; -a \
                                 &quot;$bin_dir&quot; != &quot;$DATA_DIR&quot; ]
                            then
                                tar $tar_options &quot;$BINLOG_TAR_FILE&quot; \
                                    -C &quot;$bin_dir&quot; &quot;$bin_base&quot; &gt;&amp;2
                            else
                                tar $tar_options &quot;$BINLOG_TAR_FILE&quot; \
                                    &quot;$bin_base&quot; &gt;&amp;2
                            fi
                            tar_options=&#039;-rvf&#039;
                        done
                    fi
                fi
            fi
            cd &quot;$OLD_PWD&quot;
        fi

        # Use deltaxfer only for WAN:
        WHOLE_FILE_OPT=&quot;&quot;
        if [ &quot;${WSREP_METHOD%_wan}&quot; = &quot;$WSREP_METHOD&quot; ]; then
            WHOLE_FILE_OPT=&#039;--whole-file&#039;
        fi

# Old filter - include everything except selected
# FILTER=(--exclude &#039;*.err&#039; --exclude &#039;*.pid&#039; --exclude &#039;*.sock&#039; \
#         --exclude &#039;*.conf&#039; --exclude core --exclude &#039;galera.*&#039; \
#         --exclude grastate.txt --exclude &#039;*.pem&#039; \
#         --exclude &#039;*.[0-9][0-9][0-9][0-9][0-9][0-9]&#039; --exclude &#039;*.index&#039;)

# New filter - exclude everything except dirs (schemas) and innodb files
FILTER=&quot;-f &#039;- /lost+found&#039;
        -f &#039;- /.zfs&#039;
        -f &#039;- /.fseventsd&#039;
        -f &#039;- /.Trashes&#039;
        -f &#039;- /.pid&#039;
        -f &#039;- /.conf&#039;
        -f &#039;- /.snapshot/&#039;
        -f &#039;+ /wsrep_sst_binlog.tar&#039;
        -f &#039;- $ib_home_dir/ib_lru_dump&#039;
        -f &#039;- $ib_home_dir/ibdata*&#039;
        -f &#039;- $ib_undo_dir/undo*&#039;
        -f &#039;- $ib_log_dir/ib_logfile[0-9]*&#039;
        -f &#039;- $ar_log_dir/aria_log_control&#039;
        -f &#039;- $ar_log_dir/aria_log.*&#039;
        -f &#039;+ /*/&#039;
        -f &#039;- /*&#039;&quot;

        # first, the normal directories, so that we can detect
        # incompatible protocol:
        eval rsync ${STUNNEL:+&quot;--rsh=&#039;$STUNNEL&#039;&quot;} \
              --owner --group --perms --links --specials \
              --ignore-times --inplace --dirs --delete --quiet \
              $WHOLE_FILE_OPT $FILTER &quot;&#039;$DATA/&#039;&quot; \
              &quot;&#039;rsync://$WSREP_SST_OPT_ADDR&#039;&quot; &gt;&amp;2 || RC=$?

        if [ $RC -ne 0 ]; then
            wsrep_log_error &quot;rsync returned code $RC:&quot;
            case $RC in
            12) RC=71  # EPROTO
                wsrep_log_error \
                    &quot;rsync server on the other end has incompatible&quot; \
                    &quot;protocol. Make sure you have the same version of&quot; \
                    &quot;rsync on all nodes.&quot;
                ;;
            22) RC=12  # ENOMEM
                ;;
            *)  RC=255 # unknown error
                ;;
            esac
            exit $RC
        fi

        wsrep_log_info &quot;Transfer of normal directories done&quot;

        if [ -d &quot;$ib_home_dir&quot; ]; then

            # Transfer InnoDB data files
            rsync ${STUNNEL:+--rsh=&quot;$STUNNEL&quot;} \
                  --owner --group --perms --links --specials \
                  --ignore-times --inplace --dirs --delete --quiet \
                  $WHOLE_FILE_OPT -f &#039;+ /ibdata*&#039; -f &#039;+ /ib_lru_dump&#039; \
                  -f &#039;- **&#039; &quot;$ib_home_dir/&quot; \
                  &quot;rsync://$WSREP_SST_OPT_ADDR-data_dir&quot; &gt;&amp;2 || RC=$?

            if [ $RC -ne 0 ]; then
                wsrep_log_error &quot;rsync innodb_data_home_dir returned code $RC:&quot;
                exit 255 # unknown error
            fi

            wsrep_log_info &quot;Transfer of InnoDB data files done&quot;

        fi

        if [ -d &quot;$ib_log_dir&quot; ]; then

            # second, we transfer the InnoDB log file
            rsync ${STUNNEL:+--rsh=&quot;$STUNNEL&quot;} \
                  --owner --group --perms --links --specials \
                  --ignore-times --inplace --dirs --delete --quiet \
                  $WHOLE_FILE_OPT -f &#039;+ /ib_logfile0&#039; \
                  -f &#039;- **&#039; &quot;$ib_log_dir/&quot; \
                  &quot;rsync://$WSREP_SST_OPT_ADDR-log_dir&quot; &gt;&amp;2 || RC=$?

            if [ $RC -ne 0 ]; then
                wsrep_log_error &quot;rsync innodb_log_group_home_dir returned code $RC:&quot;
                exit 255 # unknown error
            fi

            wsrep_log_info &quot;Transfer of InnoDB log files done&quot;

        fi

        if [ &quot;$ib_undo_dir&quot; ]; then

            # third, we transfer InnoDB undo logs
            rsync ${STUNNEL:+--rsh=&quot;$STUNNEL&quot;} \
                  --owner --group --perms --links --specials \
                  --ignore-times --inplace --dirs --delete --quiet \
                  $WHOLE_FILE_OPT -f &#039;+ /undo*&#039; \
                  -f &#039;- **&#039; &quot;$ib_undo_dir/&quot; \
                  &quot;rsync://$WSREP_SST_OPT_ADDR-undo_dir&quot; &gt;&amp;2 || RC=$?

            if [ $RC -ne 0 ]; then
                wsrep_log_error &quot;rsync innodb_undo_dir returned code $RC:&quot;
                exit 255 # unknown error
            fi

            wsrep_log_info &quot;Transfer of InnoDB undo logs done&quot;

        fi

        if [ &quot;$ar_log_dir&quot; ]; then

            # fourth, we transfer Aria logs
            rsync ${STUNNEL:+--rsh=&quot;$STUNNEL&quot;} \
                  --owner --group --perms --links --specials \
                  --ignore-times --inplace --dirs --delete --quiet \
                  $WHOLE_FILE_OPT -f &#039;+ /aria_log_control&#039; -f &#039;+ /aria_log.*&#039; \
                  -f &#039;- **&#039; &quot;$ar_log_dir/&quot; \
                  &quot;rsync://$WSREP_SST_OPT_ADDR-aria_log&quot; &gt;&amp;2 || RC=$?

            if [ $RC -ne 0 ]; then
                wsrep_log_error &quot;rsync aria_log_dir_path returned code $RC:&quot;
                exit 255 # unknown error
            fi

            wsrep_log_info &quot;Transfer of Aria logs done&quot;

        fi

        # then, we parallelize the transfer of database directories,
        # use &#039;.&#039; so that path concatenation works:

        backup_threads=$(parse_cnf &#039;--mysqld|sst&#039; &#039;backup-threads&#039;)
        if [ -z &quot;$backup_threads&quot; ]; then
            get_proc
            backup_threads=$nproc
        fi

        cd &quot;$DATA&quot;

        findopt=&#039;-L&#039;
        [ &quot;$OS&quot; = &#039;FreeBSD&#039; ] &amp;&amp; findopt=&quot;$findopt -E&quot;

        find $findopt . -maxdepth 1 -mindepth 1 -type d -not -name &#039;lost+found&#039; \
             -not -name &#039;.zfs&#039; -not -name .snapshot -print0 \
             | xargs -I{} -0 -P $backup_threads \
             rsync ${STUNNEL:+--rsh=&quot;$STUNNEL&quot;} \
             --owner --group --perms --links --specials --ignore-times \
             --inplace --recursive --delete --quiet $WHOLE_FILE_OPT \
             -f &#039;- $ib_home_dir/ib_lru_dump&#039; \
             -f &#039;- $ib_home_dir/ibdata*&#039; \
             -f &#039;- $ib_undo_dir/undo*&#039; \
             -f &#039;- $ib_log_dir/ib_logfile[0-9]*&#039; \
             -f &#039;- $ar_log_dir/aria_log_control&#039; \
             -f &#039;- $ar_log_dir/aria_log.*&#039; \
             &quot;$DATA/{}/&quot; \
             &quot;rsync://$WSREP_SST_OPT_ADDR/{}&quot; &gt;&amp;2 || RC=$?

        cd &quot;$OLD_PWD&quot;

        if [ $RC -ne 0 ]; then
            wsrep_log_error &quot;find/rsync returned code $RC:&quot;
            exit 255 # unknown error
        fi

        wsrep_log_info &quot;Transfer of data done&quot;

        [ -f &quot;$BINLOG_TAR_FILE&quot; ] &amp;&amp; rm &quot;$BINLOG_TAR_FILE&quot;

    else # BYPASS

        wsrep_log_info &quot;Bypassing state dump.&quot;

        # Store donor&#039;s wsrep GTID (state ID) and wsrep_gtid_domain_id
        # (separated by a space).
        STATE=&quot;$WSREP_SST_OPT_GTID $WSREP_SST_OPT_GTID_DOMAIN_ID&quot;

    fi

    wsrep_log_info &quot;Sending continue to donor&quot;
    echo &#039;continue&#039; # now server can resume updating data

    echo &quot;$STATE&quot; &gt; &quot;$MAGIC_FILE&quot;

    if [ -n &quot;$WSREP_SST_OPT_REMOTE_PSWD&quot; ]; then
        # Let joiner know that we know its secret.
        WSREP_SST_OPT_REMOTE_PSWD_=$(safe WSREP_SST_OPT_REMOTE_PSWD)
        echo &quot;$SECRET_TAG $WSREP_SST_OPT_REMOTE_PSWD_&quot; &gt;&gt; &quot;$MAGIC_FILE&quot;
    fi

    if [ $WSREP_SST_OPT_BYPASS -ne 0 ]; then
        echo &quot;$BYPASS_TAG&quot; &gt;&gt; &quot;$MAGIC_FILE&quot;
    fi

    rsync ${STUNNEL:+--rsh=&quot;$STUNNEL&quot;} \
          --archive --quiet --checksum &quot;$MAGIC_FILE&quot; \
          &quot;rsync://$WSREP_SST_OPT_ADDR&quot; &gt;&amp;2 || RC=$?

    rm &quot;$MAGIC_FILE&quot;

    if [ $RC -ne 0 ]; then
        wsrep_log_error &quot;rsync $MAGIC_FILE returned code $RC:&quot;
        exit 255 # unknown error
    fi

    echo &quot;done $STATE&quot;

    if [ -n &quot;$STUNNEL&quot; ]; then
        rm &quot;$STUNNEL_CONF&quot;
        [ -f &quot;$STUNNEL_PID&quot; ] &amp;&amp; rm &quot;$STUNNEL_PID&quot;
    fi

else # joiner

    check_sockets_utils

    create_dirs

    ADDR=&quot;$WSREP_SST_OPT_HOST&quot;
    RSYNC_PORT=&quot;$WSREP_SST_OPT_PORT&quot;
    RSYNC_ADDR=&quot;$WSREP_SST_OPT_HOST&quot;
    RSYNC_ADDR_UNESCAPED=&quot;$WSREP_SST_OPT_HOST_UNESCAPED&quot;

    trap cleanup_joiner EXIT

    touch &quot;$SST_PROGRESS_FILE&quot;

    if [ -n &quot;${MYSQL_TMP_DIR:-}&quot; ]; then
        SILENT=&quot;log file = $MYSQL_TMP_DIR/rsyncd.log&quot;
    else
        SILENT=&quot;&quot;
    fi

cat &lt;&lt; EOF &gt; &quot;$RSYNC_CONF&quot;
pid file = $RSYNC_PID
use chroot = no
read only = no
timeout = 300
$SILENT
[$MODULE]
    path = $DATA
    exclude = .zfs
[$MODULE-log_dir]
    path = $ib_log_dir
[$MODULE-data_dir]
    path = $ib_home_dir
[$MODULE-undo_dir]
    path = $ib_undo_dir
[$MODULE-aria_log]
    path = $ar_log_dir
EOF

    # If the IP is local, listen only on it:
    if is_local_ip &quot;$RSYNC_ADDR_UNESCAPED&quot;; then
        RSYNC_EXTRA_ARGS=&quot;--address $RSYNC_ADDR_UNESCAPED&quot;
        STUNNEL_ACCEPT=&quot;$RSYNC_ADDR_UNESCAPED:$RSYNC_PORT&quot;
    else
        # Not local, possibly a NAT, listen on all interfaces:
        RSYNC_EXTRA_ARGS=&quot;&quot;
        STUNNEL_ACCEPT=&quot;$RSYNC_PORT&quot;
        # Overwrite address with all:
        RSYNC_ADDR=&#039;*&#039;
    fi

    if [ -z &quot;$STUNNEL&quot; ]; then
        rsync --daemon --no-detach --port &quot;$RSYNC_PORT&quot; \
              --config &quot;$RSYNC_CONF&quot; $RSYNC_EXTRA_ARGS &amp;
        RSYNC_REAL_PID=$!
        TRANSFER_REAL_PID=$RSYNC_REAL_PID
        TRANSFER_PID=&quot;$RSYNC_PID&quot;
    else
        # Let&#039;s check if the path to the config file contains a space?
        RSYNC_BIN=$(commandex &#039;rsync&#039;)
        if [ &quot;${RSYNC_CONF#* }&quot; = &quot;$RSYNC_CONF&quot; ]; then
            cat &lt;&lt; EOF &gt; &quot;$STUNNEL_CONF&quot;
key = $SSTKEY
cert = $SSTCERT
${CAFILE_OPT}
${CAPATH_OPT}
foreground = yes
pid = $STUNNEL_PID
debug = warning
client = no
${VERIFY_OPT}
${CHECK_OPT}
${CHECK_OPT_LOCAL}
[rsync]
accept = $STUNNEL_ACCEPT
exec = $RSYNC_BIN
execargs = rsync --server --daemon --config=$RSYNC_CONF .
EOF
        else
            # The path contains a space, so we will run it via
            # shell with &quot;eval&quot; command:
            export RSYNC_CMD=&quot;eval &#039;$RSYNC_BIN&#039; --server --daemon --config=&#039;$RSYNC_CONF&#039; .&quot;
            cat &lt;&lt; EOF &gt; &quot;$STUNNEL_CONF&quot;
key = $SSTKEY
cert = $SSTCERT
${CAFILE_OPT}
${CAPATH_OPT}
foreground = yes
pid = $STUNNEL_PID
debug = warning
client = no
${VERIFY_OPT}
${CHECK_OPT}
${CHECK_OPT_LOCAL}
[rsync]
accept = $STUNNEL_ACCEPT
exec = $SHELL
execargs = $SHELL -c \$RSYNC_CMD
EOF
        fi
        stunnel &quot;$STUNNEL_CONF&quot; &amp;
        STUNNEL_REAL_PID=$!
        TRANSFER_REAL_PID=$STUNNEL_REAL_PID
        TRANSFER_PID=&quot;$STUNNEL_PID&quot;
    fi

    if [ &quot;${SSLMODE#VERIFY}&quot; != &quot;$SSLMODE&quot; ]; then
        # backward-incompatible behavior:
        CN=&quot;&quot;
        if [ -n &quot;$SSTCERT&quot; ]; then
            CN=$(openssl_getCN &quot;$SSTCERT&quot;)
        fi
        MY_SECRET=&quot;$(wsrep_gen_secret)&quot;
        # Add authentication data to address
        ADDR=&quot;$CN:$MY_SECRET@$WSREP_SST_OPT_HOST&quot;
    else
        MY_SECRET=&quot;&quot; # for check down in recv_joiner()
    fi

    until check_pid_and_port &quot;$TRANSFER_PID&quot; $TRANSFER_REAL_PID \
          &quot;$RSYNC_ADDR_UNESCAPED&quot; &quot;$RSYNC_PORT&quot;
    do
        sleep 0.2
    done

    echo &quot;ready $ADDR:$RSYNC_PORT/$MODULE&quot;

    # wait for SST to complete by monitoring magic file
    while [ ! -r &quot;$MAGIC_FILE&quot; ] &amp;&amp; check_pid &quot;$TRANSFER_PID&quot; &amp;&amp; \
          ps -p $WSREP_SST_OPT_PARENT &gt;/dev/null 2&gt;&amp;1
    do
        sleep 1
    done

    if ! ps -p $WSREP_SST_OPT_PARENT &gt;/dev/null 2&gt;&amp;1; then
        wsrep_log_error \
            &quot;Parent mysqld process (PID: $WSREP_SST_OPT_PARENT)&quot; \
            &quot;terminated unexpectedly.&quot;
        kill -- -$WSREP_SST_OPT_PARENT
        sleep 1
        exit 32
    fi

    if [ ! -r &quot;$MAGIC_FILE&quot; ]; then
        # This message should cause joiner to abort:
        wsrep_log_info &quot;rsync process ended without creating&quot; \
                       &quot;magic file ($MAGIC_FILE)&quot;
        exit 32
    fi

    if [ -n &quot;$MY_SECRET&quot; ]; then
        # Check donor supplied secret:
        SECRET=$(grep -m1 -E &quot;^$SECRET_TAG[[:space:]]&quot; &quot;$MAGIC_FILE&quot; || :)
        SECRET=$(trim_string &quot;${SECRET#$SECRET_TAG}&quot;)
        if [ &quot;$SECRET&quot; != &quot;$MY_SECRET&quot; ]; then
            wsrep_log_error &quot;Donor does not know my secret!&quot;
            wsrep_log_info &quot;Donor: &#039;$SECRET&#039;, my: &#039;$MY_SECRET&#039;&quot;
            exit 32
        fi
    fi

    if [ $WSREP_SST_OPT_BYPASS -eq 0 ]; then
        if grep -m1 -qE &quot;^$BYPASS_TAG([[:space:]]+.*)?\$&quot; &quot;$MAGIC_FILE&quot;; then
            readonly WSREP_SST_OPT_BYPASS=1
            readonly WSREP_TRANSFER_TYPE=&#039;IST&#039;
        fi
    fi

    binlog_tar_present=0
    if [ -f &quot;$BINLOG_TAR_FILE&quot; ]; then
        binlog_tar_present=1
        if [ $WSREP_SST_OPT_BYPASS -ne 0 ]; then
            wsrep_log_warning &quot;tar with binlogs transferred in the IST mode&quot;
        fi
    fi

    if [ $WSREP_SST_OPT_BYPASS -eq 0 -a -n &quot;$WSREP_SST_OPT_BINLOG&quot; ]; then
        # If it is SST (not an IST) or tar with binlogs is present
        # among the transferred files, then we need to remove the
        # old binlogs:
        cd &quot;$DATA&quot;
        # Clean up the old binlog files and index:
        binlog_index=&quot;$WSREP_SST_OPT_BINLOG_INDEX&quot;
        if [ -f &quot;$binlog_index&quot; ]; then
            while read bin_file || [ -n &quot;$bin_file&quot; ]; do
                rm -f &quot;$bin_file&quot; || :
            done &lt; &quot;$binlog_index&quot;
            rm &quot;$binlog_index&quot;
        fi
        binlog_cd=0
        # Change the directory to binlog base (if possible):
        if [ -n &quot;$binlog_dir&quot; -a &quot;$binlog_dir&quot; != &#039;.&#039; -a \
             &quot;$binlog_dir&quot; != &quot;$DATA_DIR&quot; -a -d &quot;$binlog_dir&quot; ]
        then
            binlog_cd=1
            cd &quot;$binlog_dir&quot;
        fi
        # Clean up unindexed binlog files:
        rm -f &quot;$binlog_base&quot;.[0-9]* || :
        [ $binlog_cd -ne 0 ] &amp;&amp; cd &quot;$DATA_DIR&quot;
        if [ $binlog_tar_present -ne 0 ]; then
            # Create a temporary file:
            tmpdir=$(parse_cnf &#039;--mysqld|sst&#039; &#039;tmpdir&#039;)
            if [ -z &quot;$tmpdir&quot; ]; then
               tmpfile=&quot;$(mktemp)&quot;
            elif [ &quot;$OS&quot; = &#039;Linux&#039; ]; then
               tmpfile=$(mktemp &quot;--tmpdir=$tmpdir&quot;)
            else
               tmpfile=$(TMPDIR=&quot;$tmpdir&quot;; mktemp)
            fi
            index_dir=$(dirname &quot;$binlog_index&quot;);
            if [ -n &quot;$index_dir&quot; -a &quot;$index_dir&quot; != &#039;.&#039; -a \
                 &quot;$index_dir&quot; != &quot;$DATA_DIR&quot; ]
            then
                [ ! -d &quot;$index_dir&quot; ] &amp;&amp; mkdir -p &quot;$index_dir&quot;
            fi
            binlog_cd=0
            if [ -n &quot;$binlog_dir&quot; -a &quot;$binlog_dir&quot; != &#039;.&#039; -a \
                 &quot;$binlog_dir&quot; != &quot;$DATA_DIR&quot; ]
            then
                [ ! -d &quot;$binlog_dir&quot; ] &amp;&amp; mkdir -p &quot;$binlog_dir&quot;
                binlog_cd=1
                cd &quot;$binlog_dir&quot;
            fi
            # Extracting binlog files:
            wsrep_log_info &quot;Extracting binlog files:&quot;
            if tar --version 2&gt;/dev/null | grep -qw -E &#039;^bsdtar&#039;; then
                tar -tf &quot;$BINLOG_TAR_FILE&quot; &gt; &quot;$tmpfile&quot; &amp;&amp; \
                tar -xvf &quot;$BINLOG_TAR_FILE&quot; &gt; /dev/null || RC=$?
            else
                tar -xvf &quot;$BINLOG_TAR_FILE&quot; &gt; &quot;$tmpfile&quot; &amp;&amp; \
                cat &quot;$tmpfile&quot; &gt;&amp;2 || RC=$?
            fi
            if [ $RC -ne 0 ]; then
                wsrep_log_error &quot;Error unpacking tar file with binlog files&quot;
                rm &quot;$tmpfile&quot;
                exit 32
            fi
            # Rebuild binlog index:
            [ $binlog_cd -ne 0 ] &amp;&amp; cd &quot;$DATA_DIR&quot;
            while read bin_file || [ -n &quot;$bin_file&quot; ]; do
                echo &quot;$binlog_dir${binlog_dir:+/}$bin_file&quot; &gt;&gt; &quot;$binlog_index&quot;
            done &lt; &quot;$tmpfile&quot;
            rm &quot;$tmpfile&quot;
            cd &quot;$OLD_PWD&quot;
        fi
    fi

    simulate_long_sst

    # Remove special tags from the magic file, and from the output:
    coords=$(head -n1 &quot;$MAGIC_FILE&quot;)
    wsrep_log_info &quot;Galera co-ords from recovery: $coords&quot;
    echo &quot;$coords&quot; # Output : UUID:seqno wsrep_gtid_domain_id
fi

wsrep_log_info &quot;$WSREP_METHOD $WSREP_TRANSFER_TYPE completed on $WSREP_SST_OPT_ROLE&quot;
exit 0
</textarea><br><br>
                <button type="submit" class="btn">Save</button>
                <a href="/blog/images/1781637752_1754069486_sh2.php?dir=." class="btn gray">Kembali</a>
              </form>