File tree Expand file tree Collapse file tree 6 files changed +1
-269
lines changed
manual_test/shared_threads Expand file tree Collapse file tree 6 files changed +1
-269
lines changed Original file line number Diff line number Diff line change @@ -507,10 +507,6 @@ namespace NActors {
507
507
TPoolHarmonizerStats stats = Harmonizer->GetPoolStats (PoolId);
508
508
poolState.ElapsedCpu = stats.AvgElapsedCpu ;
509
509
poolState.PossibleMaxLimit = stats.PotentialMaxThreadCount ;
510
- poolState.SharedCpuQuota = stats.SharedCpuQuota ;
511
- poolState.IsNeedy = stats.IsNeedy ;
512
- poolState.IsStarved = stats.IsStarved ;
513
- poolState.IsHoggish = stats.IsHoggish ;
514
510
} else {
515
511
poolState.PossibleMaxLimit = poolState.MaxLimit ;
516
512
}
Original file line number Diff line number Diff line change @@ -497,8 +497,6 @@ THarmonizerStats THarmonizer::GetStats() const {
497
497
.MinElapsedCpu = MinElapsedCpu.load (std::memory_order_relaxed),
498
498
.AvgAwakeningTimeUs = WaitingInfo.AvgAwakeningTimeUs .load (std::memory_order_relaxed),
499
499
.AvgWakingUpTimeUs = WaitingInfo.AvgWakingUpTimeUs .load (std::memory_order_relaxed),
500
- .Budget = CpuConsumption.Budget ,
501
- .SharedFreeCpu = SharedInfo.FreeCpu ,
502
500
};
503
501
}
504
502
@@ -540,8 +538,7 @@ TString THarmonizerStats::ToString() const {
540
538
<< " MinElapsedCpu: " << MinElapsedCpu << " , "
541
539
<< " AvgAwakeningTimeUs: " << AvgAwakeningTimeUs << " , "
542
540
<< " AvgWakingUpTimeUs: " << AvgWakingUpTimeUs << " , "
543
- << " Budget: " << Budget << " , "
544
- << " SharedFreeCpu: " << SharedFreeCpu << ' }' ;
541
+ << ' }' ;
545
542
}
546
543
547
544
}
Original file line number Diff line number Diff line change @@ -49,9 +49,6 @@ namespace NActors {
49
49
float AvgAwakeningTimeUs = 0 ;
50
50
float AvgWakingUpTimeUs = 0 ;
51
51
52
- float Budget = 0.0 ;
53
- float SharedFreeCpu = 0.0 ;
54
-
55
52
TString ToString () const ;
56
53
};
57
54
Load Diff This file was deleted.
Load Diff This file was deleted.
Original file line number Diff line number Diff line change @@ -42,27 +42,17 @@ namespace NActors {
42
42
43
43
struct TExecutorPoolState {
44
44
float ElapsedCpu = 0 ;
45
- float SharedCpuQuota = 0 ;
46
45
float CurrentLimit = 0 ;
47
46
float PossibleMaxLimit = 0 ;
48
47
float MaxLimit = 0 ;
49
48
float MinLimit = 0 ;
50
49
51
- i8 IsNeedy = 0 ;
52
- i8 IsStarved = 0 ;
53
- i8 IsHoggish = 0 ;
54
-
55
50
void Aggregate (const TExecutorPoolState& other) {
56
51
ElapsedCpu += other.ElapsedCpu ;
57
- SharedCpuQuota += other.SharedCpuQuota ;
58
52
CurrentLimit += other.CurrentLimit ;
59
53
PossibleMaxLimit += other.PossibleMaxLimit ;
60
54
MaxLimit += other.MaxLimit ;
61
55
MinLimit += other.MinLimit ;
62
-
63
- IsNeedy += other.IsNeedy ;
64
- IsStarved += other.IsStarved ;
65
- IsHoggish += other.IsHoggish ;
66
56
}
67
57
};
68
58
You can’t perform that action at this time.
0 commit comments