From e73edd1995ca34a4cad28d04dbea9d6360069b6d Mon Sep 17 00:00:00 2001 From: franck cuny Date: Fri, 13 Mar 2009 09:19:48 +0100 Subject: remove txn::memory, update test to check if memcachedb is running --- lib/KiokuDB/Backend/Memcachedb.pm | 24 ------------------------ xt/10_backend.t | 14 ++++++++++++-- 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'; -- cgit v1.2.3