Etusivu Tutki Apua
Rekisteröidy Kirjaudu sisään
shixiong
/
okd
1
0
Fork 0
Tiedostot Ongelmat 0 Pull-pyynnöt 0 Wiki
Selaa lähdekoodia

Adding file locking to yedit.

Kenny Woodson 7 vuotta sitten
vanhempi
a8675ec0dd
commit
5cfc401b6b
34 muutettua tiedostoa jossa 98 lisäystä ja 3 poistoa
Jaettu näkymä Näytä diff tilastot
  1. 3 0
      roles/lib_openshift/library/oc_adm_ca_server_cert.py
  2. 3 0
      roles/lib_openshift/library/oc_adm_csr.py
  3. 3 0
      roles/lib_openshift/library/oc_adm_manage_node.py
  4. 3 0
      roles/lib_openshift/library/oc_adm_policy_group.py
  5. 3 0
      roles/lib_openshift/library/oc_adm_policy_user.py
  6. 3 0
      roles/lib_openshift/library/oc_adm_registry.py
  7. 3 0
      roles/lib_openshift/library/oc_adm_router.py
  8. 3 0
      roles/lib_openshift/library/oc_clusterrole.py
  9. 3 0
      roles/lib_openshift/library/oc_configmap.py
  10. 3 0
      roles/lib_openshift/library/oc_edit.py
  11. 3 0
      roles/lib_openshift/library/oc_env.py
  12. 3 0
      roles/lib_openshift/library/oc_group.py
  13. 3 0
      roles/lib_openshift/library/oc_image.py
  14. 3 0
      roles/lib_openshift/library/oc_label.py
  15. 3 0
      roles/lib_openshift/library/oc_obj.py
  16. 3 0
      roles/lib_openshift/library/oc_objectvalidator.py
  17. 3 0
      roles/lib_openshift/library/oc_process.py
  18. 3 0
      roles/lib_openshift/library/oc_project.py
  19. 3 0
      roles/lib_openshift/library/oc_pvc.py
  20. 3 0
      roles/lib_openshift/library/oc_route.py
  21. 3 0
      roles/lib_openshift/library/oc_scale.py
  22. 3 0
      roles/lib_openshift/library/oc_secret.py
  23. 3 0
      roles/lib_openshift/library/oc_service.py
  24. 3 0
      roles/lib_openshift/library/oc_serviceaccount.py
  25. 3 0
      roles/lib_openshift/library/oc_serviceaccount_secret.py
  26. 3 0
      roles/lib_openshift/library/oc_storageclass.py
  27. 3 0
      roles/lib_openshift/library/oc_user.py
  28. 3 0
      roles/lib_openshift/library/oc_version.py
  29. 3 0
      roles/lib_openshift/library/oc_volume.py
  30. 1 0
      roles/lib_openshift/src/lib/import.py
  31. 2 1
      roles/lib_utils/library/repoquery.py
  32. 4 1
      roles/lib_utils/library/yedit.py
  33. 2 0
      roles/lib_utils/src/class/yedit.py
  34. 2 1
      roles/lib_utils/src/lib/import.py

+ 3 - 0
roles/lib_openshift/library/oc_adm_ca_server_cert.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -343,7 +344,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_adm_csr.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -321,7 +322,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_adm_manage_node.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -329,7 +330,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_adm_policy_group.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -315,7 +316,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_adm_policy_user.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -329,7 +330,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_adm_registry.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -433,7 +434,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_adm_router.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -458,7 +459,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_clusterrole.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -307,7 +308,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_configmap.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -313,7 +314,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_edit.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -357,7 +358,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_env.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -324,7 +325,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_group.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -297,7 +298,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_image.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -316,7 +317,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_label.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -333,7 +334,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_obj.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -336,7 +337,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_objectvalidator.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -268,7 +269,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_process.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -325,7 +326,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_project.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -322,7 +323,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_pvc.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -329,7 +330,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_route.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -373,7 +374,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_scale.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -311,7 +312,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_secret.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -369,7 +370,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_service.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -376,7 +377,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_serviceaccount.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -309,7 +310,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_serviceaccount_secret.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -309,7 +310,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_storageclass.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -327,7 +328,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_user.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -369,7 +370,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_version.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -281,7 +282,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 3 - 0
roles/lib_openshift/library/oc_volume.py
Näytä tiedosto 

@@ -34,6 +34,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re
 
@@ -358,7 +359,9 @@ class Yedit(object):  # pragma: no cover
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 1 - 0
roles/lib_openshift/src/lib/import.py
Näytä tiedosto 

@@ -8,6 +8,7 @@
 
 from __future__ import print_function
 
 import atexit
 
 import copy
 
+import fcntl
 
 import json
 
 import os
 
 import re

+ 2 - 1
roles/lib_utils/library/repoquery.py
Näytä tiedosto 

@@ -30,7 +30,8 @@
 
 
 from __future__ import print_function  # noqa: F401
 
 import copy  # noqa: F401
 
-import json  # noqa: F401
 
+import fcntl  # noqa: F401
 
+import json   # noqa: F401
 
 import os  # noqa: F401
 
 import re  # noqa: F401
 
 import shutil  # noqa: F401

+ 4 - 1
roles/lib_utils/library/yedit.py
Näytä tiedosto 

@@ -30,7 +30,8 @@
 
 
 from __future__ import print_function  # noqa: F401
 
 import copy  # noqa: F401
 
-import json  # noqa: F401
 
+import fcntl  # noqa: F401
 
+import json   # noqa: F401
 
 import os  # noqa: F401
 
 import re  # noqa: F401
 
 import shutil  # noqa: F401
 
@@ -391,7 +392,9 @@ class Yedit(object):
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 2 - 0
roles/lib_utils/src/class/yedit.py
Näytä tiedosto 

@@ -188,7 +188,9 @@ class Yedit(object):
 
         tmp_filename = filename + '.yedit'
 
 
         with open(tmp_filename, 'w') as yfd:
 
+            fcntl.flock(yfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
 
             yfd.write(contents)
 
+            fcntl.flock(yfd, fcntl.LOCK_UN)
 
 
         os.rename(tmp_filename, filename)

+ 2 - 1
roles/lib_utils/src/lib/import.py
Näytä tiedosto 

@@ -5,7 +5,8 @@
 
 
 from __future__ import print_function  # noqa: F401
 
 import copy  # noqa: F401
 
-import json  # noqa: F401
 
+import fcntl  # noqa: F401
 
+import json   # noqa: F401
 
 import os  # noqa: F401
 
 import re  # noqa: F401
 
 import shutil  # noqa: F401