|
|
|
@ -547,8 +547,8 @@ func findAvailablePorts(n int) ([]int, error) { |
|
|
|
// startMiniCluster starts a weed mini instance directly without exec
|
|
|
|
func startMiniClusterWithExtraArgs(t *testing.T, extraArgs []string) (*TestCluster, error) { |
|
|
|
// Find available ports
|
|
|
|
// We need 8 unique ports: Master(2), Volume(2), Filer(2), S3(2)
|
|
|
|
ports, err := findAvailablePorts(8) |
|
|
|
// We need 10 unique ports: Master(2), Volume(2), Filer(2), S3(2), Admin(2)
|
|
|
|
ports, err := findAvailablePorts(10) |
|
|
|
if err != nil { |
|
|
|
return nil, fmt.Errorf("failed to find available ports: %v", err) |
|
|
|
} |
|
|
|
@ -561,6 +561,8 @@ func startMiniClusterWithExtraArgs(t *testing.T, extraArgs []string) (*TestClust |
|
|
|
filerGrpcPort := ports[5] |
|
|
|
s3Port := ports[6] |
|
|
|
s3GrpcPort := ports[7] |
|
|
|
adminPort := ports[8] |
|
|
|
adminGrpcPort := ports[9] |
|
|
|
// Create temporary directory for test data
|
|
|
|
testDir := t.TempDir() |
|
|
|
|
|
|
|
@ -631,6 +633,8 @@ func startMiniClusterWithExtraArgs(t *testing.T, extraArgs []string) (*TestClust |
|
|
|
"-filer.port.grpc=" + strconv.Itoa(filerGrpcPort), |
|
|
|
"-s3.port=" + strconv.Itoa(s3Port), |
|
|
|
"-s3.port.grpc=" + strconv.Itoa(s3GrpcPort), |
|
|
|
"-admin.port=" + strconv.Itoa(adminPort), |
|
|
|
"-admin.port.grpc=" + strconv.Itoa(adminGrpcPort), |
|
|
|
"-webdav.port=0", // Disable WebDAV
|
|
|
|
"-admin.ui=false", // Disable admin UI
|
|
|
|
"-master.volumeSizeLimitMB=32", // Small volumes for testing
|
|
|
|
|