improved cpu load trigger
This commit is contained in:
@@ -46,7 +46,9 @@
|
|||||||
<intervalInSeconds>5</intervalInSeconds>
|
<intervalInSeconds>5</intervalInSeconds>
|
||||||
<governor>performance</governor>
|
<governor>performance</governor>
|
||||||
<customConfig>
|
<customConfig>
|
||||||
<oneMinuteLoadThreshold>0.01</oneMinuteLoadThreshold>
|
<oneMinuteLoadThreshold>0.3</oneMinuteLoadThreshold>
|
||||||
|
<fiveMinuteLoadThreshold>0.2</fiveMinuteLoadThreshold>
|
||||||
|
<tenMinuteLoadThreshold>0.1</tenMinuteLoadThreshold>
|
||||||
</customConfig>
|
</customConfig>
|
||||||
</trigger>
|
</trigger>
|
||||||
</triggers>
|
</triggers>
|
||||||
|
|||||||
@@ -14,21 +14,36 @@ class CpuLoadTrigger(Trigger):
|
|||||||
def one_minute_load_threshold(self) -> float:
|
def one_minute_load_threshold(self) -> float:
|
||||||
return float(self.config.custom_config['oneMinuteLoadThreshold'])
|
return float(self.config.custom_config['oneMinuteLoadThreshold'])
|
||||||
|
|
||||||
|
@cached_property
|
||||||
|
def five_minute_load_threshold(self) -> float:
|
||||||
|
return float(self.config.custom_config['fiveMinuteLoadThreshold'])
|
||||||
|
|
||||||
|
@cached_property
|
||||||
|
def ten_minute_load_threshold(self) -> float:
|
||||||
|
return float(self.config.custom_config['tenMinuteLoadThreshold'])
|
||||||
|
|
||||||
|
@cached_property
|
||||||
|
def threshold(self) -> tuple[float, float, float]:
|
||||||
|
return self.one_minute_load_threshold, self.five_minute_load_threshold, self.ten_minute_load_threshold
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def current_load(self) -> float:
|
def current_load(self) -> tuple[float, float, float]:
|
||||||
_current_load = getloadavg()[0]
|
_current_load = getloadavg()
|
||||||
self.log.debug("current load: %s", _current_load)
|
self.log.debug("current load: %s", _current_load)
|
||||||
return _current_load
|
return _current_load
|
||||||
|
|
||||||
|
def current_load_average_over_threshold(self) -> bool:
|
||||||
|
return any(load >= threshold for load, threshold in zip(self.current_load, self.threshold))
|
||||||
|
|
||||||
def run(self) -> None:
|
def run(self) -> None:
|
||||||
current_active = self.active
|
current_active = self.active
|
||||||
current_time = datetime.now()
|
current_time = datetime.now()
|
||||||
new_active = self.current_load >= self.one_minute_load_threshold
|
new_active = self.current_load_average_over_threshold()
|
||||||
|
|
||||||
if not current_active and new_active:
|
if not current_active and new_active:
|
||||||
self.log.info(
|
self.log.info(
|
||||||
"activating trigger, load: %s, threshold: %s, governor: %s",
|
"activating trigger, load: %s, threshold: %s, governor: %s",
|
||||||
self.current_load, self.one_minute_load_threshold, self.governor.name
|
self.current_load, self.threshold, self.governor.name
|
||||||
)
|
)
|
||||||
self.timestamp_last_governor_change = current_time
|
self.timestamp_last_governor_change = current_time
|
||||||
|
|
||||||
@@ -39,7 +54,7 @@ class CpuLoadTrigger(Trigger):
|
|||||||
|
|
||||||
self.log.info(
|
self.log.info(
|
||||||
"deactivating trigger, load: %s, threshold: %s, governor: %s",
|
"deactivating trigger, load: %s, threshold: %s, governor: %s",
|
||||||
self.current_load, self.one_minute_load_threshold, self.governor.name
|
self.current_load, self.threshold, self.governor.name
|
||||||
)
|
)
|
||||||
|
|
||||||
self.active = new_active
|
self.active = new_active
|
||||||
|
|||||||
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
[project]
|
[project]
|
||||||
name = "cpu_governor_auto_adjust"
|
name = "cpu_governor_auto_adjust"
|
||||||
version = "0.1.39"
|
version = "0.1.41"
|
||||||
description = "This application has been developed to automatically change cpu governor based on certain triggers."
|
description = "This application has been developed to automatically change cpu governor based on certain triggers."
|
||||||
authors = [
|
authors = [
|
||||||
{ name = "Martin Reurekas", email = "martin@semrks.nl" }
|
{ name = "Martin Reurekas", email = "martin@semrks.nl" }
|
||||||
|
|||||||
Reference in New Issue
Block a user