0

我在守望者中缺少删除。版本 4.9.0，inotify。

我的测试代码：

#!/usr/bin/env python3

import pathlib
import pywatchman

w = pywatchman.client()

w.query('watch', '/tmp/z')
clock = w.query('clock', '/tmp/z')['clock']
print(clock)

q = w.query('subscribe', '/tmp/z', 'Buffy', {'expression':["since", clock],
"fields": ["name", "exists", "oclock", "ctime_ns", "new", "mode"]})
print(q)

f = pathlib.Path('/tmp/z/xx')

f.touch()
data = w.receive()
clock = data['clock']
print()
print('Touch file:')
print(data)
print('Clock:', clock)

f.unlink()
print()
print('Delete file:')
print(w.receive())
w.close()

w = pywatchman.client(timeout=99999)
q = w.query('subscribe', '/tmp/z', 'Buffy', {'expression':["since", clock],
"fields": ["name", "exists", "oclock", "ctime_ns", "new", "mode"]})
print(q)

print()
print('We request changes since', clock)
print(w.receive())
w.close()

我所看到的：

  1. 我们创建文件。我们收到新文件和目录更改的通知。好。我们注意到此通知的“时钟”。

  2. 我们删除文件。我们收到文件删除的通知。好。不要收到目录更改的通知。

现在想象一下，进程在更新内部细节之前崩溃了，但它记得在步骤 1 中通知的更改（目录更新和新文件的创建）。即事务 1 已处理，但程序在事务 2 处理之前崩溃。

  1. 我们现在打开一个新的 watchman 订阅（请记住，我们正在模拟崩溃）并请求自步骤 1 以来的更改。我正在模拟恢复，程序重新启动，注意事务 1 正常（文件存在）并请求更多更改（它应该被删除）。

  2. 我希望得到一个文件删除，但我得到......什么都没有。灾难性的。

成绩单：

$ ./watchman-bug.py 
c:1517109517:10868:3:23
{'clock': 'c:1517109517:10868:3:23', 'subscribe': 'Buffy', 'version': '4.9.0'}

Touch file:
{'unilateral': True, 'subscription': 'Buffy', 'root': '/tmp/z', 'files': [{'name': 'xx', 'exists': True, 'oclock': 'c:1517109517:10868:3:24', 'ctime_ns': 1517114230070245747, 'new': True, 'mode': 33188}], 'is_fresh_instance': False, 'version': '4.9.0', 'since': 'c:1517109517:10868:3:23', 'clock': 'c:1517109517:10868:3:24'}
Clock: c:1517109517:10868:3:24

Delete file:
{'unilateral': True, 'subscription': 'Buffy', 'root': '/tmp/z', 'files': [{'name': 'xx', 'exists': False, 'oclock': 'c:1517109517:10868:3:25', 'ctime_ns': 1517114230070245747, 'new': False, 'mode': 33188}], 'is_fresh_instance': False, 'version': '4.9.0', 'since': 'c:1517109517:10868:3:24', 'clock': 'c:1517109517:10868:3:25'}
{'clock': 'c:1517109517:10868:3:25', 'subscribe': 'Buffy', 'version': '4.9.0'}

We request changes since c:1517109517:10868:3:24

进程挂起，等待删除通知。

我究竟做错了什么？。

感谢您的时间和知识！

4

1 回答 1

2

问题是您使用的是since表达式术语，而不是通知守望者使用since生成器（新近指数）。

有什么不同？FROM您可以将其视为 SQL 中的andWHERE子句之间的区别。该expression字段与子句的意图相似WHERE：它适用于匹配的结果并将它们过滤掉，但您想要做的是通过在查询规范中FROM设置字段来指定子句。since诚然，这是一个微妙的区别。

解决方案是删除表达式项并添加生成器项，如下所示：

q = w.query('subscribe', '/tmp/z', 'Buffy', 
            {"since": clock,
             "fields": ["name", "exists", "oclock",
                        "ctime_ns", "new", "mode"]})

虽然我们没有任何关于使用 pywatchman API 的文档，但您可以从文档稍好一些的 nodejs API 中借用这些概念；这是一个相关的片段：

https://facebook.github.io/watchman/docs/nodejs.html#subscribing-only-to-changed-files

于 2018-01-29T02:31:10.817 回答