105
106
self.assertTrue(path_ancestor in self.eq._general_watchs)
106
107
self.assertEqual(self.eq._ancestors_watchs, {})
109
def test_rm_watch_not_dir_anymore(self):
110
"""Test that a watch can be removed even not having the dir anymore.
112
This is the case where the directory is deleted from the filesystem,
113
the watch is automatically removed in pyinotify but we need to take
114
care of it from our own data structures.
116
not_existing_dir = "not-added-dir"
117
self.eq.inotify_add_watch(not_existing_dir)
118
self.assertTrue(self.eq.inotify_has_watch(not_existing_dir))
119
self.eq.inotify_rm_watch(not_existing_dir)
120
self.assertFalse(self.eq.inotify_has_watch(not_existing_dir))
108
122
def test_rm_watch_wrong(self):
109
123
"""Test that general watchs can be removed."""
110
124
# add two types of watchs
172
187
self.assertFalse(self.eq.inotify_has_watch(path_ancestor))
190
class WatchManagerTests(BaseEQTestCase):
191
"""Test the structures where we have the path/watch."""
197
BaseEQTestCase.setUp(self)
198
self.deferred = deferred = defer.Deferred()
201
# class-closure, cannot use self, pylint: disable-msg=E0213
202
def handle_default(*a):
203
deferred.callback(True)
205
self.eq.subscribe(HitMe())
207
def test_watch_updated_when_deleting_dir(self):
208
"""Internal data structures are fixed when deleting the dir."""
209
path = os.path.join(self.root_dir, "path")
211
self.eq.inotify_add_watch(self.root_dir)
212
self.eq.inotify_add_watch(path)
214
# we have the watch, remove the dir, the watch should be gone
215
self.assertTrue(self.eq.inotify_has_watch(path))
219
"""Check state after the event."""
220
self.assertFalse(self.eq.inotify_has_watch(path))
222
self.deferred.addCallback(check)
225
def test_watch_updated_when_renaming_dir(self):
226
"""Internal data structures are fixed when renaming the dir."""
227
path1 = os.path.join(self.root_dir, "path1")
228
path2 = os.path.join(self.root_dir, "path2")
230
self.eq.inotify_add_watch(self.root_dir)
231
self.eq.inotify_add_watch(path1)
233
# we have the watch, rename the dir, new name should have the watch,
234
# old name should not
235
self.assertTrue(self.eq.inotify_has_watch(path1))
236
os.rename(path1, path2)
239
"""Check state after the event."""
240
self.assertTrue(self.eq.inotify_has_watch(path2))
241
self.assertFalse(self.eq.inotify_has_watch(path1))
243
self.deferred.addCallback(check)
246
def test_watch_updated_when_movingout_dir(self):
247
"""Internal data structures are fixed when moving out the dir."""
248
notu1 = os.path.join(self.root_dir, "notu1")
249
path1 = os.path.join(self.root_dir, "path1")
250
path2 = os.path.join(notu1, "path2")
253
self.eq.inotify_add_watch(self.root_dir)
254
self.eq.inotify_add_watch(path1)
256
# we have the watch, move it outside watched structure, no more watches
257
self.assertTrue(self.eq.inotify_has_watch(path1))
258
os.rename(path1, path2)
261
"""Check state after the event."""
262
self.assertFalse(self.eq.inotify_has_watch(path1))
263
self.assertFalse(self.eq.inotify_has_watch(path2))
265
self.deferred.addCallback(check)
268
def test_fix_path_not_there(self):
269
"""Try to fix path but it's not there."""
270
self.eq._general_watchs = {}
271
self.eq._ancestors_watchs = {}
272
self.eq.inotify_watch_fix("not-there", "new-one")
273
self.assertTrue(self.log_handler.check_warning("Tried to fix",
276
def test_fix_path_general(self):
277
"""Fixing path in general watches."""
278
self.eq._general_watchs = {'/path1/foo': 1, '/other': 2}
279
self.eq._ancestors_watchs = {'/foo': 3}
280
self.eq.inotify_watch_fix('/path1/foo', '/path1/new')
281
self.assertEqual(self.eq._general_watchs, {'/path1/new': 1, '/other': 2})
282
self.assertEqual(self.eq._ancestors_watchs, {'/foo': 3})
284
def test_fix_path_ancestors(self):
285
"""Fixing path in ancestors watches."""
286
self.eq._general_watchs = {'/bar': 3}
287
self.eq._ancestors_watchs = {'/oth': 1, '/other': 2}
288
self.eq.inotify_watch_fix('/oth', '/baz')
289
self.assertEqual(self.eq._general_watchs, {'/bar': 3})
290
self.assertEqual(self.eq._ancestors_watchs, {'/baz': 1, '/other': 2})
175
293
class DynamicHitMe(object):
176
294
"""Helper class to test a sequence of signals."""
added
removed
tests/syncdaemon/test_eq_inotify.py
