Skip to content
Snippets Groups Projects
Commit 498fdaad authored by Fabrice Le Goff's avatar Fabrice Le Goff
Browse files

small fix in DeleteThread_Test

parent da37810d
No related branches found
No related tags found
No related merge requests found
...@@ -89,7 +89,7 @@ class TestDeleteThread(unittest.TestCase): ...@@ -89,7 +89,7 @@ class TestDeleteThread(unittest.TestCase):
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.delete', new=mockdel) @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.delete', new=mockdel)
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread._getFileSystemUsage') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread._getFileSystemUsage')
def test_basic(self, mock_gfsu): def test_basic(self, mock_gfsu):
dt = DeleteThread.DeleteThread(type(self).basic_conf, type(self).ev, dt = DeleteThread.DeleteThread(self.c, type(self).ev,
type(self).dblock, type(self).dq, type(self).cq) type(self).dblock, type(self).dq, type(self).cq)
mock_gfsu.return_value = {'/': 10} mock_gfsu.return_value = {'/': 10}
fmd = FMD('/srcdir/todelete', '/eos/dummy', 'eosdummy', 0) fmd = FMD('/srcdir/todelete', '/eos/dummy', 'eosdummy', 0)
...@@ -103,9 +103,8 @@ class TestDeleteThread(unittest.TestCase): ...@@ -103,9 +103,8 @@ class TestDeleteThread(unittest.TestCase):
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.delete', new=mockdel) @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.delete', new=mockdel)
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread._getFileSystemUsage') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread._getFileSystemUsage')
def test_exclude_regex(self, mock_gfsu): def test_exclude_regex(self, mock_gfsu):
conf = type(self).getBasicConf() self.c.DeleteExcludeFileRegex = '.*DONOTDELETE.*'
conf.DeleteExcludeFileRegex = '.*DONOTDELETE.*' dt = DeleteThread.DeleteThread(self.c, type(self).ev,
dt = DeleteThread.DeleteThread(conf, type(self).ev,
type(self).dblock, type(self).dq, type(self).cq) type(self).dblock, type(self).dq, type(self).cq)
mock_gfsu.return_value = {'/': 10} mock_gfsu.return_value = {'/': 10}
...@@ -126,9 +125,8 @@ class TestDeleteThread(unittest.TestCase): ...@@ -126,9 +125,8 @@ class TestDeleteThread(unittest.TestCase):
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.delete', new=mockdel) @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.delete', new=mockdel)
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread._getFileSystemUsage') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread._getFileSystemUsage')
def test_min_file_age(self, mock_gfsu): def test_min_file_age(self, mock_gfsu):
conf = type(self).getBasicConf() self.c.DeleteMinFileAge = 100
conf.DeleteMinFileAge = 100 dt = DeleteThread.DeleteThread(self.c, type(self).ev,
dt = DeleteThread.DeleteThread(conf, type(self).ev,
type(self).dblock, type(self).dq, type(self).cq) type(self).dblock, type(self).dq, type(self).cq)
mock_gfsu.return_value = {'/': 10} mock_gfsu.return_value = {'/': 10}
...@@ -150,9 +148,8 @@ class TestDeleteThread(unittest.TestCase): ...@@ -150,9 +148,8 @@ class TestDeleteThread(unittest.TestCase):
@unittest.mock.patch('cs.Threads.DeleteThread.dir_is_locked') @unittest.mock.patch('cs.Threads.DeleteThread.dir_is_locked')
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread._getFileSystemUsage') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread._getFileSystemUsage')
def test_locked_dir(self, mock_gfsu, mock_dil): def test_locked_dir(self, mock_gfsu, mock_dil):
conf = type(self).getBasicConf() self.c.DeleteIgnoreLock = False
conf.DeleteIgnoreLock = False dt = DeleteThread.DeleteThread(self.c, type(self).ev,
dt = DeleteThread.DeleteThread(conf, type(self).ev,
type(self).dblock, type(self).dq, type(self).cq) type(self).dblock, type(self).dq, type(self).cq)
mock_gfsu.return_value = {'/': 10} mock_gfsu.return_value = {'/': 10}
...@@ -175,10 +172,9 @@ class TestDeleteThread(unittest.TestCase): ...@@ -175,10 +172,9 @@ class TestDeleteThread(unittest.TestCase):
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.delete', new=mockdel) @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.delete', new=mockdel)
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread._getFileSystemUsage') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread._getFileSystemUsage')
def test_low_watermark(self, mock_gfsu): def test_low_watermark(self, mock_gfsu):
conf = type(self).getBasicConf() self.c.DeleteLowWaterMark = [20]
conf.DeleteLowWaterMark = [20] self.c.DeleteFileSystemUsagePeriod = 1
conf.DeleteFileSystemUsagePeriod = 1 dt = DeleteThread.DeleteThread(self.c, type(self).ev,
dt = DeleteThread.DeleteThread(conf, type(self).ev,
type(self).dblock, type(self).dq, type(self).cq) type(self).dblock, type(self).dq, type(self).cq)
mock_gfsu.return_value = {'/': 10} mock_gfsu.return_value = {'/': 10}
...@@ -211,10 +207,9 @@ class TestDeleteThread(unittest.TestCase): ...@@ -211,10 +207,9 @@ class TestDeleteThread(unittest.TestCase):
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.checkMigration') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.checkMigration')
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.getFileSystemUsage') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.getFileSystemUsage')
def test_migration_delay(self, mock_gfsu, mock_cm, mock_gct): def test_migration_delay(self, mock_gfsu, mock_cm, mock_gct):
conf = type(self).getBasicConf() self.c.MigrationCheck = True
conf.MigrationCheck = True self.c.MigrationCheckDelay = 1
conf.MigrationCheckDelay = 1 dt = DeleteThread.DeleteThread(self.c, type(self).ev,
dt = DeleteThread.DeleteThread(conf, type(self).ev,
type(self).dblock, type(self).dq, type(self).cq) type(self).dblock, type(self).dq, type(self).cq)
mock_gfsu.return_value = 10 mock_gfsu.return_value = 10
mock_cm.return_value = True mock_cm.return_value = True
...@@ -250,10 +245,9 @@ class TestDeleteThread(unittest.TestCase): ...@@ -250,10 +245,9 @@ class TestDeleteThread(unittest.TestCase):
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.checkMigration') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.checkMigration')
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.getFileSystemUsage') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.getFileSystemUsage')
def test_migration(self, mock_gfsu, mock_cm): def test_migration(self, mock_gfsu, mock_cm):
conf = type(self).getBasicConf() self.c.MigrationCheck = True
conf.MigrationCheck = True self.c.MigrationCheckDelay = 0
conf.MigrationCheckDelay = 0 dt = DeleteThread.DeleteThread(self.c, type(self).ev,
dt = DeleteThread.DeleteThread(conf, type(self).ev,
type(self).dblock, type(self).dq, type(self).cq) type(self).dblock, type(self).dq, type(self).cq)
mock_gfsu.return_value = 10 mock_gfsu.return_value = 10
...@@ -276,12 +270,11 @@ class TestDeleteThread(unittest.TestCase): ...@@ -276,12 +270,11 @@ class TestDeleteThread(unittest.TestCase):
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.checkMigration') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.checkMigration')
@unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.getFileSystemUsage') @unittest.mock.patch('cs.Threads.DeleteThread.DeleteThread.getFileSystemUsage')
def test_critical_marks(self, mock_gfsu, mock_cm): def test_critical_marks(self, mock_gfsu, mock_cm):
conf = type(self).getBasicConf() self.c.MigrationCheck = True
conf.MigrationCheck = True self.c.MigrationCheckDelay = 0
conf.MigrationCheckDelay = 0 self.c.DeleteHighCriticalMark = 90
conf.DeleteHighCriticalMark = 90 self.c.DeleteLowCriticalMark = 80
conf.DeleteLowCriticalMark = 80 dt = DeleteThread.DeleteThread(self.c, type(self).ev,
dt = DeleteThread.DeleteThread(conf, type(self).ev,
type(self).dblock, type(self).dq, type(self).cq) type(self).dblock, type(self).dq, type(self).cq)
mock_cm.return_value = False mock_cm.return_value = False
fmd = FMD('/srcdir/file', '/eos/dummy', 'eosdummy', 0) fmd = FMD('/srcdir/file', '/eos/dummy', 'eosdummy', 0)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment