From 4266eb5935fbe07883471351eead60be7a71b2d5 Mon Sep 17 00:00:00 2001 From: Stuart Carnie Date: Fri, 4 Sep 2020 14:18:00 -0700 Subject: [PATCH] chore: Remove page-fault-rate flag, which is not available --- cmd/influxd/launcher/launcher.go | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/cmd/influxd/launcher/launcher.go b/cmd/influxd/launcher/launcher.go index b031313213..2ed25da8df 100644 --- a/cmd/influxd/launcher/launcher.go +++ b/cmd/influxd/launcher/launcher.go @@ -79,7 +79,6 @@ import ( jaegerconfig "github.com/uber/jaeger-client-go/config" "go.uber.org/zap" "go.uber.org/zap/zapcore" - "golang.org/x/time/rate" ) const ( @@ -368,12 +367,6 @@ func launcherOpts(l *Launcher) []cli.Opt { Default: 10, Desc: "the number of queries that are allowed to be awaiting execution before new queries are rejected", }, - { - DestP: &l.pageFaultRate, - Flag: "page-fault-rate", - Default: 0, - Desc: "the number of page faults allowed per second in the storage engine", - }, { DestP: &l.featureFlags, Flag: "feature-flags", @@ -446,8 +439,6 @@ type Launcher struct { Stdout io.Writer Stderr io.Writer apibackend *http.APIBackend - - pageFaultRate int } type stoppingScheduler interface { @@ -717,13 +708,6 @@ func (m *Launcher) run(ctx context.Context) (err error) { return err } - // Enable storage layer page fault limiting if rate set above zero. - var pageFaultLimiter *rate.Limiter - if m.pageFaultRate > 0 { - pageFaultLimiter = rate.NewLimiter(rate.Limit(m.pageFaultRate), 1) - } - _ = pageFaultLimiter - metaClient := meta.NewClient(meta.NewConfig(), m.kvStore) if err := metaClient.Open(); err != nil { m.log.Error("Failed to open meta client", zap.Error(err))