MDEV-7374 : Losing connection to MySQL while running ALTER TABLE

Backport from 10.1.

mysql-test/suite/wsrep/r/alter_table_innodb.result

+#
+# MDEV-7374 : Losing connection to MySQL while running ALTER TABLE
+#
+CREATE TABLE t1(i INT) ENGINE=INNODB;
+INSERT INTO t1 VALUES (1),(2),(3),(4),(5),(6),(7),(8);
+INSERT INTO t1 SELECT a.* FROM t1 a, t1 b, t1 c, t1 d, t1 e;
+ALTER TABLE t1 MODIFY i FLOAT;
+DROP TABLE t1;

mysql-test/suite/wsrep/t/alter_table_innodb.opt

+--wsrep-on=0

mysql-test/suite/wsrep/t/alter_table_innodb.test

+--source include/have_innodb.inc
+
+--echo #
+--echo # MDEV-7374 : Losing connection to MySQL while running ALTER TABLE
+--echo #
+CREATE TABLE t1(i INT) ENGINE=INNODB;
+INSERT INTO t1 VALUES (1),(2),(3),(4),(5),(6),(7),(8);
+INSERT INTO t1 SELECT a.* FROM t1 a, t1 b, t1 c, t1 d, t1 e;
+ALTER TABLE t1 MODIFY i FLOAT;
+DROP TABLE t1;

storage/innobase/handler/ha_innodb.cc

@@ -5747,19 +5747,21 @@ ha_innobase::write_row(
 			;
 		} else if (src_table == prebuilt->table) {
 #ifdef WITH_WSREP
-			switch (wsrep_run_wsrep_commit(user_thd, wsrep_hton, 1))
-			{
-			case WSREP_TRX_OK:
-				break;
-			case WSREP_TRX_SIZE_EXCEEDED:
-			case WSREP_TRX_CERT_FAIL:
-			case WSREP_TRX_ERROR:
-				DBUG_RETURN(1);
-			}
+			if (wsrep_on(user_thd)) {
+				switch (wsrep_run_wsrep_commit(user_thd, wsrep_hton, 1))
+				{
+				case WSREP_TRX_OK:
+					break;
+				case WSREP_TRX_SIZE_EXCEEDED:
+				case WSREP_TRX_CERT_FAIL:
+				case WSREP_TRX_ERROR:
+					DBUG_RETURN(1);
+				}
 
-			if (binlog_hton->commit(binlog_hton, user_thd, 1))
-                                DBUG_RETURN(1);
-                        wsrep_post_commit(user_thd, TRUE);
+				if (binlog_hton->commit(binlog_hton, user_thd, 1))
+					DBUG_RETURN(1);
+				wsrep_post_commit(user_thd, TRUE);
+			}
 #endif /* WITH_WSREP */
 			/* Source table is not in InnoDB format:
 			no need to re-acquire locks on it. */
@@ -5772,18 +5774,21 @@ ha_innobase::write_row(
 			prebuilt->sql_stat_start = TRUE;
 		} else {
 #ifdef WITH_WSREP
-			switch (wsrep_run_wsrep_commit(user_thd, wsrep_hton, 1))
-			{
-			case WSREP_TRX_OK:
-				break;
-			case WSREP_TRX_SIZE_EXCEEDED:
-			case WSREP_TRX_CERT_FAIL:
-			case WSREP_TRX_ERROR:
-				DBUG_RETURN(1);
+			if (wsrep_on(user_thd)) {
+				switch (wsrep_run_wsrep_commit(user_thd, wsrep_hton, 1))
+				{
+				case WSREP_TRX_OK:
+					break;
+				case WSREP_TRX_SIZE_EXCEEDED:
+				case WSREP_TRX_CERT_FAIL:
+				case WSREP_TRX_ERROR:
+					DBUG_RETURN(1);
+				}
+
+				if (binlog_hton->commit(binlog_hton, user_thd, 1))
+					DBUG_RETURN(1);
+				wsrep_post_commit(user_thd, TRUE);
 			}
-			if (binlog_hton->commit(binlog_hton, user_thd, 1))
-                                DBUG_RETURN(1);
-                        wsrep_post_commit(user_thd, TRUE);
 #endif /* WITH_WSREP */
 			/* Ensure that there are no other table locks than
 			LOCK_IX and LOCK_AUTO_INC on the destination table. */

storage/xtradb/handler/ha_innodb.cc

@@ -6711,19 +6711,21 @@ ha_innobase::write_row(
 			;
 		} else if (src_table == prebuilt->table) {
 #ifdef WITH_WSREP
-			switch (wsrep_run_wsrep_commit(user_thd, wsrep_hton, 1))
-			{
-			case WSREP_TRX_OK:
-				break;
-			case WSREP_TRX_SIZE_EXCEEDED:
-			case WSREP_TRX_CERT_FAIL:
-			case WSREP_TRX_ERROR:
-				DBUG_RETURN(1);
-			}
+			if (wsrep_on(user_thd)) {
+				switch (wsrep_run_wsrep_commit(user_thd, wsrep_hton, 1))
+				{
+				case WSREP_TRX_OK:
+					break;
+				case WSREP_TRX_SIZE_EXCEEDED:
+				case WSREP_TRX_CERT_FAIL:
+				case WSREP_TRX_ERROR:
+					DBUG_RETURN(1);
+				}
 
-			if (binlog_hton->commit(binlog_hton, user_thd, 1))
-                                DBUG_RETURN(1);
-                        wsrep_post_commit(user_thd, TRUE);
+				if (binlog_hton->commit(binlog_hton, user_thd, 1))
+					DBUG_RETURN(1);
+				wsrep_post_commit(user_thd, TRUE);
+			}
 #endif /* WITH_WSREP */
 			/* Source table is not in InnoDB format:
 			no need to re-acquire locks on it. */
@@ -6736,18 +6738,21 @@ ha_innobase::write_row(
 			prebuilt->sql_stat_start = TRUE;
 		} else {
 #ifdef WITH_WSREP
-			switch (wsrep_run_wsrep_commit(user_thd, wsrep_hton, 1))
-			{
-			case WSREP_TRX_OK:
-				break;
-			case WSREP_TRX_SIZE_EXCEEDED:
-			case WSREP_TRX_CERT_FAIL:
-			case WSREP_TRX_ERROR:
-				DBUG_RETURN(1);
+			if (wsrep_on(user_thd)) {
+				switch (wsrep_run_wsrep_commit(user_thd, wsrep_hton, 1))
+				{
+				case WSREP_TRX_OK:
+					break;
+				case WSREP_TRX_SIZE_EXCEEDED:
+				case WSREP_TRX_CERT_FAIL:
+				case WSREP_TRX_ERROR:
+					DBUG_RETURN(1);
+				}
+
+				if (binlog_hton->commit(binlog_hton, user_thd, 1))
+					DBUG_RETURN(1);
+				wsrep_post_commit(user_thd, TRUE);
 			}
-			if (binlog_hton->commit(binlog_hton, user_thd, 1))
-                                DBUG_RETURN(1);
-                        wsrep_post_commit(user_thd, TRUE);
 #endif /* WITH_WSREP */
 			/* Ensure that there are no other table locks than
 			LOCK_IX and LOCK_AUTO_INC on the destination table. */