Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitaly.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorZeger-Jan van de Weg <git@zjvandeweg.nl>2020-02-07 16:05:38 +0300
committerZeger-Jan van de Weg <git@zjvandeweg.nl>2020-02-10 12:17:33 +0300
commit0367527ec99d9149a528c5c77c1d8df641666711 (patch)
tree8e8cced74035350aa3f87511239dab31f6fcd310
parentba6b3866f6bedc6a959d7e8b56bc24e60de8548b (diff)
Remove feature flag for Delta Islands
-rw-r--r--internal/git/objectpool/fetch.go38
-rw-r--r--internal/metadata/featureflag/feature_flags.go2
-rw-r--r--internal/service/repository/repack.go23
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"})