python - enabling start, stop feature for a folder watcher program -


the code below doesn't work want to. when svc.run() programs runs okay. changes i've made folder works file. when svc.stop() doesn't stop think. perhaps there must better way of doing threading part...

import pyinotify import threading import time import os class fs_event_handler(pyinotify.processevent): def __init__(self, callback): self._callback = callback def process_in_create(self, e): self._callback(e.path, e.name, 'created') def process_in_delete(self, e): self._callback(e.path, e.name, 'deleted') def process_in_modify(self, e): self._callback(e.path, e.name, 'modified') class notificationservice(): def __init__(self, path, callback): mask = pyinotify.in_create | pyinotify.in_delete \ | pyinotify.in_modify w = pyinotify.watchmanager() self.__notifier = pyinotify.notifier(w, fs_event_handler(callback)) wdd = w.add_watch(path, mask, rec=true, auto_add=true) self.__loop = true def start(self): while self.__loop: self.__notifier.process_events() if self.__notifier.check_events(): self.__notifier.read_events() def run(self): fm = filemonitor(self) fm.start() print 'service running...' def stop(self): self.__notifier.stop() self.__loop = false class filemonitor(threading.thread): def __init__(self, srvc): threading.thread.__init__(self) self.__svc = srvc def run(self): self.__svc.start() print 'service stopped' def _callback(path, name, operation): zpad = lambda x: ''.join(['0', str(x)])[:2] ts = time.localtime() t = ':'.join(map(zpad, [ts.tm_hour, ts.tm_min, ts.tm_sec])) print t, ':', '%s %s' % (os.path.join(path, name), operation) p = '/home/deostroll/scripts/tmp' svc = notificationservice(p, _callback) svc.run()

i'm not familiar pyinorify, seems self.__notifier.process_events() blocks self.__loop doesn't read until event happens.

you can use pyinotify.threadednotifier instead:

class notificationservice(): def __init__(self, path, callback): self.path = path self.callback = callback def start(self): mask = pyinotify.in_create | pyinotify.in_delete \ | pyinotify.in_modify w = pyinotify.watchmanager() wdd = w.add_watch(self.path, mask, rec=true, auto_add=true) self.__notifier = pyinotify.threadednotifier(w, fs_event_handler(self.callback)) self.__notifier.start() print 'service running...' def run(self): self.start() def stop(self): self.__notifier.stop() print 'service stopped'

Comments

Post a Comment

Popular posts from this blog

javascript - backbone.js Collection.add() doesn't `construct` (`initialize`) an object -

<!doctype html public "-//w3c//dtd xhtml 1.0 strict//en" "http://www.w3.org/tr/xhtml1/dtd/xhtml1-strict.dtd"> <html> <head> <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.7.2/jquery.min.js"></script> <script src="http://documentcloud.github.com/underscore/underscore-min.js"></script> <script src="http://documentcloud.github.com/backbone/backbone-min.js"></script> </head> <body> <button id="cmd_create_event" name="cmd_create_event" type="button">create new `event`</button> <script type="text/javascript"> var eventmodel = backbone.model.extend({ initialize : function() { console.log("`event` initialized. id: " + this.cid); this.bind("change:status", function() { console.log(this.get("status") + " value `status`"); }); this.bind("error", function(model, e...
Read more

php - Get uncommon values from two or more arrays -

is there function in php give array of uncommon values 2 or more arrays? for example: $array1 = array( "green", "red", "blue"); $array2 = array( "green", "yellow", "red"); .... $result = function_needed($array1, $array2,...); print_r($result); should give output: array("blue", "yellow", ...); use array_diff , array_merge : $result = array_merge(array_diff($array1, $array2), array_diff($array2, $array1)); here's demo. for multiple arrays, combine callback , array_reduce : function unique(&$a, $b) { return $a ? array_merge(array_diff($a, $b), array_diff($b, $a)) : $b; } $arrays = array( array('green', 'red', 'blue'), array('green', 'yellow', 'red') ); $result = array_reduce($arrays, 'unique'); and here's demo of that.
Read more

Adding duplicate array rows in Php -

i create function in php adds rows of array shared column value. so input. $test = array( array("c", 5, 6), array("c", 2, 3), array("test", 5, 6) ); and output. $testduplicatefree = array( array("c", 7, 9), array("test", 5, 6) ) ); i'm thinking function combine_duplicates($array,$col){ ... ... return $duplicatefreearray; } where $col duplicate free array. so, in case, combine_duplicates($test,0); would me desired output. this. <?php function combine_duplicates($array,$col) { $index = array(); foreach ($array $row) { $key = $row[$col]; if (!isset($index[$key])) { $index[$key] = $row; } else { ($i = 0; $i < count($row); ++$i) { if ($i != $col) { $index[$key][$i] += $row[$i]; } } } } return array_values($index); } $array = array( array("c", 5, 6), array("c", 2, 3), array("test", 5, 6) ); print_r(combine_duplicates($array, 0)); try here: http://codepad.org/mdhesqhi
Read more