Browse Source

暂时禁用调度时保存到分片存储的机制

feature_gxh
Sydonian 4 months ago
parent
commit
ae0670b122
1 changed files with 8 additions and 9 deletions
  1. +8
    -9
      client/internal/services/user_space.go

+ 8
- 9
client/internal/services/user_space.go View File

@@ -3,7 +3,6 @@ package services
import (
"context"
"fmt"
"time"

"github.com/samber/lo"
"gitlink.org.cn/cloudream/common/pkgs/ioswitch/exec"
@@ -240,14 +239,14 @@ func (svc *UserSpaceService) DownloadPackage(packageID clitypes.PackageID, users
dstPath := rootJPath.ConcatNew(objPath)
ft.AddTo(ioswitch2.NewToBaseStore(*destStg, dstPath))
// 顺便保存到同存储服务的分片存储中
if destStg.UserSpace.ShardStore != nil {
ft.AddTo(ioswitch2.NewToShardStore(*destStg, ioswitch2.RawStream(), ""))
pinned = append(pinned, clitypes.PinnedObject{
ObjectID: details[dIndex].Object.ObjectID,
UserSpaceID: destStg.UserSpace.UserSpaceID,
CreateTime: time.Now(),
})
}
// if destStg.UserSpace.ShardStore != nil {
// ft.AddTo(ioswitch2.NewToShardStore(*destStg, ioswitch2.RawStream(), ""))
// pinned = append(pinned, clitypes.PinnedObject{
// ObjectID: details[dIndex].Object.ObjectID,
// UserSpaceID: destStg.UserSpace.UserSpaceID,
// CreateTime: time.Now(),
// })
// }

err = parser.Parse(ft, plans)
if err != nil {


Loading…
Cancel
Save