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

fix(clustermgr): complete routeVersion field in full route fetch

Browse Source 
with #23013508

Signed-off-by: tangdeyi <tangdeyi@oppo.com>
This commit is contained in:
tangdeyi 2025-02-14 11:16:10 +08:00 committed by slasher
parent 4094d85642
commit 4135173df1
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
blobstore/clustermgr/catalog/route.go
View File

@ -67,6 +67,7 @@ func (c *CatalogMgr) GetCatalogChanges(ctx context.Context, args *clustermgr.Get
shard.withRLocked(func() error {
if items[i].RouteVersion == proto.InvalidRouteVersion {
items[i].RouteVersion = shard.info.RouteVersion
ret.Items[i].RouteVersion = shard.info.RouteVersion
}
for _, unit := range shard.info.Units {
unitInfo := shardUnitToShardUnitInfo(unit, items[i].RouteVersion, shard.info.Range, shard.info.LeaderDiskID)

1
blobstore/clustermgr/catalog/route_test.go
View File

@ -163,6 +163,7 @@ func TestCatalogMgr_Route(t *testing.T) {
ret, err := mockCatalogMgr.GetCatalogChanges(ctx, &clustermgr.GetCatalogChangesArgs{})
require.NoError(t, err)
require.Equal(t, 10, len(ret.Items))
require.NotEqual(t, proto.InvalidRouteVersion, ret.Items[0].RouteVersion)
require.Equal(t, proto.RouteVersion(11), ret.RouteVersion)
// get catalog with normal routerVersion