tyler.durden/powerline
1
0
Fork 0
mirror of https://github.com/powerline/powerline.git synced 2025-07-23 13:55:45 +02:00
Code Issues Packages Projects Releases Wiki Activity

Use monotonic clock, not time.time

Browse Source
This commit is contained in:
ZyX 2013-03-30 18:12:55 +04:00
parent a31d6f00a7
commit 90c8020e09
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
powerline/lib/file_watcher.py
View File

@ -7,7 +7,8 @@ __docformat__ = 'restructuredtext en'
import os import os
import sys import sys
import errno import errno
import time from powerline.lib.time import monotonic
from time import sleep
from threading import RLock from threading import RLock
@ -121,7 +122,7 @@ class INotifyWatch(object):
self.process_event(wd, mask, cookie) self.process_event(wd, mask, cookie)
def expire_watches(self): def expire_watches(self):
now = time.time() now = monotonic()
for path, last_query in tuple(self.last_query.items()): for path, last_query in tuple(self.last_query.items()):
if last_query - now > self.expire_time: if last_query - now > self.expire_time:
self.unwatch(path) self.unwatch(path)
@ -168,7 +169,7 @@ class INotifyWatch(object):
raise OSError if the path does not exist. ''' raise OSError if the path does not exist. '''
path = self.os.path.abspath(path) path = self.os.path.abspath(path)
with self.lock: with self.lock:
self.last_query[path] = time.time() self.last_query[path] = monotonic()
self.expire_watches() self.expire_watches()
if path not in self.watches: if path not in self.watches:
# Try to re-add the watch, it will fail if the file does not # Try to re-add the watch, it will fail if the file does not
@ -269,7 +270,7 @@ class StatWatch(object):
def close(self): def close(self):
with self.lock: with self.lock:
self.watches = {} self.watches.clear()
def create_file_watcher(use_stat=False, expire_time=10): def create_file_watcher(use_stat=False, expire_time=10):
@ -302,7 +303,7 @@ if __name__ == '__main__':
while True: while True:
if watcher(sys.argv[-1]): if watcher(sys.argv[-1]):
print ('%s has changed' % sys.argv[-1]) print ('%s has changed' % sys.argv[-1])
time.sleep(1) sleep(1)
except KeyboardInterrupt: except KeyboardInterrupt:
pass pass
watcher.close() watcher.close()