| Server IP : 85.193.89.191 / Your IP : 3.15.221.67 Web Server : Apache System : Linux 956367-cx40159.tmweb.ru 3.10.0-1160.105.1.el7.x86_64 #1 SMP Thu Dec 7 15:39:45 UTC 2023 x86_64 User : bitrix ( 600) PHP Version : 8.1.27 Disable Function : NONE MySQL : OFF | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python2.7/site-packages/ansible/plugins/strategy/ |
Upload File : |
�
� �\c @` s� d d l m Z m Z m Z e Z d d l Z d d l Z d d l Z d d l Z d d l
Z
d d l Z d d l 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 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& m' Z' m( Z( d d l) m* Z* d d l+ m, Z, m- Z- d d l. m/ Z/ d d l0 m1 Z1 d d l2 m3 Z3 d d l4 m5 Z5 d d l6 m7 Z7 m8 Z8 m9 Z9 m: Z: m; Z; m< Z< d d l= m> Z> d d l? m@ Z@ d d lA mB ZB y d d lC mD ZD Wn* eE k
rBd d lF mG ZG eG � ZD n Xd g ZH d f d � � YZI d f d � � YZJ eI � ZK d � ZL d � ZM d f d! � � YZN d" eO f d# � � YZP d$ e jQ f d% � � YZR d S(& i ( t absolute_importt divisiont print_functionN( t deque( t Lock( t UndefinedError( t constants( t AnsibleErrort AnsibleParserErrort AnsibleUndefinedVariable( t action_write_locks( t
WorkerProcess( t
TaskResult( t Host( t queue( t iteritemst
itervaluest string_types( t to_text( t
Connectiont ConnectionError( t load_list_of_blocks( t IncludedFile( t TaskInclude( t IncludeRole( t
action_loadert connection_loadert
filter_loadert
lookup_loadert
module_loadert test_loader( t Templar( t combine_vars( t strip_internal_keys( t display( t Displayt StrategyBaset StrategySentinelc B` s e Z RS( ( t __name__t
__module__( ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR% ? s t SharedPluginLoaderObjc B` s e Z d Z d � Z RS( ss
A simple object to make pass the various plugin loaders to
the forked processes over the queue easier
c C` s: t | _ t | _ t | _ t | _ t | _ t | _ d S( N( R R R R R R ( t self( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt __init__K s ( R& R' t __doc__R* ( ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR( F s c C` s� x� t r� yP | j j � } t | t � r. Pn* | j j � | j j | � | j j � Wq t
t f k
rs Pq t j
k
r� q Xq Wd S( N( t Truet _final_qt gett
isinstanceR% t
_results_lockt acquiret _resultst appendt releaset IOErrort EOFErrort Queuet Empty( t strategyt result( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt results_thread_mainW s
c ` s( t j � � t d � f d � � } | S( sV Closure to wrap ``StrategyBase._process_pending_results`` and invoke the task debuggerc ` s4 d d d d f } | j j � } � | | d | d
| �} g } x�| D]�} | j } | j }
| j j |
j | j f d � } | d } | d }
y | |
j } Wn t k
r� | j
|
� } n Xx_| j d
| j � r t
� } t | |
| |
| | � } | j � | j t
j k r�| j j � | | j |
j <xB | D]: \ } } t | | � � rF| j j j | |
j � qFqFW| j j j d |
j � | j |
| | |
� | j t � � | | | � � Pq� | j t
j k r�| j | � Pq� | j t
j k r� t j d � q� q� W| j | � qI W| S( Nt is_failedt failurest is_unreachablet darkt
is_changedt changedt
is_skippedt skippedt one_passt
max_passest task_varst play_contextt globally_enabledt okic ( s is_failedR= ( s is_unreachableR? ( s
is_changeds changed( s
is_skippeds skipped( t _host_statest copyt _taskt _hostt _queued_task_cachet popt namet _uuidt Nonet KeyErrort get_host_statet needs_debuggert debugger_activet
NextActiont Debuggert cmdloopR: t REDOt _tqmt clear_failed_hostst getattrt _statst decrementt _queue_taskt extendt
debug_closuret CONTINUER3 t EXITt syst exit( R) t iteratorRD RE t status_to_stats_mapt prev_host_statest resultst _processed_resultsR: t taskt hostt _queued_task_argsRF RG t prev_host_statet next_actiont dbgt methodt what( t func( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt inneri sL
!
N( t functoolst wrapst FalseRR ( Rt Ru ( ( Rt sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyRb g s 7c B` s� e Z d Z d � Z d � Z d d � Z d � Z d � Z d � Z d � Z d � Z
d
� Z e e
e d � � Z d � Z d
� Z d � Z d � Z d � Z e
d � Z d � Z e d � Z d � Z e d � Z d � Z d � Z d � Z d � Z RS( s�
This is the base class for strategy plugins, which contains some common
code useful to all strategies like running handlers, cleanup actions, etc.
c C` sd | | _ | j � | _ | j � | _ | j | _ | j | _ | j � | _ | j � | _
| j | _ t | j
d t � | _ t | j
d t � | _ t | j
d t � | _ i | _ t | _ d | _ d | _ t � | _ t � | _ t � | _ t j t j � � | _ t j d t! d | f � | _" t# | j" _$ | j" j% � t � | _& t' j( | _) d S( Nt stept difft flush_cachei t targett args(* R[ t
get_inventoryt
_inventoryt get_workerst _workerst _notified_handlerst _listening_handlerst get_variable_managert _variable_managert
get_loadert _loaderR- R] t _optionsRx t _stept _diffR{ RN R" t _displayt _pending_resultst _cur_workert dictt _blocked_hostst _flushed_hostsR R2 t threadingt ConditionR R0 t ThreadR; t _results_threadR, t daemont startt _active_connectionst Ct ENABLE_TASK_DEBUGGERRV ( R) t tqm( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR* � s0
c C` s| xX t | j � D]G } y t | � } | j � Wq t k
rV } t j d | � q Xq W| j j t � | j
j � d S( Ns4 got an error while closing persistent connection: %s( R R� R t resetR R" t debugR- t putt _sentinelR� t join( R) t sockt connt e( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt cleanup� s i c C` sz | j j | j j d | j j �} g | D]* } | j | j j k r+ | j | � ^ q+ | j � } | j j j
� } t j d � | j
| | � } t | t � r� | r� | | j j O} n | s� | | O} n t | � j | j � � } t | � j | j j j
� � } t | t � r4| | j j k r4| St | � d k rP| j j St | � d k rl| j j S| j j Sd S( Nt orders running handlersi ( R t get_hostst _playt hostsR� RP R[ t _unreachable_hostst get_next_task_for_hostt get_failed_hostst keysR" R� t run_handlersR/ t boolt RUN_ERRORt sett uniont RUN_OKt lent RUN_UNREACHABLE_HOSTSt RUN_FAILED_HOSTS( R) Rg RG R: t inv_hostsRm t failed_hostst unreachable_hostst handler_result( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt run� s& $5
!"
c C` sP g | j j | j � D]6 } | j | j j k r | j | j j k r | ^ q S( N( R R� R� RP R[ t
_failed_hostsR� ( R) t playRm ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt get_hosts_remaining
s c C` s; g | j j | j � D]! } | j | j j k r | ^ q S( N( R R� R� RP R[ R� ( R) R� Rm ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR� s c C` sV g | j | � D] } | j ^ q | d <g | j | � D] } | j ^ q9 | d <d S( s�
Base class method to add extra variables/information to the list of task
vars sent through the executor engine regarding the task queue manager state.
t ansible_current_hostst ansible_failed_hostsN( R� RP R� ( R) t varsR� t h( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt add_tqm_variables s )c
C` s t j d | j | j f � | j t j k rY t j d | j � t � t j | j <n yft � } t } | j } x8t r�| j
| j } | d k s� | j � rOi | d 6| d 6| d 6| d 6| j
| j | j f <t | j | | | | | j | j | � } | | j
| j <| j � t j d | j d t | j
� f � t } n | j d 7_ | j t | j
� k r�d | _ n | r�Pqw | j | k rw t j d
� qw qw W| j d 7_ Wn. t t t f k
r�} t j d | � d SXt j d
| j | j f � d S( s5 handles queueing the task up to be sent to a worker s entering _queue_task() for %s/%ss Creating lock for %sRm Rl RF RG s" worker is %d (out of %d available)i i g-C ��6?s got an error while queuing: %sNs exiting _queue_task() for %s/%s( R" R� RP t actionR
R R( Rx R� R, R� RR t is_aliveRN RQ R R- R� R� R� R� t timet sleepR� R6 R5 t AssertionError(
R) Rm Rl RF RG t shared_loader_objt queuedt starting_workert
worker_prcR� ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR` sB
*
' c C` sY | j rL g | j j | j j � D]! } | j | j j k r" | ^ q" } n | g } | S( N( t run_onceR R� R� R� RP R[ R� ( R) Rg t task_hostRl Rm t host_list( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt get_task_hostsT s C c C` sv | j d i � j d d � } | d k r] | j j | � } | d k ro t d | � } qo n t d | j � } | g S( Nt _ansible_delegated_varst ansible_delegated_hostRP ( R. RR R t get_hostR
t delegate_to( R) R: Rl t host_namet actual_host( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt get_delegated_hosts[ s c + ` s� g } � f d � } � � f d � } d � } � � � f d � � d } x� t r� z9 y � j j � � j j � } Wn t k
r� Pn XWd � j j � X| | j � }
|
j | j f } � j
j | � d } | j d t d t � }
| j
|
_
|
j | j � |
| _ |
| _ d
| j k rC� j j d | � qN n� d | j k r�| j � sj| j � r�� j j d
| � qN | j � r�� j j d | � qN d | j k r�� j s�t |
d t � r�� j j d | � q�n � j j d | � qN n |
j rr� j � |
|
� } t | j � } d | k rA| d =n x. | D]# } � j j | i | |
j 6� qHWn t } | j � rtt } |
j } | st j d |
j � |
j! r7x� � j" j# � j$ j% � D]a } | j � j j& k r�� j' | d t �\ } } � j( | � � j' | d t �\ } } q�q�Wn
� j( |
� � j j) j* d |
j � � j' |
d t �\ } } � j |
� r�| r�| j+ � j, k r�t � j j- |
j <n | rX� j. | � j+ � j/ k rX� j j |
t0 d |
j1 � d | j � � qXnQ � j j) j* d |
j � d | j k rX| j d rX� j j) j* d |
j � n � j j d | d | �n�| j � r|
j2 } | s�t � j j& |
j <� j$ j3 j4 |
j � n- � j j) j* d |
j � d |
j | j d <� j j) j* d |
j � � j j d | � n�| j � rR� j j) j* d |
j � � j j d! | � n�t } |
j5 ry| j j d" g � } n | j g } x�| D]�} d# | k r�| j6 � r�x| d# D]} t } | | � j$ j7 � } | d k rVt } | j9 � j: k r
g � j: | j9 <n |
� j: | j9 k r�� j: | j9 j4 |
� � j j d$ | |
� q�n� x� � j: D] } | | � j$ j7 � } | r`� | | � r`t } |
� j: | j9 k r�� j: | j9 j4 |
� � j j d$ | |
� q�q`q`W| � j; k r�x� � j; | D]y } | | � j$ j7 � } | d k r t } n q |
� j: | j9 k r � j: | j9 j4 |
� � j j d$ | |
� q q Wn | s�d% | } t< j= r�t> | � � q�t j? | � q�q�Wq�n d& | k r�| j d& t0 � � }! � j@ |! � � n d' | k r� jA |
| � n d( | k rH |
jB d k rN|
jC rN� jD | |
� } n � j � |
|
� } |
jE d) k r�x� tF | d( � D]3 \ }" }# x$ | D] } � j jG | |" |# � q�Wq�WqH | jH d* t � }$ xv | D]k } |
jE d+ k s�|$ r � j jI | | d( j � � n |
jE d+ k r�� j j | | d( j � � q�q�Wn d, | k r�d- | d, k r�| d, d- r�d. | d, k s� | d, d. r� � j � |
|
� } n d g } | d, d- }% d/ | d, k o� | d, d/ }& xk | D]` }' xW |% jJ � D]I }( |& r#
� j j) jK |( |% |( |' � q� � j j) jL |( |% |( |' � q� Wq� Wq�q�Wd | j k r�
� j sy
t |
d t � r�
� j j d | � q�
n tM |
tN � s�
� j j) j* d |
j � d | j k r�
| j d r�
� j j) j* d |
j � q�
n � j j d0 | � � jO d1 8_O |
j � jP k r9 � jP |
j =n |
jQ d k r� | r� xU tF � j$ jR |
jQ jS � D]4 \ }) }* |* j9 |
jQ j9 k rk t |* jT |
j <qk qk Wn | j4 | � | s� | d k r� | d1 | k r� Pn | d1 7} qN W| S(2 s�
Reads results off the final queue and takes appropriate action
based on the result (executing callbacks, updating state, etc.).
c ` s@ t | � } | � j j k r, � j j | S� j j | � Sd S( N( R R R� R� ( R� ( R) ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt get_original_hosto s c ` s� x� | D]� } x� | j D]� } | j r � j j d � j d | � } t d � j d | � } yK | j | j � } | | k r� | S| j | j � � } | | k r� | SWq� t t
f k
r� q q� Xq q Wq Wd S( NR� Rl t loadert variables( t blockRP R� t get_varsR� R R� t templatet get_nameR R RR ( t handler_namet handler_blockst
handler_blockt handler_taskt handler_varst templart target_handler_name( Rg R) ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt search_handler_blocks_by_namew s
c S` s< x5 | D]- } x$ | j D] } | | j k r | Sq Wq Wd S( N( R� RQ RR ( t handler_uuidR� R� R� ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt search_handler_blocks_by_uuid� s
c ` s� | r� t | t t f � r� y� � j j d � j d | � } t d � j d | � } | j | j � } | | k rv t
S| j | j � � } | | k r� t
SWq� t t
f k
r� q� Xn � | j | � St Sd S( NR� Rl R� R� ( R/ R R R� R� R� R R� R� RP R, R� R R t _parentRx ( t target_handlerR� R� R� R� ( Rg t parent_handler_matchR) ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR� � s i NRl t exclude_parentt
exclude_taskst _ansible_retryt v2_runner_retryt _ansible_item_resultt v2_runner_item_on_failedt v2_runner_item_on_skippedRz t v2_on_file_difft v2_runner_item_on_okt
invocations marking %s as failedt peekR= t ansible_failed_taskt ansible_failed_resultRI RA t v2_runner_on_failedt
ignore_errorsRC s Host %s is unreachablet skip_reasonR? t v2_runner_on_unreachablet v2_runner_on_skippedRj t _ansible_notifyt v2_playbook_on_notifysl The requested handler '%s' was not found in either the main handlers list nor in the listening handlers listt add_hostt add_groupt
ansible_factst include_varst _ansible_facts_cacheablet set_factt
ansible_statst datat per_hostt aggregatet v2_runner_on_oki (U R, R0 R1 R2 t popleftt
IndexErrorR4 RM RP RL RN R. RK R� t
from_attrst _task_fieldst _resultR[ t
send_callbackR< R> RB R� R] Rx t registerR� R! R� t set_nonpersistent_factsR� R" R� R� R R� R� R� R� R� t mark_host_failedR^ t incrementt run_statet ITERATING_COMPLETER� t get_active_statet ITERATING_RESCUER� t serializet ignore_unreachablet _removed_hostsR3 t loopR@ t handlersRR RQ R� R� R� t ERROR_ON_MISSING_HANDLERR t warningt _add_hostt
_add_groupR� t delegate_factsR� R� R t set_host_variableRO t set_host_factsR� t update_custom_statst set_custom_statsR/ R R� R� t _rolet
ROLE_CACHEt
_role_namet
_had_task_run(+ R) Rg RD RE t ret_resultsR� R� R� t cur_passt task_resultt
original_hostt queue_cache_entryt
found_taskt
original_taskR� t
clean_copyt target_hostt role_ranR� R� t statet _t new_taskR t result_itemst result_itemR� t foundR� t target_handler_uuidt listening_handler_uuidt listening_handlert msgt
new_host_infot var_namet var_valuet cacheableR R t myhostt kt entryt role_obj( ( Rg R� R) sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt _process_pending_resultsf sT
$
%
'!
!
'*
, )
"c C` s g } d } t j d � x� | j d k r� | t | � k r� | j j r� | j j � rh t d � � n | j | � } | j | � | t g | D]0 } | j
| k r� | j | j k r� | j
^ q� � 7} | j d k r t
j t j � q q Wt j d � | S( s�
Wait for the handler tasks to complete, using a short sleep
between checks to ensure we don't spin lock
i s waiting for handler results...s" A worker was found in a dead states0 no more pending handlers, returning what we have( R" R� R� R� R[ t _terminatedt has_dead_workersR RE Ra RM t task_nameRP R� R� R� t DEFAULT_INTERNAL_POLL_INTERVAL( R) Rg t handlert notified_hostsR) t handler_resultsRj t r( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt _wait_on_handler_results� s"
%
c C` s� g } t j d � x| | j d k r� | j j r� | j j � rP t d � � n | j | � } | j | � | j d k r t j
t j � q q Wt j d � | S( s�
Wait for the shared counter to drop to zero, using a short sleep
between checks to ensure we don't spin lock
s waiting for pending results...i s" A worker was found in a dead states/ no more pending results, returning what we have(
R" R� R� R[ RF RG R RE Ra R� R� R� RI ( R) Rg R) Rj ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt _wait_on_pending_results� s
c C` s� | r� | j d � } | | j j k r= | j j | d � n | j j j | � } t | j � | j d t � � � | _ | j d g � } xZ | D]R } | | j j k r� | j j | � n | j j | } | j | j j | � q� W| j j
� n d S( sX
Helper function to add a new host to inventory based on a task result.
R� t allt host_varst groupsN( R. R R� R� R R� R� R� RR R� t reconcile_inventory( R) t host_infoRg R� t new_hostt
new_groupst
group_namet new_group( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR � s '
c C` sv t } | j j j | j � } | d k rg | j | j j j k rQ | j j } qg t d | j � � n | j d � } | j d g � } x@ | g | D]1 } | | j j k r� | j j | � t
} q� q� W| j j | } x+ | D]# } | j j | }
|
j | � q� W| j | j � k r4| j
| � t
} n | | j � k r\| j | � t
} n | rr| j j � n | S( s�
Helper function to add a group (if it does not exist), and to assign the
specified host to that group.
s! %s cannot be matched in inventoryR� t
parent_groupsN( Rx R R� R. RP RR t localhostR RR R� R, t add_child_groupR� R� t
get_groupsRS ( R) Rm R7 RA t real_hostRW t parent_group_namesRP t groupt parent_group_namet parent_group( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR � s2
c C` sP | j j d t � } | j j | _ | j j � } | j | j � | | _ | S( sW
A proven safe and performant way to create a copy of an included file
R� ( RL RK R, R� R� t updatet _args( R) t
included_filet ti_copyt temp_vars( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt _copy_included_file s c C` sJ t j d | j � yh| j j | j � } | d k r< g St | t � sZ t d � � n | j | � } | j
j j d g � } t | t
� r� | j d � } n t | � d k r t | j
j � d k r� t d d | j
j �� n t j d d d
�| | j
_ n t | d | j d | j � d
| j
j d | d | j d | j �} x* | j D] } | j j j d | j � qXWWn� t k
r%} x� | j D]� } t d | d | j
d t d t d t! | � � � }
| j" | � t | j j# | j <| j j j d | j � | j j$ d |
� q�Wg SX| j j$ d | � t j d � | S( s_
Loads an included YAML file of tasks, applying the optional set of variables.
s loading included file: %ss0 included task files must contain a list of taskst tagst ,i s� Include tasks should not specify tags in more than one way (both via args and directly on the task). Mixing tag specify styles is prohibited for whole import hierarchy, not only for single import statementt objso You should not specify tags in the include parameters. All tags should be specified using the task-level optiont versions 2.12R� t parent_blockt rolet use_handlersR� t variable_managerRI Rm Rl t return_datat failedt reasonR= R� t v2_playbook_on_includes done processing included fileN(% R" R� t _filenameR� t load_from_fileRR R/ t listR Rg RL R� RO R t splitR� Rh R t _dst
deprecatedR R� t build_parent_blockR% R� t _hostsR[ R^ R RP R R� R, R R R� R ( R) Rd Rg t
is_handlerR Re Rh t
block_listRm R� t tr( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt _load_included_file& sN !3
c
C` s� | j j } x� | j j D]� } x� | j D]� } | j | j k r) t | j | j � r) | j j d | j d | � } t
d | j d | � } | j � } y | j
| � } Wn t t f k
r� n X| j | | d | d | �} | s� Pq� q) q) Wq W| S( sH
Runs handlers on those hosts which have been notified.
R� Rl R� R� Rg RG ( R[ R� R� R R� RQ R� R� R� R� R R� R� R� R R t _do_handler_run( R) Rg RG R: R� RJ R� R� R� ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR� b s ( c C` sl | d k r | j | j } n | j | � } t | � d k rq | j } | | _ | j j d | � | | _ n t } y@ t j
| j d t �} | j
s� t | d t � r� t } n Wn t k
r� n Xg } x� | D]� }
| j |
� r� | j |
� s| j r� | j j d | j d |
d | � } | j | d | j �| j |
| | | � | rdPqdq� q� W| j | | | � } y+ t j | d | d | j d
| j �} Wn t k
r�}
t SXt } t | � d k r xD| D]9} y� | j | d | d t �} x� | D]� } | j j j | � | j | � x� | j! D]u } | j" � } t# j$ d | | f � | j% | j | j <| j& d
| d | d | d | d | j% � } | s9Pq9q9Wq WWq�t k
r}
x1 | j% D]& }
| j' |
� t | j j( |
j <q�Wt# j) t* |
� � q�q�Xq�Wn g | j | j D] } | | k r/| ^ q/| j | j <t# j$ d | � | S( Ni t! v2_playbook_on_handler_task_startt
class_onlyt BYPASS_HOST_LOOPR� Rm Rl Rg R� Ro R| s) adding task '%s' included in handler '%s'RJ R� RG RK s$ done running handlers, result is: %s(+ RR R� RQ t _filter_notified_hostsR� RP R[ R Rx R R. R� R, R� R] RS t
has_triggeredR< t force_handlersR� R� R� R� R` RN R t process_include_resultsR� R R R R3 t cache_block_tasksR� R� R" R� R{ R� R R� R t str( R) RJ R� Rg RG RK t
saved_nameR� R� t host_resultsRm RF t included_filesR� R: Rd t
new_blocksR� Rl RH R� ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR� { s|
)$
"c C` s | S( s?
Filter notified hosts accordingly to strategy
( ( R) RK ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR� � s c C` s� t } d | } | r' | d | 7} n | d 7} t j | � } | j � d k rh t j d � t } n> | j � d k r� t j d � t | _ t } n
t j d
� t j | � | S(
Nu Perform task: %s u on %s u (N)o/(y)es/(c)ontinue: t yt yess
User ran taskt ct continues$ User ran task and canceled step modes User skipped task( R� s yes( R� R� ( Rx R" t promptt lowerR� R, R� t banner( R) Rl Rm t retR< t resp( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt
_take_step� s
c C` s t j d | � d S( Ns) %s task does not support when conditional( R" R ( R) RH ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt _cond_not_supported_warn� s c ` s/ � j j d � } � � � f d � } t } d } | d k ra � j rX � j | � n d } n�| d k r� � j r� � j | � n t � j | <� j � | � t � j | <d } n(| d k s� � j r� � j r� � j | � n � j j
� d } n�| d k rf| | � r]x< � j j � j j
� D]" } | j � }
� j j |
� q.Wd
} q�t } n{| d k r�| | � r�xh � j j � j j
� D]N } � j j j | j t � � j j j | j t � � j � j | j _ q�Wd } q�t } n�| d
k rp| | � r�xN � j j � j j
� D]4 } | j � j j k r,� j � j | j _ q,q,Wd } q�nq| d k r�� j j d � j d | d � � } t d � j d | � } | j d � d | d | � } | j d | � | j s�| j! | _ n | j" | � � j r$� j | � n | � j# k rSt$ � j# | � }
� j# | =n( t% j | j& | t' j( � }
| j) |
� |
r�y |
j* � d } Wq�t+ k
r�} t, j- d | � q�Xq�d } n t. d | d � j/ �� i | d 6} | rt | d <n
t | d <t, j0 d | � t1 | � | � g S( Nt _raw_paramsc ` sL � j j d � j d | d � � } t d � j d | � } � j | | � S( NR� Rm Rl R� R� ( R� R� R� R R� t evaluate_conditional( R� t all_varsR� ( Rg R) Rl ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt _evaluate_conditional� s $t t noopt flush_handlerss ran handlerst refresh_inventorys inventory successfully refreshedt clear_factss
facts clearedt clear_host_errorss cleared host errorst end_plays ending playt reset_connectionR� Rm Rl R� R� R� s reset connections4 got an error while closing persistent connection: %ss no connection, nothing to resets! invalid meta action requested: %sRj R< RC RA s META: %s(2 R} R. Rx t whenR� R, R� R� R{ R R� R� R� R� R� R� R� R[ R� RO RP R� t FAILED_NONERJ t
fail_stateR R R� R R� t set_task_and_variable_overridet
post_validatet remote_addrt addresst update_varsR� R R t
connectiont ost devnullt set_options_from_pluginR� R R" R� R Rx t vvR ( R) Rl RG Rg R1 t meta_actionR� RC R< Rm t hostnameR� R� R� R� R: ( ( Rg R) Rl sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt
_execute_meta� s�
$
c C` s^ g } xQ | j j | j j d | j j �D]+ } | j | j j k r+ | j | � q+ q+ W| S( sQ returns list of available hosts for this iterator by filtering out unreachables R� ( R R� R� R� R� RP R[ R� R3 ( R) Rg t
hosts_leftRm ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt get_hosts_left` s
+c C` sk xd | D]\ } d | j k r | j d j d � } | rc | j | j k r` | | j | j <q` qc q q Wd S( s3 updates the current active persistent connections R} t _ansible_socketN( R R. RM R� ( R) Rj RM t socket_path( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt update_active_connectionsi s
( R& R' R+ R* R� R� R� R� R� R` R� R� Rb Rx RR RE RN RO R R Rg R R� R� R� R� R� R� R� R� ( ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR$ � s6 / $ ; � 9 + < W k RW c B` s, e Z d Z d Z d Z d Z e d � Z RS( s. The next action after an interpreter's exit. i i i c C` s
| | _ d S( N( R: ( R) R: ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR* y s ( R& R' R+ RZ Rc Rd R* ( ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyRW s s
RX c B` s� e Z d Z d � Z d � Z e j j Z d � Z d � Z
e
Z d � Z e Z
d � Z e Z d � Z d � Z e Z d � Z d
� Z RS( s > c C` s� t j j | � d | | f | _ d | _ i | _ | | j d <| | j d <| | j d <| | j d <| | j d <| | _ d S( Ns [%s] %s (debug)> Rl RF Rm RG R: ( t cmdt CmdR* R� RR t introt scopeRp ( R) Rl Rm RF RG R: Rp ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR* � s
c C` s, y t j j | � Wn t k
r' n Xd S( N( R� R� RY t KeyboardInterrupt( R) ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyRY � s
c C` s
| j | � S( t Quit( t do_quit( R) R} ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt do_EOF� s c C` s t j d � t j | j _ t S( R� s User interrupted execution( R" RW Rd Rp R: R, ( R) R} ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyR� � s
c C` s t j | j _ t S( s Continue to next result( RW Rc Rp R: R, ( R) R} ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt do_continue� s c C` s t j | j _ t S( sK Schedule task for re-execution. The re-execution may not be the next result( RW RZ Rp R: R, ( R) R} ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt do_redo� s c C` s� y t | t � | j � SWnh t k
r� t j � d \ } } t | t � rX | } n | j } t j d | t
| � f � � n Xd S( Ni s ***%s:%s( t evalt globalsR� t ExceptionRe t exc_infoR/ R� R& R" t repr( R) R} t tt vt
exc_type_name( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt evaluate� s
c C` sA y) | j | � } t j t j | � � Wn t k
r< n Xd S( s Pretty PrintN( R� R" t pprintt pformatR� ( R) R} R: ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt do_pprint� s
c B` s� y1 e | d d d � } | e � | j f d UWnh e k
r� e j � d \ } } e | e � ro | } n | j } e j d | e
| � f � � n Xd S( Ns
s <stdin>t singlei s ***%s:%s( t compileR� R� R� Re R� R/ R� R& R" R� ( R) R} t codeR� R� R� ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt execute� s
c C` s) y | j | � Wn t k
r$ n Xd S( N( R� R� ( R) t line( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt default� s
( R& R' t prompt_continuousR* RY R� R� t do_helpt do_hR� R� t do_qR� t do_cR� t do_rR� R� t do_pR� R� ( ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyRX } s
(S t
__future__R R R t typet
__metaclass__R� Rv R� R� Re R� R� t collectionsR t multiprocessingR t jinja2.exceptionsR t ansibleR R� t ansible.errorsR R R t ansible.executorR
t ansible.executor.process.workerR t ansible.executor.task_resultR t ansible.inventory.hostR
t ansible.module_utils.six.movesR R7 t ansible.module_utils.sixR R R t ansible.module_utils._textR t ansible.module_utils.connectionR R t ansible.playbook.helpersR t ansible.playbook.included_fileR t ansible.playbook.task_includeR t ansible.playbook.role_includeR t ansible.plugins.loaderR R R R R R t ansible.templateR t ansible.utils.varsR t ansible.vars.cleanR! t __main__R" t ImportErrort ansible.utils.displayR# t __all__R% R( R� R; Rb R$ t objectRW R� RX ( ( ( sE /usr/lib/python2.7/site-packages/ansible/plugins/strategy/__init__.pyt <module> s\ .
=� � � �