From d30cb4b66e60b348fbc26e90d26c152baa1b2b8a Mon Sep 17 00:00:00 2001 From: yutianwu Date: Mon, 31 Jul 2023 15:37:02 +0800 Subject: [PATCH] delete unused code --- x/storage/abci.go | 51 ----------------------------------------------- 1 file changed, 51 deletions(-) delete mode 100644 x/storage/abci.go diff --git a/x/storage/abci.go b/x/storage/abci.go deleted file mode 100644 index b395f512c..000000000 --- a/x/storage/abci.go +++ /dev/null @@ -1,51 +0,0 @@ -package storage - -import ( - sdk "github.com/cosmos/cosmos-sdk/types" - - paymenttypes "github.com/bnb-chain/greenfield/x/payment/types" - k "github.com/bnb-chain/greenfield/x/storage/keeper" -) - -func BeginBlocker(ctx sdk.Context, keeper k.Keeper) { - blockHeight := uint64(ctx.BlockHeight()) - countingWindow := keeper.DiscontinueCountingWindow(ctx) - if blockHeight > 0 && countingWindow > 0 && blockHeight%countingWindow == 0 { - keeper.ClearDiscontinueObjectCount(ctx) - keeper.ClearDiscontinueBucketCount(ctx) - } -} - -func EndBlocker(ctx sdk.Context, keeper k.Keeper) { - deletionMax := keeper.DiscontinueDeletionMax(ctx) - if deletionMax == 0 { - return - } - - blockTime := ctx.BlockTime().Unix() - - // set ForceUpdateStreamRecordKey to true in context to force update frozen stream record - ctx = ctx.WithValue(paymenttypes.ForceUpdateStreamRecordKey, true) - - // delete objects - deleted, err := keeper.DeleteDiscontinueObjectsUntil(ctx, blockTime, deletionMax) - if err != nil { - ctx.Logger().Error("should not happen, fail to delete objects, err " + err.Error()) - panic("should not happen") - } - - if deleted >= deletionMax { - return - } - - // delete buckets - _, err = keeper.DeleteDiscontinueBucketsUntil(ctx, blockTime, deletionMax-deleted) - if err != nil { - ctx.Logger().Error("should not happen, fail to delete buckets, err " + err.Error()) - panic("should not happen") - } - keeper.PersistDeleteInfo(ctx) - - // Permission GC - keeper.GarbageCollectResourcesStalePolicy(ctx) -}