services/fuse/arvados_fuse/fresh.py

   1 # Copyright (C) The Arvados Authors. All rights reserved.
   2 #
   3 # SPDX-License-Identifier: AGPL-3.0
   4
   5 import ciso8601
   6 import calendar
   7 import functools
   8 import time
   9
  10 def convertTime(t):
  11     """Parse Arvados timestamp to unix time."""
  12     if not t:
  13         return 0
  14     try:
  15         return calendar.timegm(ciso8601.parse_datetime_as_naive(t).timetuple())
  16     except (TypeError, ValueError):
  17         return 0
  18
  19 def use_counter(orig_func):
  20     @functools.wraps(orig_func)
  21     def use_counter_wrapper(self, *args, **kwargs):
  22         try:
  23             self.inc_use()
  24             return orig_func(self, *args, **kwargs)
  25         finally:
  26             self.dec_use()
  27     return use_counter_wrapper
  28
  29 def check_update(orig_func):
  30     @functools.wraps(orig_func)
  31     def check_update_wrapper(self, *args, **kwargs):
  32         self.checkupdate()
  33         return orig_func(self, *args, **kwargs)
  34     return check_update_wrapper
  35
  36 class FreshBase(object):
  37     """Base class for maintaining object lifecycle.
  38
  39     Functions include:
  40
  41     * Indicate if an object is up to date (stale() == false) or needs to be
  42       updated sets stale() == True).  Use invalidate() to mark the object as
  43       stale.  An object is also automatically stale if it has not been updated
  44       in `_poll_time` seconds.
  45
  46     * Record access time (atime) timestamp
  47
  48     * Manage internal use count used by the inode cache ("inc_use" and
  49       "dec_use").  An object which is in use cannot be cleared by the inode
  50       cache.
  51
  52     * Manage the kernel reference count ("inc_ref" and "dec_ref").  An object
  53       which is referenced by the kernel cannot have its inode entry deleted.
  54
  55     * Record cache footprint, cache priority
  56
  57     * Record Arvados uuid at the time the object is placed in the cache
  58
  59     * Clear the object contents (invalidates the object)
  60
  61     """
  62
  63     __slots__ = ("_stale", "_poll", "_last_update", "_atime", "_poll_time", "use_count",
  64                  "ref_count", "cache_size", "cache_uuid", "allow_attr_cache")
  65
  66     def __init__(self):
  67         self._stale = True
  68         self._poll = False
  69         self._last_update = time.time()
  70         self._atime = time.time()
  71         self._poll_time = 60
  72         self.use_count = 0
  73         self.ref_count = 0
  74         self.cache_size = 0
  75         self.cache_uuid = None
  76
  77         # Can the kernel cache attributes?
  78         self.allow_attr_cache = True
  79
  80     def invalidate(self):
  81         """Indicate that object contents should be refreshed from source."""
  82         self._stale = True
  83
  84     def kernel_invalidate(self):
  85         """Indicate that an invalidation for this object should be sent to the kernel."""
  86         pass
  87
  88     # Test if the entries dict is stale.
  89     def stale(self):
  90         if self._stale:
  91             return True
  92         if self._poll:
  93             return (self._last_update + self._poll_time) < self._atime
  94         return False
  95
  96     def fresh(self):
  97         self._stale = False
  98         self._last_update = time.time()
  99
 100     def atime(self):
 101         return self._atime
 102
 103     def persisted(self):
 104         return False
 105
 106     def clear(self):
 107         pass
 108
 109     def in_use(self):
 110         return self.use_count > 0
 111
 112     def inc_use(self):
 113         self.use_count += 1
 114
 115     def dec_use(self):
 116         self.use_count -= 1
 117
 118     def inc_ref(self):
 119         self.ref_count += 1
 120         return self.ref_count
 121
 122     def dec_ref(self, n):
 123         self.ref_count -= n
 124         return self.ref_count
 125
 126     def has_ref(self):
 127         """Determine if there are any kernel references to this
 128         object.
 129         """
 130         return self.ref_count > 0
 131
 132     def objsize(self):
 133         return 0
 134
 135     def uuid(self):
 136         return None
 137
 138     def finalize(self):
 139         pass
 140
 141     def child_event(self, ev):
 142         pass
 143
 144     def time_to_next_poll(self):
 145         if self._poll:
 146             t = (self._last_update + self._poll_time) - self._atime
 147             if t < 0:
 148                 return 0
 149             else:
 150                 return t
 151         else:
 152             return self._poll_time