Skip to content

fix: Change the value pass in slope to a reference pass. #116

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Oct 31, 2022
Merged

fix: Change the value pass in slope to a reference pass. #116

Changes from 1 commit
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
dd427b5
fix: Change the value pass in slope to a reference pass.
Super-long May 27, 2022
2e26260
Merge branch 'master' into fix_slopePercent
tiny-x Jun 14, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 10 additions & 8 deletions exec/cpu/cpu.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -282,7 +282,9 @@ func (ce *cpuExecutor) start(ctx context.Context, cpuList string, cpuCount, cpuP
}
}

slope(ctx, cpuPercent, climbTime, slopePercent, precpu, cpuIndex)
// make CPU slowly climb to some level, to simulate slow resource competition
// which system faults cannot be quickly noticed by monitoring system.
slope(ctx, cpuPercent, climbTime, &slopePercent, precpu, cpuIndex)

quota := make(chan int64, cpuCount)
for i := 0; i < cpuCount; i++ {
Expand All @@ -299,17 +301,17 @@ func (ce *cpuExecutor) start(ctx context.Context, cpuList string, cpuCount, cpuP

const period = int64(1000000000)

func slope(ctx context.Context, cpuPercent int, climbTime int, slopePercent float64, precpu bool, cpuIndex int) {
func slope(ctx context.Context, cpuPercent int, climbTime int, slopePercent *float64, precpu bool, cpuIndex int) {
if climbTime != 0 {
var ticker = time.NewTicker(time.Second)
slopePercent = getUsed(ctx, precpu, cpuIndex)
var startPercent = float64(cpuPercent) - slopePercent
*slopePercent = getUsed(ctx, precpu, cpuIndex)
var startPercent = float64(cpuPercent) - *slopePercent
go func() {
for range ticker.C {
if slopePercent < float64(cpuPercent) {
slopePercent += startPercent / float64(climbTime)
} else if slopePercent > float64(cpuPercent) {
slopePercent -= startPercent / float64(climbTime)
if *slopePercent < float64(cpuPercent) {
*slopePercent += startPercent / float64(climbTime)
} else if *slopePercent > float64(cpuPercent) {
*slopePercent -= startPercent / float64(climbTime)
}
}
}()
Expand Down