close StreamChunks on file release

Added release method for StreamedResponseCache for closing
unnecessary file chunks. Should prevent excessive number of open
sockets (concerns #98).

Author: yadayada

acd_cli.py

@@ -33,7 +33,7 @@
 for plug_mod in iter_entry_points(group='acdcli.plugins', name=None):
     __import__(plug_mod.module_name)
 
-__version__ = '0.3.0a2'
+__version__ = '0.3.0a3'
 _app_name = 'acd_cli'
 
 logger = logging.getLogger(_app_name)

acdcli/fuse.py

@@ -88,11 +88,12 @@ def get(self, id, offset, length, total):
                 return chunk.get(length)
 
         def clear(self):
-            for chunk in self.chunks():
+            for chunk in self.chunks:
                 try:
                     chunk.close()
                 except:
                     pass
+            self.chunks.clear()
 
     files = defaultdict(File)
 
@@ -104,6 +105,10 @@ def get(cls, id, offset, length, total):
     def invalidate(cls):
         pass
 
+    @classmethod
+    def release(cls, id):
+        cls.files[id].clear()
+
 
 class ACDFuse(Operations):
     def __init__(self):
@@ -309,6 +314,9 @@ def open(self, path, flags):
     def release(self, path, fh):
         logger.debug('release %s, %d' % (path, fh))
 
+        node, _ = query.resolve(path, trash=False)
+        StreamedResponseCache.release(node.id)
+
     def utimens(self, path, times=None):
         logger.debug('utimens %s' % path)