Added "thread_safe" meta value

fs/base.py

@@ -178,7 +178,7 @@ class FS(object):
 
         """
         pass
-    # Depricating cache_hint in favour of no underscore version, for consistency
+    # Deprecating cache_hint in favour of no underscore version, for consistency
     cache_hint = cachehint 
 
     def close(self):
@@ -225,6 +225,7 @@ class FS(object):
         following are common:
         
          * *read_only* True if the file system cannot be modified
+         * *thread_safe* True if the implementation is thread safe
          * *network* True if the file system requires network access
          * *unicode_paths* True if the file system supports unicode paths
          * *case_insensitive_paths* True if the file system ignores the case of paths        

fs/ftpfs.py

@@ -802,7 +802,8 @@ class _DirCache(dict):
 
 class FTPFS(FS):    
     
-    _meta = { 'network' : True,
+    _meta = { 'thread_safe' : True,
+              'network' : True,
               'virtual': False,
               'read_only' : False,
               'unicode_paths' : True,

fs/memoryfs.py

@@ -235,16 +235,17 @@ class MemoryFS(FS):
 
     """
     
-    _meta = { 'network' : False,
-              'virtual': False,
-              'read_only' : False,
-              'unicode_paths' : True,
-              'case_insensitive_paths' : False,
-              'atomic.move' : False,
-              'atomic.copy' : False,
-              'atomic.makedir' : True,
-              'atomic.rename' : True,
-              'atomic.setcontents' : False,              
+    _meta = {'thread_safe' : True,            
+             'network' : False,
+             'virtual': False,
+             'read_only' : False,
+             'unicode_paths' : True,
+             'case_insensitive_paths' : False,
+             'atomic.move' : False,
+             'atomic.copy' : False,
+             'atomic.makedir' : True,
+             'atomic.rename' : True,
+             'atomic.setcontents' : False,              
               }
 
     def _make_dir_entry(self, *args, **kwargs):

fs/osfs/__init__.py

@@ -74,7 +74,8 @@ class OSFS(OSFSXAttrMixin, OSFSWatchMixin, FS):
     methods in the os and os.path modules.
     """
     
-    _meta = { 'network' : False,
+    _meta = { 'thread_safe' : True,
+              'network' : False,
               'virtual' : False,
               'read_only' : False,
               'unicode_paths' : os.path.supports_unicode_filenames,

fs/rpcfs.py

@@ -8,7 +8,6 @@ class from the :mod:`fs.expose.xmlrpc` module.
 
 """
 
-import sys
 import xmlrpclib
 import socket
 
@@ -92,8 +91,9 @@ class RPCFS(FS):
 
     """
 
-    _meta = { 'virtual': False,                                          
-              'network' : True,              
+    _meta = {'thread_safe' : True,               
+             'virtual': False,                                          
+             'network' : True,              
               }
 
     def __init__(self, uri, transport=None):

fs/s3fs.py

@@ -57,7 +57,8 @@ class S3FS(FS):
     or flushed.
     """
 
-    _meta = { 'virtual': False,
+    _meta = { 'thread_safe' : True,
+              'virtual': False,
               'read_only' : False,
               'unicode_paths' : True,
               'case_insensitive_paths' : False,

fs/sftpfs.py

@@ -52,7 +52,8 @@ class SFTPFS(FS):
     
     """
 
-    _meta = { 'virtual': False,
+    _meta = { 'thread_safe' : True,
+              'virtual': False,
               'read_only' : False,
               'unicode_paths' : True,
               'case_insensitive_paths' : False,

fs/tempfs.py

@@ -21,7 +21,8 @@ class TempFS(OSFS):
     """Create a Filesystem in a tempory directory (with tempfile.mkdtemp),
     and removes it when the TempFS object is cleaned up."""
     
-    _meta = { 'virtual' : False,
+    _meta = { 'thread_safe' : True,
+              'virtual' : False,
               'read_only' : False,
               'unicode_paths' : os.path.supports_unicode_filenames,
               'case_insensitive_paths' : os.path.normcase('Aa') == 'aa',

fs/zipfs.py

@@ -72,7 +72,8 @@ class ZipFS(FS):
 
     """A FileSystem that represents a zip file."""
     
-    _meta = { 'virtual' : False,
+    _meta = { 'thread_safe' : True,
+              'virtual' : False,
               'read_only' : False,
               'unicode_paths' : True,
               'case_insensitive_paths' : False,