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
|
package inotify
import (
"errors"
"syscall"
"unsafe"
)
var InotifyAlreadyClosedError error = errors.New("inotify instance already closed")
type Inotify struct {
fd Cint
isClosed bool
fullbuff [4096]byte
buff []byte
}
type Event struct {
Wd Cint /* Watch descriptor */
Mask Mask /* Mask describing event */
Cookie uint32 /* Unique cookie associating related events (for rename(2)) */
Name *string /* Optional name */
}
func InotifyInit() (*Inotify, error) {
fd, err := inotify_init()
o := Inotify{
fd: Cint(fd),
isClosed: false,
}
o.buff = o.fullbuff[:0]
return &o, err
}
func InotifyInit1(flags Cint) (*Inotify, error) {
fd, err := inotify_init1(flags)
o := Inotify{
fd: Cint(fd),
isClosed: false,
}
o.buff = o.fullbuff[:0]
return &o, err
}
func (o *Inotify) AddWatch(path string, mask Mask) (Cint, error) {
if o.isClosed {
return -1, InotifyAlreadyClosedError
}
return inotify_add_watch(o.fd, path, uint32(mask))
}
func (o *Inotify) RmWatch(wd Cint) error {
if o.isClosed {
return InotifyAlreadyClosedError
}
return inotify_rm_watch(o.fd, wd)
}
func (o *Inotify) Close() error {
if o.isClosed {
return InotifyAlreadyClosedError
}
o.isClosed = true
return sysclose(o.fd)
}
func (o *Inotify) Read() (Event, error) {
if len(o.buff) == 0 {
if o.isClosed {
return Event{Wd: -1}, InotifyAlreadyClosedError
}
len, err := sysread(o.fd, o.buff)
if len == 0 {
return Event{Wd: -1}, o.Close()
} else if len <= 0 {
return Event{Wd: -1}, err
}
o.buff = o.fullbuff[0:len]
}
raw := (*syscall.InotifyEvent)(unsafe.Pointer(&o.buff[0]))
ret := Event{
Wd: Cint(raw.Wd),
Mask: Mask(raw.Mask),
Cookie: raw.Cookie,
Name: nil,
}
if raw.Len > 0 {
bytes := (*[syscall.NAME_MAX]byte)(unsafe.Pointer(&o.buff[syscall.SizeofInotifyEvent]))
name := string(bytes[:raw.Len-1])
ret.Name = &name
}
o.buff = o.buff[0 : syscall.SizeofInotifyEvent+raw.Len]
return ret, nil
}
|
