line |
stmt |
bran |
cond |
sub |
pod |
time |
code |
1
|
2
|
|
|
2
|
|
156125
|
use utf8; |
|
2
|
|
|
|
|
18
|
|
|
2
|
|
|
|
|
10
|
|
2
|
2
|
|
|
2
|
|
49
|
use strict; |
|
2
|
|
|
|
|
3
|
|
|
2
|
|
|
|
|
30
|
|
3
|
2
|
|
|
2
|
|
6
|
use warnings; |
|
2
|
|
|
|
|
3
|
|
|
2
|
|
|
|
|
74
|
|
4
|
|
|
|
|
|
|
|
5
|
|
|
|
|
|
|
package DR::Tnt::Client::Coro; |
6
|
2
|
|
|
2
|
|
10
|
use Carp; |
|
2
|
|
|
|
|
2
|
|
|
2
|
|
|
|
|
123
|
|
7
|
|
|
|
|
|
|
$Carp::Internal{ (__PACKAGE__) }++; |
8
|
2
|
|
|
2
|
|
1031
|
use Coro; |
|
2
|
|
|
|
|
14486
|
|
|
2
|
|
|
|
|
139
|
|
9
|
2
|
|
|
2
|
|
761
|
use Mouse; |
|
2
|
|
|
|
|
46975
|
|
|
2
|
|
|
|
|
8
|
|
10
|
|
|
|
|
|
|
|
11
|
0
|
|
|
0
|
0
|
|
sub driver { 'async' } |
12
|
|
|
|
|
|
|
|
13
|
|
|
|
|
|
|
sub request { |
14
|
0
|
|
|
0
|
0
|
|
my ($self, @args) = @_; |
15
|
|
|
|
|
|
|
|
16
|
0
|
|
|
|
|
|
my $cb = Coro::rouse_cb; |
17
|
|
|
|
|
|
|
|
18
|
0
|
|
|
|
|
|
my $m = $args[0]; |
19
|
|
|
|
|
|
|
|
20
|
0
|
0
|
|
|
|
|
@args = ('select', @args[1, 2, 3], 1, 0, 'EQ') if $m eq 'get'; |
21
|
|
|
|
|
|
|
|
22
|
0
|
|
|
|
|
|
$self->_fcb->request(@args, $cb); |
23
|
0
|
|
|
|
|
|
my ($status, $message, $resp) = Coro::rouse_wait $cb; |
24
|
|
|
|
|
|
|
|
25
|
0
|
|
|
|
|
|
return $self->_response($m, $status, $message, $resp); |
26
|
|
|
|
|
|
|
} |
27
|
|
|
|
|
|
|
|
28
|
|
|
|
|
|
|
with 'DR::Tnt::Client::Role::LikeSync'; |
29
|
|
|
|
|
|
|
|
30
|
|
|
|
|
|
|
__PACKAGE__->meta->make_immutable; |