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(lcnode): hybrid cloud new blobstore client only when migrating to blobstore #22404848

Browse Source 
Signed-off-by: zhaochenyang <zhaochenyang@oppo.com>
This commit is contained in:
zhaochenyang 2024-07-18 16:40:26 +08:00 committed by AmazingChi
parent af298477f3
commit 744b001d5c
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
lcnode/lc_scanner.go
View File

@ -94,7 +94,15 @@ func NewS3Scanner(adminTask *proto.AdminTask, l *LcNode) (*LcScanner, error) {
}
var ebsClient *blobstore.BlobStoreClient
if l.ebsAddr != "" {
var toEbs bool
if scanner.rule.Transitions != nil {
for _, sc := range scanner.rule.Transitions {
if sc.StorageClass == proto.OpTypeStorageClassEBS {
toEbs = true
}
}
}
if toEbs {
ebsConfig := access.Config{
ConnMode: access.NoLimitConnMode,
Consul: access.ConsulConfig{
@ -106,9 +114,10 @@ func NewS3Scanner(adminTask *proto.AdminTask, l *LcNode) (*LcScanner, error) {
},
}
if ebsClient, err = blobstore.NewEbsClient(ebsConfig); err != nil {
log.LogErrorf("NewEbsClient err: %v", err)
log.LogErrorf("NewEbsClient err: %v, rule id: %v", err, scanner.rule.ID)
return nil, err
}
log.LogDebug("NewEbsClient success")
}
var volumeInfo *proto.SimpleVolView