#!/usr/bin/python
#
# Check the flood control under dnotify
# Scenario: the main thread watch a directory, a second thread is created
#  writing 30 times a sec to that directory, then after 4.5 seconds it stops
#  and stops modifying the directory 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.
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 directory_update_thread(directory):
    global threads
    global block

    threads = threads + 1
    i = 0
    while i < 15:
	f = open(directory + '/a', "w").close()
	f = open(directory + '/b', "w").close()
	f = open(directory + '/c', "w").close()
        wait_ms(100)
	os.unlink(directory + '/a')
	f = open(directory + '/d', "w").close()
	os.unlink(directory + '/b')
	f = open(directory + '/e', "w").close()
        wait_ms(100)
	os.unlink(directory + '/c')
	os.unlink(directory + '/d')
	os.unlink(directory + '/e')
        wait_ms(100)
	i = i + 1
    wait_ms(8000)
    threads = threads - 1
    thread.exit()

ok = 1
top = 0
dbg = 0
db_expect = [ 51, 54, 55, 52 ]
expect = [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.GAMCreated and event != gamin.GAMDeleted and \
         event != gamin.GAMChanged:
	print "Error got event %d" % (event)
	ok = 0
    top = top + 1

shutil.rmtree ("temp_dir", True)
os.mkdir ("temp_dir")
thread.start_new_thread(directory_update_thread, ("temp_dir",))

mon = gamin.WatchMonitor()
mon._debug_object("notify", debug, 0)
mon.watch_directory("temp_dir", callback, 0)

# wait until the thread finishes, collecting events
wait_ms(100)
while threads > 0:
    mon.handle_events()
    wait_ms(100)

#print "all threads terminated, exiting ..."

mon.stop_watch("temp_dir")
time.sleep(1)
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 >= 60:
    print "Error: event flow didn't worked properly, gor %d events" % (top)
elif dbg != 4 and gamin.has_debug_api == 1:
    print "Error: debug got %d events insteads of 4" % (dbg)
elif ok == 1:
    print "OK"