summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorSiddharth Ravikumar <sravik@bgsu.edu>2015-03-13 12:03:20 -0400
committerSiddharth Ravikumar <sravik@bgsu.edu>2015-03-13 12:03:20 -0400
commit1f91f748cb2ff193011aaab714442298a231aa10 (patch)
treea17f5adcaafc18e5fdf5a3f5f954ca34e4141015
parent27acc86045b457bd800b5203d97218c0197bfeea (diff)
Added `shardp' method to combox.events.NodeDirMonitor + test for it.
modified: combox/events.py modified: tests/events_test.py
-rw-r--r--combox/events.py11
-rw-r--r--tests/events_test.py10
2 files changed, 21 insertions, 0 deletions
diff --git a/combox/events.py b/combox/events.py
index 71431c6..973a79d 100644
--- a/combox/events.py
+++ b/combox/events.py
@@ -202,6 +202,17 @@ class NodeDirMonitor(LoggingEventHandler):
self.silo = ComboxSilo(self.config)
+ def shardp(self, path):
+ """Returns True if `path' is a shard
+
+ Shards end with `.shardN' where `N' is a natural number.
+ """
+ if path[:-1].endswith('.shard'):
+ return True
+ else:
+ return False
+
+
def housekeep(self):
"""Recursively traverses node directory, discovers changes and updates silo and combox directory.
diff --git a/tests/events_test.py b/tests/events_test.py
index bdb1c1a..1212d69 100644
--- a/tests/events_test.py
+++ b/tests/events_test.py
@@ -314,6 +314,16 @@ class TestEvents(object):
observer.join()
+ def test_NDM_shardp(self):
+ """Testing shardp method in NodeDirMonitor class"""
+ shard = 'some.shard0'
+ not_shard = 'some.extension'
+ ndm = NodeDirMonitor(self.config)
+
+ assert_equal(True, ndm.shardp(shard))
+ assert_equal(False, ndm.shardp(not_shard))
+
+
def teardown(self):
"""Cleans up things after each test in this class"""
purge_nodedirs(self.config)