mirror of
https://github.com/OpenListTeam/OpenList.git
synced 2025-11-25 03:15:19 +08:00
549e60136b
* fix retry task after restart * fix: initialize SrcStorage and DstStorage in tasks to prevent nil pointer dereference * feat: implement storage load signal mechanism for improved synchronization * fix: update StoragesLoaded logic * refactor: reorganize storage loading logic and improve synchronization handling --------- Co-authored-by: j2rong4cn <j2rong@qq.com>
31 lines
865 B
Go
31 lines
865 B
Go
package bootstrap
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/OpenListTeam/OpenList/v4/internal/conf"
|
|
"github.com/OpenListTeam/OpenList/v4/internal/db"
|
|
"github.com/OpenListTeam/OpenList/v4/internal/model"
|
|
"github.com/OpenListTeam/OpenList/v4/internal/op"
|
|
"github.com/OpenListTeam/OpenList/v4/pkg/utils"
|
|
)
|
|
|
|
func LoadStorages() {
|
|
storages, err := db.GetEnabledStorages()
|
|
if err != nil {
|
|
utils.Log.Fatalf("failed get enabled storages: %+v", err)
|
|
}
|
|
go func(storages []model.Storage) {
|
|
for i := range storages {
|
|
err := op.LoadStorage(context.Background(), storages[i])
|
|
if err != nil {
|
|
utils.Log.Errorf("failed get enabled storages: %+v", err)
|
|
} else {
|
|
utils.Log.Infof("success load storage: [%s], driver: [%s], order: [%d]",
|
|
storages[i].MountPath, storages[i].Driver, storages[i].Order)
|
|
}
|
|
}
|
|
conf.SendStoragesLoadedSignal()
|
|
}(storages)
|
|
}
|