??????????????
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 173
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 174
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 175
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 176
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 177
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 178
σ
ΰUdac @` s d d l m Z m Z m Z e Z d Z d d l m Z d d l
m Z m Z d d l
m Z d d l m Z d d l m Z d d l m Z d d l m Z d d
l m Z d d l m Z d d l m Z d d
l m Z d d l m Z e Z! d e f d YZ" d S( i ( t absolute_importt divisiont print_functions
strategy: linear
short_description: Executes tasks in a linear fashion
description:
- Task execution is in lockstep per host batch as defined by C(serial) (default all).
Up to the fork limit of hosts will execute each task at the same time and then
the next series of hosts until the batch is done, before going on to the next task.
version_added: "2.0"
notes:
- This was the default Ansible behaviour before 'strategy plugins' were introduced in 2.0.
author: Ansible Core Team
( t constants( t AnsibleErrort AnsibleAssertionError( t PlayIterator( t iteritems( t to_text( t Block( t IncludedFile( t Task( t
action_loader( t StrategyBase( t Templar( t Displayt StrategyModulec B` s; e Z d Z d Z d Z d Z d Z d Z RS( c C` s | j d k r t d n g } x^ | D]V } t | t rS | j | j q+ t | t r+ | j | j | | j q+ q+ W| S( Ns= strategy.linear.StrategyModule.noop_task is None, need Task()( t noop_taskt NoneR t
isinstanceR t appendR t _create_noop_block_fromt _parent( t selft targett resultt el( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyt _replace_with_noop6 s
#c C` sR t d | } | j | j | _ | j | j | _ | j | j | _ | S( Nt parent_block( R R t blockt alwayst rescue( R t original_blockt parentt
noop_block( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyR B s
c C` sN t | _ d | j _ d | j j d <| j j | j j | j | | S( Nt metat noopt _raw_params( R R t actiont argst
set_loadert _playt _loaderR ( R R R! t iterator( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyt# _prepare_and_create_noop_block_fromJ s
c ` sί t d _ d j d < j j j i t j d x* | D]" } j | d t | j
q s sn done counting tasks in each state of execution:
num_setups: %s
num_tasks: %s
num_rescue: %s
num_always: %sc ` sά g } t j d x΅ | D] } j | j } | d k rD q n | \ } } j | } | d k rq q n | j | k r΄ | j | k r΄ j | } | j | | f q | j | f q Wt j d | S( s
This helper returns the task for all hosts in the requested
state, otherwise they get a noop dummy task. This also advances
the state of the host, since the given states are determined
while using peek=True.
s starting to advance hostss! done advancing hosts to next taskN(
t displayt debugt gett nameR R0 R. R1 t get_next_task_for_hostR ( t hostsR1 t cur_statet rvalst hostt host_state_taskR4 R5 t new_t( t
host_tasksR+ R ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyt _advance_selected_hosts s
s" advancing hosts in ITERATING_SETUPs" advancing hosts in ITERATING_TASKSs# advancing hosts in ITERATING_RESCUEs# advancing hosts in ITERATING_ALWAYSs5 all hosts are done, so returning None's for all hostsN( R R& R' R( R) R* R6 R7 R: t TrueR9 R t mint
ValueErrorR R0 R1 R. R t ITERATING_SETUPt ITERATING_TASKSt ITERATING_RESCUEt ITERATING_ALWAYS( R R; R+ R> t
num_setupst num_taskst
num_rescuet
num_alwayst
state_taskt host_tasks_to_runt lowest_cur_blockt kt vR4 R5 RB ( ( RA R+ R sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyt _get_next_task_lockstepR sp
"
c & C` sf
| j j } t } | j | j x%
| rI
| j j rI
yΪ t j d | j | } t j d t } t } g } | j
| | } t } t }
t } g } x| D]w\ }
} | sΏ q§ n | j j rΟ Pn t } t } y t j | j
d t } Wn t k
rd? } n X| j rt| j j |
rt| j j d? k sZ| j j rt| j j j rtt j d | q§ qtn | j
t j k rξ| j | j | | | |
| j j d d? d@ k rΙt } n | j sΨ| rά| j rάt } qάnξ| j r |
r | j | rt }
q t } Pn t j d | j j d
| j d |
d | d
| j d | j } | j! | d
| j t" d | j# d | } t j d | j$ | j% pΔ| oΔt& | d t } | j sΦ| rι| j rιt } n | s°t j d | j' } t j d y8 t( | j$ | j' d t d d | _' t j d Wn t) k
rjt j d n Xt j d | j j* d | d t | | _' t } t j d n t | j+ |
j, <| j- |
| | | ~ | rζPn | | j. | d t/ d t0 t1 | j j2 d 7} q§ W| r.w% n t j d! | j3 d" k r`| | j4 | 7} n | j | | j5 | t6 j7 | d# | d | j# d$ | j } t } t1 | d" k rt j d% t j d& t8 d' | D } t j d( xΣ| D]Λ} t j d) | j9 yE| j: rb| j; | } | j< d
| j d$ | j d | j# \ } } n | j= | d# | } t j d* xΗ | D]Ώ } | j j d
| j d | j> d
| j d | j } t j d+ | j? | } t j d, | j@ | | j> | } xB | D]: }
|
| jA k r5| |
jB | q | |
jB | q WqWt j d- WqύtC k
rΗ} x1 | jA D]& }
t | j jD |
j' <| jE |
qxWt jF t( | d. t t } qύqύXqύWt j d/ x" | D] }
| jG |
| |
qΰWt j d0 t j d1 n t j d2 t j d3 g } g } xy | D]q }! |! jH so|! jI j
t j k r| jH |! jJ r| jB |! jJ j' qH|! jK rH| jB |! jJ j' qHqHW| rt1 | d" k sηt1 | d" k rtL | jM | jN g }" x | D] }
| jO |
d4 t \ }# }$ | jP |# }# |# jQ |" k sm|# jQ | jM k r|# jR | jS @d" k rt | j jD |
j' <| | j jT O} qqWn t j d5 t j d6 | j jU d? k r t1 | d" k r | j jU d7 }% t1 | j jD | jV |% k rm x@ | D]8 }
|
j' | k r t | j jD |
j' <| jE |
q q W| j j* d8 | | j jT O} n t j d9 t1 | j jD | jV |% f n t j d: t j d; | | j j k r
t1 | j jD t1 | k r
t j d< | j j* d8 | St j d= Wq% tW tX f k
rE
} t j d> | | j jY SXq% WtZ t[ | j\ | | | S(A s²
The linear strategy is simple - get the next task and queue
it for all hosts, then wait for the queue to drain before
moving on to the next task
s) getting the remaining hosts for this loops. done getting the remaining hosts for this loopt
class_onlys) '%s' skipped because role has already runR% R$ t reset_connectiont end_hosts getting variablest playR> t taskt _hostst
_hosts_allt loadert variabless done getting variablest BYPASS_HOST_LOOPsO sending task start callback, copying the task so we can template it temporarilys# done copying, going to template nowt fail_on_undefinedt nonstringt emptys done templatings! templating failed for some reasons here goes the callback...t v2_playbook_on_task_startt is_conditionals sending task start callbackt
max_passesi gΉ?s> done queuing things up, now waiting for results queue to draini R+ t variable_managers! we have included files to processs generating all_blocks datac s` s | ] } | g f Vq d S( N( ( R2 R> ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pys X s s done generating all_blocks datas processing included file: %ss2 iterating over new_blocks loaded from include files filtering new block on tagss done filtering new block on tagss7 done iterating over new_blocks loaded from include filet wrap_texts7 extending task lists for all hosts with included blockss done extending task listss done processing included filess results queue emptys checking for any_errors_fatalR- s" done checking for any_errors_fatals checking for max_fail_percentageg Y@t! v2_playbook_on_no_hosts_remainings$ (%s failed / %s total )> %s max fails% done checking for max_fail_percentagesI checking to see if all hosts have failed and the running result is not oks! ^ not ok, so returning result nows- done checking to see if all hosts have faileds% got IOError/EOFError in task loop: %sN( s noopRU RV (] t _tqmt RUN_OKRC t _set_hosts_cacheR) t _terminatedR6 R7 t get_hosts_leftt FalseRS R R8 R& t KeyErrorR t _rolet has_runt _metadatat allow_duplicatest Ct _ACTION_METAt extendt
_execute_metaR' t any_errors_fatalt
ignore_errorst _stept
_take_stept _variable_managert get_varst _hosts_cachet _hosts_cache_allt add_tqm_variablesR R* t templatet run_oncet getattrR9 R t Exceptiont
send_callbackt _blocked_hostst get_namet _queue_taskt _process_pending_resultst maxt intt lent _workerst _pending_resultst _wait_on_pending_resultst update_active_connectionsR
t process_include_resultst dictt _filenamet _is_rolet _copy_included_filet get_block_listt _load_included_fileR t filter_tagged_tasksR, RY R R t
_failed_hostst mark_host_failedt errort add_taskst is_failedt _taskt _hostt is_unreachablet frozensetRH RI R: R0 R. t
fail_statet
FAILED_RESCUEt RUN_FAILED_BREAK_PLAYt max_fail_percentaget
batch_sizet IOErrort EOFErrort RUN_UNKNOWN_ERRORt superR t run(& R R+ t play_contextR t
work_to_dot
hosts_leftt
callback_sentt host_resultsRA t skip_restt choose_stepRv t resultsR> RX R R& t task_varst templart
saved_namet included_filest include_failuret
all_blockst
included_filet new_irt
new_blockst handler_blockst new_blockt final_blockR" t et failed_hostst unreachable_hostst rest dont_fail_statesR4 t _t
percentage( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyR© Η sP
.
!
*
'
<
3 *
(
$
,
0
N( t __name__t
__module__R R R R R, RS R© ( ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyR 2 s uN(# t
__future__R R R t typet
__metaclass__t
DOCUMENTATIONt ansibleR Rr t ansible.errorsR R t ansible.executor.play_iteratorR t ansible.module_utils.sixR t ansible.module_utils._textR t ansible.playbook.blockR t ansible.playbook.included_fileR
t ansible.playbook.taskR t ansible.plugins.loaderR t ansible.plugins.strategyR
t ansible.templateR t ansible.utils.displayR R6 R ( ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyt s