aboutsummaryrefslogtreecommitdiff
path: root/weed/server
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2023-03-19 18:30:13 -0700
committerchrislu <chris.lu@gmail.com>2023-03-19 18:30:13 -0700
commit784daea1fa99d2e626e39824563b957703f98e70 (patch)
tree38266e97bfbc8e4ae052b5dcb20daacf5ef4d736 /weed/server
parent264be0d2d4e61543902e79c0b092103400c283f7 (diff)
downloadseaweedfs-784daea1fa99d2e626e39824563b957703f98e70.tar.xz
seaweedfs-784daea1fa99d2e626e39824563b957703f98e70.zip
fix volume not found if marked as read only
fix https://github.com/seaweedfs/seaweedfs/issues/4088
Diffstat (limited to 'weed/server')
-rw-r--r--weed/server/master_grpc_server_volume.go11
1 files changed, 9 insertions, 2 deletions
diff --git a/weed/server/master_grpc_server_volume.go b/weed/server/master_grpc_server_volume.go
index 77154972b..06dbb4bb5 100644
--- a/weed/server/master_grpc_server_volume.go
+++ b/weed/server/master_grpc_server_volume.go
@@ -309,12 +309,19 @@ func (ms *MasterServer) VolumeMarkReadonly(ctx context.Context, req *master_pb.V
replicaPlacement, _ := super_block.NewReplicaPlacementFromByte(byte(req.ReplicaPlacement))
vl := ms.Topo.GetVolumeLayout(req.Collection, replicaPlacement, needle.LoadTTLFromUint32(req.Ttl), types.ToDiskType(req.DiskType))
dataNodes := ms.Topo.Lookup(req.Collection, needle.VolumeId(req.VolumeId))
+ if req.IsReadonly {
+ for _, dn := range dataNodes {
+ if dn.Ip == req.Ip && dn.Port == int(req.Port) {
+
+ }
+ }
+ }
for _, dn := range dataNodes {
if dn.Ip == req.Ip && dn.Port == int(req.Port) {
if req.IsReadonly {
- vl.SetVolumeUnavailable(dn, needle.VolumeId(req.VolumeId))
+ vl.SetVolumeReadOnly(dn, needle.VolumeId(req.VolumeId))
} else {
- vl.SetVolumeAvailable(dn, needle.VolumeId(req.VolumeId), false)
+ vl.SetVolumeWritable(dn, needle.VolumeId(req.VolumeId))
}
}
}