mirror of
https://github.com/tahoe-lafs/tahoe-lafs.git
synced 2025-02-22 10:20:59 +00:00
Convert this message to an action for success/failure reporting
This commit is contained in:
parent
5cf223645d
commit
8fa6c66c2f
@ -5,6 +5,7 @@
|
|||||||
import os, sys
|
import os, sys
|
||||||
|
|
||||||
from eliot import (
|
from eliot import (
|
||||||
|
start_action,
|
||||||
Message,
|
Message,
|
||||||
log_call,
|
log_call,
|
||||||
)
|
)
|
||||||
@ -294,14 +295,15 @@ class INotify(PollMixin):
|
|||||||
|
|
||||||
while True:
|
while True:
|
||||||
self._state = STARTED
|
self._state = STARTED
|
||||||
Message.log(
|
action = start_action(
|
||||||
message_type=u"read-changes",
|
action_type=u"read-changes",
|
||||||
directory=self._path.path,
|
directory=self._path.path,
|
||||||
recursive=self._recursive,
|
recursive=self._recursive,
|
||||||
filter=self._filter,
|
filter=self._filter,
|
||||||
)
|
)
|
||||||
try:
|
try:
|
||||||
fni.read_changes(self._hDirectory, self._recursive, self._filter)
|
with action:
|
||||||
|
fni.read_changes(self._hDirectory, self._recursive, self._filter)
|
||||||
except WindowsError as e:
|
except WindowsError as e:
|
||||||
self._state = STOPPING
|
self._state = STOPPING
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user