@@ -38,22 +38,25 @@ import (
3838func TestProcessClusterRecovery (t * testing.T ) {
3939 removeArangodProcesses (t )
4040 testMatch (t , testModeProcess , starterModeCluster , false )
41- dataDirMaster := SetUniqueDataDir (t )
42- defer os .RemoveAll (dataDirMaster )
4341
4442 start := time .Now ()
4543
44+ dataDirMaster := SetUniqueDataDir (t )
45+ defer os .RemoveAll (dataDirMaster )
4646 master := Spawn (t , "${STARTER} --starter.port=8528 " + createEnvironmentStarterOptions ())
47+ master .label = "Master"
4748 defer closeProcess (t , master , "Master" )
4849
4950 dataDirSlave1 := SetUniqueDataDir (t )
5051 defer os .RemoveAll (dataDirSlave1 )
5152 slave1 := Spawn (t , "${STARTER} --starter.port=8628 --starter.join 127.0.0.1:8528 " + createEnvironmentStarterOptions ())
53+ slave1 .label = "Slave1"
5254 defer closeProcess (t , slave1 , "Slave1" )
5355
5456 dataDirSlave2 := SetUniqueDataDir (t )
5557 defer os .RemoveAll (dataDirSlave2 )
5658 slave2 := Spawn (t , "${STARTER} --starter.port=8728 --starter.join 127.0.0.1:8528 " + createEnvironmentStarterOptions ())
59+ slave2 .label = "Slave2"
5760 defer closeProcess (t , slave2 , "Slave2" )
5861
5962 if ok := WaitUntilStarterReady (t , whatCluster , 3 , master , slave1 , slave2 ); ok {
@@ -102,20 +105,21 @@ func TestProcessClusterRecovery(t *testing.T) {
102105 t .Errorf ("Failed to create RECOVERY file: %s" , describe (err ))
103106 }
104107
105- // Restart slave1
108+ // Restart slave1 (recovery)
106109 os .Setenv ("DATA_DIR" , dataDirSlave1 )
107- master = Spawn (t , "${STARTER} --starter.port=8628 --starter.join 127.0.0.1:8528 " + createEnvironmentStarterOptions ())
108- defer closeProcess (t , master , "Master 2" )
110+ slave1Recovery := Spawn (t , "${STARTER} --starter.port=8628 --starter.join 127.0.0.1:8528 " + createEnvironmentStarterOptions ())
111+ slave1Recovery .label = "Slave1 Recovery"
112+ defer closeProcess (t , slave1Recovery , "Slave 1 Recovery" )
109113
110114 // Wait until recovered
111- if ok := WaitUntilStarterReady (t , whatCluster , 3 , master , slave1 , slave2 ); ok {
115+ if ok := WaitUntilStarterReady (t , whatCluster , 3 , master , slave1Recovery , slave2 ); ok {
112116 t .Logf ("Cluster start (with recovery) took %s" , time .Since (start ))
113117 testCluster (t , insecureStarterEndpoint (0 ), false )
114118 testCluster (t , insecureStarterEndpoint (100 ), false )
115119 testCluster (t , insecureStarterEndpoint (200 ), false )
116120 }
117121
118- // RECOVERY file must now be gone within 30s:
122+ // The RECOVERY file must now be gone within the 30s:
119123 startWait := time .Now ()
120124 for {
121125 if _ , err := os .Stat (filepath .Join (dataDirSlave1 , "RECOVERY" )); os .IsNotExist (err ) {
@@ -131,5 +135,6 @@ func TestProcessClusterRecovery(t *testing.T) {
131135 if isVerbose {
132136 t .Log ("Waiting for termination" )
133137 }
134- SendIntrAndWait (t , master , slave1 , slave2 )
138+
139+ SendIntrAndWait (t , master , slave1Recovery , slave2 )
135140}
0 commit comments