@@ -30,6 +30,7 @@ def main():
30
30
node .declare_parameter ("update_frequency" , 10.0 )
31
31
node .declare_parameter ("do_memory" , True )
32
32
node .declare_parameter ("do_cpu" , True )
33
+ node .declare_parameter ("do_network" , True )
33
34
node .declare_parameter ("cpu_load_percentage" , 80.0 )
34
35
node .declare_parameter ("memory_load_percentage" , 80.0 )
35
36
node .declare_parameter ("network_rate_received_errors" , 10.0 )
@@ -38,6 +39,7 @@ def main():
38
39
rate = node .get_parameter ("update_frequency" ).get_parameter_value ().double_value
39
40
do_memory = node .get_parameter ("do_memory" ).get_parameter_value ().bool_value
40
41
do_cpu = node .get_parameter ("do_cpu" ).get_parameter_value ().bool_value
42
+ do_network = node .get_parameter ("do_network" ).get_parameter_value ().bool_value
41
43
cpu_load_percentage = node .get_parameter ("cpu_load_percentage" ).get_parameter_value ().double_value
42
44
memory_load_percentage = node .get_parameter ("memory_load_percentage" ).get_parameter_value ().double_value
43
45
network_rate_received_errors = node .get_parameter ("network_rate_received_errors" ).get_parameter_value ().double_value
@@ -47,7 +49,7 @@ def main():
47
49
last_send_time = time .time ()
48
50
running_processes , cpu_usages , overall_usage_percentage = cpus .collect_all () if do_cpu else (- 1 , [], 0 )
49
51
memory_available , memory_used , memory_total = memory .collect_all () if do_memory else (- 1 , - 1 , - 1 )
50
- interfaces = network_interfaces .collect_all (node .get_clock ())
52
+ interfaces = network_interfaces .collect_all (node .get_clock ()) if do_network else []
51
53
52
54
msg = WorkloadMsg (
53
55
hostname = hostname ,
0 commit comments