Changeset 20091

Timestamp:

Oct 13, 2008, 10:41:17 AM (18 years ago)

Author:

jhoblitt

Message:

add Nebulous::Server->swap_objects() method

Location:

trunk/Nebulous-Server

Files:

• Changes (modified) (1 diff)
• MANIFEST (modified) (1 diff)
• lib/Nebulous/Server.pm (modified) (2 diffs)
• t/16_server_swap_objects.t (added)

trunk/Nebulous-Server/Changes

@@ -29 +29 @@
     - change Nebulous::Server->new() to call ->db() instead of setting up the
       DBH itself; cleanup Nebulous::Server->db()
+    - add Nebulous::Server->swap_objects() method
 
 0.15 Thu Sep 11 13:00:59 HST 2008

trunk/Nebulous-Server/MANIFEST

@@ -49 +49 @@
 t/14_server_xattr.t
 t/15_mounts.t
+t/16_server_swap_objects.t
 t/75_parse_neb_key.t

trunk/Nebulous-Server/lib/Nebulous/Server.pm

@@ -1 +1 @@
 # Copyright (c) 2004-2008  Joshua Hoblitt
 #
-# $Id: Server.pm,v 1.92 2008-10-13 20:09:38 jhoblitt Exp $
+# $Id: Server.pm,v 1.93 2008-10-13 20:41:17 jhoblitt Exp $
 
 package Nebulous::Server;
@@ -296 +296 @@
 
 
+sub swap_objects
+{
+    my $self = shift;
+
+    my ($key1, $key2) = validate_pos(@_,
+        {
+            type        => SCALAR,
+            callbacks   => {
+                'is valid object key' => sub { $self->_is_valid_object_key($_[0]) },
+            },
+        },
+        {
+            type        => SCALAR,
+            callbacks   => {
+                'is valid object key' => sub { $self->_is_valid_object_key($_[0]) },
+            },
+        },
+    );
+
+    my $log = $self->log;
+    my $sql = $self->sql;
+    my $db  =$self->db;
+
+    $log->debug("entered - @_");
+
+    # ignore volumes
+    $key1 = parse_neb_key($key1);
+    $key2 = parse_neb_key($key2);
+
+    # order of operations for the swap:
+    # key1 -> key1.swap
+    # key2 -> key1
+    # key1.swap -> key2
+
+    eval {
+        {
+            # key1 -> key1.swap
+            my $query = $db->prepare_cached($sql->rename_object); 
+            # this SQL statment takes the new key name as the first param
+            my $rows = $query->execute($key1->path . ".swap", $key1->path);
+
+            # if we affected more then one row something very bad has happened.
+            unless ($rows == 1) {
+                $query->finish;
+                $log->logdie("affected row count is $rows instead of 1");
+            }
+        }
+
+        {
+            # key2 -> key1
+            my $query = $db->prepare_cached($sql->rename_object); 
+            # this SQL statment takes the new key name as the first param
+            my $rows = $query->execute($key1->path, $key2->path);
+
+            # if we affected more then one row something very bad has happened.
+            unless ($rows == 1) {
+                $query->finish;
+                $log->logdie("affected row count is $rows instead of 1");
+            }
+        }
+
+        {
+            # key1.swap -> key2
+            my $query = $db->prepare_cached($sql->rename_object); 
+            # this SQL statment takes the new key name as the first param
+            my $rows = $query->execute($key2->path, $key1->path . ".swap");
+
+            # if we affected more then one row something very bad has happened.
+            unless ($rows == 1) {
+                $query->finish;
+                $log->logdie("affected row count is $rows instead of 1");
+            }
+        }
+
+        $db->commit;
+        $log->debug("commit");
+    };
+    if ($@) {
+        $db->rollback;
+        $log->debug("rollback");
+        $log->logdie("database error: $@");
+    }
+
+    $log->debug("leaving");
+
+    return 1;
+}
+
+
 sub replicate_object
 {