1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
# coding: utf-8
import pytest
from watchdog.utils import platform
if not platform.is_darwin(): # noqa
pytest.skip("macOS only.", allow_module_level=True)
import logging
import os
import time
from functools import partial
from os import mkdir, rmdir
from queue import Queue
from watchdog.events import FileSystemEventHandler
from watchdog.observers import Observer
from watchdog.observers.api import ObservedWatch
from watchdog.observers.fsevents import FSEventsEmitter
from .shell import mkdtemp, rm, touch
logging.basicConfig(level=logging.DEBUG)
logger = logging.getLogger(__name__)
def setup_function(function):
global p, event_queue
tmpdir = os.path.realpath(mkdtemp())
p = partial(os.path.join, tmpdir)
event_queue = Queue()
def teardown_function(function):
emitter.stop()
emitter.join(5)
rm(p(""), recursive=True)
assert not emitter.is_alive()
def start_watching(path=None, use_full_emitter=False):
global emitter
path = p("") if path is None else path
emitter = FSEventsEmitter(event_queue, ObservedWatch(path, recursive=True))
emitter.start()
@pytest.fixture
def observer():
obs = Observer()
obs.start()
yield obs
obs.stop()
try:
obs.join()
except RuntimeError:
pass
def test_remove_watch_twice():
"""
ValueError: PyCapsule_GetPointer called with invalid PyCapsule object
The above exception was the direct cause of the following exception:
src/watchdog/utils/__init__.py:92: in stop
self.on_thread_stop()
src/watchdog/observers/fsevents.py:73: SystemError
def on_thread_stop(self):
> _fsevents.remove_watch(self.watch)
E SystemError: <built-in function remove_watch> returned a result with an error set
(FSEvents.framework) FSEventStreamStop(): failed assertion 'streamRef != NULL'
(FSEvents.framework) FSEventStreamInvalidate(): failed assertion 'streamRef != NULL'
(FSEvents.framework) FSEventStreamRelease(): failed assertion 'streamRef != NULL'
"""
start_watching()
# This one must work
emitter.stop()
# This is allowed to call several times .stop()
emitter.stop()
def test_unschedule_removed_folder(observer):
"""
TypeError: PyCObject_AsVoidPtr called with null pointer
The above exception was the direct cause of the following exception:
def on_thread_stop(self):
if self.watch:
_fsevents.remove_watch(self.watch)
E SystemError: <built-in function stop> returned a result with an error set
(FSEvents.framework) FSEventStreamStop(): failed assertion 'streamRef != NULL'
(FSEvents.framework) FSEventStreamInvalidate(): failed assertion 'streamRef != NULL'
(FSEvents.framework) FSEventStreamRelease(): failed assertion 'streamRef != NULL'
"""
a = p("a")
mkdir(a)
w = observer.schedule(FileSystemEventHandler(), a, recursive=False)
rmdir(a)
time.sleep(0.1)
with pytest.raises(KeyError):
# watch no longer exists!
observer.unschedule(w)
def test_watchdog_recursive():
""" See https://github.com/gorakhargosh/watchdog/issues/706
"""
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler
import os.path
class Handler(FileSystemEventHandler):
def __init__(self):
FileSystemEventHandler.__init__(self)
self.changes = []
def on_any_event(self, event):
self.changes.append(os.path.basename(event.src_path))
handler = Handler()
observer = Observer()
watches = []
watches.append(observer.schedule(handler, str(p('')), recursive=True))
try:
observer.start()
time.sleep(0.1)
touch(p('my0.txt'))
mkdir(p('dir_rec'))
touch(p('dir_rec', 'my1.txt'))
expected = {"dir_rec", "my0.txt", "my1.txt"}
timeout_at = time.time() + 5
while not expected.issubset(handler.changes) and time.time() < timeout_at:
time.sleep(0.2)
assert expected.issubset(handler.changes), "Did not find expected changes. Found: {}".format(handler.changes)
finally:
for watch in watches:
observer.unschedule(watch)
observer.stop()
observer.join(1)
|
