GithubBackup/httprunner
1
0
Fork 0
mirror of https://github.com/httprunner/httprunner.git synced 2026-06-03 14:59:38 +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 e16c8bb565
commit f13a698da3
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() b.InitBoomer()
} }
func (b *HRPBoomer) rebalanceBoomer(profile *boomer.Profile) { func (b *HRPBoomer) rebalanceRunner(profile *boomer.Profile) {
b.SetProfile(profile) b.SetSpawnCount(profile.SpawnCount)
b.SetSpawnCount(b.GetProfile().SpawnCount) b.SetSpawnRate(profile.SpawnRate)
b.SetSpawnRate(b.GetProfile().SpawnRate)
b.SetRunTime(b.GetProfile().RunTime)
b.GetRebalanceChan() <- true b.GetRebalanceChan() <- true
log.Info().Interface("profile", profile).Msg("rebalance tasks successfully") log.Info().Interface("profile", profile).Msg("rebalance tasks successfully")
} }
func (b *HRPBoomer) PollTasks(ctx context.Context) { func (b *HRPBoomer) PollTasks(ctx context.Context) {
for { for {
select { select {