ftests.ftest_scheduling_TTR Namespace Reference

Functions
def	create_new_task (taskId, command, delta_time)
def	create_get_tasks_status (taskId)
def	get_response_event (clientConnection, timeout)

Variables
int	taskId = 10
int	delta_time = 30
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", delta_time))
	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)
def	taskManagerFields = response_event.eventObj[0]

Detailed Description

Created on Apr 8, 2014

@author: igor

Function Documentation

create_get_tasks_status()

def ftests.ftest_scheduling_TTR.create_get_tasks_status

(

taskId

)

Definition at line 28 of file ftest_scheduling_TTR.py.

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

create_new_task()

def ftests.ftest_scheduling_TTR.create_new_task	(		taskId,
			command,
			delta_time
	)

Definition at line 17 of file ftest_scheduling_TTR.py.

def create_new_task(taskId, command, delta_time):
    newTask = NewTask(command, taskId)
    newTask.session["tmode"] = NewTask.TASK_MODE_ASYNCH
    
    planedTime = time.time() + delta_time
    rDate = datetime.datetime.fromtimestamp(planedTime)    
    newTask.setSessionVar("DATE", rDate.strftime("%Y-%m-%d %H:%M:%S,%f"))
    
    return newTask

get_response_event()

def ftests.ftest_scheduling_TTR.get_response_event	(		clientConnection,
			timeout
	)

Definition at line 32 of file ftest_scheduling_TTR.py.

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

Variable Documentation

addr

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

Definition at line 45 of file ftest_scheduling_TTR.py.

client

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

Definition at line 49 of file ftest_scheduling_TTR.py.

connectBuilder

ftests.ftest_scheduling_TTR.connectBuilder = ConnectionBuilderLight()

Definition at line 46 of file ftest_scheduling_TTR.py.

delta_time

int ftests.ftest_scheduling_TTR.delta_time = 30

Definition at line 43 of file ftest_scheduling_TTR.py.

eventBuilder

ftests.ftest_scheduling_TTR.eventBuilder = EventBuilder()

Definition at line 47 of file ftest_scheduling_TTR.py.

get_tasks_status_event

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

Definition at line 52 of file ftest_scheduling_TTR.py.

new_task_event

ftests.ftest_scheduling_TTR.new_task_event = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task(taskId, "ls -la", delta_time))

Definition at line 51 of file ftest_scheduling_TTR.py.

response_event

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

Definition at line 57 of file ftest_scheduling_TTR.py.

taskId

int ftests.ftest_scheduling_TTR.taskId = 10

Definition at line 41 of file ftest_scheduling_TTR.py.

taskManagerFields

def ftests.ftest_scheduling_TTR.taskManagerFields = response_event.eventObj[0]

Definition at line 67 of file ftest_scheduling_TTR.py.

wait_response_timeout

int ftests.ftest_scheduling_TTR.wait_response_timeout = 5000

Definition at line 44 of file ftest_scheduling_TTR.py.