filer: route tests forward to a peer port the test holds (#12576)

The ring tests used 127.0.0.1:18889 as an unreachable peer, but its gRPC
port 28889 is a common filer port: on a shared CI host a live filer there
accepted the forwarded exclusive create, and
TestCreateEntryExclusiveLeavesNonOwner failed. The peer now listens on a
port the test owns and drops every connection.

Co-authored-by: Claude Opus 5.5 <noreply@anthropic.com>

weed/server/filer_grpc_server_create_route_test.go

@@ -18,7 +18,34 @@ import (
 	"github.com/seaweedfs/seaweedfs/weed/util"
 )
 
-// createRouteServer builds a filer whose ring holds two unreachable peers, so a
+// deadAddress returns a peer whose gRPC port this test holds and drops every
+// connection on, so a forward to it fails even on a host where a fixed port
+// could reach a live filer.
+func deadAddress(t *testing.T) pb.ServerAddress {
+	t.Helper()
+	lis, err := net.Listen("tcp", "127.0.0.1:0")
+	if err != nil {
+		t.Fatalf("listen: %v", err)
+	}
+	go func() {
+		for {
+			conn, err := lis.Accept()
+			if err != nil {
+				return
+			}
+			conn.Close()
+		}
+	}()
+	address := pb.NewServerAddress("127.0.0.1", 1, lis.Addr().(*net.TCPAddr).Port)
+	pb.InvalidateGrpcConnection(address.ToGrpcAddress())
+	t.Cleanup(func() {
+		lis.Close()
+		pb.InvalidateGrpcConnection(address.ToGrpcAddress())
+	})
+	return address
+}
+
+// createRouteServer builds a filer whose ring holds an unreachable peer, so a
 // forwarded create fails at the dial and is distinguishable from a local apply.
 func createRouteServer(t *testing.T) (*FilerServer, *renameTestStore) {
 	t.Helper()
@@ -27,7 +54,7 @@ func createRouteServer(t *testing.T) (*FilerServer, *renameTestStore) {
 	f := newRenameTestFiler(t, store)
 	f.DirBucketsPath = "/buckets"
 	f.Dlm = lock_manager.NewDistributedLockManager(self)
-	f.Dlm.LockRing.SetSnapshot([]pb.ServerAddress{self, "127.0.0.1:18889"}, 1)
+	f.Dlm.LockRing.SetSnapshot([]pb.ServerAddress{self, deadAddress(t)}, 1)
 	return &FilerServer{
 		filer:          f,
 		option:         &FilerOption{Host: self},
@@ -194,13 +221,13 @@ func TestCreateEntryExclusiveAppliedByOwner(t *testing.T) {
 // down, and applying here would be the second serialization point on the key.
 func TestCreateEntryFailsWhenPriorOwnerIsUnreachable(t *testing.T) {
 	const self = pb.ServerAddress("127.0.0.1:28888")
-	const peer = pb.ServerAddress("127.0.0.1:28889")
+	peer := deadAddress(t)
 	store := newRenameTestStore()
 	f := newRenameTestFiler(t, store)
 	f.DirBucketsPath = "/buckets"
 	f.Dlm = lock_manager.NewDistributedLockManager(self)
 	// Dropping the peer moves every key it owned to this filer, with the peer as
-	// their prior owner — and nothing is listening on it.
+	// their prior owner — and it answers no RPC.
 	f.Dlm.LockRing.SetSnapshot([]pb.ServerAddress{self, peer}, 1)
 	f.Dlm.LockRing.SetSnapshot([]pb.ServerAddress{self}, 2)
 	fs := &FilerServer{

weed/server/filer_grpc_server_remote_test.go

@@ -213,7 +213,7 @@ func TestPruneOnANonOwnerLeavesTheDeleteToTheOwner(t *testing.T) {
 	fs.option.Host = self
 	fs.grpcDialOption = grpc.WithTransportCredentials(insecure.NewCredentials())
 	fs.filer.Dlm = lock_manager.NewDistributedLockManager(self)
-	fs.filer.Dlm.LockRing.SetSnapshot([]pb.ServerAddress{self, "127.0.0.1:18889"}, 1)
+	fs.filer.Dlm.LockRing.SetSnapshot([]pb.ServerAddress{self, deadAddress(t)}, 1)
 	var entry *filer.Entry
 	for i := 0; i < 4000 && entry == nil; i++ {
 		p := util.FullPath(fmt.Sprintf("/buckets/b/obj-%d.bin", i))