summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJames Cammarata <jimi@sngx.net>2016-07-28 14:17:38 -0700
committerJames Cammarata <jimi@sngx.net>2016-09-05 00:27:29 -0500
commit1227b90ecd3355b9faa92e7fca82676b3bc93f2f (patch)
treeb675482f27c2f3f0c7e5c169faae143d954e57ab
parentd99c58ee555e75d3e8c42c023d7138f012036978 (diff)
downloadansible-fix_debug_lock.tar.gz
Remove debug lock outside of the global scopefix_debug_lock
-rw-r--r--lib/ansible/utils/display.py14
1 files changed, 5 insertions, 9 deletions
diff --git a/lib/ansible/utils/display.py b/lib/ansible/utils/display.py
index 93df39bb1d..0098780818 100644
--- a/lib/ansible/utils/display.py
+++ b/lib/ansible/utils/display.py
@@ -29,6 +29,7 @@ import locale
import logging
import getpass
import errno
+from multiprocessing import Lock
from struct import unpack, pack
from termios import TIOCGWINSZ
@@ -37,13 +38,6 @@ from ansible.errors import AnsibleError
from ansible.utils.color import stringc
from ansible.utils.unicode import to_bytes, to_unicode
-try:
- from __main__ import debug_lock
-except ImportError:
- # for those not using a CLI, though ...
- # this might not work well after fork
- from multiprocessing import Lock
- debug_lock = Lock()
try:
# Python 2
@@ -74,6 +68,8 @@ class Display:
self.columns = None
self.verbosity = verbosity
+ self._debug_lock = Lock()
+
# list of all deprecation messages to prevent duplicate display
self._deprecations = {}
self._warns = {}
@@ -184,9 +180,9 @@ class Display:
def debug(self, msg):
if C.DEFAULT_DEBUG:
- debug_lock.acquire()
+ self._debug_lock.acquire()
self.display("%6d %0.5f: %s" % (os.getpid(), time.time(), msg), color=C.COLOR_DEBUG)
- debug_lock.release()
+ self._debug_lock.release()
def verbose(self, msg, host=None, caplevel=2):
# FIXME: this needs to be implemented