diff options
author | Zeger-Jan van de Weg <git@zjvandeweg.nl> | 2020-02-07 16:05:38 +0300 |
---|---|---|
committer | Zeger-Jan van de Weg <git@zjvandeweg.nl> | 2020-02-10 12:17:33 +0300 |
commit | 0367527ec99d9149a528c5c77c1d8df641666711 (patch) | |
tree | 8e8cced74035350aa3f87511239dab31f6fcd310 | |
parent | ba6b3866f6bedc6a959d7e8b56bc24e60de8548b (diff) |
Remove feature flag for Delta Islands
-rw-r--r-- | internal/git/objectpool/fetch.go | 38 | ||||
-rw-r--r-- | internal/metadata/featureflag/feature_flags.go | 2 | ||||
-rw-r--r-- | internal/service/repository/repack.go | 23 |
3 files changed, 10 insertions, 53 deletions
diff --git a/internal/git/objectpool/fetch.go b/internal/git/objectpool/fetch.go index 37ad27746..4a2cf8d21 100644 --- a/internal/git/objectpool/fetch.go +++ b/internal/git/objectpool/fetch.go @@ -12,14 +12,12 @@ import ( "strings" "github.com/grpc-ecosystem/go-grpc-middleware/logging/logrus/ctxlogrus" - "github.com/prometheus/client_golang/prometheus" "github.com/sirupsen/logrus" "gitlab.com/gitlab-org/gitaly/internal/command" "gitlab.com/gitlab-org/gitaly/internal/git" "gitlab.com/gitlab-org/gitaly/internal/git/repository" "gitlab.com/gitlab-org/gitaly/internal/git/updateref" "gitlab.com/gitlab-org/gitaly/internal/helper" - "gitlab.com/gitlab-org/gitaly/internal/metadata/featureflag" "gitlab.com/gitlab-org/gitaly/proto/go/gitalypb" ) @@ -28,21 +26,6 @@ const ( sourceRefNamespace = "refs/remotes/" + sourceRemote ) -var ( - // FullRepackCounter is a counter used to track full repacks (with/without core delta islands). - FullRepackCounter = prometheus.NewCounterVec( - prometheus.CounterOpts{ - Name: "gitaly_full_repack_total", - Help: "Counter of repack commands run with/without core delta island use", - }, - []string{"core_island"}, - ) -) - -func init() { - prometheus.Register(FullRepackCounter) -} - // FetchFromOrigin initializes the pool and fetches the objects from its origin repository func (o *ObjectPool) FetchFromOrigin(ctx context.Context, origin *gitalypb.Repository) error { if err := o.Init(ctx); err != nil { @@ -188,24 +171,13 @@ func rescueDanglingObjects(ctx context.Context, repo repository.GitRepo) error { } func repackPool(ctx context.Context, pool repository.GitRepo) error { - var repackArgs []git.Option - if featureflag.IsEnabled(ctx, featureflag.UseCoreDeltaIslands) { - FullRepackCounter.WithLabelValues("yes").Inc() - repackArgs = []git.Option{ - git.ValueFlag{"-c", "pack.island=" + sourceRefNamespace + "/he(a)ds"}, - git.ValueFlag{"-c", "pack.island=" + sourceRefNamespace + "/t(a)gs"}, - git.ValueFlag{"-c", "pack.islandCore=a"}, - } - } else { - FullRepackCounter.WithLabelValues("no").Inc() - repackArgs = []git.Option{ - git.ValueFlag{"-c", "pack.island=" + sourceRefNamespace + "/heads"}, - git.ValueFlag{"-c", "pack.island=" + sourceRefNamespace + "/tags"}, - } + repackArgs := []git.Option{ + git.ValueFlag{"-c", "pack.island=" + sourceRefNamespace + "/he(a)ds"}, + git.ValueFlag{"-c", "pack.island=" + sourceRefNamespace + "/t(a)gs"}, + git.ValueFlag{"-c", "pack.islandCore=a"}, + git.ValueFlag{"-c", "pack.writeBitmapHashCache=true"}, } - repackArgs = append(repackArgs, git.ValueFlag{"-c", "pack.writeBitmapHashCache=true"}) - repackCmd, err := git.SafeCmd(ctx, pool, repackArgs, git.SubCmd{ Name: "repack", Flags: []git.Option{git.Flag{"-aidb"}}, diff --git a/internal/metadata/featureflag/feature_flags.go b/internal/metadata/featureflag/feature_flags.go index 35aa7984b..c3ad0093a 100644 --- a/internal/metadata/featureflag/feature_flags.go +++ b/internal/metadata/featureflag/feature_flags.go @@ -16,8 +16,6 @@ const ( // The old one with query fot Info before fetching info about Commit // or the new one that skips Info call and checks object type in Commit method call. CommitWithoutBatchCheck = "commit_without_batch_check" - // UseCoreDeltaIslands enables support of core delta islands for 'repack'. - UseCoreDeltaIslands = "use_core_delta_islands" // UseGitProtocolV2 enables support for git wire protocol v2 UseGitProtocolV2 = "use_git_protocol_v2" ) diff --git a/internal/service/repository/repack.go b/internal/service/repository/repack.go index 23897af74..a0add6443 100644 --- a/internal/service/repository/repack.go +++ b/internal/service/repository/repack.go @@ -6,9 +6,7 @@ import ( "github.com/prometheus/client_golang/prometheus" "gitlab.com/gitlab-org/gitaly/internal/git" - "gitlab.com/gitlab-org/gitaly/internal/git/objectpool" "gitlab.com/gitlab-org/gitaly/internal/git/repository" - "gitlab.com/gitlab-org/gitaly/internal/metadata/featureflag" "gitlab.com/gitlab-org/gitaly/internal/stats" "gitlab.com/gitlab-org/gitaly/proto/go/gitalypb" "google.golang.org/grpc/codes" @@ -73,24 +71,13 @@ func repackCommand(ctx context.Context, repo repository.GitRepo, bitmap bool, ar } func repackConfig(ctx context.Context, bitmap bool) []git.Option { - var args []git.Option - if featureflag.IsEnabled(ctx, featureflag.UseCoreDeltaIslands) { - objectpool.FullRepackCounter.WithLabelValues("yes").Inc() - args = []git.Option{ - git.ValueFlag{"-c", "pack.island=r(e)fs/heads"}, - git.ValueFlag{"-c", "pack.island=r(e)fs/tags"}, - git.ValueFlag{"-c", "pack.islandCore=e"}, - } - } else { - objectpool.FullRepackCounter.WithLabelValues("no").Inc() - args = []git.Option{ - git.ValueFlag{"-c", "pack.island=refs/heads"}, - git.ValueFlag{"-c", "pack.island=refs/tags"}, - } + args := []git.Option{ + git.ValueFlag{"-c", "pack.island=r(e)fs/heads"}, + git.ValueFlag{"-c", "pack.island=r(e)fs/tags"}, + git.ValueFlag{"-c", "pack.islandCore=e"}, + git.ValueFlag{"-c", "repack.useDeltaIslands=true"}, } - args = append(args, git.ValueFlag{"-c", "repack.useDeltaIslands=true"}) - if bitmap { args = append(args, git.ValueFlag{"-c", "repack.writeBitmaps=true"}) args = append(args, git.ValueFlag{"-c", "pack.writeBitmapHashCache=true"}) |