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(clustermgr): update disk lastupdate when disk status changes

Browse Source 
with #1000518879

Signed-off-by: tangdeyi <tangdeyi@oppo.com>
This commit is contained in:
tangdeyi 2025-12-12 15:43:05 +08:00 committed by 梁曟風
parent 6499ead6d5
commit 48d2dfdf6c
2 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
blobstore/clustermgr/persistence/normaldb/blobnodedisktbl_test.go
View File

@ -156,6 +156,7 @@ func TestBlobNodeDiskTbl(t *testing.T) {
diskInfo, err = nodeDiskTbl.GetDisk(dr1.DiskID)
require.NoError(t, err)
require.Equal(t, proto.DiskStatusRepairing, diskInfo.Status)
require.Less(t, dr1.LastUpdateAt, diskInfo.LastUpdateAt)
}
// list disk
@ -260,6 +261,10 @@ func TestBlobNodeDiskDropTbl(t *testing.T) {
err = nodeDiskTbl.DroppedDisk(diskID1)
require.NoError(t, err)
diskInfo, err := nodeDiskTbl.GetDisk(dr1.DiskID)
require.NoError(t, err)
require.Less(t, dr1.LastUpdateAt, diskInfo.LastUpdateAt)
exist, err = nodeDiskTbl.IsDroppingDisk(diskID1)
require.NoError(t, err)
require.Equal(t, false, exist)

2
blobstore/clustermgr/persistence/normaldb/nodedisktbl.go
View File

@ -295,6 +295,7 @@ func (d *nodeDiskTable) UpdateDiskStatus(diskID proto.DiskID, status proto.DiskS
batch.PutCF(d.indexes[diskStatusIndex].tbl.GetCf(), []byte(newIndexKey), key)
diskInfo.Status = status
diskInfo.LastUpdateAt = time.Now()
value, err = d.rd.marshalDiskRecord(info)
if err != nil {
return errors.Info(err, "encode disk failed").Detail(err)
@ -432,6 +433,7 @@ func (d *nodeDiskTable) DroppedDisk(diskID proto.DiskID) error {
batch.PutCF(d.indexes[diskStatusIndex].tbl.GetCf(), []byte(newIndexKey), key)
diskInfo.Status = status
diskInfo.LastUpdateAt = time.Now()
value, err = d.rd.marshalDiskRecord(info)
if err != nil {
return errors.Info(err, "encode disk failed").Detail(err)