403Webshell
Server IP : 80.87.202.40  /  Your IP : 216.73.216.169
Web Server : Apache
System : Linux rospirotorg.ru 5.14.0-539.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Dec 5 22:26:13 UTC 2024 x86_64
User : bitrix ( 600)
PHP Version : 8.2.27
Disable Function : NONE
MySQL : OFF |  cURL : ON |  WGET : ON |  Perl : ON |  Python : OFF |  Sudo : ON |  Pkexec : ON
Directory :  /lib/python3.11/site-packages/ansible/plugins/strategy/__pycache__/

Upload File :
current_dir [ Writeable] document_root [ Writeable]

 

Command :


[ Back ]     

Current File : /lib/python3.11/site-packages/ansible/plugins/strategy/__pycache__/linear.cpython-311.pyc
�

���c�P����ddlmZmZmZeZdZddlmZ	ddl
mZmZm
Z
ddlmZmZddlmZddlmZddlmZdd	lmZdd
lmZddlmZddlmZdd
lm Z e ��Z!Gd�de��Z"dS)�)�absolute_import�division�print_functiona
    name: 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
)�	constants)�AnsibleError�AnsibleAssertionError�AnsibleParserError)�IteratingStates�FailedStates)�to_text)�Handler)�IncludedFile)�Task)�
action_loader)�StrategyBase)�Templar)�Displayc�.��eZdZ�fd�Zd�Z�fd�Z�xZS)�StrategyModulec�H��t��j|i|��d|_dS)NF)�super�__init__�_in_handlers)�self�args�kwargs�	__class__s   ��D/usr/lib/python3.11/site-packages/ansible/plugins/strategy/linear.pyrzStrategyModule.__init__3s/��������$�)�&�)�)�)�"�����c��t��}d|_d|jd<d|_|�|jj��i}|D]%}|�|d���\}}|�||f||<�&|sd�|D��S|jrAttd�d	�|���D������sd
|_|jr,td�|���D����}n�d�|���D��}	d
}
|
dkrP	|j
|j}|xjdz
c_|j|	vrn2n#t $rd
|_|
dz
}
YnwxYw|
dk�Pt#d���g}|���D]{\}\}}|jr||jks|jsC|j|jkr3|�|j|��|�||f���d|�||f���||js8|jt.jvr%|j�d��dkrd|_|S)z�
        Returns a list of (host, task) tuples, where the task may
        be a noop task to keep the iterator in lock step across
        all hosts.
        �meta�noop�_raw_paramsT��peekNc��g|]}|df��S�N�)�.0�hs  r�
<listcomp>z:StrategyModule._get_next_task_lockstep.<locals>.<listcomp>Ls��-�-�-�!�Q��I�-�-�-rc�"�|tjkSr')r
�HANDLERS)�rss r�<lambda>z8StrategyModule._get_next_task_lockstep.<locals>.<lambda>Os��r�_�5�5�rc3�*K�|]\}}|jV��dSr')�	run_state)r)�s�_s   r�	<genexpr>z9StrategyModule._get_next_task_lockstep.<locals>.<genexpr>Ps(����B�B�T�Q��Q�[�B�B�B�B�B�BrFc3�TK�|]#\}}|jtjk�|jV��$dSr')r1r
r-�cur_handlers_task�r)r2�ts   rr4z9StrategyModule._get_next_task_lockstep.<locals>.<genexpr>UsE����%�%�(,��1��;�/�":�:�:��#�:�:�:�:�%�%rc�"�g|]\}}|j��
Sr()�_uuidr7s   rr+z:StrategyModule._get_next_task_lockstep.<locals>.<listcomp>Zs��K�K�K�d�a��!�'�K�K�Krr�zOBUG: There seems to be a mismatch between tasks in PlayIterator and HostStates.�flush_handlers)r�actionr�implicit�
set_loader�_play�_loader�get_next_task_for_hostr�any�filter�values�min�	all_tasks�cur_taskr:�
IndexErrorr�itemsr6�set_state_for_host�name�append�C�_ACTION_META�get)
r�hosts�iterator�	noop_task�state_task_per_host�host�state�task�lowest_cur_handler�
task_uuids�	_loop_cntrH�
host_taskss
             r�_get_next_task_lockstepz&StrategyModule._get_next_task_lockstep9s����F�F�	�!�	��(.�	��}�%�!�	�����X�^�3�4�4�4� ���	8�	8�D�"�9�9�$�T�9�J�J�K�E�4���,1�4�K�#�D�)��"�	.�-�-�u�-�-�-�-���	&�S��5�5�B�B�%8�%?�%?�%A�%A�B�B�B�*D�*D�&
�&
�	&�!&�D����	�!$�%�%�0C�0J�0J�0L�0L�%�%�%�"�"���
L�K�.A�.H�.H�.J�.J�K�K�K�J��I��q�.�.�	�'�1�(�2C�D�H��%�%��*�%�%��~��3�3��4��
"�#�#�#�()�H�%���N�I�I�I�#�����q�.�.�,�e�����
�#6�#<�#<�#>�#>�	5�	5��D�-�5�$��"�
5�'9�U�=T�'T�'T��*�(U�/7�~���/K�/K��+�+�D�I�u�=�=�=��!�!�4��,�/�/�/�/��!�!�4��"3�4�4�4�4�
�!�	%�h�o���&G�&G��
�!�!�-�0�0�4D�D�D� $�D���s� E
�
E&�%E&c�:��|jj}d}|�|j��|�r�|jj�s�	t
�d��|�|��}t
�d��d}d}|�||��}d}d}	d}
g}|D�]\}}
|
s�	|jjr�n	d}d}t|
t��sh|
jra|
j�|��rG|
jj
�|
jj
r/|
jj
jst
�d|
z����t
�d��|j�|j||
|j|j���}|�||j�	��t)|j|�
��}t
�d��|�|
j��}	t1j|d|
j���}n#t6$rd}YnwxYw|t8jvr^|�|�|
|||����|
j �d
d��dvrd}|
j!s|r	|
j"sd}
�n�|j#r|	r|�$|
��rd}	nd}�n|�|
j%��p|otM|dd��}|
j!s|r	|
j"sd}
|�s<t
�d��|
j'}t
�d��	tQ|�|
j'd���d���|
_'t
�d��n*#tR$rt
�d��YnwxYwt
�d��t|
t��r|j�*d|
��n|j�*d|
d���||
_'d}t
�d��d|j+|�,��<|�-||
||��~|rna|�|�.|t_dtatc|jj2��dz�����������!|r���t
�d��|j3d kr(|�|�4|����|�5|��tmj7|||j|j�!��}tc|��d k�r�t
�d"��t
�d#��tqd$�|D����}t
�d%��g}ts��}|D�]t}t
�d&|j:z��d}	|j;r@|�<|��}|�=|j|j|j�'��\}}n2t|j>t��}|�?|||�(��}d)�|jj@D��|_@t
�d*��|D�]}|r!|jAD]}
|jBdd�|
_C�|}n�|j�|j|�D��|j|j�+��}t
�d,��|�E|��}t
�d-��|�|�F����|D](}||jBvs|r||�G|���)��t
�d.�����#t�$r�t�$ri}|j;r)t
�JtQ|��d�/��|jKD]&} d| jLd0<|�M| jN���'Yd}~��nd}~wwxYw|D]+}d|jjO|j'<|�P|���,t
�d1��|D]}|�Q|||���||jR|jS|jS�<t
�d2��t
�d3��t
�d4��t
�d5��g}!g}"|D]�}#|#�T��s|#j>jt8jvr:|�T|#jN��r |!�G|#jNj'���h|#�U��r|"�G|#jNj'����|
r�tc|!��d kstc|"��d kr�t�t�jXt�jYg��}$|D]�}|�Z|d�6��\}%}&|�[|%��}%|%j\|$vs-|%j\t�jXkr;|%j]t�jXzd kr#d|jjO|j'<||jj_z}��t
�d7��t
�d8��|jj`��tc|��d kr�|jj`d9z}'tc|jjO��|jaz|'kr`|D]4}|j'|!vr)d|jjO|j'<|�P|���5|j�*d:��||jj_z}t
�d;tc|jjO���d<|ja�d=|'�d>���t
�d?��t
�d@��||jjkr`tc|jjO��tc|��kr6t
�dA��|j�*d:��|St
�dB��nG#t�t�f$r3}t
�dC|z��|jjdcYd}~Sd}~wwxYw|r
|jj���t�t�|���g|||��S)Dz�
        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
        Tz)getting the remaining hosts for this loopz.done getting the remaining hosts for this loopFNz)'%s' skipped because role has already runzgetting variables)�playrUrW�_hosts�
_hosts_all)r^)�loader�	variableszdone getting variables)�
class_only�collection_listr#)r"�reset_connection�end_host�
role_completer<�BYPASS_HOST_LOOPzOsending task start callback, copying the task so we can template it temporarilyz#done copying, going to template now)�fail_on_undefined�empty)�	nonstringzdone templatingz!templating failed for some reasonzhere goes the callback...�!v2_playbook_on_handler_task_start�v2_playbook_on_task_start)�is_conditionalzsending task start callbackr;g�������?)�
max_passesz>done queuing things up, now waiting for results queue to drainr)rRra�variable_managerz!we have included files to processzgenerating all_blocks datac3�K�|]}|gfV��	dSr'r()r)rUs  rr4z%StrategyModule.run.<locals>.<genexpr>s&����%H�%H�T�t�R�j�%H�%H�%H�%H�%H�%Hrzdone generating all_blocks datazprocessing included file: %s)r^rpra)rR�
is_handlerc�&�g|]}|jD]}|���Sr()�block)r)�br*s   rr+z&StrategyModule.run.<locals>.<listcomp>'s*��0e�0e�0e�q�]^�]d�0e�0e�XY��0e�0e�0e�0erz2iterating over new_blocks loaded from include file)r^rWr_r`zfiltering new block on tagsz done filtering new block on tagsz7done iterating over new_blocks loaded from include file)�	wrap_text�failedz7extending task lists for all hosts with included blockszdone extending task listszdone processing included fileszresults queue emptyzchecking for any_errors_fatalr$z"done checking for any_errors_fatalz checking for max_fail_percentagegY@�!v2_playbook_on_no_hosts_remaining�(z
 failed / z
 total )> z	 max failz%done checking for max_fail_percentagezIchecking to see if all hosts have failed and the running result is not okz!^ not ok, so returning result nowz-done checking to see if all hosts have failedz%got IOError/EOFError in task loop: %s)h�_tqm�RUN_OK�_set_hosts_cacher@�_terminated�display�debug�get_hosts_leftr\�
isinstancer
�_role�has_run�	_metadata�allow_duplicates�_variable_manager�get_vars�_hosts_cache�_hosts_cache_all�add_tqm_variablesrrA�templater=rrP�collections�KeyErrorrNrO�extend�
_execute_metar�any_errors_fatal�
ignore_errors�_step�
_take_step�run_once�getattrrLr�	Exception�
send_callback�_blocked_hosts�get_name�_queue_task�_process_pending_results�max�int�len�_workers�_pending_results�_wait_on_pending_results�update_active_connectionsr�process_include_results�dict�set�	_filename�_is_role�_copy_included_file�get_block_list�_task�_load_included_file�handlersrtr_�notified_hosts�get_first_parent_include�filter_tagged_tasks�	get_tasksrMr	r�error�_results�_result�add�_host�
_failed_hosts�mark_host_failed�	add_tasksrGrH�	is_failed�is_unreachable�	frozensetr
�RESCUE�ALWAYSrB�get_active_stater1�
fail_stater�RUN_FAILED_BREAK_PLAY�max_fail_percentage�
batch_size�IOError�EOFError�RUN_UNKNOWN_ERRORrr�run))rrR�play_context�result�
work_to_do�
hosts_left�
callback_sentr[�	skip_rest�choose_stepr��resultsrUrWr��	task_vars�templar�task_actionr=�
saved_name�included_files�
all_blocks�included_tasks�failed_includes_hosts�
included_filerr�new_ir�
new_blocks�handler_blocks�	new_block�final_block�e�r�failed_hosts�unreachable_hosts�res�dont_fail_statesr2r3�
percentagers)                                        �rr�zStrategyModule.runs�
�����!���
����h�n�-�-�-��I	3���!6�I	3�G
3��
�
�I�J�J�J�!�0�0��:�:�
��
�
�N�O�O�O�!&�
�"�
�!�9�9�*�h�O�O�
�"�	�"��$)� ���$.�YC�YC�L�T�4��!� ��y�,����$�H�!%�J�&�d�G�4�4�%���%��
�HZ�HZ�[_�H`�H`�%� �:�/�7�4�:�;O�7�X\�Xb�Xl�X}�7�#�M�M�*U�X\�*\�]�]�]�$��M�M�"5�6�6�6� $� 6� ?� ?�X�^�Z^�ei�GK�GX�ei�ez�!@�!|�!|�I��*�*�9�8�>�*�J�J�J�%�T�\�Y�O�O�O�G��M�M�":�;�;�;�#*�"2�"2�4�;�"?�"?�K�&�!.�!2�;�4�ae�aq�!r�!r�!r����#�&�&�&�"&����&����
#�a�n�4�4� ���t�'9�'9�$��h�X\�']�']�^�^�^��9�=�=���=�=�FQ�Q�Q�'+�H� �1�4�X�4�t�GY�4�/3�,�� �:�&�+�&�#���t�4�4�&�.3���,0�	� %��#*�#3�#3�D�M�#B�#B�#{�f�F{�QX�Y_�as�uz�Q{�Q{�� �1�4�X�4�t�GY�4�/3�,�,�I�#�M�M�*{�|�|�|�)-��J�#�M�M�*O�P�P�P�S�,3�G�4D�4D�T�Y�bg�4D�4h�4h�t{�,|�,|�,|��	� '�
�
�.?� @� @� @� @��#,�S�S�S�!(�
�
�.Q� R� R� R� R� R�S����$�M�M�*E�F�F�F�)�$��8�8�q� $�	� 7� 7�8[�]a� b� b� b� b� $�	� 7� 7�8S�UY�jo� 7� p� p� p�(2�D�I�,0�M�#�M�M�*G�H�H�H�?C��+�D�M�M�O�O�<��(�(��t�Y��M�M�M�%� �����N�N�4�#@�#@��VY�Z[�]`�ad�ei�en�ew�ax�ax�{~�a~�]�]�WA�WA�#@�$B�$B�C�C�C�C�����
�
�^�_�_�_��(�1�,�,��N�N�4�#@�#@��#J�#J�K�K�K��.�.�w�7�7�7�!-�!E��%��<�%)�%;�	"�"�"���~�&�&��*�*��M�M�"E�F�F�F��M�M�">�?�?�?�!%�%H�%H�Z�%H�%H�%H�!H�!H�J��M�M�"C�D�D�D�%'�N�,/�E�E�)�)7�9%�9%�
��
�
�&D�}�G^�&^�_�_�_�%*�
�6%�,�5�
�)-�)A�)A�-�)P�)P��=C�=R�=R�)1��59�5K�+/�<�>S�>"�>"� :�
�N�N�.8�
�8K�W�-U�-U�
�-1�-E�-E�m�^f�s}�-E�-~�-~�
�1f�0e�H�N�<S�0e�0e�0e�H�-�#�M�M�*^�_�_�_�-7�M�M�	�#-�!S�09��%V�%V��>K�>R�ST�ST�ST�>U��(;�(;�2;�K�K�04�0F�0O�0O�-5�^�-6�-O�-O�-Q�-Q�/3�/@�37�3H�	1P�1&�1&�I�%,�M�M�2O�$P�$P�$P�2;�2O�2O�PY�2Z�2Z�K�$+�M�M�2T�$U�$U�$U�$2�$9�$9�+�:O�:O�:Q�:Q�$R�$R�$R�,6�!M�!M�D�
(,�}�/C�'C�'C�z�'C�(2�4�(8�(?�(?��(L�(L�(L��
!M�$�M�M�*c�d�d�d�d��1�"�"�"�!�+�%�%�%�,�5�K� '�
�
�g�a�j�j�E�
� J� J� J�%2�%;�C�C��6:��	�(� 3� 5� 9� 9�!�'� B� B� B� B�$�H�H�H�H�����%����!6�8�8��=A��	�/��	�:� �1�1�$�7�7�7�7��M�M�"[�\�\�\� *�C�C�� �*�*�4��D�1A�B�B�B�B�N\�H�&�x�'8��9J�'J�K��M�M�"=�>�>�>��M�M�"B�C�C�C��
�
�3�4�4�4��
�
�=�>�>�>�!��$&�!�"�A�A�C��
�
���A�3�9�+;�q�~�+M�+M�S[�Se�Se�fi�fo�Sp�Sp�+M�$�+�+�C�I�N�;�;�;�;��+�+�-�-�A�)�0�0����@�@�@��$�
F��\�):�):�Q�)>�)>�#�FW�BX�BX�[\�B\�B\�'0�/�2H�/�J`�1a�'b�'b�$� *�F�F��!)�!@�!@��D�!@�!Q�!Q���A�%�5�5�a�8�8���;�.>�>�>��;�/�*@�@�@�Q�\�T`�Tg�Eg�kl�El�El�AE�D�I�3�D�I�>�"�d�i�&E�E�F���
�
�B�C�C�C��
�
�@�A�A�A��>�5�A�c�'�l�l�UV�FV�FV�!)��!C�e�!K�J��D�I�3�4�4�x�7J�J�j�X�X�$.�@�@�D� $�y��<�<�EI��	� 7��	� B� (� 9� 9�$� ?� ?� ?���	�/�/�0S�T�T�T��$�)�"A�A���M�M�M�C�PT�PY�Pg�Lh�Lh�Lh�Lh�jr�j}�j}�j}�@J�@J�@J�#K�L�L�L��
�
�E�F�F�F��
�
�i�j�j�j��T�Y�-�-�-�#�d�i�6M�2N�2N�RU�V`�Ra�Ra�2a�2a��M�M�"E�F�F�F��I�+�+�,O�P�P�P�!�M��
�
�M�N�N�N�N���X�&�
3�
3�
3��
�
�E��I�J�J�J��y�2�2�2�2�2�2�2�����
3����M�I	3���!6�I	3�\�^�T�*�*�.�.�x��v�N�N�Ns��F4r�0H
�r�
H�r�H�Dr�/A
M:�9r�:$N!�r� N!�!D*r�
D8r�G_�r�a�(Aa�r�a�P0r�r�s!�.(s�s!�s!)�__name__�
__module__�__qualname__rr\r��
__classcell__)rs@rrr1sv�������"�"�"�"�"�D�D�D�L[O�[O�[O�[O�[O�[O�[O�[O�[OrrN)#�
__future__rrr�type�
__metaclass__�
DOCUMENTATION�ansiblerrN�ansible.errorsrrr	�ansible.executor.play_iteratorr
r�ansible.module_utils._textr�ansible.playbook.handlerr
�ansible.playbook.included_filer�ansible.playbook.taskr�ansible.plugins.loaderr�ansible.plugins.strategyr�ansible.templater�ansible.utils.displayrr~rr(rr�<module>r�s_��$C�B�B�B�B�B�B�B�B�B��
��
�#�"�"�"�"�"�R�R�R�R�R�R�R�R�R�R�H�H�H�H�H�H�H�H�.�.�.�.�.�.�,�,�,�,�,�,�7�7�7�7�7�7�&�&�&�&�&�&�0�0�0�0�0�0�1�1�1�1�1�1�$�$�$�$�$�$�)�)�)�)�)�)�
�'�)�)��iO�iO�iO�iO�iO�\�iO�iO�iO�iO�iOr

Youez - 2016 - github.com/yon3zu
LinuXploit