GithubBackup/httprunner
1
0
Fork 0
mirror of https://github.com/httprunner/httprunner.git synced 2026-05-12 02:21:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

merge upstream master change

Browse Source
This commit is contained in:
machongwei
2022-08-21 09:11:58 +08:00
parent 7782399e15
commit 07c1f78364
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
hrp/boomer.go
View File

@@ -245,15 +245,14 @@ func (b *HRPBoomer) initWorker(profile *boomer.Profile) {
b.InitBoomer()
}
func (b *HRPBoomer) rebalanceBoomer(profile *boomer.Profile) {
b.SetProfile(profile)
b.SetSpawnCount(b.GetProfile().SpawnCount)
b.SetSpawnRate(b.GetProfile().SpawnRate)
b.SetRunTime(b.GetProfile().RunTime)
func (b *HRPBoomer) rebalanceRunner(profile *boomer.Profile) {
b.SetSpawnCount(profile.SpawnCount)
b.SetSpawnRate(profile.SpawnRate)
b.GetRebalanceChan() <- true
log.Info().Interface("profile", profile).Msg("rebalance tasks successfully")
}
func (b *HRPBoomer) PollTasks(ctx context.Context) {
for {
select {