当收到 DISPATCH_VNODE_DELETE 时,您确实可以重新打开文件并重新注册一个源(删除前一个)。或者您可以使用专为这种场景设计的调用,即 dispatch_io_create_with_path() - 它不仅会按路径观看,还会为您打开文件并让您异步读取内容。
既然你问了(不确定你要求的是哪种技术,但这是最简单的),这里有一个独立的代码示例:
#include <dispatch/dispatch.h>
#include <stdio.h>
int main(int ac, char *av[])
{
int fdes = open("/tmp/pleasewatchthis", O_RDONLY);
dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
void (^eventHandler)(void), (^cancelHandler)(void);
unsigned long mask = DISPATCH_VNODE_DELETE | DISPATCH_VNODE_WRITE | DISPATCH_VNODE_EXTEND | DISPATCH_VNODE_ATTRIB | DISPATCH_VNODE_LINK | DISPATCH_VNODE_RENAME | DISPATCH_VNODE_REVOKE;
__block dispatch_source_t source;
eventHandler = ^{
unsigned long l = dispatch_source_get_data(source);
if (l & DISPATCH_VNODE_DELETE) {
printf("watched file deleted! cancelling source\n");
dispatch_source_cancel(source);
}
else {
// handle the file has data case
printf("watched file has data\n");
}
};
cancelHandler = ^{
int fdes = dispatch_source_get_handle(source);
close(fdes);
// Wait for new file to exist.
while ((fdes = open("/tmp/pleasewatchthis", O_RDONLY)) == -1)
sleep(1);
printf("re-opened target file in cancel handler\n");
source = dispatch_source_create(DISPATCH_SOURCE_TYPE_VNODE, fdes, mask, queue);
dispatch_source_set_event_handler(source, eventHandler);
dispatch_source_set_cancel_handler(source, cancelHandler);
dispatch_resume(source);
};
source = dispatch_source_create(DISPATCH_SOURCE_TYPE_VNODE,fdes, mask, queue);
dispatch_source_set_event_handler(source, eventHandler);
dispatch_source_set_cancel_handler(source, cancelHandler);
dispatch_resume(source);
dispatch_main();
}