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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
#!/usr/bin/env python
#
# Check the flood control under dnotify
# Scenario: the main thread watch a file, a second thread is created
# writing 10 times a sec to that file, then after 5 seconds it stops
# and stops modifying the file for 6 seconds.
# the kernel monitoring should be stopped within one second in the
# first phase and then reactivated after a few seconds in the second
# phase.
# Difference from flood.py is that we also monitor a second file and
# flood it but later and with an overlapping in time (5s of flooding
# and 3s of delay between both start)
import shutil
import os
import sys
import signal
import gamin
import time
import thread
threads = 0
# create a 4k block
block = '1234'
i = 0
while i < 10:
block = block + block
i = i + 1
def wait_ms(ms = 100):
delay = 0.001
delay = delay * ms
time.sleep(delay)
def resource_update_thread(filename):
global threads
global block
threads = threads + 1
# print "%s active" % (filename)
f = open(filename, "w")
f.write(block)
j = 0
while j < 50:
wait_ms(100)
j = j + 1
f.write(block)
# print "%s quiet" % (filename)
f.close()
time.sleep(8)
threads = threads - 1
thread.exit()
ok = 1
top = 0
top2 = 0
dbg = 0
db_expect = [ 51, 53, 54, 55, 53, 52 ]
expect = [gamin.GAMExists, gamin.GAMEndExist]
expect2 = [gamin.GAMExists, gamin.GAMEndExist]
def debug(path, type, data):
global dbg, db_expect, ok
# print "Got debug %s, %s, %s" % (path, type, data)
if path[-8:] != "temp_dir":
print "Error got debug path unexpected %s" % (path)
ok = 0
if db_expect[dbg] != type:
print "Error got debug event %d expected %d" % (type, db_expect[dbg])
ok = 0
dbg = dbg + 1
def callback(path, event, which):
global top, expect, ok
# print "Got callback: %s, %s" % (path, event)
if event == gamin.GAMAcknowledge:
return
if top < 2:
if expect[top] != event:
print "Error got event %d expected %d" % (event, expect[top])
ok = 0
elif event != gamin.GAMChanged:
print "Error got event %d expected %d" % (event, gamin.GAMChanged)
ok = 0
top = top + 1
def callback2(path, event, which):
global top2, expect2, ok
# print "Got callback2: %s, %s" % (path, event)
if event == gamin.GAMAcknowledge:
return
if top2 < 2:
if expect2[top2] != event:
print "Error got event %d expected %d" % (event, expect2[top2])
ok = 0
elif event != gamin.GAMChanged:
print "Error got event %d expected %d" % (event, gamin.GAMChanged)
ok = 0
top2 = top2 + 1
shutil.rmtree ("temp_dir", True)
os.mkdir ("temp_dir")
f = open("temp_dir/a", "w").close()
f = open("temp_dir/b", "w").close()
mon = gamin.WatchMonitor()
mon._debug_object("notify", debug, 0)
mon.watch_file("temp_dir/a", callback, 0)
wait_ms(100)
mon.handle_events()
thread.start_new_thread(resource_update_thread, ("temp_dir/a",))
mon.watch_file("temp_dir/b", callback2, 0)
# wait for 3 secs in the first flood then start the second thread
i = 0
while i < 3:
i = i + 1
time.sleep(1)
mon.handle_events()
thread.start_new_thread(resource_update_thread, ("temp_dir/b",))
# wait until the thread finishes, collecting events
time.sleep(1)
while threads > 0:
mon.handle_events()
time.sleep(1)
#print "all threads terminated, exiting ..."
mon.handle_events()
mon.stop_watch("temp_dir/a")
mon.stop_watch("temp_dir/b")
wait_ms(300)
mon.handle_events()
mon.disconnect()
del mon
shutil.rmtree ("temp_dir", True)
if top <= 2:
print "Error: monitor got only %d events" % (top)
elif top >= 20:
print "Error: event flow didn't worked properly, got %d events" % (top)
elif top2 <= 2:
print "Error: monitor got only %d events" % (top2)
elif top2 >= 20:
print "Error: event flow didn't worked properly, got %d events 2" % (top2)
elif dbg != 6 and gamin.has_debug_api == 1:
print "Error: debug got %d events insteads of 6" % (dbg)
elif ok == 1:
print "OK"
|
