Action executor objects. More...
Public Member Functions | |
| def | __call__ |
| def | __init__ |
| def | __str__ |
| def | action |
| def | action |
| def | add_callback |
| def | add_condition |
| def | cancel |
| def | complete |
| def | error |
| def | id |
| def | id_string |
| def | immediate |
| def | run |
| def | set |
| def | sort_order |
| def | wait_for_exit |
Private Member Functions | |
| def | _cancel_conditions |
| def | _do_callbacks |
| def | _execute_action |
| def | _reduce_conds |
| def | _start_conds |
Private Attributes | |
| _action | |
| _args | |
| _callbacks | |
| _cancel_lock | |
| _cancelled | |
| _completed | |
| _completed_lock | |
| _conditions | |
| _err_lock | |
| _error | |
| _flag | |
| _id | |
| _kwargs | |
| _owner_flag | |
Action executor objects.
An object for managing execution of an action. This object is capable of executing an action immediately when it is called, or delaying execution until a set of conditions is reached. Which should occur is chosen automatically. If execution needs to be delayed, a new thread will be started to manage it. This thread will sleep until all pre-conditions for the action are met. Any number of condition objects can be added. Callbacks can be added to be executed after executing the action.
| def rtshell.plan.ActionExecutor.__init__ | ( | self, | |
action = None, |
|||
owner_flag = None, |
|||
| args, | |||
| kwargs | |||
| ) |
| def rtshell.plan.ActionExecutor.__call__ | ( | self, | |
| args, | |||
| kwargs | |||
| ) |
| def rtshell.plan.ActionExecutor.__str__ | ( | self | ) |
| def rtshell.plan.ActionExecutor._cancel_conditions | ( | self | ) | [private] |
| def rtshell.plan.ActionExecutor._do_callbacks | ( | self | ) | [private] |
| def rtshell.plan.ActionExecutor._execute_action | ( | self | ) | [private] |
| def rtshell.plan.ActionExecutor._reduce_conds | ( | self | ) | [private] |
| def rtshell.plan.ActionExecutor._start_conds | ( | self | ) | [private] |
| def rtshell.plan.ActionExecutor.action | ( | self | ) |
| def rtshell.plan.ActionExecutor.action | ( | self, | |
| action | |||
| ) |
| def rtshell.plan.ActionExecutor.add_callback | ( | self, | |
| callback | |||
| ) |
| def rtshell.plan.ActionExecutor.add_condition | ( | self, | |
| condition | |||
| ) |
| def rtshell.plan.ActionExecutor.cancel | ( | self | ) |
| def rtshell.plan.ActionExecutor.complete | ( | self | ) |
| def rtshell.plan.ActionExecutor.error | ( | self | ) |
| def rtshell.plan.ActionExecutor.id | ( | self | ) |
| def rtshell.plan.ActionExecutor.id_string | ( | self | ) |
| def rtshell.plan.ActionExecutor.immediate | ( | self | ) |
| def rtshell.plan.ActionExecutor.run | ( | self | ) |
| def rtshell.plan.ActionExecutor.set | ( | self | ) |
| def rtshell.plan.ActionExecutor.sort_order | ( | self | ) |
| def rtshell.plan.ActionExecutor.wait_for_exit | ( | self | ) |
rtshell::plan.ActionExecutor::_action [private] |
rtshell::plan.ActionExecutor::_args [private] |
rtshell::plan.ActionExecutor::_callbacks [private] |
rtshell::plan.ActionExecutor::_cancelled [private] |
rtshell::plan.ActionExecutor::_completed [private] |
rtshell::plan.ActionExecutor::_err_lock [private] |
rtshell::plan.ActionExecutor::_error [private] |
rtshell::plan.ActionExecutor::_flag [private] |
rtshell::plan.ActionExecutor::_id [private] |
rtshell::plan.ActionExecutor::_kwargs [private] |