守望者：我错过了订阅前发生的文件删除

Question

我在守望者中缺少删除。版本 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

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

我做错了什么？

感谢您的时间和知识！

Answer 1

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

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

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

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

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

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