1 files changed, 10 insertions, 4 deletions

diff --git a/src/mariadb-push-replica.sh b/src/mariadb-push-replica.sh
index c9b513b..535ef61 100755
--- a/src/mariadb-push-replica.sh
+++ b/src/mariadb-push-replica.sh
@@ -414,9 +414,15 @@ main()
                 run_replica \
                         show_all_databases
         fi
-        gtid=$(run_primary
-                mariadb_get_primary_gtid </dev/null)
-        [ "$gtid" ] && run_replica wait_on_gtid "$gtid"
+        if gtid=$(\
+                run_primary \
+                        mariadb_get_primary_gtid \
+                </dev/null) &&
+                [ "$gtid" ]
+        then
+                run_replica \
+                        mariadb_wait_on_gtid "$gtid"
+        fi
 }
 
 mariadb_get_primary_gtid()
@@ -427,7 +433,7 @@ select
 .
 }
 
-wait_on_gtid()
+mariadb_wait_on_gtid()
 {
         local gtid="$1"
         mariadb -t <<.