Merge pull request #30 from drougge/xmpfix

Fix race in xmp.py (Closes: #18)

Author: sdelafond

example/xmp.py

@@ -7,10 +7,13 @@
 #    See the file COPYING.
 #
 
+from __future__ import print_function
+
 import os, sys
 from errno import *
 from stat import *
 import fcntl
+from threading import Lock
 # pull in some spaghetti to make this stuff work without fuse-py being installed
 try:
     import _find_fuse_parts
@@ -166,15 +169,32 @@ def __init__(self, path, flags, *mode):
             self.file = os.fdopen(os.open("." + path, flags, *mode),
                                   flag2mode(flags))
             self.fd = self.file.fileno()
+            if hasattr(os, 'pread'):
+                self.iolock = None
+            else:
+                self.iolock = Lock()
 
         def read(self, length, offset):
-            self.file.seek(offset)
-            return self.file.read(length)
+            if self.iolock:
+                self.iolock.acquire()
+                try:
+                    self.file.seek(offset)
+                    return self.file.read(length)
+                finally:
+                    self.iolock.release()
+            else:
+                return os.pread(self.fd, length, offset)
 
         def write(self, buf, offset):
-            self.file.seek(offset)
-            self.file.write(buf)
-            return len(buf)
+            if self.iolock:
+                self.iolock.acquire()
+                try:
+                    self.file.seek(offset)
+                    return self.file.write(buf)
+                finally:
+                    self.iolock.release()
+            else:
+                return os.pwrite(self.fd, buf, offset)
 
         def release(self, flags):
             self.file.close()