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
|
#
#
# Nim's Runtime Library
# (c) Copyright 2012 Dominik Picheta
#
# See the file "copying.txt", included in this
# distribution, for details about the copyright.
#
when defined(nimPreviewSlimSystem):
import std/syncio
# Get the platform-dependent flags.
# Structure describing an inotify event.
type
InotifyEvent* {.pure, final, importc: "struct inotify_event",
header: "<sys/inotify.h>",
completeStruct.} = object ## An Inotify event.
wd* {.importc: "wd".}: FileHandle ## Watch descriptor.
mask* {.importc: "mask".}: uint32 ## Watch mask.
cookie* {.importc: "cookie".}: uint32 ## Cookie to synchronize two events.
len* {.importc: "len".}: uint32 ## Length (including NULs) of name.
name* {.importc: "name".}: UncheckedArray[char] ## Name.
# Supported events suitable for MASK parameter of INOTIFY_ADD_WATCH.
const
IN_ACCESS* = 0x00000001 ## File was accessed.
IN_MODIFY* = 0x00000002 ## File was modified.
IN_ATTRIB* = 0x00000004 ## Metadata changed.
IN_CLOSE_WRITE* = 0x00000008 ## Writtable file was closed.
IN_CLOSE_NOWRITE* = 0x00000010 ## Unwrittable file closed.
IN_CLOSE* = (IN_CLOSE_WRITE or IN_CLOSE_NOWRITE) ## Close.
IN_OPEN* = 0x00000020 ## File was opened.
IN_MOVED_FROM* = 0x00000040 ## File was moved from X.
IN_MOVED_TO* = 0x00000080 ## File was moved to Y.
IN_MOVE* = (IN_MOVED_FROM or IN_MOVED_TO) ## Moves.
IN_CREATE* = 0x00000100 ## Subfile was created.
IN_DELETE* = 0x00000200 ## Subfile was deleted.
IN_DELETE_SELF* = 0x00000400 ## Self was deleted.
IN_MOVE_SELF* = 0x00000800 ## Self was moved.
# Events sent by the kernel.
const
IN_UNMOUNT* = 0x00002000 ## Backing fs was unmounted.
IN_Q_OVERFLOW* = 0x00004000 ## Event queued overflowed.
IN_IGNORED* = 0x00008000 ## File was ignored.
# Special flags.
const
IN_ONLYDIR* = 0x01000000 ## Only watch the path if it is a directory.
IN_DONT_FOLLOW* = 0x02000000 ## Do not follow a sym link.
IN_EXCL_UNLINK* = 0x04000000 ## Exclude events on unlinked objects.
IN_MASK_ADD* = 0x20000000 ## Add to the mask of an already existing watch.
IN_ISDIR* = 0x40000000 ## Event occurred against dir.
IN_ONESHOT* = 0x80000000 ## Only send event once.
# All events which a program can wait on.
const
IN_ALL_EVENTS* = (IN_ACCESS or IN_MODIFY or IN_ATTRIB or IN_CLOSE_WRITE or
IN_CLOSE_NOWRITE or IN_OPEN or IN_MOVED_FROM or IN_MOVED_TO or
IN_CREATE or IN_DELETE or IN_DELETE_SELF or IN_MOVE_SELF)
proc inotify_init*(): FileHandle {.cdecl, importc: "inotify_init",
header: "<sys/inotify.h>".}
## Create and initialize inotify instance.
proc inotify_init1*(flags: cint): FileHandle {.cdecl, importc: "inotify_init1",
header: "<sys/inotify.h>".}
## Like `inotify_init<#inotify_init>`_ ,
## but has a flags argument that provides access to some extra functionality.
proc inotify_add_watch*(fd: cint; name: cstring; mask: uint32): cint {.cdecl,
importc: "inotify_add_watch", header: "<sys/inotify.h>".}
## Add watch of object NAME to inotify instance FD. Notify about events specified by MASK.
proc inotify_rm_watch*(fd: cint; wd: cint): cint {.cdecl,
importc: "inotify_rm_watch", header: "<sys/inotify.h>".}
## Remove the watch specified by WD from the inotify instance FD.
iterator inotify_events*(evs: pointer, n: int): ptr InotifyEvent =
## Abstract the packed buffer interface to yield event object pointers.
runnableExamples("-r:off"):
when defined(linux):
import std/posix # needed for FileHandle read procedure
const MaxWatches = 8192
let inotifyFd = inotify_init() # create new inotify instance and get it's FileHandle
let wd = inotifyFd.inotify_add_watch("/tmp", IN_CREATE or IN_DELETE) # Add new watch
var events: array[MaxWatches, byte] # event buffer
while (let n = read(inotifyFd, addr events, MaxWatches); n) > 0: # blocks until any events have been read
for e in inotify_events(addr events, n):
echo (e[].wd, e[].mask, cast[cstring](addr e[].name)) # echo watch id, mask, and name value of each event
var ev: ptr InotifyEvent = cast[ptr InotifyEvent](evs)
var n = n
while n > 0:
yield ev
let sz = InotifyEvent.sizeof + int(ev[].len)
n -= sz
ev = cast[ptr InotifyEvent](cast[uint](ev) + uint(sz))
runnableExamples:
when defined(linux):
let inotifyFd = inotify_init() # create and get new inotify FileHandle
doAssert inotifyFd >= 0 # check for errors
let wd = inotifyFd.inotify_add_watch("/tmp", IN_CREATE or IN_DELETE) # Add new watch
doAssert wd >= 0 # check for errors
discard inotifyFd.inotify_rm_watch(wd) # remove watch
|