1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
#!perl
use 5.010;
use strict;
use warnings;
use File::Basename qw//; use lib File::Basename::dirname(__FILE__).'/lib';
use Test::More;
use TestCassandra;
use Cassandra::Client::Policy::Throttle::Adaptive;
use Time::HiRes qw/time/;
use AnyEvent::XSPromises qw/collect/;
use AnyEvent;
plan skip_all => "Missing Cassandra test environment" unless TestCassandra->is_ok;
my $client= TestCassandra->new(
anyevent => 1,
throttler => Cassandra::Client::Policy::Throttle::Adaptive->new(),
);
$client->connect();
my $db= 'perl_cassandra_client_tests';
$client->execute("drop keyspace if exists $db");
$client->execute("create keyspace $db with replication={'class':'SimpleStrategy', 'replication_factor': 1}");
$client->execute("create table $db.test_int (id int primary key, value int)");
my $insert_query= "insert into $db.test_int (id, value) values (?, ?)";
my $select_query= "select id, value from $db.test_int where id=?";
my $rounds= $ENV{BENCH_ROUNDS} || 1;
my $multiply= $ENV{BENCH_MULTIPLY} || 1;
for (1..$rounds) {
SYNC_INS: {
next if $ENV{BENCH_SKIP_SYNC};
my $num= 1000 * $multiply;
my $t0= -time();
for (1..$num) {
$client->execute($insert_query, [ $_, $_ * 2 ]);
}
my $diff= time() + $t0;
ok(1, sprintf "$num synchronous inserts: %.1f seconds", $diff);
}
SYNC_SEL: {
next if $ENV{BENCH_SKIP_SYNC};
my $num= 1000 * $multiply;
my $t0= -time();
for (1..$num) {
$client->execute($select_query, [ $_ ]);
}
my $diff= time() + $t0;
ok(1, sprintf "$num synchronous selects: %.1f seconds", $diff);
}
PROMISES_INS: {
my $num= 1000 * $multiply;
my $t0= -time();
my @promises;
for (1..$num) {
push @promises, $client->async_execute($insert_query, [ $_, $_ * 2 ]);
}
my $cv= AE::cv;
my $fail;
collect(@promises)->then(sub { $cv->send; }, sub { $fail= 1; $cv->send; });
$cv->recv;
my $diff= time() + $t0;
ok(1, sprintf "$num asynchronous inserts: %.1f seconds", $diff);
}
PROMISES_SEL: {
my $num= 1000 * $multiply;
my $t0= -time();
my @promises;
for (1..$num) {
push @promises, $client->async_execute($select_query, [ $_ ]);
}
my $cv= AE::cv;
my $fail;
collect(@promises)->then(sub { $cv->send; }, sub { $fail= 1; $cv->send; });
$cv->recv;
my $diff= time() + $t0;
ok(1, sprintf "$num asynchronous selects: %.1f seconds", $diff);
}
FUTURES_INS: {
my $num= 1000 * $multiply;
my $t0= -time();
my @futures;
for (1..$num) {
push @futures, $client->future_execute($insert_query, [ $_, $_ * 2 ]);
}
$_->() for @futures;
my $diff= time() + $t0;
ok(1, sprintf "$num synchronous inserts via futures: %.1f seconds", $diff);
}
FUTURES_SEL: {
my $num= 1000 * $multiply;
my $t0= -time();
my @futures;
for (1..$num) {
push @futures, $client->future_execute($select_query, [ $_ ]);
}
$_->() for @futures;
my $diff= time() + $t0;
ok(1, sprintf "$num synchronous selects via futures: %.1f seconds", $diff);
}
}
done_testing;
|
