summaryrefslogtreecommitdiffstats
path: root/tests/events_test.py
diff options
context:
space:
mode:
authorSiddharth Ravikumar <sravik@bgsu.edu>2015-05-01 09:36:46 -0400
committerSiddharth Ravikumar <sravik@bgsu.edu>2015-05-01 09:36:46 -0400
commit2b96ea454523354de88da661219395e02694ee84 (patch)
tree18188aecc1a3dfde2f185c329bf387c8e0143bd5 /tests/events_test.py
parent6bc6c1eecc8a34ab80dc4c6e4db8ab40e6ad4712 (diff)
Updated combox.events.NodeDirMonitor.housekeep's 're-construct file' functionality.
- Now the housekeep method re-contructs the files, whose shards were created when combox was off, in the combox directory only if all of its shards have made it to the respective node directories. - If it finds only some of all the shards of a file missing, it stores this information in the `file_created' dict inside the silo. - tests.events_tests.TestEvents.test_NDM_housekeep_create tests the 're-construct file' functionality of combox.events.NodeDirMonitor.housekeep method. modified: combox/events.py modified: tests/events_test.py
Diffstat (limited to 'tests/events_test.py')
-rw-r--r--tests/events_test.py30
1 files changed, 30 insertions, 0 deletions
diff --git a/tests/events_test.py b/tests/events_test.py
index abb490a..a8b25ab 100644
--- a/tests/events_test.py
+++ b/tests/events_test.py
@@ -599,6 +599,36 @@ class TestEvents(object):
self.purge_list.append(testf2)
+ def test_NDM_housekeep_create(self):
+ """Testing NodeDirMonitor's housekeep method's delete functionality."""
+
+ # test shard creation
+ hmutant = "%s.mutant" % self.TEST_FILE
+ hmutant_content = read_file(self.TEST_FILE)
+ split_and_encrypt(hmutant, self.config,
+ hmutant_content)
+
+ lorem_c = "%s.c" % self.lorem
+ split_and_encrypt(lorem_c, self.config,
+ read_file(self.lorem))
+ # delete lorem_c's shard0
+ remove(node_paths(lorem_c, self.config, True)[0])
+
+ ndm = NodeDirMonitor(self.config, self.silo_lock,
+ self.nodem_lock)
+ ndm.housekeep()
+
+ assert path.exists(hmutant)
+ assert hmutant_content == read_file(hmutant)
+
+ assert not path.exists(lorem_c)
+ assert_equal(len(get_nodedirs(self.config))-1,
+ self.silo.node_get('file_created', lorem_c))
+
+ self.purge_list.append(hmutant)
+ self.purge_list.append(lorem_c)
+
+
def untest_NDM_housekeep(self):
"""Testing NodeDirMonitor's housekeep method."""