ACIL FM

Nama	Ukuran	Aksi
__pycache__	-	Open
add_host.py	3.58 MB	View DL Edit
assemble.py	6.42 MB	View DL Edit
assert.py	5.03 MB	View DL Edit
async_status.py	1.78 MB	View DL Edit
command.py	1.13 MB	View DL Edit
copy.py	26.72 MB	View DL Edit
debug.py	3.28 MB	View DL Edit
fail.py	1.44 MB	View DL Edit
fetch.py	9.64 MB	View DL Edit
gather_facts.py	6.55 MB	View DL Edit
group_by.py	1.87 MB	View DL Edit
include_vars.py	11.19 MB	View DL Edit
normal.py	2.39 MB	View DL Edit
package.py	4.13 MB	View DL Edit
pause.py	11.31 MB	View DL Edit
raw.py	1.78 MB	View DL Edit
reboot.py	20.59 MB	View DL Edit
script.py	7.8 MB	View DL Edit
service.py	4.51 MB	View DL Edit
set_fact.py	2.75 MB	View DL Edit
set_stats.py	2.82 MB	View DL Edit
shell.py	1.22 MB	View DL Edit
template.py	9.74 MB	View DL Edit
unarchive.py	4.78 MB	View DL Edit
uri.py	3.96 MB	View DL Edit
validate_argument_spec.py	3.98 MB	View DL Edit
wait_for_connection.py	4.47 MB	View DL Edit
yum.py	4.6 MB	View DL Edit
__init__.py	67.24 MB	View DL Edit

Edit file: /usr/lib/python3.9/site-packages/ansible/plugins/action/wait_for_connection.py

# (c) 2017, Dag Wieers <dag@wieers.com>
#
# This file is part of Ansible
#
# Ansible is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# Ansible is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with Ansible.  If not, see <http://www.gnu.org/licenses/>.

# CI-required python3 boilerplate
from __future__ import (absolute_import, division, print_function)
__metaclass__ = type

import time
from datetime import datetime, timedelta

from ansible.module_utils._text import to_text
from ansible.plugins.action import ActionBase
from ansible.utils.display import Display

display = Display()

class TimedOutException(Exception):
    pass

class ActionModule(ActionBase):
    TRANSFERS_FILES = False
    _VALID_ARGS = frozenset(('connect_timeout', 'delay', 'sleep', 'timeout'))

DEFAULT_CONNECT_TIMEOUT = 5
    DEFAULT_DELAY = 0
    DEFAULT_SLEEP = 1
    DEFAULT_TIMEOUT = 600

def do_until_success_or_timeout(self, what, timeout, connect_timeout, what_desc, sleep=1):
        max_end_time = datetime.utcnow() + timedelta(seconds=timeout)

e = None
        while datetime.utcnow() < max_end_time:
            try:
                what(connect_timeout)
                if what_desc:
                    display.debug("wait_for_connection: %s success" % what_desc)
                return
            except Exception as e:
                error = e  # PY3 compatibility to store exception for use outside of this block
                if what_desc:
                    display.debug("wait_for_connection: %s fail (expected), retrying in %d seconds..." % (what_desc, sleep))
                time.sleep(sleep)

raise TimedOutException("timed out waiting for %s: %s" % (what_desc, error))

def run(self, tmp=None, task_vars=None):
        if task_vars is None:
            task_vars = dict()

connect_timeout = int(self._task.args.get('connect_timeout', self.DEFAULT_CONNECT_TIMEOUT))
        delay = int(self._task.args.get('delay', self.DEFAULT_DELAY))
        sleep = int(self._task.args.get('sleep', self.DEFAULT_SLEEP))
        timeout = int(self._task.args.get('timeout', self.DEFAULT_TIMEOUT))

if self._play_context.check_mode:
            display.vvv("wait_for_connection: skipping for check_mode")
            return dict(skipped=True)

result = super(ActionModule, self).run(tmp, task_vars)
        del tmp  # tmp no longer has any effect

def ping_module_test(connect_timeout):
            ''' Test ping module, if available '''
            display.vvv("wait_for_connection: attempting ping module test")
            # re-run interpreter discovery if we ran it in the first iteration
            if self._discovered_interpreter_key:
                task_vars['ansible_facts'].pop(self._discovered_interpreter_key, None)
            # call connection reset between runs if it's there
            try:
                self._connection.reset()
            except AttributeError:
                pass

ping_result = self._execute_module(module_name='ansible.legacy.ping', module_args=dict(), task_vars=task_vars)

# Test module output
            if ping_result['ping'] != 'pong':
                raise Exception('ping test failed')

start = datetime.now()

if delay:
            time.sleep(delay)

try:
            # If the connection has a transport_test method, use it first
            if hasattr(self._connection, 'transport_test'):
                self.do_until_success_or_timeout(self._connection.transport_test, timeout, connect_timeout, what_desc="connection port up", sleep=sleep)

# Use the ping module test to determine end-to-end connectivity
            self.do_until_success_or_timeout(ping_module_test, timeout, connect_timeout, what_desc="ping module test", sleep=sleep)

except TimedOutException as e:
            result['failed'] = True
            result['msg'] = to_text(e)

elapsed = datetime.now() - start
        result['elapsed'] = elapsed.seconds

# remove a temporary path we created
        self._remove_tmp_path(self._connection._shell.tmpdir)

return result

Batal