Functions
def	create_new_task_ASAP (taskId, command, resource_field, resource_value)

def	create_get_tasks_status (taskId)

def	get_response_event (clientConnection, timeout)

def	get_task_state (clientConnection, timeout, taskId)

Variables
int	taskId = 20

int	wait_response_timeout = 5000

string	addr = "192.168.1.135:5501"

	connectBuilder = ConnectionBuilderLight()

	eventBuilder = EventBuilder()

	client = connectBuilder.build(consts.CLIENT_CONNECT, addr, consts.TCP_TYPE)

	new_task_event1 = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task_ASAP(taskId, "ls -la", "CPU", 200))

	new_task_event2 = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task_ASAP(taskId + 1, "ls -la", "CPU_LOAD_MAX", 20))

	new_task_event3 = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task_ASAP(taskId + 2, "ls -la", "IO_WAIT_MAX", 50))

	new_task_event4 = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task_ASAP(taskId + 3, "ls -la", "RAM_FREE", 1048576000 * 2))

list	res_exceed_tasks = [new_task_event1, new_task_event2, new_task_event3, new_task_event4]

def	response_event = get_response_event(client, wait_response_timeout)

Detailed Description

Created on Apr 8, 2014

@author: igor

Function Documentation

◆ create_get_tasks_status()

def ftests.ftest_executeTask_resources_limits.create_get_tasks_status ( taskId )

Definition at line 24 of file ftest_executeTask_resources_limits.py.

 def create_get_tasks_status(taskId):
     return GetTasksStatus([taskId])

Here is the caller graph for this function:

◆ create_new_task_ASAP()

def ftests.ftest_executeTask_resources_limits.create_new_task_ASAP	(	taskId,
		command,
		resource_field,
		resource_value
	)

Definition at line 16 of file ftest_executeTask_resources_limits.py.

 def create_new_task_ASAP(taskId, command, resource_field, resource_value):
     newTask = NewTask(command, taskId)
     newTask.session["tmode"] = NewTask.TASK_MODE_ASYNCH
     newTask.setStrategyVar(resource_field, resource_value)
         
     return newTask
 
 

◆ get_response_event()

def ftests.ftest_executeTask_resources_limits.get_response_event	(	clientConnection,
		timeout
	)

Definition at line 28 of file ftest_executeTask_resources_limits.py.

 def get_response_event(clientConnection, timeout):
     if clientConnection.poll(wait_response_timeout) == 0:
         print "NO EVENT"
         exit(1)        
     else:
         return  clientConnection.recv()
 
 

Here is the caller graph for this function:

◆ get_task_state()

def ftests.ftest_executeTask_resources_limits.get_task_state	(	clientConnection,
		timeout,
		taskId
	)

Definition at line 36 of file ftest_executeTask_resources_limits.py.

 def get_task_state(clientConnection, timeout, taskId): 
     get_tasks_status_event = eventBuilder.build(EVENT_TYPES.GET_TASK_STATUS, create_get_tasks_status(taskId))
     clientConnection.send(get_tasks_status_event)
     response_event = get_response_event(clientConnection, timeout)
     taskManagerFields = response_event.eventObj[0]
     return taskManagerFields.fields["state"]
     
     
 

Here is the call graph for this function:

Variable Documentation

◆ addr

string ftests.ftest_executeTask_resources_limits.addr = "192.168.1.135:5501"

Definition at line 48 of file ftest_executeTask_resources_limits.py.

◆ client

ftests.ftest_executeTask_resources_limits.client = connectBuilder.build(consts.CLIENT_CONNECT, addr, consts.TCP_TYPE)

Definition at line 52 of file ftest_executeTask_resources_limits.py.

◆ connectBuilder

ftests.ftest_executeTask_resources_limits.connectBuilder = ConnectionBuilderLight()

Definition at line 49 of file ftest_executeTask_resources_limits.py.

◆ eventBuilder

ftests.ftest_executeTask_resources_limits.eventBuilder = EventBuilder()

Definition at line 50 of file ftest_executeTask_resources_limits.py.

◆ new_task_event1

ftests.ftest_executeTask_resources_limits.new_task_event1 = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task_ASAP(taskId, "ls -la", "CPU", 200))

Definition at line 54 of file ftest_executeTask_resources_limits.py.

◆ new_task_event2

ftests.ftest_executeTask_resources_limits.new_task_event2 = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task_ASAP(taskId + 1, "ls -la", "CPU_LOAD_MAX", 20))

Definition at line 55 of file ftest_executeTask_resources_limits.py.

◆ new_task_event3

ftests.ftest_executeTask_resources_limits.new_task_event3 = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task_ASAP(taskId + 2, "ls -la", "IO_WAIT_MAX", 50))

Definition at line 56 of file ftest_executeTask_resources_limits.py.

◆ new_task_event4

ftests.ftest_executeTask_resources_limits.new_task_event4 = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task_ASAP(taskId + 3, "ls -la", "RAM_FREE", 1048576000 * 2))

Definition at line 57 of file ftest_executeTask_resources_limits.py.

◆ res_exceed_tasks

list ftests.ftest_executeTask_resources_limits.res_exceed_tasks = [new_task_event1, new_task_event2, new_task_event3, new_task_event4]

Definition at line 59 of file ftest_executeTask_resources_limits.py.

◆ response_event

def ftests.ftest_executeTask_resources_limits.response_event = get_response_event(client, wait_response_timeout)

Definition at line 64 of file ftest_executeTask_resources_limits.py.

◆ taskId

int ftests.ftest_executeTask_resources_limits.taskId = 20

Definition at line 46 of file ftest_executeTask_resources_limits.py.

◆ wait_response_timeout

int ftests.ftest_executeTask_resources_limits.wait_response_timeout = 5000

Definition at line 47 of file ftest_executeTask_resources_limits.py.

Functions

Variables