github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-27 13:37:30 +00:00
Code Issues Projects Releases Wiki Activity

chore: use WaitForCacheSync method after sharedInformerFactory Start

Browse Source
This commit is contained in:
googs1025 2024-07-20 16:13:36 +08:00
parent 14b34fc255
commit a6ee8599f1
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
test/integration/servicecidr/migration_test.go
View File

@ -82,6 +82,7 @@ func TestMigrateServiceCIDR(t *testing.T) {
client1, client1,
).Run(tCtx, 5) ).Run(tCtx, 5)
informers1.Start(tCtx.Done()) informers1.Start(tCtx.Done())
informers1.WaitForCacheSync(tCtx.Done())
// the default serviceCIDR should have a finalizer and ready condition set to true // the default serviceCIDR should have a finalizer and ready condition set to true
if err := wait.PollUntilContextTimeout(context.Background(), 1*time.Second, time.Minute, false, func(ctx context.Context) (bool, error) { if err := wait.PollUntilContextTimeout(context.Background(), 1*time.Second, time.Minute, false, func(ctx context.Context) (bool, error) {
@ -220,6 +221,7 @@ func TestMigrateServiceCIDR(t *testing.T) {
client2, client2,
).Run(tCtx2, 5) ).Run(tCtx2, 5)
informers2.Start(tCtx2.Done()) informers2.Start(tCtx2.Done())
informers2.WaitForCacheSync(tCtx.Done())
// delete the kubernetes.default service so the old DefaultServiceCIDR can be deleted // delete the kubernetes.default service so the old DefaultServiceCIDR can be deleted
// and the new apiserver can take over // and the new apiserver can take over

2
test/integration/servicecidr/servicecidr_test.go
View File

@ -68,6 +68,7 @@ func TestServiceAllocNewServiceCIDR(t *testing.T) {
client, client,
).Run(ctx, 5) ).Run(ctx, 5)
informerFactory.Start(ctx.Done()) informerFactory.Start(ctx.Done())
informerFactory.WaitForCacheSync(ctx.Done())
// /29 = 6 services, kubernetes.default takes the first address // /29 = 6 services, kubernetes.default takes the first address
// make 5 more services to take up all IPs // make 5 more services to take up all IPs
@ -169,6 +170,7 @@ func TestServiceCIDRDeletion(t *testing.T) {
client, client,
).Run(ctx, 5) ).Run(ctx, 5)
informerFactory.Start(ctx.Done()) informerFactory.Start(ctx.Done())
informerFactory.WaitForCacheSync(ctx.Done())
// /29 = 6 services, kubernetes.default takes the first address // /29 = 6 services, kubernetes.default takes the first address
// make 5 more services to take up all IPs // make 5 more services to take up all IPs