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

stat first before callbacks

Browse source 
so that when the callbacks run, the paths are more likely to exist
This commit is contained in:
lilydjwg 2014-02-13 21:04:08 +08:00
parent 1c97b7402d
commit 686227b6f2
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
archrepo2/repomon.py
View file

@ -354,12 +354,11 @@ class EventHandler(pyinotify.ProcessEvent):
def _real_dispatch(self, d, act): def _real_dispatch(self, d, act):
if act.action == 'add': if act.action == 'add':
arch = os.path.split(d)[1] arch = os.path.split(d)[1]
def callback(state=1): def callback(stat, state=1):
self._db.execute( self._db.execute(
'update pkginfo set state = 0 where pkgname = ? and forarch = ? and pkgrepo = ?', 'update pkginfo set state = 0 where pkgname = ? and forarch = ? and pkgrepo = ?',
(act.name, arch, self.name) (act.name, arch, self.name)
) )
stat = os.stat(act.path)
mtime = int(stat.st_mtime) mtime = int(stat.st_mtime)
try: try:
owner = pwd.getpwuid(stat.st_uid).pw_name owner = pwd.getpwuid(stat.st_uid).pw_name
@ -380,6 +379,8 @@ class EventHandler(pyinotify.ProcessEvent):
(act.path, self.name, act.name, act.arch, act.fullversion, arch, state, owner, mtime, info)) (act.path, self.name, act.name, act.arch, act.fullversion, arch, state, owner, mtime, info))
logger.info('Action %r done.', act) logger.info('Action %r done.', act)
# stat path here, so that it is more unlikely to have disappeared since
callback = partial(callback, os.stat(act.path))
else: else:
res = self._db.execute( res = self._db.execute(
'select state from pkginfo where filename = ? and state = 1 and pkgrepo = ? limit 1', 'select state from pkginfo where filename = ? and state = 1 and pkgrepo = ? limit 1',