This is an automated email from the git hooks/post-receive script. It was
generated because a ref change was pushed to the repository containing
the project "Tarantool -- an efficient key/value data store".
The branch perl-iproto-async has been updated
via 4913bf2dc614cd3b77baba9d49abcd4523fc3a0f (commit)
from bdf4e0e392e256604cc24b6e7c95f0727803c94a (commit)
Summary of changes:
.../client/perl/lib/MR/IProto/Connection/Sync.pm | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
commit 4913bf2dc614cd3b77baba9d49abcd4523fc3a0f
Author: Aleksey Mashanov <[email protected]>
Date: Mon Mar 21 17:06:21 2011 +0300
Call callbacks only on messages sent in broken connection
diff --git a/mod/silverbox/client/perl/lib/MR/IProto/Connection/Sync.pm
b/mod/silverbox/client/perl/lib/MR/IProto/Connection/Sync.pm
index 88377be..7094cad 100644
--- a/mod/silverbox/client/perl/lib/MR/IProto/Connection/Sync.pm
+++ b/mod/silverbox/client/perl/lib/MR/IProto/Connection/Sync.pm
@@ -218,10 +218,11 @@ sub _handle_error {
$self->_clear_socket();
}
$server->active(0);
+ my $sent = $self->_sent;
+ my @sent = splice @$sent, 0, $#$sent;
$server->_recv_finished($sync, undef, undef, $error);
$callback->(undef, undef, $error);
- my $sent = $self->_sent;
- while (my $args = shift @$sent) {
+ foreach my $args (@sent) {
my ($sync, $callback) = @$args;
$server->_recv_finished($sync, undef, undef, $error);
$callback->(undef, undef, $error);
--
Tarantool -- an efficient key/value data store
_______________________________________________
Mailing list: https://launchpad.net/~tarantool-developers
Post to : [email protected]
Unsubscribe : https://launchpad.net/~tarantool-developers
More help : https://help.launchpad.net/ListHelp
