2017-07-25 17:06:03 +02:00
|
|
|
import os, errno
|
2017-11-22 09:33:18 +01:00
|
|
|
import atexit
|
|
|
|
|
import tempfile
|
|
|
|
|
|
|
|
|
|
_tmpfiles = set()
|
|
|
|
|
|
|
|
|
|
def _cleanup():
|
|
|
|
|
for f in _tmpfiles:
|
2017-11-22 09:52:22 +01:00
|
|
|
silentremove(f)
|
2017-07-25 17:06:03 +02:00
|
|
|
|
|
|
|
|
def silentremove(filename): #export
|
|
|
|
|
try:
|
|
|
|
|
os.remove(filename)
|
|
|
|
|
except OSError as e:
|
|
|
|
|
if e.errno != errno.ENOENT:
|
|
|
|
|
raise # re-raise exception if a different error occurred
|
2017-10-30 10:00:25 +01:00
|
|
|
|
|
|
|
|
def pad(token, total_size, right_align = False):
|
|
|
|
|
add = total_size - len(token)
|
|
|
|
|
if add <= 0:
|
|
|
|
|
return token
|
|
|
|
|
space = ' ' * add
|
|
|
|
|
if right_align:
|
|
|
|
|
return space + token
|
|
|
|
|
return token + space
|
2017-11-22 09:33:18 +01:00
|
|
|
|
|
|
|
|
def atomic_store(contents, path): # export
|
|
|
|
|
if path[0:3] == '/dev':
|
|
|
|
|
with open(path, 'w') as outfile:
|
|
|
|
|
outfile.write(contents)
|
|
|
|
|
return
|
|
|
|
|
outfile = tempfile.NamedTemporaryFile(prefix=os.path.basename(path), delete=False, dir=os.path.dirname(path))
|
|
|
|
|
name = outfile.name
|
|
|
|
|
_tmpfiles.add(name)
|
|
|
|
|
outfile.write(contents)
|
|
|
|
|
outfile.close()
|
|
|
|
|
os.rename(name, path)
|
|
|
|
|
_tmpfiles.remove(name)
|
|
|
|
|
|
|
|
|
|
atexit.register(_cleanup)
|