Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

chore: Remove page-fault-rate flag, which is not available

pull/19508/head
Stuart Carnie 2020-09-04 14:18:00 -07:00
parent c8bcc516f6
commit 4266eb5935
1 changed files with 0 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
cmd/influxd/launcher/launcher.go
View File

@ -79,7 +79,6 @@ import (
jaegerconfig "github.com/uber/jaeger-client-go/config" jaegerconfig "github.com/uber/jaeger-client-go/config"
"go.uber.org/zap" "go.uber.org/zap"
"go.uber.org/zap/zapcore" "go.uber.org/zap/zapcore"
"golang.org/x/time/rate"
) )
const ( const (
@ -368,12 +367,6 @@ func launcherOpts(l *Launcher) []cli.Opt {
Default: 10, Default: 10,
Desc: "the number of queries that are allowed to be awaiting execution before new queries are rejected", 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, DestP: &l.featureFlags,
Flag: "feature-flags", Flag: "feature-flags",
@ -446,8 +439,6 @@ type Launcher struct {
Stdout io.Writer Stdout io.Writer
Stderr io.Writer Stderr io.Writer
apibackend *http.APIBackend apibackend *http.APIBackend
pageFaultRate int
} }
type stoppingScheduler interface { type stoppingScheduler interface {
@ -717,13 +708,6 @@ func (m *Launcher) run(ctx context.Context) (err error) {
return err 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) metaClient := meta.NewClient(meta.NewConfig(), m.kvStore)
if err := metaClient.Open(); err != nil { if err := metaClient.Open(); err != nil {
m.log.Error("Failed to open meta client", zap.Error(err)) m.log.Error("Failed to open meta client", zap.Error(err))