summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to '')
-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';