Merge pull request #2391 from bcoca/apt_lock_exception

now catches lock exceptions from apt and returns friendly message

apt

@@ -226,41 +226,45 @@ def main():
     p = module.params
     install_recommends = p['install_recommends']
 
-    cache = apt.Cache()
+    try:
-    if p['default_release']:
+        cache = apt.Cache()
-        apt_pkg.config['APT::Default-Release'] = p['default_release']
+        if p['default_release']:
-        # reopen cache w/ modified config
+            apt_pkg.config['APT::Default-Release'] = p['default_release']
-        cache.open(progress=None)
+            # reopen cache w/ modified config
+            cache.open(progress=None)
+
+        if p['update_cache']:
+            cache.update()
+            cache.open(progress=None)
+            if not p['package']:
+                module.exit_json(changed=False)
 
-    if p['update_cache']:
+        force_yes = p['force']
-        cache.update()
-        cache.open(progress=None)
-        if not p['package']:
-            module.exit_json(changed=False)
 
-    force_yes = p['force']
+        if p['upgrade']:
+            upgrade(module, p['upgrade'])
 
-    if p['upgrade']:
+        packages = p['package'].split(',')
-        upgrade(module, p['upgrade'])
+        latest = p['state'] == 'latest'
+        for package in packages:
+            if package.count('=') > 1:
+                module.fail_json(msg="invalid package spec: %s" % package)
+            if latest and '=' in package:
+                module.fail_json(msg='version number inconsistent with state=latest: %s' % package)
 
-    packages = p['package'].split(',')
+        if p['state'] == 'latest':
-    latest = p['state'] == 'latest'
+            install(module, packages, cache, upgrade=True,
-    for package in packages:
+                    default_release=p['default_release'],
-        if package.count('=') > 1:
+                    install_recommends=install_recommends,
-            module.fail_json(msg="invalid package spec: %s" % package)
+                    force=force_yes)
-        if latest and '=' in package:
+        elif p['state'] in [ 'installed', 'present' ]:
-            module.fail_json(msg='version number inconsistent with state=latest: %s' % package)
+            install(module, packages, cache, default_release=p['default_release'],
+                      install_recommends=install_recommends,force=force_yes)
+        elif p['state'] in [ 'removed', 'absent' ]:
+            remove(module, packages, cache, p['purge'])
 
-    if p['state'] == 'latest':
+    except apt.cache.LockFailedException:
-        install(module, packages, cache, upgrade=True,
+        module.fail_json(msg="Failed to lock apt for exclusive operation")
-                default_release=p['default_release'],
-                install_recommends=install_recommends,
-                force=force_yes)
-    elif p['state'] in [ 'installed', 'present' ]:
-        install(module, packages, cache, default_release=p['default_release'],
-                  install_recommends=install_recommends,force=force_yes)
-    elif p['state'] in [ 'removed', 'absent' ]:
-        remove(module, packages, cache, p['purge'])
 
 # this is magic, see lib/ansible/module_common.py
 #<<INCLUDE_ANSIBLE_MODULE_COMMON>>