increase waiting for notifications

Author: ndyakov

maintnotifications/e2e/scenario_endpoint_types_test.go

@@ -189,7 +189,7 @@ func TestEndpointTypesPushNotifications(t *testing.T) {
 			// Wait for FAILING_OVER notification
 			match, found := logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 				return strings.Contains(s, logs2.ProcessingNotificationMessage) && notificationType(s, "FAILING_OVER")
-			}, 2*time.Minute)
+			}, 3*time.Minute)
 			if !found {
 				ef("FAILING_OVER notification was not received for %s endpoint type", endpointTest.name)
 			}
@@ -201,7 +201,7 @@ func TestEndpointTypesPushNotifications(t *testing.T) {
 			connIDToObserve := uint64(failingOverData["connID"].(float64))
 			match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 				return notificationType(s, "FAILED_OVER") && connID(s, connIDToObserve) && seqID(s, seqIDToObserve+1)
-			}, 2*time.Minute)
+			}, 3*time.Minute)
 			if !found {
 				ef("FAILED_OVER notification was not received for %s endpoint type", endpointTest.name)
 			}
@@ -255,7 +255,7 @@ func TestEndpointTypesPushNotifications(t *testing.T) {
 			connIDToObserve = uint64(migrateData["connID"].(float64))
 			match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 				return notificationType(s, "MIGRATED") && connID(s, connIDToObserve) && seqID(s, seqIDToObserve+1)
-			}, 2*time.Minute)
+			}, 3*time.Minute)
 			if !found {
 				ef("MIGRATED notification was not received for %s endpoint type", endpointTest.name)
 			}
@@ -277,7 +277,7 @@ func TestEndpointTypesPushNotifications(t *testing.T) {
 			// Wait for MOVING notification
 			match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 				return strings.Contains(s, logs2.ProcessingNotificationMessage) && notificationType(s, "MOVING")
-			}, 2*time.Minute)
+			}, 3*time.Minute)
 			if !found {
 				ef("MOVING notification was not received for %s endpoint type", endpointTest.name)
 			}

maintnotifications/e2e/scenario_push_notifications_test.go

@@ -157,7 +157,7 @@ func TestPushNotifications(t *testing.T) {
 		p("Waiting for FAILING_OVER notification")
 		match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 			return strings.Contains(s, logs2.ProcessingNotificationMessage) && notificationType(s, "FAILING_OVER")
-		}, 2*time.Minute)
+		}, 3*time.Minute)
 		commandsRunner.Stop()
 	}()
 	commandsRunner.FireCommandsUntilStop(ctx)
@@ -172,7 +172,7 @@ func TestPushNotifications(t *testing.T) {
 		p("Waiting for FAILED_OVER notification on conn %d with seqID %d...", connIDToObserve, seqIDToObserve+1)
 		match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 			return notificationType(s, "FAILED_OVER") && connID(s, connIDToObserve) && seqID(s, seqIDToObserve+1)
-		}, 2*time.Minute)
+		}, 3*time.Minute)
 		commandsRunner.Stop()
 	}()
 	commandsRunner.FireCommandsUntilStop(ctx)
@@ -232,7 +232,7 @@ func TestPushNotifications(t *testing.T) {
 		p("Waiting for MIGRATED notification on conn %d with seqID %d...", connIDToObserve, seqIDToObserve+1)
 		match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 			return notificationType(s, "MIGRATED") && connID(s, connIDToObserve) && seqID(s, seqIDToObserve+1)
-		}, 2*time.Minute)
+		}, 3*time.Minute)
 		commandsRunner.Stop()
 	}()
 	commandsRunner.FireCommandsUntilStop(ctx)
@@ -299,7 +299,7 @@ func TestPushNotifications(t *testing.T) {
 		p("Waiting for MOVING notification on second client")
 		match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 			return strings.Contains(s, logs2.ProcessingNotificationMessage) && notificationType(s, "MOVING")
-		}, 2*time.Minute)
+		}, 3*time.Minute)
 		commandsRunner.Stop()
 		// once moving is received, start a second client commands runner
 		p("Starting commands on second client")
@@ -315,7 +315,7 @@ func TestPushNotifications(t *testing.T) {
 		// also validate big enough relaxed timeout
 		match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 			return strings.Contains(s, logs2.ProcessingNotificationMessage) && notificationType(s, "MOVING") && connID(s, 18)
-		}, 2*time.Minute)
+		}, 3*time.Minute)
 		if !found {
 			errChan <- fmt.Errorf("MOVING notification was not received within 2 minutes ON A SECOND CLIENT")
 			return
@@ -325,7 +325,7 @@ func TestPushNotifications(t *testing.T) {
 		// wait for relaxation of 30m
 		match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 			return strings.Contains(s, logs2.ApplyingRelaxedTimeoutDueToPostHandoffMessage) && strings.Contains(s, "30m")
-		}, 2*time.Minute)
+		}, 3*time.Minute)
 		if !found {
 			errChan <- fmt.Errorf("relaxed timeout was not applied within 2 minutes ON A SECOND CLIENT")
 			return

maintnotifications/e2e/scenario_timeout_configs_test.go

@@ -42,7 +42,7 @@ func TestTimeoutConfigurationsPushNotifications(t *testing.T) {
 		{
 			name:                       "Conservative",
 			handoffTimeout:             60 * time.Second,
-			relaxedTimeout:             60 * time.Second,
+			relaxedTimeout:             30 * time.Second,
 			postHandoffRelaxedDuration: 2 * time.Minute,
 			description:                "Conservative timeouts for stable environments",
 			expectedBehavior:           "Longer timeouts, fewer timeout errors",
@@ -293,7 +293,7 @@ func TestTimeoutConfigurationsPushNotifications(t *testing.T) {
 			// waiting for moving notification
 			match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 				return strings.Contains(s, logs2.ProcessingNotificationMessage) && notificationType(s, "MOVING")
-			}, 2*time.Minute)
+			}, 3*time.Minute)
 			if !found {
 				ef("MOVING notification was not received for %s timeout config", timeoutTest.name)
 			}

maintnotifications/e2e/scenario_tls_configs_test.go

@@ -208,7 +208,7 @@ func ТestTLSConfigurationsPushNotifications(t *testing.T) {
 			// Wait for FAILING_OVER notification
 			match, found := logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 				return strings.Contains(s, logs2.ProcessingNotificationMessage) && notificationType(s, "FAILING_OVER")
-			}, 2*time.Minute)
+			}, 3*time.Minute)
 			if !found {
 				ef("FAILING_OVER notification was not received for %s TLS config", tlsTest.name)
 			}
@@ -220,7 +220,7 @@ func ТestTLSConfigurationsPushNotifications(t *testing.T) {
 			connIDToObserve := uint64(failingOverData["connID"].(float64))
 			match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
 				return notificationType(s, "FAILED_OVER") && connID(s, connIDToObserve) && seqID(s, seqIDToObserve+1)
-			}, 2*time.Minute)
+			}, 3*time.Minute)
 			if !found {
 				ef("FAILED_OVER notification was not received for %s TLS config", tlsTest.name)
 			}