BioArchLinux/archrepo2
2
0
Fork 0
mirror of https://github.com/lilydjwg/archrepo2.git synced 2025-03-10 12:02:43 +00:00
Code Issues Projects Releases Packages Wiki Activity

write a lastupdate file in the repo

Browse source
This commit is contained in:
lilydjwg 2019-02-26 15:50:14 +08:00
parent 79494a5722
commit fe1e4b10cf
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
archrepo2/repomon.py
View file

@ -167,6 +167,7 @@ class RepoMan:
class EventHandler(pyinotify.ProcessEvent): class EventHandler(pyinotify.ProcessEvent):
_n_running = 0 _n_running = 0
def my_init( def my_init(
self, filter_pkg, supported_archs, config, wm, self, filter_pkg, supported_archs, config, wm,
): ):
@ -192,6 +193,8 @@ class EventHandler(pyinotify.ProcessEvent):
self._ioloop = IOLoop.current() self._ioloop = IOLoop.current()
base = config.get('path') base = config.get('path')
self._lastupdate_file = os.path.join(base, 'lastupdate')
dbname = config.get('info-db', os.path.join(base, 'pkginfo.db')) dbname = config.get('info-db', os.path.join(base, 'pkginfo.db'))
new_db = not os.path.exists(dbname) new_db = not os.path.exists(dbname)
self._db = sqlite3.connect(dbname, isolation_level=None) # isolation_level=None means autocommit self._db = sqlite3.connect(dbname, isolation_level=None) # isolation_level=None means autocommit
@ -424,6 +427,7 @@ class EventHandler(pyinotify.ProcessEvent):
self._n_running -= 1 self._n_running -= 1
if self._n_running == 0: if self._n_running == 0:
self.send_notification() self.send_notification()
self.update_lastupdate()
def inc_running(self): def inc_running(self):
self._n_running += 1 self._n_running += 1
@ -474,6 +478,11 @@ class EventHandler(pyinotify.ProcessEvent):
def send_notification_null(self): def send_notification_null(self):
logger.info('null notification sent.') logger.info('null notification sent.')
def update_lastupdate(self):
t = '%d\n' % time.time()
with open(self._lastupdate_file, 'w') as f:
f.write(t)
def filter_pkg(regex, path): def filter_pkg(regex, path):
if isinstance(path, Event): if isinstance(path, Event):
path = path.pathname path = path.pathname