Functions
def	create_new_task (taskId, command)

def	create_check_task_state (taskId)

def	create_get_tasks_status (taskId)

def	create_delete_task (deletedTaskId, taskId, host, port)

def	get_response_event (clientConnection, timeout)

Variables
int	taskId = 10

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_event = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task(taskId, "ls -la"))

	check_task_state_event = eventBuilder.build(EVENT_TYPES.CHECK_TASK_STATE, create_check_task_state(taskId))

	get_tasks_status_event = eventBuilder.build(EVENT_TYPES.GET_TASK_STATUS, create_get_tasks_status(taskId))

def	response_event = get_response_event(client, wait_response_timeout)

	host = None

	port = None

	delete_task_event

	get_tasks_status_event1 = eventBuilder.build(EVENT_TYPES.GET_TASK_STATUS, create_get_tasks_status(taskId + 1))

Detailed Description

Created on Apr 2, 2014

@author: igor

Function Documentation

◆ create_check_task_state()

def ftests.ftest_delete_task_life_cycle.create_check_task_state ( taskId )

Definition at line 22 of file ftest_delete_task_life_cycle.py.

 def create_check_task_state(taskId):
     return CheckTaskState(taskId, CheckTaskState.TYPE_FULL)

◆ create_delete_task()

def ftests.ftest_delete_task_life_cycle.create_delete_task	(	deletedTaskId,
		taskId,
		host,
		port
	)

Definition at line 30 of file ftest_delete_task_life_cycle.py.

 def create_delete_task(deletedTaskId, taskId, host, port):
     delTask = DeleteTask(deletedTaskId, taskId)
     delTask.host = host
     delTask.port = port
     return delTask
 
 

◆ create_get_tasks_status()

def ftests.ftest_delete_task_life_cycle.create_get_tasks_status ( taskId )

Definition at line 26 of file ftest_delete_task_life_cycle.py.

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

◆ create_new_task()

def ftests.ftest_delete_task_life_cycle.create_new_task	(	taskId,
		command
	)

Definition at line 16 of file ftest_delete_task_life_cycle.py.

 def create_new_task(taskId, command):
     newTask = NewTask(command, taskId)
     
     return newTask

◆ get_response_event()

def ftests.ftest_delete_task_life_cycle.get_response_event	(	clientConnection,
		timeout
	)

Definition at line 37 of file ftest_delete_task_life_cycle.py.

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