| line |
stmt |
bran |
cond |
sub |
pod |
time |
code |
|
1
|
|
|
|
|
|
|
package RedisDB; |
|
2
|
|
|
|
|
|
|
|
|
3
|
17
|
|
|
17
|
|
943658
|
use strict; |
|
|
17
|
|
|
|
|
108
|
|
|
|
17
|
|
|
|
|
608
|
|
|
4
|
17
|
|
|
17
|
|
93
|
use warnings; |
|
|
17
|
|
|
|
|
34
|
|
|
|
17
|
|
|
|
|
808
|
|
|
5
|
|
|
|
|
|
|
|
|
6
|
|
|
|
|
|
|
our $VERSION = "2.57"; |
|
7
|
|
|
|
|
|
|
$VERSION = eval $VERSION; |
|
8
|
|
|
|
|
|
|
|
|
9
|
17
|
|
|
17
|
|
7073
|
use RedisDB::Error; |
|
|
17
|
|
|
|
|
38
|
|
|
|
17
|
|
|
|
|
501
|
|
|
10
|
17
|
|
|
17
|
|
8186
|
use RedisDB::Parser; |
|
|
17
|
|
|
|
|
70224
|
|
|
|
17
|
|
|
|
|
589
|
|
|
11
|
17
|
|
|
17
|
|
10979
|
use IO::Socket::IP; |
|
|
17
|
|
|
|
|
571808
|
|
|
|
17
|
|
|
|
|
95
|
|
|
12
|
17
|
|
|
17
|
|
8145
|
use IO::Socket::UNIX; |
|
|
17
|
|
|
|
|
46
|
|
|
|
17
|
|
|
|
|
189
|
|
|
13
|
17
|
|
|
17
|
|
13373
|
use Socket qw(MSG_DONTWAIT MSG_NOSIGNAL SO_RCVTIMEO SO_SNDTIMEO); |
|
|
17
|
|
|
|
|
47
|
|
|
|
17
|
|
|
|
|
1154
|
|
|
14
|
17
|
|
|
17
|
|
109
|
use POSIX qw(:errno_h); |
|
|
17
|
|
|
|
|
33
|
|
|
|
17
|
|
|
|
|
149
|
|
|
15
|
17
|
|
|
17
|
|
6681
|
use Config; |
|
|
17
|
|
|
|
|
35
|
|
|
|
17
|
|
|
|
|
745
|
|
|
16
|
17
|
|
|
17
|
|
102
|
use Carp; |
|
|
17
|
|
|
|
|
41
|
|
|
|
17
|
|
|
|
|
984
|
|
|
17
|
17
|
|
|
17
|
|
104
|
use Try::Tiny; |
|
|
17
|
|
|
|
|
40
|
|
|
|
17
|
|
|
|
|
898
|
|
|
18
|
17
|
|
|
17
|
|
10664
|
use Encode qw(); |
|
|
17
|
|
|
|
|
170548
|
|
|
|
17
|
|
|
|
|
437
|
|
|
19
|
17
|
|
|
17
|
|
9818
|
use URI; |
|
|
17
|
|
|
|
|
81366
|
|
|
|
17
|
|
|
|
|
566
|
|
|
20
|
17
|
|
|
17
|
|
7881
|
use URI::redis; |
|
|
17
|
|
|
|
|
152516
|
|
|
|
17
|
|
|
|
|
67705
|
|
|
21
|
|
|
|
|
|
|
|
|
22
|
|
|
|
|
|
|
=head1 NAME |
|
23
|
|
|
|
|
|
|
|
|
24
|
|
|
|
|
|
|
RedisDB - Perl extension to access redis database |
|
25
|
|
|
|
|
|
|
|
|
26
|
|
|
|
|
|
|
=head1 SYNOPSIS |
|
27
|
|
|
|
|
|
|
|
|
28
|
|
|
|
|
|
|
use RedisDB; |
|
29
|
|
|
|
|
|
|
|
|
30
|
|
|
|
|
|
|
my $redis = RedisDB->new(host => 'localhost', port => 6379); |
|
31
|
|
|
|
|
|
|
$redis->set($key, $value); |
|
32
|
|
|
|
|
|
|
my $value = $redis->get($key); |
|
33
|
|
|
|
|
|
|
|
|
34
|
|
|
|
|
|
|
=head1 DESCRIPTION |
|
35
|
|
|
|
|
|
|
|
|
36
|
|
|
|
|
|
|
This module provides interface to access redis key-value store, it |
|
37
|
|
|
|
|
|
|
transparently handles disconnects and forks, supports transactions, |
|
38
|
|
|
|
|
|
|
pipelining, and subscription mode. |
|
39
|
|
|
|
|
|
|
|
|
40
|
|
|
|
|
|
|
=head1 METHODS |
|
41
|
|
|
|
|
|
|
|
|
42
|
|
|
|
|
|
|
=cut |
|
43
|
|
|
|
|
|
|
|
|
44
|
|
|
|
|
|
|
=head2 $class->new(%options) |
|
45
|
|
|
|
|
|
|
|
|
46
|
|
|
|
|
|
|
Creates a new RedisDB object. The following options are accepted: |
|
47
|
|
|
|
|
|
|
|
|
48
|
|
|
|
|
|
|
=over 4 |
|
49
|
|
|
|
|
|
|
|
|
50
|
|
|
|
|
|
|
=item host |
|
51
|
|
|
|
|
|
|
|
|
52
|
|
|
|
|
|
|
domain name of the host running redis server. Default: "localhost" |
|
53
|
|
|
|
|
|
|
|
|
54
|
|
|
|
|
|
|
=item port |
|
55
|
|
|
|
|
|
|
|
|
56
|
|
|
|
|
|
|
port to connect. Default: 6379 |
|
57
|
|
|
|
|
|
|
|
|
58
|
|
|
|
|
|
|
=item path |
|
59
|
|
|
|
|
|
|
|
|
60
|
|
|
|
|
|
|
you can connect to redis using UNIX socket. In this case instead of |
|
61
|
|
|
|
|
|
|
L and L you should specify I. |
|
62
|
|
|
|
|
|
|
|
|
63
|
|
|
|
|
|
|
=item password |
|
64
|
|
|
|
|
|
|
|
|
65
|
|
|
|
|
|
|
Password, if redis server requires authentication. Alternatively you can use |
|
66
|
|
|
|
|
|
|
I method after creating the object. |
|
67
|
|
|
|
|
|
|
|
|
68
|
|
|
|
|
|
|
=item database |
|
69
|
|
|
|
|
|
|
|
|
70
|
|
|
|
|
|
|
DB number to use. Specified database will be selected immediately after |
|
71
|
|
|
|
|
|
|
connecting to the server. Database changes when you sending I |
|
72
|
|
|
|
|
|
|
to the server. You can get current database using I method. |
|
73
|
|
|
|
|
|
|
Default value is 0. |
|
74
|
|
|
|
|
|
|
|
|
75
|
|
|
|
|
|
|
=item url |
|
76
|
|
|
|
|
|
|
|
|
77
|
|
|
|
|
|
|
A Redis URL as described in L. |
|
78
|
|
|
|
|
|
|
|
|
79
|
|
|
|
|
|
|
You cannot use C together with any of C, C, C, |
|
80
|
|
|
|
|
|
|
C, C. |
|
81
|
|
|
|
|
|
|
|
|
82
|
|
|
|
|
|
|
=item raise_error |
|
83
|
|
|
|
|
|
|
|
|
84
|
|
|
|
|
|
|
By default if redis-server returned error reply, or there was a connection |
|
85
|
|
|
|
|
|
|
error I method throws an exception of L type, if you |
|
86
|
|
|
|
|
|
|
set this parameter to false it will return an error object instead. Note, that |
|
87
|
|
|
|
|
|
|
if you set this to false you should always check if the result you've got from |
|
88
|
|
|
|
|
|
|
RedisDB method is a L object. |
|
89
|
|
|
|
|
|
|
|
|
90
|
|
|
|
|
|
|
=item timeout |
|
91
|
|
|
|
|
|
|
|
|
92
|
|
|
|
|
|
|
IO timeout. With this option set, if I/O operation has taken more than |
|
93
|
|
|
|
|
|
|
specified number of seconds, module will croak or return |
|
94
|
|
|
|
|
|
|
L error object depending on L setting. |
|
95
|
|
|
|
|
|
|
Note, that some OSes do not support SO_RCVTIMEO, and SO_SNDTIMEO socket |
|
96
|
|
|
|
|
|
|
options, in this case timeout will not work. |
|
97
|
|
|
|
|
|
|
|
|
98
|
|
|
|
|
|
|
=item utf8 |
|
99
|
|
|
|
|
|
|
|
|
100
|
|
|
|
|
|
|
Assume that all data on the server encoded in UTF-8. As result all strings will |
|
101
|
|
|
|
|
|
|
be converted to UTF-8 before sending to server, and all results will be decoded |
|
102
|
|
|
|
|
|
|
from UTF-8. See L"UTF-8 SUPPORT">. |
|
103
|
|
|
|
|
|
|
|
|
104
|
|
|
|
|
|
|
=item connection_name |
|
105
|
|
|
|
|
|
|
|
|
106
|
|
|
|
|
|
|
After establishing a connection set its name to the specified using "CLIENT |
|
107
|
|
|
|
|
|
|
SETNAME" command. |
|
108
|
|
|
|
|
|
|
|
|
109
|
|
|
|
|
|
|
=item lazy |
|
110
|
|
|
|
|
|
|
|
|
111
|
|
|
|
|
|
|
by default I establishes a connection to the server. If this parameter is |
|
112
|
|
|
|
|
|
|
set, then connection will be established only when you will send first command |
|
113
|
|
|
|
|
|
|
to the server. |
|
114
|
|
|
|
|
|
|
|
|
115
|
|
|
|
|
|
|
=item reconnect_attempts |
|
116
|
|
|
|
|
|
|
|
|
117
|
|
|
|
|
|
|
this parameter allows you to specify how many attempts to (re)connect to the |
|
118
|
|
|
|
|
|
|
server should be made before returning an error. Default value is 1, set to -1 |
|
119
|
|
|
|
|
|
|
if module should try to reconnect indefinitely. |
|
120
|
|
|
|
|
|
|
|
|
121
|
|
|
|
|
|
|
=item reconnect_delay_max |
|
122
|
|
|
|
|
|
|
|
|
123
|
|
|
|
|
|
|
module waits some time before every new attempt to connect. Delay increases |
|
124
|
|
|
|
|
|
|
each time. This parameter allows you to specify maximum delay between attempts |
|
125
|
|
|
|
|
|
|
to reconnect. Default value is 10. |
|
126
|
|
|
|
|
|
|
|
|
127
|
|
|
|
|
|
|
=item on_connect_error |
|
128
|
|
|
|
|
|
|
|
|
129
|
|
|
|
|
|
|
if module failed to establish connection with the server it will invoke this |
|
130
|
|
|
|
|
|
|
callback. First argument to the callback is a reference to the RedisDB object, |
|
131
|
|
|
|
|
|
|
and second is the error description. You must not invoke any methods on the |
|
132
|
|
|
|
|
|
|
object inside the callback, but you can change I and I, or I |
|
133
|
|
|
|
|
|
|
attributes of the I object to point to another server. After callback |
|
134
|
|
|
|
|
|
|
returned, module tries to establish connection again using new parameters. To |
|
135
|
|
|
|
|
|
|
prevent further connection attempts callback should throw an exception, which |
|
136
|
|
|
|
|
|
|
is done by default callback. This may be useful to switch to backup server if |
|
137
|
|
|
|
|
|
|
primary went down. RedisDB distribution includes an example of using this |
|
138
|
|
|
|
|
|
|
callback in eg/server_failover.pl. |
|
139
|
|
|
|
|
|
|
|
|
140
|
|
|
|
|
|
|
=back |
|
141
|
|
|
|
|
|
|
|
|
142
|
|
|
|
|
|
|
=cut |
|
143
|
|
|
|
|
|
|
|
|
144
|
|
|
|
|
|
|
sub new { |
|
145
|
36
|
|
|
36
|
1
|
4044902
|
my $class = shift; |
|
146
|
36
|
50
|
|
|
|
1621
|
my $self = ref $_[0] ? $_[0] : {@_}; |
|
147
|
36
|
|
|
|
|
256
|
bless $self, $class; |
|
148
|
36
|
100
|
100
|
|
|
623
|
if ( $self->{path} and ( $self->{host} or $self->{port} ) ) { |
|
|
|
|
100
|
|
|
|
|
|
149
|
2
|
|
|
|
|
157
|
croak "You can't specify \"path\" together with \"host\" and \"port\""; |
|
150
|
|
|
|
|
|
|
} |
|
151
|
34
|
100
|
|
|
|
397
|
if ( $self->{url} ) { |
|
152
|
8
|
100
|
100
|
|
|
49
|
if ( $self->{host} or $self->{port} or $self->{path} ) { |
|
|
|
|
100
|
|
|
|
|
|
153
|
3
|
|
|
|
|
39
|
croak "You can't specify \"url\" together with \"host\", \"port\" and \"path\""; |
|
154
|
|
|
|
|
|
|
} |
|
155
|
|
|
|
|
|
|
|
|
156
|
5
|
|
|
|
|
16
|
$self->_parse_url( $self->{url} ); |
|
157
|
|
|
|
|
|
|
} |
|
158
|
31
|
|
100
|
|
|
588
|
$self->{port} ||= 6379; |
|
159
|
31
|
|
100
|
|
|
214
|
$self->{host} ||= 'localhost'; |
|
160
|
31
|
100
|
|
|
|
257
|
$self->{raise_error} = 1 unless exists $self->{raise_error}; |
|
161
|
31
|
|
|
|
|
296
|
$self->{_replies} = []; |
|
162
|
31
|
|
|
|
|
251
|
$self->{_to_be_fetched} = 0; |
|
163
|
31
|
|
100
|
|
|
625
|
$self->{database} ||= 0; |
|
164
|
31
|
|
100
|
|
|
335
|
$self->{reconnect_attempts} ||= 1; |
|
165
|
31
|
|
100
|
|
|
208
|
$self->{reconnect_delay_max} ||= 10; |
|
166
|
31
|
|
100
|
|
|
428
|
$self->{on_connect_error} ||= \&_on_connect_error; |
|
167
|
31
|
|
|
|
|
312
|
$self->_init_parser; |
|
168
|
31
|
100
|
|
|
|
2591
|
$self->_connect unless $self->{lazy}; |
|
169
|
25
|
|
|
|
|
130
|
return $self; |
|
170
|
|
|
|
|
|
|
} |
|
171
|
|
|
|
|
|
|
|
|
172
|
|
|
|
|
|
|
sub _parse_url { |
|
173
|
5
|
|
|
5
|
|
13
|
my ($self, $url) = @_; |
|
174
|
|
|
|
|
|
|
|
|
175
|
5
|
|
|
|
|
25
|
my $uri = URI->new($url); |
|
176
|
|
|
|
|
|
|
|
|
177
|
5
|
50
|
|
|
|
1680
|
if ( $uri->scheme !~ /^redis/ ) { |
|
178
|
0
|
|
|
|
|
0
|
die "Unknown URL scheme '" . $uri->scheme . "' in URL '$url'"; |
|
179
|
|
|
|
|
|
|
} |
|
180
|
|
|
|
|
|
|
|
|
181
|
5
|
|
|
|
|
348
|
$self->{host} = $uri->host; |
|
182
|
5
|
|
|
|
|
175
|
$self->{port} = $uri->port; |
|
183
|
5
|
|
|
|
|
96
|
$self->{path} = $uri->socket_path; |
|
184
|
5
|
|
|
|
|
47
|
$self->{password} = $uri->password; |
|
185
|
5
|
|
|
|
|
338
|
$self->{database} = $uri->database; |
|
186
|
|
|
|
|
|
|
} |
|
187
|
|
|
|
|
|
|
|
|
188
|
|
|
|
|
|
|
sub _is_redisdb_error { |
|
189
|
37
|
|
|
37
|
|
688
|
ref(shift) =~ /^RedisDB::Error/; |
|
190
|
|
|
|
|
|
|
} |
|
191
|
|
|
|
|
|
|
|
|
192
|
|
|
|
|
|
|
sub _init_parser { |
|
193
|
83
|
|
|
83
|
|
187
|
my $self = shift; |
|
194
|
|
|
|
|
|
|
$self->{_parser} = RedisDB::Parser->new( |
|
195
|
|
|
|
|
|
|
utf8 => $self->{utf8}, |
|
196
|
83
|
|
|
|
|
1517
|
master => $self, |
|
197
|
|
|
|
|
|
|
error_class => 'RedisDB::Error', |
|
198
|
|
|
|
|
|
|
); |
|
199
|
|
|
|
|
|
|
} |
|
200
|
|
|
|
|
|
|
|
|
201
|
|
|
|
|
|
|
=head2 $self->execute($command, @arguments) |
|
202
|
|
|
|
|
|
|
|
|
203
|
|
|
|
|
|
|
send a command to the server, wait for the result and return it. It will throw |
|
204
|
|
|
|
|
|
|
an exception if the server returns an error or return L object |
|
205
|
|
|
|
|
|
|
depending on L parameter. It may be more convenient to use |
|
206
|
|
|
|
|
|
|
instead of this method wrapper named after the corresponding redis command. |
|
207
|
|
|
|
|
|
|
E.g.: |
|
208
|
|
|
|
|
|
|
|
|
209
|
|
|
|
|
|
|
$redis->execute('set', key => 'value'); |
|
210
|
|
|
|
|
|
|
# is the same as |
|
211
|
|
|
|
|
|
|
$redis->set(key => 'value'); |
|
212
|
|
|
|
|
|
|
|
|
213
|
|
|
|
|
|
|
See L"WRAPPER METHODS"> section for the full list of defined aliases. |
|
214
|
|
|
|
|
|
|
|
|
215
|
|
|
|
|
|
|
Note, that you can not use I if you have sent some commands using |
|
216
|
|
|
|
|
|
|
I method without the I argument and have not yet got |
|
217
|
|
|
|
|
|
|
all replies. |
|
218
|
|
|
|
|
|
|
|
|
219
|
|
|
|
|
|
|
=cut |
|
220
|
|
|
|
|
|
|
|
|
221
|
|
|
|
|
|
|
sub execute { |
|
222
|
45
|
|
|
45
|
1
|
121
|
my $self = shift; |
|
223
|
45
|
50
|
|
|
|
412
|
croak "You can't use RedisDB::execute when you have replies to fetch." |
|
224
|
|
|
|
|
|
|
if $self->replies_to_fetch; |
|
225
|
45
|
50
|
|
|
|
133
|
croak "This function is not available in subscription mode." if $self->{_subscription_loop}; |
|
226
|
45
|
|
|
|
|
148
|
my $cmd = uc shift; |
|
227
|
45
|
|
|
|
|
376
|
$self->send_command( $cmd, @_ ); |
|
228
|
42
|
|
|
|
|
215
|
return $self->get_reply; |
|
229
|
|
|
|
|
|
|
} |
|
230
|
|
|
|
|
|
|
|
|
231
|
|
|
|
|
|
|
sub _on_connect_error { |
|
232
|
14
|
|
|
14
|
|
65
|
my ( $self, $err ) = @_; |
|
233
|
14
|
|
66
|
|
|
131
|
my $server = $self->{path} || ("$self->{host}:$self->{port}"); |
|
234
|
14
|
|
|
|
|
244
|
my $error_obj = |
|
235
|
|
|
|
|
|
|
RedisDB::Error::DISCONNECTED->new("Couldn't connect to the redis server at $server: $!"); |
|
236
|
14
|
|
|
|
|
381
|
die $error_obj; |
|
237
|
|
|
|
|
|
|
} |
|
238
|
|
|
|
|
|
|
|
|
239
|
|
|
|
|
|
|
sub _on_disconnect { |
|
240
|
28
|
|
|
28
|
|
106
|
my ( $self, $err, $error_obj ) = @_; |
|
241
|
|
|
|
|
|
|
|
|
242
|
28
|
100
|
|
|
|
93
|
if ($err) { |
|
243
|
11
|
|
66
|
|
|
693
|
$error_obj ||= RedisDB::Error::DISCONNECTED->new( |
|
244
|
|
|
|
|
|
|
"Server unexpectedly closed connection. Some data might have been lost."); |
|
245
|
11
|
100
|
66
|
|
|
1063
|
if ( $self->{raise_error} or $self->{_in_multi} or $self->{_watching} ) { |
|
|
|
50
|
33
|
|
|
|
|
|
246
|
7
|
|
|
|
|
64
|
$self->reset_connection; |
|
247
|
7
|
|
|
|
|
99
|
die $error_obj; |
|
248
|
|
|
|
|
|
|
} |
|
249
|
|
|
|
|
|
|
elsif ( my $loop_type = $self->{_subscription_loop} ) { |
|
250
|
0
|
|
|
|
|
0
|
my $subscribed = delete $self->{_subscribed}; |
|
251
|
0
|
|
|
|
|
0
|
my $psubscribed = delete $self->{_psubscribed}; |
|
252
|
0
|
|
|
|
|
0
|
my $callback = delete $self->{_subscription_cb}; |
|
253
|
0
|
|
|
|
|
0
|
$self->reset_connection; |
|
254
|
|
|
|
|
|
|
|
|
255
|
|
|
|
|
|
|
# there's no simple way to return error from here |
|
256
|
|
|
|
|
|
|
# TODO: handle it |
|
257
|
0
|
|
|
|
|
0
|
$self->{raise_error}++; |
|
258
|
0
|
|
|
|
|
0
|
$self->_connect; |
|
259
|
0
|
|
|
|
|
0
|
$self->{_subscription_loop} = $loop_type; |
|
260
|
0
|
|
|
|
|
0
|
$self->{_subscription_cb} = $callback; |
|
261
|
0
|
|
|
|
|
0
|
$self->{_parser}->set_default_callback($callback); |
|
262
|
0
|
|
|
|
|
0
|
$self->{_subscribed} = $subscribed; |
|
263
|
0
|
|
|
|
|
0
|
$self->{_psubscribed} = $psubscribed; |
|
264
|
|
|
|
|
|
|
|
|
265
|
0
|
|
|
|
|
0
|
for ( keys %$subscribed ) { |
|
266
|
0
|
|
|
|
|
0
|
$self->send_command( 'subscribe', $_ ); |
|
267
|
|
|
|
|
|
|
} |
|
268
|
0
|
|
|
|
|
0
|
for ( keys %$psubscribed ) { |
|
269
|
0
|
|
|
|
|
0
|
$self->send_command( 'psubscribe', $_ ); |
|
270
|
|
|
|
|
|
|
} |
|
271
|
0
|
|
|
|
|
0
|
$self->{raise_error}--; |
|
272
|
|
|
|
|
|
|
} |
|
273
|
|
|
|
|
|
|
else { |
|
274
|
|
|
|
|
|
|
|
|
275
|
|
|
|
|
|
|
# parser may be in inconsistent state, so we just replace it with a new one |
|
276
|
4
|
|
|
|
|
64
|
my $parser = delete $self->{_parser}; |
|
277
|
4
|
|
|
|
|
248
|
delete $self->{_socket}; |
|
278
|
4
|
|
|
|
|
116
|
$parser->propagate_reply($error_obj); |
|
279
|
|
|
|
|
|
|
} |
|
280
|
|
|
|
|
|
|
} |
|
281
|
|
|
|
|
|
|
else { |
|
282
|
17
|
50
|
0
|
|
|
85
|
$self->{warnings} and warn( $error_obj || "Server closed connection, reconnecting..." ); |
|
283
|
|
|
|
|
|
|
} |
|
284
|
|
|
|
|
|
|
} |
|
285
|
|
|
|
|
|
|
|
|
286
|
|
|
|
|
|
|
# establish connection to the server. |
|
287
|
|
|
|
|
|
|
# returns undef on success. On failure returns RedisDB::Error or throws an exception. |
|
288
|
|
|
|
|
|
|
sub _connect { |
|
289
|
56
|
|
|
56
|
|
203
|
my $self = shift; |
|
290
|
|
|
|
|
|
|
|
|
291
|
|
|
|
|
|
|
# this is to prevent recursion |
|
292
|
|
|
|
|
|
|
confess "Couldn't connect to the redis-server." |
|
293
|
|
|
|
|
|
|
. " Connection was immediately closed by the server." |
|
294
|
56
|
100
|
|
|
|
397
|
if $self->{_in_connect}; |
|
295
|
|
|
|
|
|
|
|
|
296
|
53
|
|
|
|
|
636
|
$self->{_pid} = $$; |
|
297
|
|
|
|
|
|
|
|
|
298
|
53
|
|
|
|
|
135
|
delete $self->{_socket}; |
|
299
|
53
|
|
|
|
|
89
|
my $error; |
|
300
|
53
|
|
|
|
|
156
|
while ( not $self->{_socket} ) { |
|
301
|
58
|
100
|
|
|
|
228
|
if ( $self->{path} ) { |
|
302
|
|
|
|
|
|
|
$self->{_socket} = IO::Socket::UNIX->new( |
|
303
|
|
|
|
|
|
|
Type => SOCK_STREAM, |
|
304
|
|
|
|
|
|
|
Peer => $self->{path}, |
|
305
|
2
|
100
|
|
|
|
57
|
) or $error = $!; |
|
306
|
|
|
|
|
|
|
} |
|
307
|
|
|
|
|
|
|
else { |
|
308
|
56
|
|
|
|
|
126
|
my $attempts = $self->{reconnect_attempts}; |
|
309
|
56
|
|
|
|
|
93
|
my $delay; |
|
310
|
56
|
|
100
|
|
|
396
|
while ( not $self->{_socket} and $attempts ) { |
|
311
|
86
|
100
|
|
|
|
30005720
|
sleep $delay if $delay; |
|
312
|
|
|
|
|
|
|
$self->{_socket} = IO::Socket::IP->new( |
|
313
|
|
|
|
|
|
|
PeerAddr => $self->{host}, |
|
314
|
|
|
|
|
|
|
PeerPort => $self->{port}, |
|
315
|
|
|
|
|
|
|
Proto => 'tcp', |
|
316
|
86
|
100
|
|
|
|
2906
|
( $self->{timeout} ? ( Timeout => $self->{timeout} ) : () ), |
|
|
|
100
|
|
|
|
|
|
|
317
|
|
|
|
|
|
|
) or $error = $!; |
|
318
|
86
|
100
|
|
|
|
86848
|
$delay = $delay ? ( 1 + rand ) * $delay : 1; |
|
319
|
86
|
100
|
|
|
|
377
|
$delay = $self->{reconnect_delay_max} if $delay > $self->{reconnect_delay_max}; |
|
320
|
86
|
|
|
|
|
525
|
$attempts--; |
|
321
|
|
|
|
|
|
|
} |
|
322
|
|
|
|
|
|
|
} |
|
323
|
|
|
|
|
|
|
} |
|
324
|
|
|
|
|
|
|
continue { |
|
325
|
58
|
100
|
|
|
|
1102
|
unless ( $self->{_socket} ) { |
|
326
|
19
|
|
|
|
|
53
|
my $new_error; |
|
327
|
|
|
|
|
|
|
try { |
|
328
|
19
|
|
|
19
|
|
3096
|
$self->{on_connect_error}->( $self, $error ); |
|
329
|
|
|
|
|
|
|
} |
|
330
|
|
|
|
|
|
|
catch { |
|
331
|
14
|
100
|
|
14
|
|
307
|
if ( $self->{raise_error} ) { |
|
332
|
6
|
|
|
|
|
58
|
$self->reset_connection; |
|
333
|
6
|
|
|
|
|
85
|
die $_; |
|
334
|
|
|
|
|
|
|
} |
|
335
|
|
|
|
|
|
|
else { |
|
336
|
8
|
50
|
|
|
|
176
|
$self->{_parser}->propagate_reply($_) if $self->{_parser}; |
|
337
|
8
|
|
|
|
|
48
|
$new_error = $_; |
|
338
|
|
|
|
|
|
|
} |
|
339
|
19
|
|
|
|
|
754
|
}; |
|
340
|
13
|
100
|
|
|
|
356
|
return $new_error if $new_error; |
|
341
|
|
|
|
|
|
|
} |
|
342
|
|
|
|
|
|
|
} |
|
343
|
|
|
|
|
|
|
|
|
344
|
39
|
100
|
|
|
|
179
|
if ( $self->{timeout} ) { |
|
345
|
2
|
|
|
|
|
54
|
my $tv_sec = int $self->{timeout}; |
|
346
|
2
|
|
|
|
|
40
|
my $tv_usec = ($self->{timeout} * 1e6) % 1e6; |
|
347
|
2
|
|
|
|
|
20
|
my $timeout; |
|
348
|
|
|
|
|
|
|
|
|
349
|
|
|
|
|
|
|
# NetBSD 6 and OpenBSD 5.5 use 64-bit time_t on all architectures |
|
350
|
|
|
|
|
|
|
my $timet64; |
|
351
|
2
|
50
|
|
|
|
244
|
if ( $Config{osname} eq 'netbsd' ) { |
|
|
|
50
|
|
|
|
|
|
|
352
|
0
|
|
|
|
|
0
|
$Config{osvers} =~ /^([0-9]+)/; |
|
353
|
0
|
0
|
0
|
|
|
0
|
if ( $1 and $1 >= 6 ) { |
|
354
|
0
|
|
|
|
|
0
|
$timet64 = 1; |
|
355
|
|
|
|
|
|
|
} |
|
356
|
|
|
|
|
|
|
} |
|
357
|
|
|
|
|
|
|
elsif ( $Config{osname} eq 'openbsd' ) { |
|
358
|
0
|
|
|
|
|
0
|
$Config{osvers} =~ /^([0-9]+)\.([0-9]+)/; |
|
359
|
0
|
0
|
0
|
|
|
0
|
if ( $1 and ( $1 > 5 or ( $1 == 5 and $2 >= 5 ) ) ) { |
|
|
|
|
0
|
|
|
|
|
|
360
|
0
|
|
|
|
|
0
|
$timet64 = 1; |
|
361
|
|
|
|
|
|
|
} |
|
362
|
|
|
|
|
|
|
} |
|
363
|
2
|
50
|
33
|
|
|
48
|
if ( $timet64 and $Config{longsize} == 4 ) { |
|
364
|
0
|
0
|
|
|
|
0
|
if ( defined $Config{use64bitint} ) { |
|
365
|
0
|
|
|
|
|
0
|
$timeout = pack( 'QL', $tv_sec, $tv_usec ); |
|
366
|
|
|
|
|
|
|
} |
|
367
|
|
|
|
|
|
|
else { |
|
368
|
|
|
|
|
|
|
$timeout = pack( |
|
369
|
|
|
|
|
|
|
'LLL', |
|
370
|
|
|
|
|
|
|
( |
|
371
|
0
|
0
|
|
|
|
0
|
$Config{byteorder} eq '1234' |
|
372
|
|
|
|
|
|
|
? ( $tv_sec, 0, $tv_usec ) |
|
373
|
|
|
|
|
|
|
: ( 0, $tv_sec, $tv_usec ) |
|
374
|
|
|
|
|
|
|
) |
|
375
|
|
|
|
|
|
|
); |
|
376
|
|
|
|
|
|
|
} |
|
377
|
|
|
|
|
|
|
} |
|
378
|
|
|
|
|
|
|
else { |
|
379
|
2
|
|
|
|
|
42
|
$timeout = pack( 'L!L!', $tv_sec, $tv_usec); |
|
380
|
|
|
|
|
|
|
} |
|
381
|
|
|
|
|
|
|
try { |
|
382
|
2
|
50
|
|
2
|
|
500
|
defined $self->{_socket}->sockopt( SO_RCVTIMEO, $timeout ) |
|
383
|
|
|
|
|
|
|
or die "Can't set timeout: $!"; |
|
384
|
2
|
50
|
|
|
|
84
|
defined $self->{_socket}->sockopt( SO_SNDTIMEO, $timeout ) |
|
385
|
|
|
|
|
|
|
or die "Can't set send timeout: $!"; |
|
386
|
|
|
|
|
|
|
} |
|
387
|
|
|
|
|
|
|
catch { |
|
388
|
0
|
|
|
0
|
|
0
|
warn "$_\n"; |
|
389
|
2
|
|
|
|
|
146
|
}; |
|
390
|
|
|
|
|
|
|
} |
|
391
|
|
|
|
|
|
|
|
|
392
|
39
|
|
|
|
|
341
|
$self->{_in_connect}++; |
|
393
|
39
|
|
|
|
|
216
|
$self->_init_parser; |
|
394
|
39
|
|
|
|
|
1339
|
$self->{_subscription_loop} = 0; |
|
395
|
39
|
|
|
|
|
89
|
delete $self->{_server_version}; |
|
396
|
|
|
|
|
|
|
|
|
397
|
|
|
|
|
|
|
# authenticate |
|
398
|
39
|
50
|
|
|
|
126
|
if ( $self->{password} ) { |
|
399
|
|
|
|
|
|
|
$self->send_command( |
|
400
|
|
|
|
|
|
|
"AUTH", |
|
401
|
|
|
|
|
|
|
$self->{password}, |
|
402
|
|
|
|
|
|
|
sub { |
|
403
|
0
|
|
|
0
|
|
0
|
my ( $self, $res ) = @_; |
|
404
|
0
|
0
|
|
|
|
0
|
croak "$res" if _is_redisdb_error($res); |
|
405
|
|
|
|
|
|
|
} |
|
406
|
0
|
|
|
|
|
0
|
); |
|
407
|
|
|
|
|
|
|
} |
|
408
|
|
|
|
|
|
|
|
|
409
|
|
|
|
|
|
|
# connection name |
|
410
|
39
|
50
|
|
|
|
156
|
if ( $self->{connection_name} ) { |
|
411
|
0
|
|
|
|
|
0
|
$self->send_command( qw(CLIENT SETNAME), $self->{connection_name}, IGNORE_REPLY() ); |
|
412
|
|
|
|
|
|
|
} |
|
413
|
|
|
|
|
|
|
|
|
414
|
|
|
|
|
|
|
# select database |
|
415
|
39
|
100
|
|
|
|
126
|
if ( $self->{database} ) { |
|
416
|
3
|
|
|
|
|
132
|
$self->send_command( "SELECT", $self->{database}, IGNORE_REPLY() ); |
|
417
|
|
|
|
|
|
|
} |
|
418
|
|
|
|
|
|
|
|
|
419
|
36
|
|
|
|
|
81
|
delete $self->{_in_connect}; |
|
420
|
36
|
|
|
|
|
76
|
return; |
|
421
|
|
|
|
|
|
|
} |
|
422
|
|
|
|
|
|
|
|
|
423
|
|
|
|
|
|
|
my $SET_NB = 0; |
|
424
|
|
|
|
|
|
|
my $DONTWAIT = 0; |
|
425
|
|
|
|
|
|
|
|
|
426
|
|
|
|
|
|
|
# Windows don't have MSG_DONTWAIT, so we need to switch socket into non-blocking mode |
|
427
|
|
|
|
|
|
|
if ( $^O eq 'MSWin32' ) { |
|
428
|
|
|
|
|
|
|
$SET_NB = 1; |
|
429
|
|
|
|
|
|
|
} |
|
430
|
|
|
|
|
|
|
else { |
|
431
|
|
|
|
|
|
|
$DONTWAIT = MSG_DONTWAIT; |
|
432
|
|
|
|
|
|
|
} |
|
433
|
|
|
|
|
|
|
|
|
434
|
|
|
|
|
|
|
# parse data from the receive buffer without blocking |
|
435
|
|
|
|
|
|
|
# Returns undef in case of success or RedisDB::Error if failed |
|
436
|
|
|
|
|
|
|
sub _recv_data_nb { |
|
437
|
47
|
|
|
47
|
|
133
|
my $self = shift; |
|
438
|
|
|
|
|
|
|
|
|
439
|
47
|
50
|
|
|
|
214
|
$self->{_socket}->blocking(0) if $SET_NB; |
|
440
|
|
|
|
|
|
|
|
|
441
|
47
|
|
|
|
|
85
|
while (1) { |
|
442
|
47
|
|
|
|
|
837
|
my $ret = recv( $self->{_socket}, my $buf, 131072, $DONTWAIT ); |
|
443
|
47
|
50
|
|
|
|
310
|
unless ( defined $ret ) { |
|
|
|
100
|
|
|
|
|
|
|
444
|
|
|
|
|
|
|
|
|
445
|
|
|
|
|
|
|
# socket is connected, no data in recv buffer |
|
446
|
30
|
50
|
33
|
|
|
438
|
last if $! == EAGAIN or $! == EWOULDBLOCK; |
|
447
|
0
|
0
|
|
|
|
0
|
next if $! == EINTR; |
|
448
|
|
|
|
|
|
|
|
|
449
|
|
|
|
|
|
|
# on any other error close the connection |
|
450
|
0
|
|
|
|
|
0
|
my $error = |
|
451
|
|
|
|
|
|
|
RedisDB::Error::DISCONNECTED->new("Error reading from server: $!"); |
|
452
|
0
|
|
|
|
|
0
|
$self->_on_disconnect( 1, $error ); |
|
453
|
0
|
|
|
|
|
0
|
return $error; |
|
454
|
|
|
|
|
|
|
} |
|
455
|
0
|
|
|
|
|
0
|
elsif ( $buf ne '' ) { |
|
456
|
|
|
|
|
|
|
|
|
457
|
|
|
|
|
|
|
# received some data |
|
458
|
0
|
|
|
|
|
0
|
$self->{_parser}->parse($buf); |
|
459
|
|
|
|
|
|
|
} |
|
460
|
|
|
|
|
|
|
else { |
|
461
|
17
|
|
|
|
|
2146
|
delete $self->{_socket}; |
|
462
|
|
|
|
|
|
|
|
|
463
|
17
|
50
|
33
|
|
|
495
|
if ( $self->{_parser}->callbacks or $self->{_in_multi} or $self->{_watching} ) { |
|
|
|
|
33
|
|
|
|
|
|
464
|
|
|
|
|
|
|
|
|
465
|
|
|
|
|
|
|
# there are some replies lost |
|
466
|
0
|
|
|
|
|
0
|
$self->_on_disconnect(1); |
|
467
|
|
|
|
|
|
|
} |
|
468
|
|
|
|
|
|
|
else { |
|
469
|
|
|
|
|
|
|
# clean disconnect, try to reconnect |
|
470
|
17
|
|
|
|
|
98
|
$self->_on_disconnect(0); |
|
471
|
|
|
|
|
|
|
} |
|
472
|
|
|
|
|
|
|
|
|
473
|
17
|
50
|
|
|
|
75
|
unless ( $self->{_socket} ) { |
|
474
|
17
|
|
|
|
|
104
|
my $error = $self->_connect; |
|
475
|
14
|
100
|
|
|
|
91
|
return $error if $error; |
|
476
|
|
|
|
|
|
|
} |
|
477
|
10
|
|
|
|
|
30
|
last; |
|
478
|
|
|
|
|
|
|
} |
|
479
|
|
|
|
|
|
|
} |
|
480
|
|
|
|
|
|
|
|
|
481
|
40
|
50
|
|
|
|
118
|
$self->{_socket}->blocking(1) if $SET_NB; |
|
482
|
|
|
|
|
|
|
|
|
483
|
40
|
|
|
|
|
100
|
return; |
|
484
|
|
|
|
|
|
|
} |
|
485
|
|
|
|
|
|
|
|
|
486
|
|
|
|
|
|
|
sub _queue { |
|
487
|
37
|
|
|
37
|
|
181
|
my ( $self, $reply ) = @_; |
|
488
|
37
|
|
|
|
|
91
|
--$self->{_to_be_fetched}; |
|
489
|
37
|
|
|
|
|
87
|
push @{ $self->{_replies} }, $reply; |
|
|
37
|
|
|
|
|
235
|
|
|
490
|
|
|
|
|
|
|
} |
|
491
|
|
|
|
|
|
|
|
|
492
|
|
|
|
|
|
|
=head2 $self->send_command($command[, @arguments][, \&callback]) |
|
493
|
|
|
|
|
|
|
|
|
494
|
|
|
|
|
|
|
send a command to the server. If send has failed command will die or return |
|
495
|
|
|
|
|
|
|
L object depending on L parameter. Note, that it |
|
496
|
|
|
|
|
|
|
does not return reply from the server, if I was not specified, you |
|
497
|
|
|
|
|
|
|
should retrieve result using I method, otherwise I will |
|
498
|
|
|
|
|
|
|
be invoked upon receiving the result with two arguments: the RedisDB object, |
|
499
|
|
|
|
|
|
|
and the reply from the server. If the server returned an error, the second |
|
500
|
|
|
|
|
|
|
argument to the callback will be a L object, you can get |
|
501
|
|
|
|
|
|
|
description of the error using this object in string context. If you are not |
|
502
|
|
|
|
|
|
|
interested in reply, you can use RedisDB::IGNORE_REPLY constant as the last |
|
503
|
|
|
|
|
|
|
argument. |
|
504
|
|
|
|
|
|
|
|
|
505
|
|
|
|
|
|
|
Note, that RedisDB does not run any background threads, so it will not receive |
|
506
|
|
|
|
|
|
|
the reply and invoke the callback unless you call some of its methods which |
|
507
|
|
|
|
|
|
|
check if there are replies from the server, like I, |
|
508
|
|
|
|
|
|
|
I, I, or I. |
|
509
|
|
|
|
|
|
|
|
|
510
|
|
|
|
|
|
|
=cut |
|
511
|
|
|
|
|
|
|
|
|
512
|
|
|
|
|
|
|
my $NOSIGNAL = try { MSG_NOSIGNAL } || 0; |
|
513
|
|
|
|
|
|
|
|
|
514
|
|
|
|
|
|
|
sub send_command { |
|
515
|
54
|
|
|
54
|
1
|
432
|
my $self = shift; |
|
516
|
|
|
|
|
|
|
|
|
517
|
54
|
|
|
|
|
103
|
my $callback; |
|
518
|
54
|
100
|
|
|
|
212
|
if ( ref $_[-1] eq 'CODE' ) { |
|
519
|
7
|
|
|
|
|
231
|
$callback = pop; |
|
520
|
|
|
|
|
|
|
} |
|
521
|
|
|
|
|
|
|
else { |
|
522
|
47
|
|
|
|
|
94
|
++$self->{_to_be_fetched}; |
|
523
|
47
|
|
|
|
|
192
|
$callback = \&_queue; |
|
524
|
|
|
|
|
|
|
} |
|
525
|
|
|
|
|
|
|
|
|
526
|
54
|
|
|
|
|
163
|
my $command = uc shift; |
|
527
|
54
|
50
|
|
|
|
202
|
if ( $self->{_subscription_loop} ) { |
|
528
|
0
|
0
|
|
|
|
0
|
croak "only (UN)(P)SUBSCRIBE and QUIT allowed in subscription loop" |
|
529
|
|
|
|
|
|
|
unless $command =~ /^(P?(UN)?SUBSCRIBE|QUIT)$/; |
|
530
|
|
|
|
|
|
|
} |
|
531
|
|
|
|
|
|
|
|
|
532
|
|
|
|
|
|
|
# remember password |
|
533
|
54
|
50
|
33
|
|
|
361
|
if ( $command eq 'AUTH' ) { |
|
|
|
100
|
|
|
|
|
|
|
|
|
50
|
|
|
|
|
|
|
534
|
0
|
|
|
|
|
0
|
$self->{password} = $_[0]; |
|
535
|
|
|
|
|
|
|
} |
|
536
|
|
|
|
|
|
|
|
|
537
|
|
|
|
|
|
|
# if SELECT has been successful, we should update database |
|
538
|
|
|
|
|
|
|
elsif ( $command eq 'SELECT' ) { |
|
539
|
3
|
|
|
|
|
27
|
my $cb = $callback; |
|
540
|
3
|
|
|
|
|
33
|
my $dbnum = $_[0]; |
|
541
|
|
|
|
|
|
|
$callback = sub { |
|
542
|
0
|
0
|
|
0
|
|
0
|
$_[0]->{database} = $dbnum unless ref $_[1]; |
|
543
|
0
|
|
|
|
|
0
|
$cb->(@_); |
|
544
|
3
|
|
|
|
|
132
|
}; |
|
545
|
|
|
|
|
|
|
} |
|
546
|
|
|
|
|
|
|
|
|
547
|
|
|
|
|
|
|
# if CLIENT SETNAME we should remember the name |
|
548
|
|
|
|
|
|
|
elsif ( $command eq 'CLIENT' && uc $_[0] eq 'SETNAME' ) { |
|
549
|
0
|
|
|
|
|
0
|
$self->{connection_name} = $_[1]; |
|
550
|
|
|
|
|
|
|
} |
|
551
|
|
|
|
|
|
|
|
|
552
|
|
|
|
|
|
|
# if not yet connected to server, or if process was forked |
|
553
|
|
|
|
|
|
|
# reestablish connection |
|
554
|
54
|
100
|
66
|
|
|
553
|
unless ( $self->{_socket} and $self->{_pid} == $$ ) { |
|
555
|
21
|
|
|
|
|
223
|
my $error = $self->_connect; |
|
556
|
18
|
100
|
|
|
|
117
|
if ($error) { |
|
557
|
4
|
|
|
|
|
156
|
$callback->( $self, $error ); |
|
558
|
4
|
|
|
|
|
16
|
return $error; |
|
559
|
|
|
|
|
|
|
} |
|
560
|
|
|
|
|
|
|
} |
|
561
|
|
|
|
|
|
|
|
|
562
|
|
|
|
|
|
|
# Here we are reading received data and parsing it, |
|
563
|
|
|
|
|
|
|
# and at the same time checking if the connection is still alive |
|
564
|
47
|
|
|
|
|
232
|
my $error = $self->_recv_data_nb; |
|
565
|
44
|
100
|
|
|
|
143
|
if ($error) { |
|
566
|
4
|
|
|
|
|
84
|
$callback->( $self, $error ); |
|
567
|
4
|
|
|
|
|
16
|
return $error; |
|
568
|
|
|
|
|
|
|
} |
|
569
|
|
|
|
|
|
|
|
|
570
|
40
|
|
|
|
|
219
|
$self->{_parser}->push_callback($callback); |
|
571
|
|
|
|
|
|
|
|
|
572
|
40
|
|
|
|
|
421
|
my $request = $self->{_parser}->build_request( $command, @_ ); |
|
573
|
|
|
|
|
|
|
{ |
|
574
|
40
|
50
|
|
|
|
103
|
local $SIG{PIPE} = 'IGNORE' unless $NOSIGNAL; |
|
|
40
|
|
|
|
|
116
|
|
|
575
|
40
|
50
|
|
|
|
2608
|
defined send( $self->{_socket}, $request, $NOSIGNAL ) |
|
576
|
|
|
|
|
|
|
or $self->_on_disconnect( 1, |
|
577
|
|
|
|
|
|
|
RedisDB::Error::DISCONNECTED->new("Can't send request to server: $!") ); |
|
578
|
|
|
|
|
|
|
} |
|
579
|
|
|
|
|
|
|
|
|
580
|
40
|
|
|
|
|
339
|
return 1; |
|
581
|
|
|
|
|
|
|
} |
|
582
|
|
|
|
|
|
|
|
|
583
|
|
|
|
|
|
|
sub _ignore { |
|
584
|
0
|
|
|
0
|
|
0
|
my ( $self, $res ) = @_; |
|
585
|
0
|
0
|
|
|
|
0
|
if ( _is_redisdb_error($res) ) { |
|
586
|
0
|
|
|
|
|
0
|
warn "Ignoring error returned by redis-server: $res"; |
|
587
|
|
|
|
|
|
|
} |
|
588
|
|
|
|
|
|
|
} |
|
589
|
|
|
|
|
|
|
|
|
590
|
3
|
|
|
3
|
0
|
78
|
sub IGNORE_REPLY { return \&_ignore; } |
|
591
|
|
|
|
|
|
|
|
|
592
|
|
|
|
|
|
|
=begin comment |
|
593
|
|
|
|
|
|
|
|
|
594
|
|
|
|
|
|
|
=head2 $self->send_command_cb($command[, @arguments][, \&callback]) |
|
595
|
|
|
|
|
|
|
|
|
596
|
|
|
|
|
|
|
send a command to the server, invoke specified I on reply. The |
|
597
|
|
|
|
|
|
|
callback is invoked with two arguments: the RedisDB object, and reply from the |
|
598
|
|
|
|
|
|
|
server. If the server returned an error, the second argument will be a |
|
599
|
|
|
|
|
|
|
L object, you can get description of the error using this |
|
600
|
|
|
|
|
|
|
object in string context. If the I is not specified, the reply will |
|
601
|
|
|
|
|
|
|
be discarded. Note, that RedisDB does not run any background threads, so it |
|
602
|
|
|
|
|
|
|
will not receive the reply and invoke the callback unless you call some of its |
|
603
|
|
|
|
|
|
|
methods which check if there are replies from the server, like I, |
|
604
|
|
|
|
|
|
|
I, I, I, or I. |
|
605
|
|
|
|
|
|
|
|
|
606
|
|
|
|
|
|
|
B this method is deprecated and may be removed in some future |
|
607
|
|
|
|
|
|
|
version. Please use I method instead. If you are using |
|
608
|
|
|
|
|
|
|
I with I<&callback> argument, you can just replace the method |
|
609
|
|
|
|
|
|
|
with I and it will do the same. If you are using |
|
610
|
|
|
|
|
|
|
I with the default callback, you should add the |
|
611
|
|
|
|
|
|
|
RedisDB::IGNORE_REPLY constant as the last argument when replacing the method |
|
612
|
|
|
|
|
|
|
with I. Here is the example that shows equivalents with |
|
613
|
|
|
|
|
|
|
I: |
|
614
|
|
|
|
|
|
|
|
|
615
|
|
|
|
|
|
|
$redis->send_command_cb("SET", "Key", "Value"); |
|
616
|
|
|
|
|
|
|
# may be replaced with |
|
617
|
|
|
|
|
|
|
$redis->send_command("SET", "Key", "Value", RedisDB::IGNORE_REPLY); |
|
618
|
|
|
|
|
|
|
|
|
619
|
|
|
|
|
|
|
$redis->send_command_cb("GET", "Key", \&process_reply); |
|
620
|
|
|
|
|
|
|
# may be replaced with |
|
621
|
|
|
|
|
|
|
$redis->send_command("GET", "Key", \&process_reply); |
|
622
|
|
|
|
|
|
|
|
|
623
|
|
|
|
|
|
|
=end comment |
|
624
|
|
|
|
|
|
|
|
|
625
|
|
|
|
|
|
|
=cut |
|
626
|
|
|
|
|
|
|
|
|
627
|
|
|
|
|
|
|
sub send_command_cb { |
|
628
|
0
|
|
|
0
|
1
|
0
|
my $self = shift; |
|
629
|
0
|
0
|
|
|
|
0
|
my $callback = pop if ref $_[-1] eq 'CODE'; |
|
630
|
0
|
|
0
|
|
|
0
|
$callback ||= \&_ignore; |
|
631
|
0
|
|
|
|
|
0
|
return $self->send_command( @_, $callback ); |
|
632
|
|
|
|
|
|
|
} |
|
633
|
|
|
|
|
|
|
|
|
634
|
|
|
|
|
|
|
=head2 $self->reply_ready |
|
635
|
|
|
|
|
|
|
|
|
636
|
|
|
|
|
|
|
this method may be used in the pipelining mode to check if there are some |
|
637
|
|
|
|
|
|
|
replies already received from the server. Returns true if there are replies |
|
638
|
|
|
|
|
|
|
ready to be fetched with I method. |
|
639
|
|
|
|
|
|
|
|
|
640
|
|
|
|
|
|
|
=cut |
|
641
|
|
|
|
|
|
|
|
|
642
|
|
|
|
|
|
|
sub reply_ready { |
|
643
|
0
|
|
|
0
|
1
|
0
|
my $self = shift; |
|
644
|
|
|
|
|
|
|
|
|
645
|
0
|
|
|
|
|
0
|
my $error = $self->_recv_data_nb; |
|
646
|
0
|
0
|
|
|
|
0
|
if ($error) { |
|
647
|
0
|
|
|
|
|
0
|
$self->_on_disconnect( 1, $error ); |
|
648
|
|
|
|
|
|
|
} |
|
649
|
0
|
0
|
|
|
|
0
|
return @{ $self->{_replies} } ? 1 : 0; |
|
|
0
|
|
|
|
|
0
|
|
|
650
|
|
|
|
|
|
|
} |
|
651
|
|
|
|
|
|
|
|
|
652
|
|
|
|
|
|
|
=head2 $self->mainloop |
|
653
|
|
|
|
|
|
|
|
|
654
|
|
|
|
|
|
|
this method blocks till all replies from the server will be received. Note, |
|
655
|
|
|
|
|
|
|
that callbacks for some replies may send new requests to the server and so this |
|
656
|
|
|
|
|
|
|
method may block for indefinite time. |
|
657
|
|
|
|
|
|
|
|
|
658
|
|
|
|
|
|
|
=cut |
|
659
|
|
|
|
|
|
|
|
|
660
|
|
|
|
|
|
|
sub mainloop { |
|
661
|
0
|
|
|
0
|
1
|
0
|
my $self = shift; |
|
662
|
|
|
|
|
|
|
|
|
663
|
0
|
0
|
|
|
|
0
|
return unless $self->{_parser}; |
|
664
|
|
|
|
|
|
|
|
|
665
|
0
|
|
|
|
|
0
|
while ( $self->{_parser}->callbacks ) { |
|
666
|
0
|
0
|
|
|
|
0
|
croak "You can't call mainloop in the child process" unless $self->{_pid} == $$; |
|
667
|
0
|
|
|
|
|
0
|
my $ret = recv( $self->{_socket}, my $buffer, 131073, 0 ); |
|
668
|
0
|
0
|
|
|
|
0
|
unless ( defined $ret ) { |
|
669
|
0
|
0
|
|
|
|
0
|
next if $! == EINTR; |
|
670
|
0
|
0
|
|
|
|
0
|
if ( $! == EAGAIN ) { |
|
671
|
0
|
|
|
|
|
0
|
confess "Timed out waiting reply from the server"; |
|
672
|
|
|
|
|
|
|
} |
|
673
|
|
|
|
|
|
|
else { |
|
674
|
0
|
|
|
|
|
0
|
$self->_on_disconnect( 1, |
|
675
|
|
|
|
|
|
|
RedisDB::Error::DISCONNECTED->new("Error reading reply from the server: $!") ); |
|
676
|
0
|
|
|
|
|
0
|
next; |
|
677
|
|
|
|
|
|
|
} |
|
678
|
|
|
|
|
|
|
} |
|
679
|
0
|
0
|
|
|
|
0
|
if ( $buffer ne '' ) { |
|
680
|
|
|
|
|
|
|
|
|
681
|
|
|
|
|
|
|
# received some data |
|
682
|
0
|
|
|
|
|
0
|
$self->{_parser}->parse($buffer); |
|
683
|
|
|
|
|
|
|
} |
|
684
|
|
|
|
|
|
|
else { |
|
685
|
|
|
|
|
|
|
|
|
686
|
|
|
|
|
|
|
# disconnected |
|
687
|
0
|
|
|
|
|
0
|
$self->_on_disconnect( |
|
688
|
|
|
|
|
|
|
1, |
|
689
|
|
|
|
|
|
|
RedisDB::Error::DISCONNECTED->new( |
|
690
|
|
|
|
|
|
|
"Server unexpectedly closed connection before sending full reply") |
|
691
|
|
|
|
|
|
|
); |
|
692
|
|
|
|
|
|
|
} |
|
693
|
|
|
|
|
|
|
} |
|
694
|
0
|
|
|
|
|
0
|
return; |
|
695
|
|
|
|
|
|
|
} |
|
696
|
|
|
|
|
|
|
|
|
697
|
|
|
|
|
|
|
=head2 $self->get_reply |
|
698
|
|
|
|
|
|
|
|
|
699
|
|
|
|
|
|
|
receive and return reply from the server. If the server returned an error, |
|
700
|
|
|
|
|
|
|
method throws L exception or returns L object, |
|
701
|
|
|
|
|
|
|
depending on the L parameter. |
|
702
|
|
|
|
|
|
|
|
|
703
|
|
|
|
|
|
|
=cut |
|
704
|
|
|
|
|
|
|
|
|
705
|
|
|
|
|
|
|
sub get_reply { |
|
706
|
44
|
|
|
44
|
1
|
2980
|
my $self = shift; |
|
707
|
|
|
|
|
|
|
|
|
708
|
|
|
|
|
|
|
croak "We are not waiting for reply" |
|
709
|
44
|
|
|
|
|
408
|
unless @{ $self->{_replies} } |
|
710
|
|
|
|
|
|
|
or $self->{_to_be_fetched} |
|
711
|
44
|
0
|
66
|
|
|
67
|
or $self->{_subscription_loop}; |
|
|
|
|
33
|
|
|
|
|
|
712
|
44
|
50
|
|
|
|
218
|
croak "You can't read reply in child process" unless $self->{_pid} == $$; |
|
713
|
44
|
|
|
|
|
198
|
while ( not @{ $self->{_replies} } ) { |
|
|
82
|
|
|
|
|
290
|
|
|
714
|
45
|
|
|
|
|
6000396
|
my $ret = recv( $self->{_socket}, my $buffer, 131074, 0 ); |
|
715
|
45
|
100
|
|
|
|
383
|
if ( not defined $ret ) { |
|
|
|
100
|
|
|
|
|
|
|
716
|
2
|
50
|
33
|
|
|
170
|
next if $! == EINTR or $! == 0; |
|
717
|
2
|
|
|
|
|
6
|
my $err; |
|
718
|
2
|
50
|
33
|
|
|
68
|
if ( $! == EAGAIN or $! == EWOULDBLOCK ) { |
|
719
|
2
|
|
|
|
|
192
|
$err = RedisDB::Error::EAGAIN->new("$!"); |
|
720
|
|
|
|
|
|
|
} |
|
721
|
|
|
|
|
|
|
else { |
|
722
|
0
|
|
|
|
|
0
|
$err = RedisDB::Error::DISCONNECTED->new("Connection error: $!"); |
|
723
|
|
|
|
|
|
|
} |
|
724
|
2
|
|
|
|
|
156
|
$self->_on_disconnect( 1, $err ); |
|
725
|
|
|
|
|
|
|
} |
|
726
|
|
|
|
|
|
|
elsif ( $buffer ne '' ) { |
|
727
|
|
|
|
|
|
|
|
|
728
|
|
|
|
|
|
|
# received some data |
|
729
|
34
|
|
|
|
|
349
|
$self->{_parser}->parse($buffer); |
|
730
|
|
|
|
|
|
|
} |
|
731
|
|
|
|
|
|
|
else { |
|
732
|
|
|
|
|
|
|
|
|
733
|
|
|
|
|
|
|
# disconnected, should die unless raise_error is unset |
|
734
|
9
|
|
|
|
|
46
|
$self->_on_disconnect(1); |
|
735
|
|
|
|
|
|
|
} |
|
736
|
|
|
|
|
|
|
} |
|
737
|
|
|
|
|
|
|
|
|
738
|
37
|
|
|
|
|
80
|
my $res = shift @{ $self->{_replies} }; |
|
|
37
|
|
|
|
|
101
|
|
|
739
|
37
|
50
|
33
|
|
|
132
|
if ( _is_redisdb_error($res) |
|
|
|
|
66
|
|
|
|
|
|
740
|
|
|
|
|
|
|
and ( $self->{raise_error} or $self->{_in_multi} or $self->{_watching} ) ) |
|
741
|
|
|
|
|
|
|
{ |
|
742
|
0
|
|
|
|
|
0
|
croak $res; |
|
743
|
|
|
|
|
|
|
} |
|
744
|
|
|
|
|
|
|
|
|
745
|
37
|
50
|
|
|
|
141
|
if ( $self->{_subscription_loop} ) { |
|
746
|
0
|
0
|
|
|
|
0
|
confess "Expected multi-bulk reply, but got $res" unless ref $res; |
|
747
|
0
|
0
|
|
|
|
0
|
if ( $res->[0] eq 'message' ) { |
|
|
|
0
|
|
|
|
|
|
|
|
|
0
|
|
|
|
|
|
|
748
|
|
|
|
|
|
|
$self->{_subscribed}{ $res->[1] }( $self, $res->[1], undef, $res->[2] ) |
|
749
|
0
|
0
|
|
|
|
0
|
if $self->{_subscribed}{ $res->[1] }; |
|
750
|
|
|
|
|
|
|
} |
|
751
|
|
|
|
|
|
|
elsif ( $res->[0] eq 'pmessage' ) { |
|
752
|
|
|
|
|
|
|
$self->{_psubscribed}{ $res->[1] }( $self, $res->[2], $res->[1], $res->[3] ) |
|
753
|
0
|
0
|
|
|
|
0
|
if $self->{_psubscribed}{ $res->[1] }; |
|
754
|
|
|
|
|
|
|
} |
|
755
|
|
|
|
|
|
|
elsif ( $res->[0] =~ /^p?(un)?subscribe/ ) { |
|
756
|
|
|
|
|
|
|
|
|
757
|
|
|
|
|
|
|
# ignore |
|
758
|
|
|
|
|
|
|
} |
|
759
|
|
|
|
|
|
|
else { |
|
760
|
0
|
|
|
|
|
0
|
confess "Got unknown reply $res->[0] in subscription mode"; |
|
761
|
|
|
|
|
|
|
} |
|
762
|
|
|
|
|
|
|
} |
|
763
|
|
|
|
|
|
|
|
|
764
|
37
|
|
|
|
|
697
|
return $res; |
|
765
|
|
|
|
|
|
|
} |
|
766
|
|
|
|
|
|
|
|
|
767
|
|
|
|
|
|
|
=head2 $self->get_all_replies |
|
768
|
|
|
|
|
|
|
|
|
769
|
|
|
|
|
|
|
wait till replies to all the commands without callback set will be received. |
|
770
|
|
|
|
|
|
|
Returns a list of replies to these commands. For commands with callback set |
|
771
|
|
|
|
|
|
|
replies are processed as usual. Unlike I this method blocks only till |
|
772
|
|
|
|
|
|
|
replies to all commands for which callback was NOT set will be received. |
|
773
|
|
|
|
|
|
|
|
|
774
|
|
|
|
|
|
|
=cut |
|
775
|
|
|
|
|
|
|
|
|
776
|
|
|
|
|
|
|
sub get_all_replies { |
|
777
|
0
|
|
|
0
|
1
|
0
|
my $self = shift; |
|
778
|
0
|
|
|
|
|
0
|
my @res; |
|
779
|
0
|
|
|
|
|
0
|
while ( $self->replies_to_fetch ) { |
|
780
|
0
|
|
|
|
|
0
|
push @res, $self->get_reply; |
|
781
|
|
|
|
|
|
|
} |
|
782
|
0
|
|
|
|
|
0
|
return @res; |
|
783
|
|
|
|
|
|
|
} |
|
784
|
|
|
|
|
|
|
|
|
785
|
|
|
|
|
|
|
=head2 $self->replies_to_fetch |
|
786
|
|
|
|
|
|
|
|
|
787
|
|
|
|
|
|
|
return the number of commands sent to the server replies to which were not yet |
|
788
|
|
|
|
|
|
|
retrieved with I or I. This number only includes |
|
789
|
|
|
|
|
|
|
commands for which callback was not set. |
|
790
|
|
|
|
|
|
|
|
|
791
|
|
|
|
|
|
|
=cut |
|
792
|
|
|
|
|
|
|
|
|
793
|
|
|
|
|
|
|
sub replies_to_fetch { |
|
794
|
45
|
|
|
45
|
1
|
98
|
my $self = shift; |
|
795
|
45
|
|
|
|
|
127
|
return $self->{_to_be_fetched} + @{ $self->{_replies} }; |
|
|
45
|
|
|
|
|
246
|
|
|
796
|
|
|
|
|
|
|
} |
|
797
|
|
|
|
|
|
|
|
|
798
|
|
|
|
|
|
|
=head2 $self->selected_database |
|
799
|
|
|
|
|
|
|
|
|
800
|
|
|
|
|
|
|
get currently selected database. |
|
801
|
|
|
|
|
|
|
|
|
802
|
|
|
|
|
|
|
=cut |
|
803
|
|
|
|
|
|
|
|
|
804
|
|
|
|
|
|
|
sub selected_database { |
|
805
|
0
|
|
|
0
|
1
|
0
|
shift->{database}; |
|
806
|
|
|
|
|
|
|
} |
|
807
|
|
|
|
|
|
|
|
|
808
|
|
|
|
|
|
|
=head2 $self->reset_connection |
|
809
|
|
|
|
|
|
|
|
|
810
|
|
|
|
|
|
|
reset connection. This method closes existing connection and drops all |
|
811
|
|
|
|
|
|
|
previously sent requests. After invoking this method the object returns to the |
|
812
|
|
|
|
|
|
|
same state as it was returned by the constructor. |
|
813
|
|
|
|
|
|
|
|
|
814
|
|
|
|
|
|
|
=cut |
|
815
|
|
|
|
|
|
|
|
|
816
|
|
|
|
|
|
|
sub reset_connection { |
|
817
|
13
|
|
|
13
|
1
|
43
|
my $self = shift; |
|
818
|
13
|
|
|
|
|
1238
|
delete $self->{$_} for grep /^_/, keys %$self; |
|
819
|
13
|
|
|
|
|
82
|
$self->{_replies} = []; |
|
820
|
13
|
|
|
|
|
74
|
$self->_init_parser; |
|
821
|
13
|
|
|
|
|
368
|
$self->{_to_be_fetched} = 0; |
|
822
|
13
|
|
|
|
|
65
|
return; |
|
823
|
|
|
|
|
|
|
} |
|
824
|
|
|
|
|
|
|
|
|
825
|
|
|
|
|
|
|
=head2 $self->version |
|
826
|
|
|
|
|
|
|
|
|
827
|
|
|
|
|
|
|
return the version of the server the client is connected to. The version is |
|
828
|
|
|
|
|
|
|
returned as a floating point number represented the same way as the perl |
|
829
|
|
|
|
|
|
|
versions. E.g. for redis 2.1.12 it will return 2.001012. |
|
830
|
|
|
|
|
|
|
|
|
831
|
|
|
|
|
|
|
=cut |
|
832
|
|
|
|
|
|
|
|
|
833
|
|
|
|
|
|
|
sub version { |
|
834
|
0
|
|
|
0
|
1
|
0
|
my $self = shift; |
|
835
|
0
|
|
|
|
|
0
|
my $info = $self->info; |
|
836
|
0
|
0
|
|
|
|
0
|
$info->{redis_version} =~ /^([0-9]+)[.]([0-9]+)(?:[.]([0-9]+))?/ |
|
837
|
|
|
|
|
|
|
or croak "Can't parse version string: $info->{redis_version}"; |
|
838
|
0
|
0
|
|
|
|
0
|
$self->{_server_version} = $1 + 0.001 * $2 + ( $3 ? 0.000001 * $3 : 0 ); |
|
839
|
0
|
|
|
|
|
0
|
return $self->{_server_version}; |
|
840
|
|
|
|
|
|
|
} |
|
841
|
|
|
|
|
|
|
|
|
842
|
|
|
|
|
|
|
# don't forget to update POD |
|
843
|
|
|
|
|
|
|
my @commands = qw( |
|
844
|
|
|
|
|
|
|
append asking auth bgrewriteaof bgsave bitcount bitop bitpos |
|
845
|
|
|
|
|
|
|
blpop brpop brpoplpush client client_kill client_getname client_setname |
|
846
|
|
|
|
|
|
|
cluster command |
|
847
|
|
|
|
|
|
|
config config_get config_set config_resetstat config_rewrite |
|
848
|
|
|
|
|
|
|
dbsize debug_error debug_object debug_segfault |
|
849
|
|
|
|
|
|
|
decr decrby del dump echo eval evalsha exists expire expireat flushall |
|
850
|
|
|
|
|
|
|
flushdb geoadd geodist geohash geopos georadius georadiusbymember |
|
851
|
|
|
|
|
|
|
get getbit getrange getset hdel hexists hget hgetall |
|
852
|
|
|
|
|
|
|
hincrby hincrbyfloat hkeys hlen hmget hscan hmset hset hsetnx hvals incr incrby |
|
853
|
|
|
|
|
|
|
incrbyfloat keys lastsave lindex linsert llen lpop lpush lpushx |
|
854
|
|
|
|
|
|
|
lrange lrem lset ltrim mget migrate move mset msetnx object object_refcount |
|
855
|
|
|
|
|
|
|
object_encoding object_idletime persist pexpire pexpireat pfadd pfcount pfmerge ping psetex pttl |
|
856
|
|
|
|
|
|
|
pubsub pubsub_channels pubsub_numsub pubsub_numpat |
|
857
|
|
|
|
|
|
|
publish quit randomkey rename renamenx restore rpop rpoplpush |
|
858
|
|
|
|
|
|
|
rpush rpushx sadd save scan scard script script_exists script_flush script_kill |
|
859
|
|
|
|
|
|
|
script_load sdiff sdiffstore select set |
|
860
|
|
|
|
|
|
|
setbit setex setnx setrange sinter sinterstore |
|
861
|
|
|
|
|
|
|
sismember slaveof slowlog smembers smove sort spop srandmember |
|
862
|
|
|
|
|
|
|
srem sscan strlen sunion sunionstore time ttl type |
|
863
|
|
|
|
|
|
|
zadd zcard zcount zincrby zinterstore zlexcount zrange zrangebylex |
|
864
|
|
|
|
|
|
|
zrangebyscore zrank zrem zremrangebylex |
|
865
|
|
|
|
|
|
|
zremrangebyrank zremrangebyscore zrevrange zrevrangebyscore zrevrank |
|
866
|
|
|
|
|
|
|
zscan zscore zunionstore |
|
867
|
|
|
|
|
|
|
); |
|
868
|
|
|
|
|
|
|
|
|
869
|
|
|
|
|
|
|
sub _simple_commands { |
|
870
|
0
|
|
|
0
|
|
0
|
return @commands; |
|
871
|
|
|
|
|
|
|
} |
|
872
|
|
|
|
|
|
|
|
|
873
|
|
|
|
|
|
|
=head1 WRAPPER METHODS |
|
874
|
|
|
|
|
|
|
|
|
875
|
|
|
|
|
|
|
Instead of using I and I methods directly, it may be |
|
876
|
|
|
|
|
|
|
more convenient to use wrapper methods with names matching names of the redis |
|
877
|
|
|
|
|
|
|
commands. These methods call I or I depending on the |
|
878
|
|
|
|
|
|
|
presence of the callback argument. If callback is specified, the method invokes |
|
879
|
|
|
|
|
|
|
I and returns as soon as the command has been sent to the server; |
|
880
|
|
|
|
|
|
|
when the reply is received, it will be passed to the callback (see |
|
881
|
|
|
|
|
|
|
L"PIPELINING SUPPORT">). If there is no callback, the method invokes |
|
882
|
|
|
|
|
|
|
I, waits for the reply from the server, and returns it. E.g.: |
|
883
|
|
|
|
|
|
|
|
|
884
|
|
|
|
|
|
|
$val = $redis->get($key); |
|
885
|
|
|
|
|
|
|
# equivalent to |
|
886
|
|
|
|
|
|
|
$val = $redis->execute("get", $key); |
|
887
|
|
|
|
|
|
|
|
|
888
|
|
|
|
|
|
|
$redis->get($key, sub { $val = $_[1] }); |
|
889
|
|
|
|
|
|
|
# equivalent to |
|
890
|
|
|
|
|
|
|
$redis->send_command("get", $key, sub { $val = $_[1] }); |
|
891
|
|
|
|
|
|
|
|
|
892
|
|
|
|
|
|
|
The following wrapper methods are defined: append, asking, auth, bgrewriteaof, bgsave, |
|
893
|
|
|
|
|
|
|
bitcount, bitop, bitpos, blpop, brpop, brpoplpush, client, client_kill, |
|
894
|
|
|
|
|
|
|
client_getname, client_setname, cluster, command, config, config_get, config_set, |
|
895
|
|
|
|
|
|
|
config_resetstat, config_rewrite, dbsize, debug_error, debug_object, debug_segfault, decr, |
|
896
|
|
|
|
|
|
|
decrby, del, dump, echo, eval, evalsha, exists, expire, expireat, flushall, |
|
897
|
|
|
|
|
|
|
flushdb, geoadd, geodist, geohash, geopos, georadius, georadiusbymember, |
|
898
|
|
|
|
|
|
|
get, getbit, getrange, getset, hdel, hexists, hget, hgetall, hincrby, |
|
899
|
|
|
|
|
|
|
hincrbyfloat, hkeys, hlen, hmget, hscan, hmset, hset, hsetnx, hvals, incr, |
|
900
|
|
|
|
|
|
|
incrby, incrbyfloat, keys, lastsave, lindex, linsert, llen, lpop, lpush, |
|
901
|
|
|
|
|
|
|
lpushx, lrange, lrem, lset, ltrim, mget, migrate, move, mset, msetnx, object, |
|
902
|
|
|
|
|
|
|
object_refcount, object_encoding, object_idletime, persist, pexpire, pexpireat, |
|
903
|
|
|
|
|
|
|
pfadd, pfcount, pfmerge, ping, psetex, pttl, publish, pubsub, pubsub_channels, pubsub_numsub, |
|
904
|
|
|
|
|
|
|
pubsub_numpat, quit, randomkey, rename, renamenx, restore, rpop, rpoplpush, |
|
905
|
|
|
|
|
|
|
rpush, rpushx, sadd, save, scan, scard, script, script_exists, script_flush, |
|
906
|
|
|
|
|
|
|
script_kill, script_load, sdiff, sdiffstore, select, set, setbit, setex, setnx, |
|
907
|
|
|
|
|
|
|
setrange, sinter, sinterstore, sismember, slaveof, slowlog, smembers, smove, |
|
908
|
|
|
|
|
|
|
sort, spop, srandmember, srem, sscan strlen, sunion, sunionstore, time, |
|
909
|
|
|
|
|
|
|
ttl, type, unwatch, watch, zadd, zcard, zcount, zincrby, zinterstore, |
|
910
|
|
|
|
|
|
|
zlexcount, zrange, zrangebylex, zrangebyscore, zrank, zrem, zremrangebylex, |
|
911
|
|
|
|
|
|
|
zremrangebyrank, zremrangebyscore, zrevrange, zrevrangebyscore, zrevrank, |
|
912
|
|
|
|
|
|
|
zscan, zscore, zunionstore. |
|
913
|
|
|
|
|
|
|
|
|
914
|
|
|
|
|
|
|
See description of all commands in redis documentation at |
|
915
|
|
|
|
|
|
|
L. |
|
916
|
|
|
|
|
|
|
|
|
917
|
|
|
|
|
|
|
=cut |
|
918
|
|
|
|
|
|
|
|
|
919
|
|
|
|
|
|
|
for my $command (@commands) { |
|
920
|
|
|
|
|
|
|
my @uccom = split /_/, uc $command; |
|
921
|
17
|
|
|
17
|
|
161
|
no strict 'refs'; |
|
|
17
|
|
|
|
|
48
|
|
|
|
17
|
|
|
|
|
24528
|
|
|
922
|
|
|
|
|
|
|
*{ __PACKAGE__ . "::$command" } = sub { |
|
923
|
49
|
|
|
49
|
|
1044081
|
my $self = shift; |
|
924
|
49
|
100
|
|
|
|
275
|
if ( ref $_[-1] eq 'CODE' ) { |
|
925
|
4
|
|
|
|
|
204
|
return $self->send_command( @uccom, @_ ); |
|
926
|
|
|
|
|
|
|
} |
|
927
|
|
|
|
|
|
|
else { |
|
928
|
45
|
|
|
|
|
270
|
return $self->execute( @uccom, @_ ); |
|
929
|
|
|
|
|
|
|
} |
|
930
|
|
|
|
|
|
|
}; |
|
931
|
|
|
|
|
|
|
} |
|
932
|
|
|
|
|
|
|
|
|
933
|
|
|
|
|
|
|
=pod |
|
934
|
|
|
|
|
|
|
|
|
935
|
|
|
|
|
|
|
The following commands implement some additional postprocessing of the results: |
|
936
|
|
|
|
|
|
|
|
|
937
|
|
|
|
|
|
|
=cut |
|
938
|
|
|
|
|
|
|
|
|
939
|
|
|
|
|
|
|
sub _execute_with_postprocess { |
|
940
|
0
|
|
|
0
|
|
|
my $self = shift; |
|
941
|
0
|
|
|
|
|
|
my $ppsub = pop; |
|
942
|
0
|
0
|
0
|
|
|
|
if ( $_[-1] && ref $_[-1] eq 'CODE' ) { |
|
943
|
0
|
|
|
|
|
|
my $orig = pop; |
|
944
|
|
|
|
|
|
|
my $cb = sub { |
|
945
|
0
|
|
|
0
|
|
|
my ( $redis, $reply ) = @_; |
|
946
|
0
|
0
|
|
|
|
|
$reply = $ppsub->($reply) unless _is_redisdb_error($reply); |
|
947
|
0
|
|
|
|
|
|
$orig->( $redis, $reply ); |
|
948
|
0
|
|
|
|
|
|
}; |
|
949
|
0
|
|
|
|
|
|
return $self->send_command( @_, $cb ); |
|
950
|
|
|
|
|
|
|
} |
|
951
|
|
|
|
|
|
|
else { |
|
952
|
0
|
|
|
|
|
|
my $reply = $self->execute(@_); |
|
953
|
0
|
0
|
|
|
|
|
$reply = $ppsub->($reply) unless _is_redisdb_error($reply); |
|
954
|
0
|
|
|
|
|
|
return $reply; |
|
955
|
|
|
|
|
|
|
} |
|
956
|
|
|
|
|
|
|
} |
|
957
|
|
|
|
|
|
|
|
|
958
|
|
|
|
|
|
|
=head2 $self->info([\&callback]) |
|
959
|
|
|
|
|
|
|
|
|
960
|
|
|
|
|
|
|
return information and statistics about the server. Redis-server returns |
|
961
|
|
|
|
|
|
|
information in form of I, the I method parses result and |
|
962
|
|
|
|
|
|
|
returns it as a hash reference. |
|
963
|
|
|
|
|
|
|
|
|
964
|
|
|
|
|
|
|
=cut |
|
965
|
|
|
|
|
|
|
|
|
966
|
|
|
|
|
|
|
sub info { |
|
967
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
968
|
0
|
|
|
|
|
|
return $self->_execute_with_postprocess('INFO', @_, \&_parse_info); |
|
969
|
|
|
|
|
|
|
} |
|
970
|
|
|
|
|
|
|
|
|
971
|
|
|
|
|
|
|
sub _parse_info { |
|
972
|
0
|
|
|
0
|
|
|
my $info = shift; |
|
973
|
0
|
0
|
0
|
|
|
|
return $info if !$info || ref $info; |
|
974
|
0
|
|
|
|
|
|
my %info = map { /^([^:]+):(.*)$/ } split /\r\n/, $info; |
|
|
0
|
|
|
|
|
|
|
|
975
|
0
|
|
|
|
|
|
return \%info; |
|
976
|
|
|
|
|
|
|
} |
|
977
|
|
|
|
|
|
|
|
|
978
|
|
|
|
|
|
|
=head2 $self->client_list([\&callback]) |
|
979
|
|
|
|
|
|
|
|
|
980
|
|
|
|
|
|
|
return list of clients connected to the server. This method parses server |
|
981
|
|
|
|
|
|
|
output and returns result as reference to array of hashes. |
|
982
|
|
|
|
|
|
|
|
|
983
|
|
|
|
|
|
|
=cut |
|
984
|
|
|
|
|
|
|
|
|
985
|
|
|
|
|
|
|
sub client_list { |
|
986
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
987
|
0
|
|
|
|
|
|
return $self->_execute_with_postprocess('CLIENT', 'LIST', @_, \&_parse_client_list); |
|
988
|
|
|
|
|
|
|
} |
|
989
|
|
|
|
|
|
|
|
|
990
|
|
|
|
|
|
|
sub _parse_client_list { |
|
991
|
0
|
|
|
0
|
|
|
my $list = shift; |
|
992
|
0
|
0
|
0
|
|
|
|
return $list if !$list || ref $list; |
|
993
|
0
|
|
|
|
|
|
my @clients = split /\015?\012/, $list; |
|
994
|
0
|
|
|
|
|
|
my $res = []; |
|
995
|
0
|
|
|
|
|
|
for (@clients) { |
|
996
|
0
|
0
|
|
|
|
|
my %cli = map { /^([^=]+)=(.*)$/ ? ( $1, $2 ) : () } split / /; |
|
|
0
|
|
|
|
|
|
|
|
997
|
0
|
|
|
|
|
|
push @$res, \%cli; |
|
998
|
|
|
|
|
|
|
} |
|
999
|
0
|
|
|
|
|
|
return $res; |
|
1000
|
|
|
|
|
|
|
} |
|
1001
|
|
|
|
|
|
|
|
|
1002
|
|
|
|
|
|
|
=head2 $self->cluster_info([\&callback]) |
|
1003
|
|
|
|
|
|
|
|
|
1004
|
|
|
|
|
|
|
return information and statistics about the cluster. Redis-server returns |
|
1005
|
|
|
|
|
|
|
information in form of I, the I method parses result |
|
1006
|
|
|
|
|
|
|
and returns it as a hash reference. |
|
1007
|
|
|
|
|
|
|
|
|
1008
|
|
|
|
|
|
|
=cut |
|
1009
|
|
|
|
|
|
|
|
|
1010
|
|
|
|
|
|
|
sub cluster_info { |
|
1011
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1012
|
0
|
|
|
|
|
|
return $self->_execute_with_postprocess('CLUSTER', 'INFO', @_, \&_parse_info); |
|
1013
|
|
|
|
|
|
|
} |
|
1014
|
|
|
|
|
|
|
|
|
1015
|
|
|
|
|
|
|
=head2 $self->cluster_nodes([\&callback]) |
|
1016
|
|
|
|
|
|
|
|
|
1017
|
|
|
|
|
|
|
return list of cluster nodes. Each node represented as a hash with the |
|
1018
|
|
|
|
|
|
|
following keys: node_id, address, host, port, flags, master_id, last_ping_sent, |
|
1019
|
|
|
|
|
|
|
last_pong_received, link_state, slots. |
|
1020
|
|
|
|
|
|
|
|
|
1021
|
|
|
|
|
|
|
=cut |
|
1022
|
|
|
|
|
|
|
|
|
1023
|
|
|
|
|
|
|
sub cluster_nodes { |
|
1024
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1025
|
|
|
|
|
|
|
return $self->_execute_with_postprocess( 'CLUSTER', 'NODES', @_, |
|
1026
|
0
|
|
|
0
|
|
|
sub { $self->_parse_cluster_nodes(@_) } ); |
|
|
0
|
|
|
|
|
|
|
|
1027
|
|
|
|
|
|
|
} |
|
1028
|
|
|
|
|
|
|
|
|
1029
|
|
|
|
|
|
|
sub _parse_cluster_nodes { |
|
1030
|
0
|
|
|
0
|
|
|
my ($self, $list) = @_; |
|
1031
|
|
|
|
|
|
|
|
|
1032
|
0
|
|
|
|
|
|
my @nodes; |
|
1033
|
0
|
|
|
|
|
|
for ( split /^/, $list ) { |
|
1034
|
0
|
|
|
|
|
|
my ( $node_id, $addr, $flags, $master_id, $ping, $pong, $state, @slots ) = |
|
1035
|
|
|
|
|
|
|
split / /; |
|
1036
|
0
|
|
|
|
|
|
my %flags = map { $_ => 1 } split /,/, $flags; |
|
|
0
|
|
|
|
|
|
|
|
1037
|
0
|
|
|
|
|
|
my ( $host_port ) = split /@/, $addr; |
|
1038
|
0
|
|
|
|
|
|
my ( $host, $port ) = split /:([^:]+)$/, $host_port; |
|
1039
|
0
|
0
|
|
|
|
|
unless ($host) { |
|
1040
|
0
|
|
|
|
|
|
$host = $self->{host}, $addr = "$self->{host}:$port", |
|
1041
|
|
|
|
|
|
|
} |
|
1042
|
0
|
|
|
|
|
|
my $node = { |
|
1043
|
|
|
|
|
|
|
node_id => $node_id, |
|
1044
|
|
|
|
|
|
|
address => $addr, |
|
1045
|
|
|
|
|
|
|
host => $host, |
|
1046
|
|
|
|
|
|
|
port => $port, |
|
1047
|
|
|
|
|
|
|
flags => \%flags, |
|
1048
|
|
|
|
|
|
|
master_id => $master_id, |
|
1049
|
|
|
|
|
|
|
last_ping_sent => $ping, |
|
1050
|
|
|
|
|
|
|
last_pong_received => $pong, |
|
1051
|
|
|
|
|
|
|
link_state => $state, |
|
1052
|
|
|
|
|
|
|
slots => \@slots, |
|
1053
|
|
|
|
|
|
|
}; |
|
1054
|
0
|
|
|
|
|
|
push @nodes, $node; |
|
1055
|
|
|
|
|
|
|
} |
|
1056
|
|
|
|
|
|
|
|
|
1057
|
0
|
|
|
|
|
|
return \@nodes; |
|
1058
|
|
|
|
|
|
|
} |
|
1059
|
|
|
|
|
|
|
|
|
1060
|
|
|
|
|
|
|
sub _parse_role { |
|
1061
|
0
|
|
|
0
|
|
|
my $role = shift; |
|
1062
|
|
|
|
|
|
|
|
|
1063
|
0
|
|
|
|
|
|
my $parsed = { |
|
1064
|
|
|
|
|
|
|
role => $role->[0], |
|
1065
|
|
|
|
|
|
|
}; |
|
1066
|
0
|
0
|
|
|
|
|
if ( $parsed->{role} eq 'master' ) { |
|
|
|
0
|
|
|
|
|
|
|
|
|
0
|
|
|
|
|
|
|
1067
|
0
|
|
|
|
|
|
$parsed->{replication_offset} = $role->[1]; |
|
1068
|
0
|
|
|
|
|
|
for ( @{ $role->[2] } ) { |
|
|
0
|
|
|
|
|
|
|
|
1069
|
0
|
|
|
|
|
|
push @{ $parsed->{slaves} }, |
|
|
0
|
|
|
|
|
|
|
|
1070
|
|
|
|
|
|
|
{ |
|
1071
|
|
|
|
|
|
|
host => $_->[0], |
|
1072
|
|
|
|
|
|
|
port => $_->[1], |
|
1073
|
|
|
|
|
|
|
replication_offset => $_->[2], |
|
1074
|
|
|
|
|
|
|
}; |
|
1075
|
|
|
|
|
|
|
} |
|
1076
|
|
|
|
|
|
|
} |
|
1077
|
|
|
|
|
|
|
elsif ( $parsed->{role} eq 'slave' ) { |
|
1078
|
|
|
|
|
|
|
$parsed->{master} = { |
|
1079
|
0
|
|
|
|
|
|
host => $role->[1], |
|
1080
|
|
|
|
|
|
|
port => $role->[2], |
|
1081
|
|
|
|
|
|
|
}; |
|
1082
|
0
|
|
|
|
|
|
$parsed->{status} = $role->[3]; |
|
1083
|
0
|
|
|
|
|
|
$parsed->{replication_offset} = $role->[4]; |
|
1084
|
|
|
|
|
|
|
} |
|
1085
|
|
|
|
|
|
|
elsif ( $parsed->{role} eq 'sentinel' ) { |
|
1086
|
0
|
|
|
|
|
|
for ( @{ $role->[1] } ) { |
|
|
0
|
|
|
|
|
|
|
|
1087
|
0
|
|
|
|
|
|
push @{ $parsed->{services} }, $_; |
|
|
0
|
|
|
|
|
|
|
|
1088
|
|
|
|
|
|
|
} |
|
1089
|
|
|
|
|
|
|
} else { |
|
1090
|
0
|
|
|
|
|
|
confess "Unknown role $parsed->{role}"; |
|
1091
|
|
|
|
|
|
|
} |
|
1092
|
|
|
|
|
|
|
|
|
1093
|
0
|
|
|
|
|
|
return $parsed; |
|
1094
|
|
|
|
|
|
|
} |
|
1095
|
|
|
|
|
|
|
|
|
1096
|
|
|
|
|
|
|
=head2 $self->role([\&callback]) |
|
1097
|
|
|
|
|
|
|
|
|
1098
|
|
|
|
|
|
|
return reference to a hash describing the role of the server. Hash contains |
|
1099
|
|
|
|
|
|
|
"role" element that can be either "master", "slave", or "sentinel". For master |
|
1100
|
|
|
|
|
|
|
hash will also contain "replication_offset" and "slaves" elements, for slave it |
|
1101
|
|
|
|
|
|
|
will contain "master", "status", and "replication_offset" elements, and for |
|
1102
|
|
|
|
|
|
|
sentinel it will contain "services". |
|
1103
|
|
|
|
|
|
|
|
|
1104
|
|
|
|
|
|
|
=cut |
|
1105
|
|
|
|
|
|
|
|
|
1106
|
|
|
|
|
|
|
sub role { |
|
1107
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1108
|
0
|
|
|
|
|
|
return $self->_execute_with_postprocess( 'ROLE', @_, \&_parse_role ); |
|
1109
|
|
|
|
|
|
|
} |
|
1110
|
|
|
|
|
|
|
|
|
1111
|
|
|
|
|
|
|
=head2 $self->shutdown |
|
1112
|
|
|
|
|
|
|
|
|
1113
|
|
|
|
|
|
|
Shuts the redis server down. Returns undef, as the server doesn't send the |
|
1114
|
|
|
|
|
|
|
answer. Croaks in case of the error. |
|
1115
|
|
|
|
|
|
|
|
|
1116
|
|
|
|
|
|
|
=cut |
|
1117
|
|
|
|
|
|
|
|
|
1118
|
|
|
|
|
|
|
sub shutdown { |
|
1119
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1120
|
0
|
|
|
|
|
|
$self->send_command_cb( 'SHUTDOWN', @_ ); |
|
1121
|
0
|
|
|
|
|
|
return; |
|
1122
|
|
|
|
|
|
|
} |
|
1123
|
|
|
|
|
|
|
|
|
1124
|
|
|
|
|
|
|
=head2 $self->scan_all([MATCH => $pattern,][COUNT => $count,]) |
|
1125
|
|
|
|
|
|
|
|
|
1126
|
|
|
|
|
|
|
this method starts a new SCAN iteration and executes SCAN commands till cursor |
|
1127
|
|
|
|
|
|
|
returned by server is 0. It then returns all the keys returned by server during |
|
1128
|
|
|
|
|
|
|
the iteration. MATCH and COUNT are passed to SCAN command. In case of success |
|
1129
|
|
|
|
|
|
|
returns reference to array with matching keys, in case of error dies or returns |
|
1130
|
|
|
|
|
|
|
L object depending on I option. |
|
1131
|
|
|
|
|
|
|
|
|
1132
|
|
|
|
|
|
|
=cut |
|
1133
|
|
|
|
|
|
|
|
|
1134
|
|
|
|
|
|
|
sub scan_all { |
|
1135
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1136
|
0
|
0
|
|
|
|
|
if ( ref $_[-1] eq 'CODE' ) { |
|
1137
|
0
|
|
|
|
|
|
croak "scan_all does not accept callback parameter"; |
|
1138
|
|
|
|
|
|
|
} |
|
1139
|
0
|
|
|
|
|
|
my $cursor = 0; |
|
1140
|
0
|
|
|
|
|
|
my @result; |
|
1141
|
0
|
|
|
|
|
|
do { |
|
1142
|
0
|
|
|
|
|
|
my $res = $self->execute( 'SCAN', $cursor, @_ ); |
|
1143
|
|
|
|
|
|
|
|
|
1144
|
|
|
|
|
|
|
# in case of error just return it |
|
1145
|
0
|
0
|
|
|
|
|
return $res unless ref $res eq 'ARRAY'; |
|
1146
|
0
|
|
|
|
|
|
$cursor = $res->[0]; |
|
1147
|
0
|
|
|
|
|
|
push @result, @{ $res->[1] }; |
|
|
0
|
|
|
|
|
|
|
|
1148
|
|
|
|
|
|
|
} while $cursor; |
|
1149
|
0
|
|
|
|
|
|
return \@result; |
|
1150
|
|
|
|
|
|
|
} |
|
1151
|
|
|
|
|
|
|
|
|
1152
|
|
|
|
|
|
|
=head2 $self->hscan_all($key, [MATCH => $pattern,][COUNT => $count,]) |
|
1153
|
|
|
|
|
|
|
|
|
1154
|
|
|
|
|
|
|
=head2 $self->sscan_all($key, [MATCH => $pattern,][COUNT => $count,]) |
|
1155
|
|
|
|
|
|
|
|
|
1156
|
|
|
|
|
|
|
=head2 $self->zscan_all($key, [MATCH => $pattern,][COUNT => $count,]) |
|
1157
|
|
|
|
|
|
|
|
|
1158
|
|
|
|
|
|
|
these three methods are doing the same thing as I except that they |
|
1159
|
|
|
|
|
|
|
require a key as the first parameter, and they iterate using HSCAN, SSCAN and |
|
1160
|
|
|
|
|
|
|
ZSCAN commands. |
|
1161
|
|
|
|
|
|
|
|
|
1162
|
|
|
|
|
|
|
=cut |
|
1163
|
|
|
|
|
|
|
|
|
1164
|
|
|
|
|
|
|
for my $command (qw(hscan sscan zscan)) { |
|
1165
|
|
|
|
|
|
|
my $uccom = uc $command; |
|
1166
|
17
|
|
|
17
|
|
159
|
no strict 'refs'; |
|
|
17
|
|
|
|
|
42
|
|
|
|
17
|
|
|
|
|
28052
|
|
|
1167
|
|
|
|
|
|
|
my $name = "${command}_all"; |
|
1168
|
|
|
|
|
|
|
*{ __PACKAGE__ . "::$name" } = sub { |
|
1169
|
0
|
|
|
0
|
|
|
my $self = shift; |
|
1170
|
0
|
|
|
|
|
|
my $key = shift; |
|
1171
|
0
|
0
|
|
|
|
|
if ( ref $_[-1] eq 'CODE' ) { |
|
1172
|
0
|
|
|
|
|
|
croak "$name does not accept callback parameter"; |
|
1173
|
|
|
|
|
|
|
} |
|
1174
|
0
|
|
|
|
|
|
my $cursor = 0; |
|
1175
|
0
|
|
|
|
|
|
my @result; |
|
1176
|
0
|
|
|
|
|
|
do { |
|
1177
|
0
|
|
|
|
|
|
my $res = $self->execute( $uccom, $key, $cursor, @_ ); |
|
1178
|
0
|
0
|
|
|
|
|
return $res unless ref $res eq 'ARRAY'; |
|
1179
|
0
|
|
|
|
|
|
$cursor = $res->[0]; |
|
1180
|
0
|
|
|
|
|
|
push @result, @{ $res->[1] }; |
|
|
0
|
|
|
|
|
|
|
|
1181
|
|
|
|
|
|
|
} while $cursor; |
|
1182
|
0
|
|
|
|
|
|
return \@result; |
|
1183
|
|
|
|
|
|
|
}; |
|
1184
|
|
|
|
|
|
|
} |
|
1185
|
|
|
|
|
|
|
|
|
1186
|
|
|
|
|
|
|
=head1 UTF-8 SUPPORT |
|
1187
|
|
|
|
|
|
|
|
|
1188
|
|
|
|
|
|
|
The redis protocol is designed to work with the binary data, both keys and |
|
1189
|
|
|
|
|
|
|
values are encoded in the same way as sequences of octets. By default this |
|
1190
|
|
|
|
|
|
|
module expects all data to be just strings of bytes. There is an option to |
|
1191
|
|
|
|
|
|
|
treat all data as UTF-8 strings. If you pass I parameter to the |
|
1192
|
|
|
|
|
|
|
constructor, module will encode all strings to UTF-8 before sending them to |
|
1193
|
|
|
|
|
|
|
server, and will decode all strings received from server from UTF-8. This has |
|
1194
|
|
|
|
|
|
|
following repercussions you should be aware off: first, you can't store binary |
|
1195
|
|
|
|
|
|
|
data on server with this option on, it would be treated as a sequence of latin1 |
|
1196
|
|
|
|
|
|
|
characters, and would be converted into a corresponding sequence of UTF-8 |
|
1197
|
|
|
|
|
|
|
encoded characters; second, if data returned by the server is not a valid UTF-8 |
|
1198
|
|
|
|
|
|
|
encoded string, the module will croak, and you will have to reinitialize the |
|
1199
|
|
|
|
|
|
|
connection. The parser only checks for invalid UTF-8 byte sequences, it doesn't |
|
1200
|
|
|
|
|
|
|
check if input contains invalid code points. Generally, using this option is |
|
1201
|
|
|
|
|
|
|
not recommended. |
|
1202
|
|
|
|
|
|
|
|
|
1203
|
|
|
|
|
|
|
=cut |
|
1204
|
|
|
|
|
|
|
|
|
1205
|
|
|
|
|
|
|
=head1 ERROR HANDLING |
|
1206
|
|
|
|
|
|
|
|
|
1207
|
|
|
|
|
|
|
If L parameter was set to true in the constructor (which is |
|
1208
|
|
|
|
|
|
|
default setting), then module will throw an exception in case network IO |
|
1209
|
|
|
|
|
|
|
function returned an error, or if redis-server returned an error reply. Network |
|
1210
|
|
|
|
|
|
|
exceptions belong to L or |
|
1211
|
|
|
|
|
|
|
L class, if redis-server returned an error |
|
1212
|
|
|
|
|
|
|
exception will be of L class. If the object was in subscription |
|
1213
|
|
|
|
|
|
|
mode, you will have to restore all the subscriptions. If the object was in the |
|
1214
|
|
|
|
|
|
|
middle of transaction, when after network error you will have to start the |
|
1215
|
|
|
|
|
|
|
transaction again. |
|
1216
|
|
|
|
|
|
|
|
|
1217
|
|
|
|
|
|
|
If L parameter was disabled, then instead of throwing an |
|
1218
|
|
|
|
|
|
|
exception, module will return exception object and also pass this exception |
|
1219
|
|
|
|
|
|
|
object to every callback waiting for the reply from the server. If the object |
|
1220
|
|
|
|
|
|
|
is in subscription mode, then module will automatically restore all |
|
1221
|
|
|
|
|
|
|
subscriptions after reconnect. Note, that during transaction L is |
|
1222
|
|
|
|
|
|
|
always enabled, so any error will throw an exception. |
|
1223
|
|
|
|
|
|
|
|
|
1224
|
|
|
|
|
|
|
=cut |
|
1225
|
|
|
|
|
|
|
|
|
1226
|
|
|
|
|
|
|
=head1 HANDLING OF SERVER DISCONNECTS |
|
1227
|
|
|
|
|
|
|
|
|
1228
|
|
|
|
|
|
|
Redis server may close a connection if it was idle for some time, also the |
|
1229
|
|
|
|
|
|
|
connection may be closed in case when redis-server was restarted, or just |
|
1230
|
|
|
|
|
|
|
because of the network problem. RedisDB always tries to restore connection to |
|
1231
|
|
|
|
|
|
|
the server if no data has been lost as a result of disconnect, and if |
|
1232
|
|
|
|
|
|
|
L parameter disabled it will try to reconnect even if disconnect |
|
1233
|
|
|
|
|
|
|
happened during data transmission. E.g. if the client was idle for some time |
|
1234
|
|
|
|
|
|
|
and the redis server closed the connection, it will be transparently restored |
|
1235
|
|
|
|
|
|
|
when you send a command next time no matter if L enabled or not. |
|
1236
|
|
|
|
|
|
|
If you sent a command and the server has closed the connection without sending |
|
1237
|
|
|
|
|
|
|
a complete reply, then module will act differently depending on L |
|
1238
|
|
|
|
|
|
|
value. If L enabled, the module will cancel all current |
|
1239
|
|
|
|
|
|
|
callbacks, reset the object to the initial state, and throw an exception of |
|
1240
|
|
|
|
|
|
|
L class, next time you use the object it will |
|
1241
|
|
|
|
|
|
|
establish a new connection. If L disabled, the module will pass |
|
1242
|
|
|
|
|
|
|
L object to all outstanding callbacks and will |
|
1243
|
|
|
|
|
|
|
try to reconnect to the server; it will also automatically restore |
|
1244
|
|
|
|
|
|
|
subscriptions if object was in subscription mode. Module never tries to |
|
1245
|
|
|
|
|
|
|
reconnect after MULTI or WATCH command was sent to server and before |
|
1246
|
|
|
|
|
|
|
corresponding UNWATCH, EXEC or DISCARD was sent as this may cause data |
|
1247
|
|
|
|
|
|
|
corruption, so during transaction module behaves like if L is |
|
1248
|
|
|
|
|
|
|
set. |
|
1249
|
|
|
|
|
|
|
|
|
1250
|
|
|
|
|
|
|
Module makes several attempts to reconnect each time increasing interval before |
|
1251
|
|
|
|
|
|
|
the next attempt, depending on the values of L and |
|
1252
|
|
|
|
|
|
|
L. After each failed attempt to connect module will |
|
1253
|
|
|
|
|
|
|
invoke L callback which for example may change redis-server |
|
1254
|
|
|
|
|
|
|
hostname, so on next attempt module will try to connect to different server. |
|
1255
|
|
|
|
|
|
|
|
|
1256
|
|
|
|
|
|
|
=cut |
|
1257
|
|
|
|
|
|
|
|
|
1258
|
|
|
|
|
|
|
=head1 PIPELINING |
|
1259
|
|
|
|
|
|
|
|
|
1260
|
|
|
|
|
|
|
You can send commands in the pipelining mode. It means you are sending multiple |
|
1261
|
|
|
|
|
|
|
commands to the server without waiting for the replies. This is implemented by |
|
1262
|
|
|
|
|
|
|
the I method. Recommended way of using it is to pass a reference |
|
1263
|
|
|
|
|
|
|
to the callback function as the last argument. When module receives reply from |
|
1264
|
|
|
|
|
|
|
the server, it will call this function with two arguments: reference to the |
|
1265
|
|
|
|
|
|
|
RedisDB object, and reply from the server. It is important to understand |
|
1266
|
|
|
|
|
|
|
though, that RedisDB does not run any background threads, neither it checks for |
|
1267
|
|
|
|
|
|
|
the replies by setting some timer, so e.g. in the following example callback |
|
1268
|
|
|
|
|
|
|
will never be invoked: |
|
1269
|
|
|
|
|
|
|
|
|
1270
|
|
|
|
|
|
|
my $pong; |
|
1271
|
|
|
|
|
|
|
$redis->send_command( "ping", sub { $pong = $_[1] } ); |
|
1272
|
|
|
|
|
|
|
sleep 1 while not $pong; # this will never return |
|
1273
|
|
|
|
|
|
|
|
|
1274
|
|
|
|
|
|
|
Therefore you need periodically trigger check for the replies. The check is |
|
1275
|
|
|
|
|
|
|
triggered when you call the following methods: I, I, |
|
1276
|
|
|
|
|
|
|
I, I. Calling wrapper method, like |
|
1277
|
|
|
|
|
|
|
C<< $redis->get('key') >>, will also trigger check as internally wrapper methods |
|
1278
|
|
|
|
|
|
|
use methods listed above. |
|
1279
|
|
|
|
|
|
|
|
|
1280
|
|
|
|
|
|
|
Also you can omit callback argument when invoke I. In this case |
|
1281
|
|
|
|
|
|
|
you have to fetch reply later explicitly using I method. This is how |
|
1282
|
|
|
|
|
|
|
synchronous I is implemented, basically it is: |
|
1283
|
|
|
|
|
|
|
|
|
1284
|
|
|
|
|
|
|
sub execute { |
|
1285
|
|
|
|
|
|
|
my $self = shift; |
|
1286
|
|
|
|
|
|
|
$self->send_command(@_); |
|
1287
|
|
|
|
|
|
|
return $self->get_reply; |
|
1288
|
|
|
|
|
|
|
} |
|
1289
|
|
|
|
|
|
|
|
|
1290
|
|
|
|
|
|
|
That is why it is not allowed to call I unless you have got replies to |
|
1291
|
|
|
|
|
|
|
all commands sent previously with I without callback. Using |
|
1292
|
|
|
|
|
|
|
I without callback is not recommended. |
|
1293
|
|
|
|
|
|
|
|
|
1294
|
|
|
|
|
|
|
Sometimes you are not interested in replies sent by the server, e.g. SET |
|
1295
|
|
|
|
|
|
|
command usually just return 'OK', in this case you can pass to I |
|
1296
|
|
|
|
|
|
|
callback which ignores its arguments, or use C constant, it |
|
1297
|
|
|
|
|
|
|
is a no-op function: |
|
1298
|
|
|
|
|
|
|
|
|
1299
|
|
|
|
|
|
|
for (@keys) { |
|
1300
|
|
|
|
|
|
|
# execute will not just send 'GET' command to the server, |
|
1301
|
|
|
|
|
|
|
# but it will also receive response to the 'SET' command sent on |
|
1302
|
|
|
|
|
|
|
# the previous loop iteration |
|
1303
|
|
|
|
|
|
|
my $val = $redis->execute( "get", $_ ); |
|
1304
|
|
|
|
|
|
|
$redis->send_command( "set", $_, fun($val), RedisDB::IGNORE_REPLY ); |
|
1305
|
|
|
|
|
|
|
} |
|
1306
|
|
|
|
|
|
|
# and this will wait for the last reply |
|
1307
|
|
|
|
|
|
|
$redis->mainloop; |
|
1308
|
|
|
|
|
|
|
|
|
1309
|
|
|
|
|
|
|
or using L"WRAPPER METHODS"> you can rewrite it as: |
|
1310
|
|
|
|
|
|
|
|
|
1311
|
|
|
|
|
|
|
for (@keys) { |
|
1312
|
|
|
|
|
|
|
my $val = $redis->get($_); |
|
1313
|
|
|
|
|
|
|
$redis->set( $_, fun($val), RedisDB::IGNORE_REPLY ); |
|
1314
|
|
|
|
|
|
|
} |
|
1315
|
|
|
|
|
|
|
$redis->mainloop; |
|
1316
|
|
|
|
|
|
|
|
|
1317
|
|
|
|
|
|
|
=cut |
|
1318
|
|
|
|
|
|
|
|
|
1319
|
|
|
|
|
|
|
=head1 PUB/SUB MESSAGING |
|
1320
|
|
|
|
|
|
|
|
|
1321
|
|
|
|
|
|
|
RedisDB supports subscriptions to redis channels. In the subscription mode you |
|
1322
|
|
|
|
|
|
|
can subscribe to some channels and receive all the messages sent to these |
|
1323
|
|
|
|
|
|
|
channels. You can subscribe to channels and then manually check messages using |
|
1324
|
|
|
|
|
|
|
I method, or you can invoke I method, which will |
|
1325
|
|
|
|
|
|
|
block in loop waiting for messages and invoking callback for each received |
|
1326
|
|
|
|
|
|
|
message. In the first case you can use I and I methods |
|
1327
|
|
|
|
|
|
|
to subscribe to channels and then you can use I method to get |
|
1328
|
|
|
|
|
|
|
messages from the channel: |
|
1329
|
|
|
|
|
|
|
|
|
1330
|
|
|
|
|
|
|
$redis->subscribe( |
|
1331
|
|
|
|
|
|
|
foo => sub { |
|
1332
|
|
|
|
|
|
|
my ( $redis, $channel, $patern, $message ) = @_; |
|
1333
|
|
|
|
|
|
|
print "Foo: $message\n"; |
|
1334
|
|
|
|
|
|
|
} |
|
1335
|
|
|
|
|
|
|
); |
|
1336
|
|
|
|
|
|
|
# Wait for messages |
|
1337
|
|
|
|
|
|
|
$res = $redis->get_reply; |
|
1338
|
|
|
|
|
|
|
|
|
1339
|
|
|
|
|
|
|
I method for messages from the channel will invoke callback |
|
1340
|
|
|
|
|
|
|
specified as the second optional argument of the I method and will |
|
1341
|
|
|
|
|
|
|
also return raw replies from the server, both for messages from the channels |
|
1342
|
|
|
|
|
|
|
and for informational messages from the redis server. If you do not want to |
|
1343
|
|
|
|
|
|
|
block in I method, you can check if there are any messages using |
|
1344
|
|
|
|
|
|
|
I method. |
|
1345
|
|
|
|
|
|
|
|
|
1346
|
|
|
|
|
|
|
In the second case you invoke I method, it subscribes to |
|
1347
|
|
|
|
|
|
|
specified channels and waits for messages, when a message arrived it invokes |
|
1348
|
|
|
|
|
|
|
callback defined for the channel from which the message came. Here is an |
|
1349
|
|
|
|
|
|
|
example: |
|
1350
|
|
|
|
|
|
|
|
|
1351
|
|
|
|
|
|
|
my $message_cb = sub { |
|
1352
|
|
|
|
|
|
|
my ( $redis, $channel, $pattern, $message ) = @_; |
|
1353
|
|
|
|
|
|
|
print "$channel: $message\n"; |
|
1354
|
|
|
|
|
|
|
}; |
|
1355
|
|
|
|
|
|
|
|
|
1356
|
|
|
|
|
|
|
my $control_cb = sub { |
|
1357
|
|
|
|
|
|
|
my ( $redis, $channel, $pattern, $message ) = @_; |
|
1358
|
|
|
|
|
|
|
if ( $channel eq 'control.quit' ) { |
|
1359
|
|
|
|
|
|
|
$redis->unsubscribe; |
|
1360
|
|
|
|
|
|
|
$redis->punsubscribe; |
|
1361
|
|
|
|
|
|
|
} |
|
1362
|
|
|
|
|
|
|
elsif ( $channel eq 'control.subscribe' ) { |
|
1363
|
|
|
|
|
|
|
$redis->subscribe($message); |
|
1364
|
|
|
|
|
|
|
} |
|
1365
|
|
|
|
|
|
|
}; |
|
1366
|
|
|
|
|
|
|
|
|
1367
|
|
|
|
|
|
|
$redis->subscription_loop( |
|
1368
|
|
|
|
|
|
|
subscribe => [ 'news', ], |
|
1369
|
|
|
|
|
|
|
psubscribe => [ 'control.*' => $control_cb ], |
|
1370
|
|
|
|
|
|
|
default_callback => $message_cb, |
|
1371
|
|
|
|
|
|
|
); |
|
1372
|
|
|
|
|
|
|
|
|
1373
|
|
|
|
|
|
|
subscription_loop will subscribe you to the "news" channel and "control.*" |
|
1374
|
|
|
|
|
|
|
channels. It will call specified callbacks every time a new message received. |
|
1375
|
|
|
|
|
|
|
When message came from "control.subscribe" channel, callback subscribes to an |
|
1376
|
|
|
|
|
|
|
additional channel. When message came from "control.quit" channel, callback |
|
1377
|
|
|
|
|
|
|
unsubscribes from all channels. |
|
1378
|
|
|
|
|
|
|
|
|
1379
|
|
|
|
|
|
|
Callbacks used in subscription mode receive four arguments: the RedisDB object, |
|
1380
|
|
|
|
|
|
|
the channel from which the message came, the pattern if you subscribed to this |
|
1381
|
|
|
|
|
|
|
channel using I method, and the message itself. |
|
1382
|
|
|
|
|
|
|
|
|
1383
|
|
|
|
|
|
|
Once you switched into subscription mode using either I or |
|
1384
|
|
|
|
|
|
|
I command, or by entering I, you only can send |
|
1385
|
|
|
|
|
|
|
I, I, I, and I commands to |
|
1386
|
|
|
|
|
|
|
the server, other commands will throw an exception. |
|
1387
|
|
|
|
|
|
|
|
|
1388
|
|
|
|
|
|
|
You can publish messages into the channels using the I method. This |
|
1389
|
|
|
|
|
|
|
method should be called when you in the normal mode, and can't be used while |
|
1390
|
|
|
|
|
|
|
you're in the subscription mode. |
|
1391
|
|
|
|
|
|
|
|
|
1392
|
|
|
|
|
|
|
Following methods can be used in subscription mode: |
|
1393
|
|
|
|
|
|
|
|
|
1394
|
|
|
|
|
|
|
=cut |
|
1395
|
|
|
|
|
|
|
|
|
1396
|
|
|
|
|
|
|
=head2 $self->subscription_loop(%parameters) |
|
1397
|
|
|
|
|
|
|
|
|
1398
|
|
|
|
|
|
|
Enter into the subscription mode. The method subscribes you to the specified |
|
1399
|
|
|
|
|
|
|
channels, waits for the messages, and invokes the appropriate callback for |
|
1400
|
|
|
|
|
|
|
every received message. The method returns after you unsubscribed from all the |
|
1401
|
|
|
|
|
|
|
channels. It accepts the following parameters: |
|
1402
|
|
|
|
|
|
|
|
|
1403
|
|
|
|
|
|
|
=over 4 |
|
1404
|
|
|
|
|
|
|
|
|
1405
|
|
|
|
|
|
|
=item default_callback |
|
1406
|
|
|
|
|
|
|
|
|
1407
|
|
|
|
|
|
|
reference to the default callback. This callback is invoked for a message if you |
|
1408
|
|
|
|
|
|
|
didn't specify other callback for the channel this message comes from. |
|
1409
|
|
|
|
|
|
|
|
|
1410
|
|
|
|
|
|
|
=item subscribe |
|
1411
|
|
|
|
|
|
|
|
|
1412
|
|
|
|
|
|
|
an array reference. Contains the list of channels you want to subscribe. A |
|
1413
|
|
|
|
|
|
|
channel name may be optionally followed by the reference to a callback function |
|
1414
|
|
|
|
|
|
|
for this channel. E.g.: |
|
1415
|
|
|
|
|
|
|
|
|
1416
|
|
|
|
|
|
|
[ 'news', 'messages', 'errors' => \&error_cb, 'other' ] |
|
1417
|
|
|
|
|
|
|
|
|
1418
|
|
|
|
|
|
|
channels "news", "messages", and "other" will use default callback, but for |
|
1419
|
|
|
|
|
|
|
the "errors" channel error_cb function will be used. |
|
1420
|
|
|
|
|
|
|
|
|
1421
|
|
|
|
|
|
|
=item psubscribe |
|
1422
|
|
|
|
|
|
|
|
|
1423
|
|
|
|
|
|
|
same as subscribe, but you specify patterns for channels' names. |
|
1424
|
|
|
|
|
|
|
|
|
1425
|
|
|
|
|
|
|
=back |
|
1426
|
|
|
|
|
|
|
|
|
1427
|
|
|
|
|
|
|
All parameters are optional, but you must subscribe at least to one channel. Also |
|
1428
|
|
|
|
|
|
|
if default_callback is not specified, you have to explicitly specify a callback |
|
1429
|
|
|
|
|
|
|
for every channel you are going to subscribe. |
|
1430
|
|
|
|
|
|
|
|
|
1431
|
|
|
|
|
|
|
=cut |
|
1432
|
|
|
|
|
|
|
|
|
1433
|
|
|
|
|
|
|
sub subscription_loop { |
|
1434
|
0
|
|
|
0
|
1
|
|
my ( $self, %args ) = @_; |
|
1435
|
0
|
0
|
|
|
|
|
croak "Already in subscription loop" if $self->{_subscription_loop} > 0; |
|
1436
|
0
|
0
|
|
|
|
|
croak "You can't start subscription loop while in pipelining mode." |
|
1437
|
|
|
|
|
|
|
if $self->replies_to_fetch; |
|
1438
|
0
|
|
0
|
|
|
|
$self->{_subscribed} ||= {}; |
|
1439
|
0
|
|
0
|
|
|
|
$self->{_psubscribed} ||= {}; |
|
1440
|
0
|
|
|
|
|
|
$self->{_subscription_cb} = $args{default_callback}; |
|
1441
|
0
|
|
|
|
|
|
$self->{_subscription_loop} = 1; |
|
1442
|
0
|
|
|
|
|
|
$self->{_parser}->set_default_callback( \&_queue ); |
|
1443
|
|
|
|
|
|
|
|
|
1444
|
0
|
0
|
|
|
|
|
if ( $args{subscribe} ) { |
|
1445
|
0
|
|
|
|
|
|
while ( my $channel = shift @{ $args{subscribe} } ) { |
|
|
0
|
|
|
|
|
|
|
|
1446
|
0
|
|
|
|
|
|
my $cb; |
|
1447
|
0
|
0
|
|
|
|
|
$cb = shift @{ $args{subscribe} } if ref $args{subscribe}[0] eq 'CODE'; |
|
|
0
|
|
|
|
|
|
|
|
1448
|
0
|
|
|
|
|
|
$self->subscribe( $channel, $cb ); |
|
1449
|
|
|
|
|
|
|
} |
|
1450
|
|
|
|
|
|
|
} |
|
1451
|
0
|
0
|
|
|
|
|
if ( $args{psubscribe} ) { |
|
1452
|
0
|
|
|
|
|
|
while ( my $channel = shift @{ $args{psubscribe} } ) { |
|
|
0
|
|
|
|
|
|
|
|
1453
|
0
|
|
|
|
|
|
my $cb; |
|
1454
|
0
|
0
|
|
|
|
|
$cb = shift @{ $args{psubscribe} } if ref $args{psubscribe}[0] eq 'CODE'; |
|
|
0
|
|
|
|
|
|
|
|
1455
|
0
|
|
|
|
|
|
$self->psubscribe( $channel, $cb ); |
|
1456
|
|
|
|
|
|
|
} |
|
1457
|
|
|
|
|
|
|
} |
|
1458
|
|
|
|
|
|
|
croak "You must subscribe at least to one channel" |
|
1459
|
0
|
0
|
0
|
|
|
|
unless ( keys %{ $self->{_subscribed} } or keys %{ $self->{_psubscribed} } ); |
|
|
0
|
|
|
|
|
|
|
|
|
0
|
|
|
|
|
|
|
|
1460
|
|
|
|
|
|
|
|
|
1461
|
0
|
|
|
|
|
|
while ( $self->{_subscription_loop} ) { |
|
1462
|
0
|
|
|
|
|
|
$self->get_reply; |
|
1463
|
|
|
|
|
|
|
} |
|
1464
|
0
|
|
|
|
|
|
return; |
|
1465
|
|
|
|
|
|
|
} |
|
1466
|
|
|
|
|
|
|
|
|
1467
|
|
|
|
|
|
|
=head2 $self->subscribe($channel[, \&callback]) |
|
1468
|
|
|
|
|
|
|
|
|
1469
|
|
|
|
|
|
|
Subscribe to the I<$channel>. If I<$callback> is not specified, default |
|
1470
|
|
|
|
|
|
|
callback will be used in subscription loop, or messages will be returned by |
|
1471
|
|
|
|
|
|
|
I if you are not using subscription loop. |
|
1472
|
|
|
|
|
|
|
|
|
1473
|
|
|
|
|
|
|
=cut |
|
1474
|
|
|
|
|
|
|
|
|
1475
|
|
|
|
|
|
|
sub subscribe { |
|
1476
|
0
|
|
|
0
|
1
|
|
my ( $self, $channel, $callback ) = @_; |
|
1477
|
0
|
0
|
|
|
|
|
unless ( $self->{_subscription_loop} ) { |
|
1478
|
0
|
|
|
|
|
|
$self->{_subscription_loop} = -1; |
|
1479
|
0
|
|
|
|
|
|
$self->{_subscription_cb} = \&_queue; |
|
1480
|
0
|
|
|
|
|
|
$self->{_parser}->set_default_callback( \&_queue ); |
|
1481
|
|
|
|
|
|
|
} |
|
1482
|
0
|
0
|
|
|
|
|
croak "Subscribe to what channel?" unless length $channel; |
|
1483
|
0
|
0
|
|
|
|
|
if ( $self->{_subscription_loop} > 0 ) { |
|
1484
|
|
|
|
|
|
|
$callback ||= $self->{_subscription_cb} |
|
1485
|
0
|
0
|
0
|
|
|
|
or croak "Callback for $channel not specified, neither default callback defined"; |
|
1486
|
|
|
|
|
|
|
} |
|
1487
|
|
|
|
|
|
|
else { |
|
1488
|
0
|
|
0
|
0
|
|
|
$callback ||= sub { 1 }; |
|
|
0
|
|
|
|
|
|
|
|
1489
|
|
|
|
|
|
|
} |
|
1490
|
0
|
|
|
|
|
|
$self->{_subscribed}{$channel} = $callback; |
|
1491
|
0
|
|
|
|
|
|
$self->send_command( "SUBSCRIBE", $channel, \&_queue ); |
|
1492
|
0
|
|
|
|
|
|
return; |
|
1493
|
|
|
|
|
|
|
} |
|
1494
|
|
|
|
|
|
|
|
|
1495
|
|
|
|
|
|
|
=head2 $self->psubscribe($pattern[, \&callback]) |
|
1496
|
|
|
|
|
|
|
|
|
1497
|
|
|
|
|
|
|
Subscribe to channels matching I<$pattern>. If I<$callback> is not specified, |
|
1498
|
|
|
|
|
|
|
default callback will be used in subscription loop, or messages will be |
|
1499
|
|
|
|
|
|
|
returned by I if you are not using subscription loop. |
|
1500
|
|
|
|
|
|
|
|
|
1501
|
|
|
|
|
|
|
=cut |
|
1502
|
|
|
|
|
|
|
|
|
1503
|
|
|
|
|
|
|
sub psubscribe { |
|
1504
|
0
|
|
|
0
|
1
|
|
my ( $self, $channel, $callback ) = @_; |
|
1505
|
0
|
0
|
|
|
|
|
unless ( $self->{_subscription_loop} ) { |
|
1506
|
0
|
|
|
|
|
|
$self->{_subscription_loop} = -1; |
|
1507
|
0
|
|
|
|
|
|
$self->{_subscription_cb} = \&_queue; |
|
1508
|
0
|
|
|
|
|
|
$self->{_parser}->set_default_callback( \&_queue ); |
|
1509
|
|
|
|
|
|
|
} |
|
1510
|
0
|
0
|
|
|
|
|
croak "Subscribe to what channel?" unless length $channel; |
|
1511
|
0
|
0
|
|
|
|
|
if ( $self->{_subscription_loop} > 0 ) { |
|
1512
|
|
|
|
|
|
|
$callback ||= $self->{_subscription_cb} |
|
1513
|
0
|
0
|
0
|
|
|
|
or croak "Callback for $channel not specified, neither default callback defined"; |
|
1514
|
|
|
|
|
|
|
} |
|
1515
|
|
|
|
|
|
|
else { |
|
1516
|
0
|
|
0
|
0
|
|
|
$callback ||= sub { 1 }; |
|
|
0
|
|
|
|
|
|
|
|
1517
|
|
|
|
|
|
|
} |
|
1518
|
0
|
|
|
|
|
|
$self->{_psubscribed}{$channel} = $callback; |
|
1519
|
0
|
|
|
|
|
|
$self->send_command( "PSUBSCRIBE", $channel, \&_queue ); |
|
1520
|
0
|
|
|
|
|
|
return; |
|
1521
|
|
|
|
|
|
|
} |
|
1522
|
|
|
|
|
|
|
|
|
1523
|
|
|
|
|
|
|
=head2 $self->unsubscribe([@channels]) |
|
1524
|
|
|
|
|
|
|
|
|
1525
|
|
|
|
|
|
|
Unsubscribe from the listed I<@channels>. If no channels was specified, |
|
1526
|
|
|
|
|
|
|
unsubscribe from all the channels to which you have subscribed using |
|
1527
|
|
|
|
|
|
|
I. |
|
1528
|
|
|
|
|
|
|
|
|
1529
|
|
|
|
|
|
|
=cut |
|
1530
|
|
|
|
|
|
|
|
|
1531
|
|
|
|
|
|
|
sub unsubscribe { |
|
1532
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1533
|
0
|
0
|
|
|
|
|
if (@_) { |
|
1534
|
0
|
|
|
|
|
|
delete $self->{_subscribed}{$_} for @_; |
|
1535
|
|
|
|
|
|
|
} |
|
1536
|
|
|
|
|
|
|
else { |
|
1537
|
0
|
|
|
|
|
|
$self->{_subscribed} = {}; |
|
1538
|
|
|
|
|
|
|
} |
|
1539
|
0
|
0
|
0
|
|
|
|
if ( %{ $self->{_subscribed} } |
|
|
0
|
|
|
|
|
|
|
|
1540
|
0
|
0
|
|
|
|
|
or %{ $self->{_psubscribed} || {} } ) |
|
1541
|
|
|
|
|
|
|
{ |
|
1542
|
0
|
|
|
|
|
|
return $self->send_command( "UNSUBSCRIBE", @_ ); |
|
1543
|
|
|
|
|
|
|
} |
|
1544
|
|
|
|
|
|
|
else { |
|
1545
|
0
|
|
|
|
|
|
delete $self->{_subscription_loop}; |
|
1546
|
0
|
|
|
|
|
|
$self->{_to_be_fetched} = 0; |
|
1547
|
0
|
|
|
|
|
|
return $self->_connect; |
|
1548
|
|
|
|
|
|
|
} |
|
1549
|
|
|
|
|
|
|
} |
|
1550
|
|
|
|
|
|
|
|
|
1551
|
|
|
|
|
|
|
=head2 $self->punsubscribe([@patterns]) |
|
1552
|
|
|
|
|
|
|
|
|
1553
|
|
|
|
|
|
|
Unsubscribe from the listed I<@patterns>. If no patterns was specified, |
|
1554
|
|
|
|
|
|
|
unsubscribe from all the channels to which you have subscribed using |
|
1555
|
|
|
|
|
|
|
I. |
|
1556
|
|
|
|
|
|
|
|
|
1557
|
|
|
|
|
|
|
=cut |
|
1558
|
|
|
|
|
|
|
|
|
1559
|
|
|
|
|
|
|
sub punsubscribe { |
|
1560
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1561
|
0
|
0
|
|
|
|
|
if (@_) { |
|
1562
|
0
|
|
|
|
|
|
delete $self->{_psubscribed}{$_} for @_; |
|
1563
|
|
|
|
|
|
|
} |
|
1564
|
|
|
|
|
|
|
else { |
|
1565
|
0
|
|
|
|
|
|
$self->{_psubscribed} = {}; |
|
1566
|
|
|
|
|
|
|
} |
|
1567
|
0
|
0
|
0
|
|
|
|
if ( %{ $self->{_subscribed} || {} } |
|
|
0
|
0
|
|
|
|
|
|
|
1568
|
0
|
|
|
|
|
|
or %{ $self->{_psubscribed} } ) |
|
1569
|
|
|
|
|
|
|
{ |
|
1570
|
0
|
|
|
|
|
|
return $self->send_command( "PUNSUBSCRIBE", @_ ); |
|
1571
|
|
|
|
|
|
|
} |
|
1572
|
|
|
|
|
|
|
else { |
|
1573
|
0
|
|
|
|
|
|
delete $self->{_subscription_loop}; |
|
1574
|
0
|
|
|
|
|
|
$self->{_to_be_fetched} = 0; |
|
1575
|
0
|
|
|
|
|
|
return $self->_connect; |
|
1576
|
|
|
|
|
|
|
} |
|
1577
|
|
|
|
|
|
|
} |
|
1578
|
|
|
|
|
|
|
|
|
1579
|
|
|
|
|
|
|
=head2 $self->subscribed |
|
1580
|
|
|
|
|
|
|
|
|
1581
|
|
|
|
|
|
|
Return list of channels to which you have subscribed using I |
|
1582
|
|
|
|
|
|
|
|
|
1583
|
|
|
|
|
|
|
=cut |
|
1584
|
|
|
|
|
|
|
|
|
1585
|
|
|
|
|
|
|
sub subscribed { |
|
1586
|
0
|
|
|
0
|
1
|
|
return keys %{ shift->{_subscribed} }; |
|
|
0
|
|
|
|
|
|
|
|
1587
|
|
|
|
|
|
|
} |
|
1588
|
|
|
|
|
|
|
|
|
1589
|
|
|
|
|
|
|
=head2 $self->psubscribed |
|
1590
|
|
|
|
|
|
|
|
|
1591
|
|
|
|
|
|
|
Return list of channels to which you have subscribed using I |
|
1592
|
|
|
|
|
|
|
|
|
1593
|
|
|
|
|
|
|
=cut |
|
1594
|
|
|
|
|
|
|
|
|
1595
|
|
|
|
|
|
|
sub psubscribed { |
|
1596
|
0
|
|
|
0
|
1
|
|
return keys %{ shift->{_psubscribed} }; |
|
|
0
|
|
|
|
|
|
|
|
1597
|
|
|
|
|
|
|
} |
|
1598
|
|
|
|
|
|
|
|
|
1599
|
|
|
|
|
|
|
=head1 TRANSACTIONS |
|
1600
|
|
|
|
|
|
|
|
|
1601
|
|
|
|
|
|
|
Transactions allow you to execute a sequence of commands in a single step. In |
|
1602
|
|
|
|
|
|
|
order to start a transaction you should use the I method. After you |
|
1603
|
|
|
|
|
|
|
have entered a transaction all the commands you issue are queued, but not |
|
1604
|
|
|
|
|
|
|
executed till you call the I method. Typically these commands return |
|
1605
|
|
|
|
|
|
|
string "QUEUED" as a result, but if there is an error in e.g. number of |
|
1606
|
|
|
|
|
|
|
arguments, they may return an error. When you call exec, all the queued |
|
1607
|
|
|
|
|
|
|
commands will be executed and exec will return a list of results for every |
|
1608
|
|
|
|
|
|
|
command in the transaction. If instead of I you call I, all |
|
1609
|
|
|
|
|
|
|
scheduled commands will be canceled. |
|
1610
|
|
|
|
|
|
|
|
|
1611
|
|
|
|
|
|
|
You can set some keys as watched. If any watched key has been changed by |
|
1612
|
|
|
|
|
|
|
another client before you called exec, the transaction will be discarded and |
|
1613
|
|
|
|
|
|
|
exec will return false value. |
|
1614
|
|
|
|
|
|
|
|
|
1615
|
|
|
|
|
|
|
=cut |
|
1616
|
|
|
|
|
|
|
|
|
1617
|
|
|
|
|
|
|
=head2 $self->watch(@keys[, \&callback]) |
|
1618
|
|
|
|
|
|
|
|
|
1619
|
|
|
|
|
|
|
mark given keys to be watched |
|
1620
|
|
|
|
|
|
|
|
|
1621
|
|
|
|
|
|
|
=cut |
|
1622
|
|
|
|
|
|
|
|
|
1623
|
|
|
|
|
|
|
sub watch { |
|
1624
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1625
|
|
|
|
|
|
|
|
|
1626
|
0
|
|
|
|
|
|
$self->{_watching} = 1; |
|
1627
|
0
|
0
|
|
|
|
|
if ( ref $_[-1] eq 'CODE' ) { |
|
1628
|
0
|
|
|
|
|
|
return $self->send_command( 'WATCH', @_ ); |
|
1629
|
|
|
|
|
|
|
} |
|
1630
|
|
|
|
|
|
|
else { |
|
1631
|
0
|
|
|
|
|
|
return $self->execute( 'WATCH', @_ ); |
|
1632
|
|
|
|
|
|
|
} |
|
1633
|
|
|
|
|
|
|
} |
|
1634
|
|
|
|
|
|
|
|
|
1635
|
|
|
|
|
|
|
=head2 $self->unwatch([\&callback]) |
|
1636
|
|
|
|
|
|
|
|
|
1637
|
|
|
|
|
|
|
unwatch all keys |
|
1638
|
|
|
|
|
|
|
|
|
1639
|
|
|
|
|
|
|
=cut |
|
1640
|
|
|
|
|
|
|
|
|
1641
|
|
|
|
|
|
|
sub unwatch { |
|
1642
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1643
|
|
|
|
|
|
|
|
|
1644
|
0
|
|
|
|
|
|
my $res; |
|
1645
|
0
|
0
|
|
|
|
|
if ( ref $_[-1] eq 'CODE' ) { |
|
1646
|
0
|
|
|
|
|
|
$res = $self->send_command( 'UNWATCH', @_ ); |
|
1647
|
|
|
|
|
|
|
} |
|
1648
|
|
|
|
|
|
|
else { |
|
1649
|
0
|
|
|
|
|
|
$res = $self->execute( 'UNWATCH', @_ ); |
|
1650
|
|
|
|
|
|
|
} |
|
1651
|
0
|
|
|
|
|
|
$self->{_watching} = undef; |
|
1652
|
0
|
|
|
|
|
|
return $res; |
|
1653
|
|
|
|
|
|
|
} |
|
1654
|
|
|
|
|
|
|
|
|
1655
|
|
|
|
|
|
|
=head2 $self->multi([\&callback]) |
|
1656
|
|
|
|
|
|
|
|
|
1657
|
|
|
|
|
|
|
Enter the transaction. After this and till I or I will be called, |
|
1658
|
|
|
|
|
|
|
all the commands will be queued but not executed. |
|
1659
|
|
|
|
|
|
|
|
|
1660
|
|
|
|
|
|
|
=cut |
|
1661
|
|
|
|
|
|
|
|
|
1662
|
|
|
|
|
|
|
sub multi { |
|
1663
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1664
|
|
|
|
|
|
|
|
|
1665
|
0
|
0
|
|
|
|
|
die "Multi calls can not be nested!" if $self->{_in_multi}; |
|
1666
|
0
|
|
|
|
|
|
$self->{_in_multi} = 1; |
|
1667
|
0
|
0
|
|
|
|
|
if ( ref $_[-1] eq 'CODE' ) { |
|
1668
|
0
|
|
|
|
|
|
return $self->send_command( 'MULTI', @_ ); |
|
1669
|
|
|
|
|
|
|
} |
|
1670
|
|
|
|
|
|
|
else { |
|
1671
|
0
|
|
|
|
|
|
return $self->execute('MULTI'); |
|
1672
|
|
|
|
|
|
|
} |
|
1673
|
|
|
|
|
|
|
} |
|
1674
|
|
|
|
|
|
|
|
|
1675
|
|
|
|
|
|
|
=head2 $self->exec([\&callback]) |
|
1676
|
|
|
|
|
|
|
|
|
1677
|
|
|
|
|
|
|
Execute all queued commands and finish the transaction. Returns a list of |
|
1678
|
|
|
|
|
|
|
results for every command. Will croak if some command has failed. Also |
|
1679
|
|
|
|
|
|
|
unwatches all the keys. If some of the watched keys has been changed by other |
|
1680
|
|
|
|
|
|
|
client, the transaction will be canceled and I will return false. |
|
1681
|
|
|
|
|
|
|
|
|
1682
|
|
|
|
|
|
|
=cut |
|
1683
|
|
|
|
|
|
|
|
|
1684
|
|
|
|
|
|
|
sub exec { |
|
1685
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1686
|
|
|
|
|
|
|
|
|
1687
|
0
|
|
|
|
|
|
my $res; |
|
1688
|
0
|
0
|
|
|
|
|
if ( ref $_[-1] eq 'CODE' ) { |
|
1689
|
0
|
|
|
|
|
|
$res = $self->send_command( 'EXEC', @_ ); |
|
1690
|
|
|
|
|
|
|
} |
|
1691
|
|
|
|
|
|
|
else { |
|
1692
|
0
|
|
|
|
|
|
$res = $self->execute('EXEC'); |
|
1693
|
|
|
|
|
|
|
} |
|
1694
|
0
|
|
|
|
|
|
$self->{_in_multi} = undef; |
|
1695
|
0
|
|
|
|
|
|
$self->{_watching} = undef; |
|
1696
|
0
|
|
|
|
|
|
return $res; |
|
1697
|
|
|
|
|
|
|
} |
|
1698
|
|
|
|
|
|
|
|
|
1699
|
|
|
|
|
|
|
=head2 $self->discard([\&callback]) |
|
1700
|
|
|
|
|
|
|
|
|
1701
|
|
|
|
|
|
|
Discard all queued commands without executing them and unwatch all keys. |
|
1702
|
|
|
|
|
|
|
|
|
1703
|
|
|
|
|
|
|
=cut |
|
1704
|
|
|
|
|
|
|
|
|
1705
|
|
|
|
|
|
|
sub discard { |
|
1706
|
0
|
|
|
0
|
1
|
|
my $self = shift; |
|
1707
|
|
|
|
|
|
|
|
|
1708
|
0
|
|
|
|
|
|
my $res; |
|
1709
|
0
|
0
|
|
|
|
|
if ( ref $_[-1] eq 'CODE' ) { |
|
1710
|
0
|
|
|
|
|
|
$res = $self->send_command( 'DISCARD', @_ ); |
|
1711
|
|
|
|
|
|
|
} |
|
1712
|
|
|
|
|
|
|
else { |
|
1713
|
0
|
|
|
|
|
|
$res = $self->execute('DISCARD'); |
|
1714
|
|
|
|
|
|
|
} |
|
1715
|
0
|
|
|
|
|
|
$self->{_in_multi} = undef; |
|
1716
|
0
|
|
|
|
|
|
$self->{_watching} = undef; |
|
1717
|
0
|
|
|
|
|
|
return $res; |
|
1718
|
|
|
|
|
|
|
} |
|
1719
|
|
|
|
|
|
|
|
|
1720
|
|
|
|
|
|
|
=head1 CLUSTER SUPPORT |
|
1721
|
|
|
|
|
|
|
|
|
1722
|
|
|
|
|
|
|
For accessing redis cluster use L package |
|
1723
|
|
|
|
|
|
|
|
|
1724
|
|
|
|
|
|
|
=head1 SENTINEL SUPPORT |
|
1725
|
|
|
|
|
|
|
|
|
1726
|
|
|
|
|
|
|
For accessing redis servers managed by sentinel use L package |
|
1727
|
|
|
|
|
|
|
|
|
1728
|
|
|
|
|
|
|
=cut |
|
1729
|
|
|
|
|
|
|
|
|
1730
|
|
|
|
|
|
|
1; |
|
1731
|
|
|
|
|
|
|
|
|
1732
|
|
|
|
|
|
|
__END__ |