Changeset 28484 for branches/pap/Nebulous-Server/lib/Nebulous/Server.pm

Timestamp:

Jun 24, 2010, 2:59:09 PM (16 years ago)

Author:

Paul Price

Message:

Merging trunk in advance of reintegrating into trunk.

Location:

branches/pap

Files:

• . (modified) (1 prop)
• Nebulous-Server/lib/Nebulous/Server.pm (modified) (1 diff)

branches/pap/Nebulous-Server/lib/Nebulous/Server.pm

@@ -1598 +1598 @@
 }
 
+sub find_ext_id_by_volume
+{
+    my $self = shift;
+    my $log = $self->log;
+    $log->debug("entered - @_");
+    my ($vol_name,$limit) = validate_pos(@_,
+                                        {
+                                            type      => SCALAR,
+# #                                         callbacks => {
+# #                                             'is valid volume name' => sub {
+# #                                                 return 1 if not defined $_[0];
+# #                                                 $self->_is_valid_volume_name($_[0])
+# #                                             },
+#                                           },
+                                        },
+                                        {
+                                            type      => SCALAR|UNDEF,
+                                            optional => 1,
+                                        },
+        );
+    unless (defined($limit)) {
+        $limit = 50000;
+    }
+
+    my $sql = $self->sql;
+    my @ext_ids;
+    my $db = $self->_db_for_index(0);
+    eval {
+        my $query;
+        $query = $db->prepare_cached( $sql->get_ext_id_by_vol_name );
+        my $rows = $query->execute($vol_name, 1,$limit);
+        unless ($rows > 0) {
+            $query->finish;
+            $log->logdie("no instances on storage volume or volume is not avaiable for volume: $vol_name");
+        }
+        while (my $row = $query->fetchrow_hashref) {
+            my $ext_id = $row->{ 'ext_id' };
+            push @ext_ids, $ext_id if $ext_id;
+        }
+    };
+    if ($@) {
+        $db->rollback;
+        $log->logdie("database error: $@");
+    }
+
+    # XXX remove this?
+    $log->logdie("no ext_ids found") unless (scalar @ext_ids);
+
+    $log->debug("found: \@ext_ids");
+
+    $log->debug("leaving");
+
+    return \@ext_ids;
+}
 
 sub find_instances