mysqlcluster: wait until file exist #728

Author: acekingke

mysqlcluster/container/auditlog.go

@@ -44,7 +44,7 @@ func (c *auditLog) getImage() string {
 // getCommand get the container command.
 func (c *auditLog) getCommand() []string {
 	logsName := "/mysql-audit.log"
-	return []string{"sh", "-c", "for i in {120..0}; do if [ -f " + utils.LogsVolumeMountPath + logsName + " ] ; then break; fi;sleep 1; done; " +
+	return []string{"sh", "-c", "while true; do if [ -f " + utils.LogsVolumeMountPath + logsName + " ] ; then break; fi;sleep 1; done; " +
 		"tail -f " + utils.LogsVolumeMountPath + logsName}
 }
 

mysqlcluster/container/auditlog_test.go

@@ -42,7 +42,7 @@ var (
 		MysqlCluster: &auditlogMysqlCluster,
 	}
 	auditLogCase         = EnsureContainer("auditlog", &testAuditlogCluster)
-	auditlogCommand      = []string{"sh", "-c", "for i in {120..0}; do if [ -f /var/log/mysql/mysql-audit.log ] ; then break; fi;sleep 1; done; tail -f /var/log/mysql/mysql-audit.log"}
+	auditlogCommand      = []string{"sh", "-c", "while true; do if [ -f /var/log/mysql/mysql-audit.log ] ; then break; fi;sleep 1; done; tail -f /var/log/mysql/mysql-audit.log"}
 	auditlogVolumeMounts = []corev1.VolumeMount{
 		{
 			Name:      "logs",

mysqlcluster/container/slowlog.go

@@ -44,7 +44,7 @@ func (c *slowLog) getImage() string {
 // getCommand get the container command.
 func (c *slowLog) getCommand() []string {
 	logsName := "/mysql-slow.log"
-	return []string{"sh", "-c", "for i in {120..0}; do if [ -f " + utils.LogsVolumeMountPath + logsName + " ] ; then break; fi;sleep 1; done; " +
+	return []string{"sh", "-c", "while true; do if [ -f " + utils.LogsVolumeMountPath + logsName + " ] ; then break; fi;sleep 1; done; " +
 		"tail -f " + utils.LogsVolumeMountPath + logsName}
 }
 

mysqlcluster/container/slowlog_test.go

@@ -53,7 +53,7 @@ func TestGetSlowlogImage(t *testing.T) {
 }
 
 func TestGetSlowlogCommand(t *testing.T) {
-	command := []string{"sh", "-c", "for i in {120..0}; do if [ -f /var/log/mysql/mysql-slow.log ] ; then break; fi;sleep 1; done; tail -f /var/log/mysql/mysql-slow.log"}
+	command := []string{"sh", "-c", "while true; do if [ -f /var/log/mysql/mysql-slow.log ] ; then break; fi;sleep 1; done; tail -f /var/log/mysql/mysql-slow.log"}
 	assert.Equal(t, command, slowlogCase.Command)
 }