FIX: not enough time for delete meta make effect

bitleak · Sep 15, 2020 · 10f5d90 · 10f5d90
1 parent 2d476a2
commit 10f5d90
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/push/meta_test.go b/push/meta_test.go
@@ -120,7 +120,7 @@ func TestMetaManager_Delete(t *testing.T) {
 	if err != nil {
 		t.Fatalf("expect metaManager create return nil, but got %v", err)
 	}
-	time.Sleep(4 * time.Second)
+	time.Sleep(6 * time.Second)
 	meta := _manager.MetaManager.Get("default", "test-ns", "test-queue-delete")
 	if meta == nil {
 		t.Fatalf("expect metaManager get return meta, but got nil")
@@ -141,7 +141,7 @@ func TestMetaManager_Delete(t *testing.T) {
 		t.Fatalf("expect metaManager get from remote meta equel nil")
 	}
 	// wait for meta update and pusher stop
-	time.Sleep(6 * time.Second)
+	time.Sleep(12 * time.Second)
 	meta = _manager.MetaManager.Get("default", "test-ns", "test-queue-delete")
 	if meta != nil {
 		t.Fatalf("expect metaManager get return nil")
@@ -162,7 +162,7 @@ func TestMetaManager_ListPusherByNamespace(t *testing.T) {
 	if err != nil {
 		t.Fatalf("expect metaManager create return nil, but got %v", err)
 	}
-	time.Sleep(4 * time.Second)
+	time.Sleep(6 * time.Second)
 	metaMap := _manager.MetaManager.ListPusherByNamespace("default", "test-ns-list")
 	if len(metaMap) != 2 {
 		t.Fatalf("expect list pusher by namespace return 2 meta, but got %d", len(metaMap))

diff --git a/server/handlers/pusher_test.go b/server/handlers/pusher_test.go
@@ -92,7 +92,7 @@ func TestUpdateQueuePusher(t *testing.T) {
 		t.Logf(resp.Body.String())
 		t.Fatal("Failed to update queue pusher")
 	}
-	time.Sleep(7 * time.Second)
+	time.Sleep(12 * time.Second)
 	meta := push.GetManager().Get("default", "ns-pusher", "queue-pusher")
 	if meta == nil || meta.Endpoint != "http://test-enpoint-new" || meta.Timeout != 1 || meta.Workers != 3 {
 		t.Fatal("Mismatch meta in update queue pusher")
@@ -112,7 +112,7 @@ func TestDeleteQueuePusher(t *testing.T) {
 		t.Logf(resp.Body.String())
 		t.Fatal("Failed to list namespace pusher")
 	}
-	time.Sleep(7 * time.Second)
+	time.Sleep(12 * time.Second)
 	meta := push.GetManager().Get("default", "ns-pusher", "queue-pusher")
 	if meta != nil {
 		t.Fatal("Mismatch meta in delete queue pusher")