From bd41ce39f7a0cca67a6f0f79d03a432a43733eca Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Fri, 18 Sep 2026 11:34:05 -0700 Subject: [PATCH] test: opt erasure-coding loopback clusters out of the remote endpoint guard The erasure-coding suites drive VolumeEcShardsCopy / VolumeCopy between volume servers bound to 127.0.0.1, which the copy/tail source guard now rejects by default. Pass -volume.allowUntrustedRemoteEndpoints to the test volume launches, matching what the volume_server framework harnesses already do. --- test/erasure_coding/admin_dockertest/ec_integration_test.go | 2 +- test/erasure_coding/chaos_lifecycle_test.go | 1 + test/erasure_coding/ec_integration_test.go | 6 ++++++ test/erasure_coding/multidisk_shell_lifecycle_test.go | 1 + 4 files changed, 9 insertions(+), 1 deletion(-) diff --git a/test/erasure_coding/admin_dockertest/ec_integration_test.go b/test/erasure_coding/admin_dockertest/ec_integration_test.go index 8d62f3279..7840aca1d 100644 --- a/test/erasure_coding/admin_dockertest/ec_integration_test.go +++ b/test/erasure_coding/admin_dockertest/ec_integration_test.go @@ -129,7 +129,7 @@ func ensureEnvironment(t *testing.T) { port := 8080 + i - 1 dir := filepath.Join("tmp", volName) os.MkdirAll(dir, 0755) - startWeed(t, volName, "volume", "-dir="+dir, "-mserver=localhost:9333", fmt.Sprintf("-port=%d", port), "-ip=localhost") + startWeed(t, volName, "volume", "-dir="+dir, "-mserver=localhost:9333", fmt.Sprintf("-port=%d", port), "-ip=localhost", "-volume.allowUntrustedRemoteEndpoints") }(i) } volWg.Wait() diff --git a/test/erasure_coding/chaos_lifecycle_test.go b/test/erasure_coding/chaos_lifecycle_test.go index 27185f8e3..7d5c9758b 100644 --- a/test/erasure_coding/chaos_lifecycle_test.go +++ b/test/erasure_coding/chaos_lifecycle_test.go @@ -1215,6 +1215,7 @@ func (c *chaosCluster) startVolumeServer(ctx context.Context, i int, logName str "-max", strings.Join(maxVolumes, ","), "-minFreeSpace", "0", "-master", chaosMasterAddr, + "-volume.allowUntrustedRemoteEndpoints", "-ip", "127.0.0.1", "-dataCenter", "dc1", "-rack", fmt.Sprintf("rack%d", i), diff --git a/test/erasure_coding/ec_integration_test.go b/test/erasure_coding/ec_integration_test.go index 75aaf5025..f3a146133 100644 --- a/test/erasure_coding/ec_integration_test.go +++ b/test/erasure_coding/ec_integration_test.go @@ -439,6 +439,7 @@ func startSeaweedFSCluster(ctx context.Context, dataDir string) (*TestCluster, e "-dir", volumeDir, "-max", "10", "-master", "127.0.0.1:9333", + "-volume.allowUntrustedRemoteEndpoints", "-ip", "127.0.0.1", "-dataCenter", "dc1", "-rack", rack, @@ -1082,6 +1083,7 @@ func startMultiDiskCluster(ctx context.Context, dataDir string) (*MultiDiskClust "-dir", strings.Join(diskDirs, ","), "-max", strings.Join(maxVolumes, ","), "-master", "127.0.0.1:9334", + "-volume.allowUntrustedRemoteEndpoints", "-ip", "127.0.0.1", "-dataCenter", "dc1", "-rack", rack, @@ -1478,6 +1480,7 @@ func startClusterWithDiskType(ctx context.Context, dataDir string, diskType stri "-dir", diskDir, "-max", "10", "-mserver", "127.0.0.1:9335", + "-volume.allowUntrustedRemoteEndpoints", "-ip", "127.0.0.1", "-dataCenter", "dc1", "-rack", rack, @@ -1708,6 +1711,7 @@ func startMixedDiskTypeCluster(ctx context.Context, dataDir string) (*MultiDiskC "-dir", diskDir, "-max", "10", "-mserver", "127.0.0.1:9336", + "-volume.allowUntrustedRemoteEndpoints", "-ip", "127.0.0.1", "-dataCenter", "dc1", "-rack", rack, @@ -2030,6 +2034,7 @@ func startLimitedSsdCluster(ctx context.Context, dataDir string) (*MultiDiskClus "-dir", diskDir, "-max", "10", "-mserver", "127.0.0.1:9337", + "-volume.allowUntrustedRemoteEndpoints", "-ip", "127.0.0.1", "-dataCenter", "dc1", "-rack", config.rack, @@ -2112,6 +2117,7 @@ func startMultiRackCluster(ctx context.Context, dataDir string) (*MultiDiskClust "-dir", diskDir, "-max", "10", "-mserver", "127.0.0.1:9338", + "-volume.allowUntrustedRemoteEndpoints", "-ip", "127.0.0.1", "-dataCenter", "dc1", "-rack", rack, diff --git a/test/erasure_coding/multidisk_shell_lifecycle_test.go b/test/erasure_coding/multidisk_shell_lifecycle_test.go index 3a9408ddd..58c189910 100644 --- a/test/erasure_coding/multidisk_shell_lifecycle_test.go +++ b/test/erasure_coding/multidisk_shell_lifecycle_test.go @@ -233,6 +233,7 @@ func (c *MultiDiskCluster) startVolumeServers(ctx context.Context) error { "-dir", strings.Join(diskDirs, ","), "-max", strings.Join(maxVolumes, ","), "-master", "127.0.0.1:9334", + "-volume.allowUntrustedRemoteEndpoints", "-ip", "127.0.0.1", "-dataCenter", "dc1", "-rack", fmt.Sprintf("rack%d", i),