X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/03faf36a90f23cdf6ec2e07ffe905bc46fb5a048..8fd360faf91921c557f44f079b127a4fa5830486:/services/fuse/arvados_fuse/fresh.py diff --git a/services/fuse/arvados_fuse/fresh.py b/services/fuse/arvados_fuse/fresh.py index e7e91db427..2e7a2a8182 100644 --- a/services/fuse/arvados_fuse/fresh.py +++ b/services/fuse/arvados_fuse/fresh.py @@ -1,3 +1,7 @@ +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: AGPL-3.0 + import time import ciso8601 import calendar @@ -8,7 +12,7 @@ def convertTime(t): if not t: return 0 try: - return calendar.timegm(ciso8601.parse_datetime_unaware(t).timetuple()) + return calendar.timegm(ciso8601.parse_datetime_as_naive(t).timetuple()) except (TypeError, ValueError): return 0 @@ -55,6 +59,10 @@ class FreshBase(object): * Clear the object contents (invalidates the object) """ + + __slots__ = ("_stale", "_poll", "_last_update", "_atime", "_poll_time", "use_count", + "ref_count", "dead", "cache_size", "cache_uuid", "allow_attr_cache") + def __init__(self): self._stale = True self._poll = False @@ -66,8 +74,9 @@ class FreshBase(object): self.dead = False self.cache_size = 0 self.cache_uuid = None + + # Can the kernel cache attributes? self.allow_attr_cache = True - self.allow_dirent_cache = True def invalidate(self): """Indicate that object contents should be refreshed from source.""" @@ -135,3 +144,16 @@ class FreshBase(object): def finalize(self): pass + + def child_event(self, ev): + pass + + def time_to_next_poll(self): + if self._poll: + t = (self._last_update + self._poll_time) - self._atime + if t < 0: + return 0 + else: + return t + else: + return self._poll_time