.

wcfs/__init__.py

@@ -126,6 +126,14 @@ class _Mapping(object):
 def connect(wc, at): # -> Conn
     return Conn(wc, at)
 
+# close releases resources associated with wconn.
+# XXX what happens to file mmappings?
+@func(Conn)
+def close(wconn):
+    # XXX stop/join pinner
+    wconn._wlink.close()
+
+
 # _pinner receives pin messages from wcfs and adjusts wconn mappings.
 @func(Conn)
 def _pinner(wconn, ctx):

wcfs/wcfs_test.py

@@ -19,7 +19,7 @@
 # See https://www.nexedi.com/licensing for rationale and options.
 """wcfs_test tests wcfs filesystem from outside as python client process
 
-It also unit-tests wcfs.py virtmem-level infrastructure.
+It also unit-tests wcfs.py virtmem-level integration.
 
 At functional level, the whole wendelin.core test suite is used to verify
 wcfs.py/wcfs.go while running tox tests in wcfs mode.
@@ -1685,8 +1685,9 @@ def test_wcfs_watch_2files():
 
 # ---- wcfs.py + virtmem integration ----
 
-# XXX name, text ...
-def test_XXX():
+# XXX text ...
+@func
+def test_wcfspy_virtmem():
     t = tDB(); zf = t.zfile
     defer(t.close)
 
@@ -1694,6 +1695,7 @@ def test_XXX():
     at2 = t.commit(zf, {2:'c2'})
 
     wconn = t.wc.connect(at1)
+    defer(wconn.close)
 
 
 # ---- misc ---