summary refs log tree commit diff
diff options
context:
space:
mode:
authorfranck cuny <franck.cuny@rtgi.fr>2009-03-13 09:19:48 +0100
committerfranck cuny <franck.cuny@rtgi.fr>2009-03-13 09:19:48 +0100
commite73edd1995ca34a4cad28d04dbea9d6360069b6d (patch)
tree7598fb1965319efdb39d3f30ff551b955ee5577a
parentfix stupid typo (diff)
downloadkiokudb-backend-memcachedb-e73edd1995ca34a4cad28d04dbea9d6360069b6d.tar.gz
remove txn::memory, update test to check if memcachedb is running
-rw-r--r--lib/KiokuDB/Backend/Memcachedb.pm24
-rw-r--r--xt/10_backend.t14
2 files changed, 12 insertions, 26 deletions
diff --git a/lib/KiokuDB/Backend/Memcachedb.pm b/lib/KiokuDB/Backend/Memcachedb.pm
index 1341c79..e352eac 100644
--- a/lib/KiokuDB/Backend/Memcachedb.pm
+++ b/lib/KiokuDB/Backend/Memcachedb.pm
@@ -13,7 +13,6 @@ our $VERSION = "0.01";
 with qw(
     KiokuDB::Backend
     KiokuDB::Backend::Serialize::Delegate
-    KiokuDB::Backend::Role::TXN::Memory
     KiokuDB::Backend::Role::Concurrency::POSIX
 );
 
@@ -59,29 +58,6 @@ sub get {
     @objs;
 }
 
-sub commit_entries {
-    my ( $self, @entries ) = @_;
-    my $db = $self->db;
-    my @checks = $self->exists( map { $_->id } @entries );
-
-    foreach my $entry ( @entries ) {
-        my $id = $entry->id;
-
-        my $status = shift @checks;
-        if ( $entry->deleted ) {
-            if ( !$status ) {
-                croak "Entry $id doesn't exist in the database";
-            }
-            $db->delete( $id );
-        } else {
-            if ( $status and not $entry->has_prev ) {
-                croak "Entry $id already exists in the database";
-            }
-            $db->set( $id, $self->serialize( $entry ) );
-        }
-    }
-}
-
 sub exists {
     my ( $self, @ids ) = @_;
     my $check = $self->db->get_multi( @ids );
diff --git a/xt/10_backend.t b/xt/10_backend.t
index 7210a76..9184bcf 100644
--- a/xt/10_backend.t
+++ b/xt/10_backend.t
@@ -5,8 +5,18 @@ use Test::More;
 use Scope::Guard;
 
 BEGIN {
-    #plan skip_all => 'Please set KIOKU_COUCHDB_URI to a CouchDB instance URI' unless $ENV{KIOKU_COUCHDB_URI};
-    plan 'no_plan';
+    use IO::Socket::INET;
+    my $addr = shift || "127.0.0.1:21201";
+    my $msock = IO::Socket::INET->new(
+        PeerAddr => $addr,
+        Timeout  => 3
+    );
+    if ( $msock ) {
+        plan 'no_plan';
+    } else {
+        plan skip_all => "No memcachedb instance running\n";
+        exit 0;
+    }
 }
 
 use ok 'KiokuDB';