Copy items asynchronously, support moves instead of copies

update() and create() now support a 'transfer_ownership' argument that
causes the datastore to move the object, rather than copy it when it can.
When copies must be done, the copy is internally asynchronous when
possible to allow the datastore to continue processing requests from
clients while the copy is ongoing.

1 files changed, 7 insertions, 0 deletions

diff --git a/src/olpc/datastore/bin_copy.py b/src/olpc/datastore/bin_copy.py
index 1be1b6b..df28052 100644
--- a/src/olpc/datastore/bin_copy.py
+++ b/src/olpc/datastore/bin_copy.py
@@ -9,6 +9,13 @@ def bin_copy(src, dest, mode=0600):
     else:
         os.chmod(dest, mode)
 
+def bin_mv(src, dest, mode=0600):
+    try:
+        subprocess.check_call(['/bin/mv', src, dest])
+    except subprocess.CalledProcessError:
+        raise OSError("Move failed %s %s" % (src, dest))
+    else:
+        os.chmod(dest, mode)
 
 if __name__ == "__main__":
     import sys