From: Christian Heller Date: Sun, 22 Feb 2015 10:28:33 +0000 (+0100) Subject: Server/py: Add atomic writing to record(). X-Git-Tag: tce~504 X-Git-Url: https://plomlompom.com/repos/%7B%7B%20web_path%20%7D%7D/%7B%7Bdb.prefix%7D%7D/%7B%7Bprefix%7D%7D/static/day?a=commitdiff_plain;h=ad68927997c51a97dc2efc863c50243f28f2d63d;p=plomrogue Server/py: Add atomic writing to record(). --- diff --git a/plomrogue-server.py b/plomrogue-server.py index 568b21c..47390a4 100755 --- a/plomrogue-server.py +++ b/plomrogue-server.py @@ -2,6 +2,7 @@ import argparse import errno import os import shlex +import shutil import time @@ -71,17 +72,23 @@ def obey(cmd, io_db, prefix): raise SystemExit("received QUIT command") elif "MAKE_WORLD" == tokens[0] and 2 == len(tokens): print("I would generate a new world now, if only I knew how.") - record(cmd, io_db["path_record"]) + record(cmd, io_db) else: print("Invalid command/argument, or bad number of tokens.") -def record(cmd, path_recordfile): +def record(cmd, io_db): """Append cmd string plus newline to file at path_recordfile.""" # Doesn't yet replace old record() fully. - file = open(path_recordfile, "a") + path_tmp = io_db["path_record"] + io_db["tmp_suffix"] + if os.access(io_db["path_record"], os.F_OK): + shutil.copyfile(io_db["path_record"], path_tmp) + file = open(path_tmp, "a") file.write(cmd + "\n") + file.flush() + os.fsync(file.fileno()) file.close() + os.rename(path_tmp, io_db["path_record"]) def obey_lines_in_file(path, name):