diff options
Diffstat (limited to 'tests/events_test.py')
| -rw-r--r-- | tests/events_test.py | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/tests/events_test.py b/tests/events_test.py index f143c9e..8dce21c 100644 --- a/tests/events_test.py +++ b/tests/events_test.py @@ -65,6 +65,34 @@ def dirp(d): directory = path.join(node, rel_path) assert path.isdir(directory) +def renamedp(old_p, new_p): + """ + Checks if the file shards or directory were/was renamed in the under the node directories. + + old_p: old path to directory or file under combox directory. + new_p: new (present) path to the directory or file under combox directory. + """ + + nodes = get_nodedirs(config) + + is_dir = True if path.isdir(new_p) else False + i = 0 + + for node in nodes: + old_rel_path = relative_path(old_p, config) + new_rel_path = relative_path(new_p, config) + + if is_dir: + old_path = path.join(node, old_rel_path) + new_path = path.join(node, new_rel_path) + else: + old_path = "%s.shard%s" % (path.join(node, old_rel_path), i) + new_path = "%s.shard%s" % (path.join(node, new_rel_path), i) + i += 1 + + assert not path.exists(old_path) + assert path.exists(new_path) + def path_deletedp(p): """ @@ -133,6 +161,15 @@ def test_CEH(): time.sleep(1) shardedp(TEST_FILE_COPY_1) + # Test - dir rename + TEST_DIR_1_NEW = path.join(path.dirname(TEST_DIR_1), + 'snafu') + TEST_FILE_COPY_1_NEW = path.join(TEST_DIR_1_NEW, path.basename(TEST_FILE)) + os.rename(TEST_DIR_1, TEST_DIR_1_NEW) + time.sleep(1) + renamedp(TEST_DIR_1, TEST_DIR_1_NEW) + renamedp(TEST_FILE_COPY_1, TEST_FILE_COPY_1_NEW) + # Test directory & file deletion purge_dir(TEST_DIR_0) # remove the directory itself. |