← Back to branch summary

~ubuntu-branches/ubuntu/trusty/mysql-5.6/trusty

« back to all changes in this revision

Viewing changes to plugin/innodb_memcached/daemon_memcached/t/multiversioning.t

  • Committer: Package Import Robot
  • Author(s): James Page
  • Date: 2014-02-12 11:54:27 UTC
  • Revision ID: package-import@ubuntu.com-20140212115427-oq6tfsqxl1wuwehi
Tags: upstream-5.6.15
Import upstream version 5.6.15

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/innodb_memcached/daemon_memcached/t/multiversioning.t
 
1
#!/usr/bin/perl
 
2
 
 
3
use strict;
 
4
use Test::More tests => 13;
 
5
use FindBin qw($Bin);
 
6
use lib "$Bin/lib";
 
7
use MemcachedTest;
 
8
 
 
9
my $server = new_memcached();
 
10
my $sock  = $server->sock;
 
11
my $sock2 = $server->new_sock;
 
12
 
 
13
ok($sock != $sock2, "have two different connections open");
 
14
 
 
15
# set large value
 
16
my $size   = 256 * 1024;  # 256 kB
 
17
my $bigval = "0123456789abcdef" x ($size / 16);
 
18
$bigval =~ s/^0/\[/; $bigval =~ s/f$/\]/;
 
19
my $bigval2 = uc($bigval);
 
20
 
 
21
print $sock "set big 0 0 $size\r\n$bigval\r\n";
 
22
is(scalar <$sock>, "STORED\r\n", "stored foo");
 
23
mem_get_is($sock, "big", $bigval, "big value got correctly");
 
24
 
 
25
print $sock "get big\r\n";
 
26
my $buf;
 
27
is(read($sock, $buf, $size / 2), $size / 2, "read half the answer back");
 
28
like($buf, qr/VALUE big/, "buf has big value header in it");
 
29
like($buf, qr/abcdef/, "buf has some data in it");
 
30
unlike($buf, qr/abcde\]/, "buf doesn't yet close");
 
31
 
 
32
# sock2 interrupts (maybe sock1 is slow) and deletes stuff:
 
33
print $sock2 "delete big\r\n";
 
34
is(scalar <$sock2>, "DELETED\r\n", "deleted big from sock2 while sock1's still reading it");
 
35
mem_get_is($sock2, "big", undef, "nothing from sock2 now.  gone from namespace.");
 
36
print $sock2 "set big 0 0 $size\r\n$bigval2\r\n";
 
37
is(scalar <$sock2>, "STORED\r\n", "stored big w/ val2");
 
38
mem_get_is($sock2, "big", $bigval2, "big value2 got correctly");
 
39
 
 
40
# sock1 resumes reading...
 
41
$buf .= <$sock>;
 
42
$buf .= <$sock>;
 
43
like($buf, qr/abcde\]/, "buf now closes");
 
44
 
 
45
# and if sock1 reads again, it's the uppercase version:
 
46
mem_get_is($sock, "big", $bigval2, "big value2 got correctly from sock1");