HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
ftest_executeTask_resources_limits.py File Reference

Go to the source code of this file.

Namespaces

 ftests.ftest_executeTask_resources_limits
 

Functions

def ftests.ftest_executeTask_resources_limits.create_new_task_ASAP (taskId, command, resource_field, resource_value)
 
def ftests.ftest_executeTask_resources_limits.create_get_tasks_status (taskId)
 
def ftests.ftest_executeTask_resources_limits.get_response_event (clientConnection, timeout)
 
def ftests.ftest_executeTask_resources_limits.get_task_state (clientConnection, timeout, taskId)
 

Variables

int ftests.ftest_executeTask_resources_limits.taskId = 20
 
int ftests.ftest_executeTask_resources_limits.wait_response_timeout = 5000
 
string ftests.ftest_executeTask_resources_limits.addr = "192.168.1.135:5501"
 
 ftests.ftest_executeTask_resources_limits.connectBuilder = ConnectionBuilderLight()
 
 ftests.ftest_executeTask_resources_limits.eventBuilder = EventBuilder()
 
 ftests.ftest_executeTask_resources_limits.client = connectBuilder.build(consts.CLIENT_CONNECT, addr, consts.TCP_TYPE)
 
 ftests.ftest_executeTask_resources_limits.new_task_event1 = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task_ASAP(taskId, "ls -la", "CPU", 200))
 
 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))
 
 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))
 
 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))
 
list ftests.ftest_executeTask_resources_limits.res_exceed_tasks = [new_task_event1, new_task_event2, new_task_event3, new_task_event4]
 
def ftests.ftest_executeTask_resources_limits.response_event = get_response_event(client, wait_response_timeout)