#!/usr/bin/perl
use strict;
use warnings;
use Test::More;
use FindBin qw($Bin);
use lib "$Bin/lib";
use MemcachedTest;
plan skip_all => 'Test is flaky. Needs special hooks.';
plan tests => 74;
# start up a server with 10 maximum connections
my $server = new_memcached("-m 16 -o modern");
my $sock = $server->sock;
my $hangsock = $server->new_sock;
my $value = "B"x260144;
my $key = 0;
# disable the normal automover.
print $sock "slabs automove 0\r\n";
is(scalar <$sock>, "OK\r\n", "automover disabled");
# These aren't set to expire.
my $mget = '';
for ($key = 0; $key < 70; $key++) {
$mget .= "key$key ";
print $sock "set key$key 0 0 260144\r\n$value\r\n";
is(scalar <$sock>, "STORED\r\n", "stored key$key");
}
chop $mget;
# Don't intend to read the results, need to fill the socket.
print $hangsock "get $mget\r\n";
#sleep 8;
my $stats = mem_stats($sock, "slabs");
my $source = 0;
for my $key (keys %$stats) {
if ($key =~ m/^(\d+):total_pages/) {
my $sid = $1;
if ($stats->{$key} > 10) {
$source = $sid;
last;
}
}
}
isnt($source, 0, "found the source slab: $source");
my $busy;
my $tomove = 4;
my $reassign = "slabs reassign $source 1\r\n";
while ($tomove) {
$busy = 0;
print $sock $reassign;
my $res = scalar <$sock>;
while ($res =~ m/^BUSY/) {
if ($hangsock && $busy > 5) {
# unjam the pipeline
$hangsock->close;
}
last if ($busy > 10);
sleep 1;
$busy++;
print $sock $reassign;
$res = scalar <$sock>;
}
last if ($busy > 10);
$tomove--;
}
ok($busy <= 10, "didn't time out moving pages");
$stats = mem_stats($sock);
isnt($stats->{"slab_reassign_busy_deletes"}, "0", "deleted some busy items");