x/terracotta
Code Issues Proposed changes

Added a network_migration_bandwidth config option

Browse Source
This commit is contained in:
Anton Beloglazov 2012-10-01 18:46:18 +10:00
parent 53afb43f2f
commit 4b2dd5ab02
3 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
neat.conf
View File

@ -76,6 +76,9 @@ compute_user = neat
# hosts to switch them into the sleep mode # hosts to switch them into the sleep mode
compute_password = neatpassword compute_password = neatpassword
# The network bandwidth in MB/s available for VM migration
network_migration_bandwidth = 10
# A shell command used to switch a host into the sleep mode, the # A shell command used to switch a host into the sleep mode, the
# compute_user must have permissions to execute this command # compute_user must have permissions to execute this command
sleep_command = pm-suspend sleep_command = pm-suspend

1
neat/config.py
View File

@ -55,6 +55,7 @@ REQUIRED_FIELDS = [
'compute_user', 'compute_user',
'compute_password', 'compute_password',
'sleep_command', 'sleep_command',
'network_migration_bandwidth',
'algorithm_underload_detection_factory', 'algorithm_underload_detection_factory',
'algorithm_underload_detection_parameters', 'algorithm_underload_detection_parameters',
'algorithm_overload_detection_factory', 'algorithm_overload_detection_factory',

8
neat/locals/manager.py
View File

@ -210,7 +210,7 @@ def execute(config, state):
if not vm_cpu_mhz: if not vm_cpu_mhz:
return return
physical_cpu_mhz_total = int(config['physical_cpu_mhz_total']) physical_cpu_mhz_total = int(state['physical_cpu_mhz_total'])
host_cpu_utilization = vm_mhz_to_percentage( host_cpu_utilization = vm_mhz_to_percentage(
vm_cpu_mhz, physical_cpu_mhz_total) vm_cpu_mhz, physical_cpu_mhz_total)
time_step = int(config['data_collector_interval']) time_step = int(config['data_collector_interval'])
@ -219,7 +219,7 @@ def execute(config, state):
if 'underload_detection' not in state: if 'underload_detection' not in state:
underload_detection_params = json.loads( underload_detection_params = json.loads(
config['algorithm_underload_detection_params']) config['algorithm_underload_detection_parameters'])
underload_detection_state = None underload_detection_state = None
underload_detection = \ underload_detection = \
config['algorithm_underload_detection_factory']( config['algorithm_underload_detection_factory'](
@ -229,7 +229,7 @@ def execute(config, state):
state['underload_detection'] = underload_detection state['underload_detection'] = underload_detection
overload_detection_params = json.loads( overload_detection_params = json.loads(
config['algorithm_overload_detection_params']) config['algorithm_overload_detection_parameters'])
overload_detection_state = None overload_detection_state = None
overload_detection = \ overload_detection = \
config['algorithm_overload_detection_factory']( config['algorithm_overload_detection_factory'](
@ -239,7 +239,7 @@ def execute(config, state):
state['overload_detection'] = overload_detection state['overload_detection'] = overload_detection
vm_selection_params = json.loads( vm_selection_params = json.loads(
config['algorithm_vm_selection_params']) config['algorithm_vm_selection_parameters'])
vm_selection_state = None vm_selection_state = None
vm_selection = \ vm_selection = \
config['algorithm_vm_selection_factory']( config['algorithm_vm_selection_factory'](