gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat(client): exit when volume has been marked delete

Browse Source 
Signed-off-by: lily-lee <lilylee88756@gmail.com>
This commit is contained in:
lily-lee 2023-12-22 10:08:49 +08:00 committed by leonrayang
parent 47a7953811
commit 74c7211a71
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
client/fuse.go
View File

@ -657,8 +657,18 @@ func mount(opt *proto.MountOptions) (fsConn *fuse.Conn, super *cfs.Super, err er
volumeInfo, err = mc.AdminAPI().GetVolumeSimpleInfo(opt.Volname)
if err != nil {
log.LogErrorf("UpdateVolConf: get vol info from master failed, err %s", err.Error())
if err == proto.ErrVolNotExists {
daemonize.SignalOutcome(err)
os.Exit(1)
}
continue
}
if volumeInfo.Status == proto.VolStatusMarkDelete {
err = fmt.Errorf("vol [%s] has been deleted, stop client", volumeInfo.Name)
log.LogError(err)
daemonize.SignalOutcome(err)
os.Exit(1)
}
super.SetTransaction(volumeInfo.EnableTransaction, volumeInfo.TxTimeout, volumeInfo.TxConflictRetryNum, volumeInfo.TxConflictRetryInterval)
if proto.IsCold(opt.VolType) {
super.CacheAction = volumeInfo.CacheAction

6
proto/status.go
View File

@ -21,3 +21,9 @@ const (
ReadWrite = 2
Unavailable = -1
)
// volume status
const (
VolStatusNormal uint8 = 0
VolStatusMarkDelete uint8 = 1
)