#!/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");