X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/96040562743f6056c2b243db16b5a83244894bd8..6c7373c9d66ab358ea48ea7c1d0e59551364e064:/services/fuse/arvados_fuse/__init__.py diff --git a/services/fuse/arvados_fuse/__init__.py b/services/fuse/arvados_fuse/__init__.py index 6e2bf2896d..5d782d2641 100644 --- a/services/fuse/arvados_fuse/__init__.py +++ b/services/fuse/arvados_fuse/__init__.py @@ -2,7 +2,6 @@ # FUSE driver for Arvados Keep # -from __future__ import print_function import os import sys @@ -226,7 +225,7 @@ class MagicDirectory(Directory): else: return False except Exception as e: - logging.debug('arv-mount exception keep', e) + logging.debug('arv-mount exception keep %s', e) return False def __getitem__(self, item): @@ -256,10 +255,11 @@ class TagsDirectory(Directory): def update(self): tags = self.api.links().list(filters=[['link_class', '=', 'tag']], select=['name'], distinct = True).execute() - self.merge(tags['items'], - lambda i: i['name'], - lambda a, i: a.tag == i, - lambda i: TagDirectory(self.inode, self.inodes, self.api, i['name'], poll=self._poll, poll_time=self._poll_time)) + if "items" in tags: + self.merge(tags['items'], + lambda i: i['name'], + lambda a, i: a.tag == i, + lambda i: TagDirectory(self.inode, self.inodes, self.api, i['name'], poll=self._poll, poll_time=self._poll_time)) class TagDirectory(Directory): '''A special directory that contains as subdirectories all collections visible @@ -416,13 +416,9 @@ class Operations(llfuse.Operations): so request handlers do not run concurrently unless the lock is explicitly released with llfuse.lock_released.''' - def __init__(self, uid, gid, debug): + def __init__(self, uid, gid): super(Operations, self).__init__() - if debug: - logging.setLevel(logging.DEBUG) - logging.info("arv-mount debug enabled") - self.inodes = Inodes() self.uid = uid self.gid = gid @@ -479,7 +475,7 @@ class Operations(llfuse.Operations): return entry def lookup(self, parent_inode, name): - logging.debug("arv-mount lookup: parent_inode", parent_inode, "name", name) + logging.debug("arv-mount lookup: parent_inode %i name %s", parent_inode, name) inode = None if name == '.': @@ -515,7 +511,7 @@ class Operations(llfuse.Operations): return fh def read(self, fh, off, size): - logging.debug("arv-mount read", fh, off, size) + logging.debug("arv-mount read %i %i %i", fh, off, size) if fh in self._filehandles: handle = self._filehandles[fh] else: @@ -532,7 +528,7 @@ class Operations(llfuse.Operations): del self._filehandles[fh] def opendir(self, inode): - logging.debug("arv-mount opendir: inode", inode) + logging.debug("arv-mount opendir: inode %i", inode) if inode in self.inodes: p = self.inodes[inode] @@ -553,14 +549,14 @@ class Operations(llfuse.Operations): return fh def readdir(self, fh, off): - logging.debug("arv-mount readdir: fh", fh, "off", off) + logging.debug("arv-mount readdir: fh %i off %i", fh, off) if fh in self._filehandles: handle = self._filehandles[fh] else: raise llfuse.FUSEError(errno.EBADF) - logging.debug("arv-mount handle.entry", handle.entry) + logging.debug("arv-mount handle.entry %s", handle.entry) e = off while e < len(handle.entry):