From: Dobrica Pavlinusic Date: Sun, 22 Mar 2009 18:07:46 +0000 (+0000) Subject: REDIS enviroment variable controlls debug output X-Git-Tag: 0.0801~26 X-Git-Url: http://git.rot13.org/?p=perl-Redis.git;a=commitdiff_plain;h=8834a0a9ea5b9ac45bd020405ac7a2aea6ee3046;hp=a3369adfe29f184cd6805caa4f33a7f163f6f152;ds=sidebyside REDIS enviroment variable controlls debug output git-svn-id: svn+ssh://llin/home/dpavlin/private/svn/Redis@37 447b33ff-793d-4489-8442-9bea7d161be5 --- diff --git a/lib/Redis.pm b/lib/Redis.pm index 88ba139..6f3f3e6 100644 --- a/lib/Redis.pm +++ b/lib/Redis.pm @@ -33,6 +33,8 @@ L =cut +our $debug = $ENV{REDIS} || 0; + our $sock; my $server = '127.0.0.1:6379'; @@ -53,19 +55,19 @@ sub new { sub _sock_result { my $result = <$sock>; - warn "# result: ",dump( $result ); + warn "## result: ",dump( $result ) if $debug; $result =~ s{\r\n$}{} || warn "can't find cr/lf"; return $result; } sub _sock_read_bulk { my $len = <$sock>; - warn "## bulk len: ",dump($len); + warn "## bulk len: ",dump($len) if $debug; return undef if $len eq "nil\r\n"; my $v; if ( $len > 0 ) { read($sock, $v, $len) || die $!; - warn "## bulk v: ",dump($v); + warn "## bulk v: ",dump($v) if $debug; } my $crlf; read($sock, $crlf, 2); # skip cr/lf @@ -74,14 +76,14 @@ sub _sock_read_bulk { sub _sock_result_bulk { my $self = shift; - warn "## _sock_result_bulk ",dump( @_ ); + warn "## _sock_result_bulk ",dump( @_ ) if $debug; print $sock join(' ',@_) . "\r\n"; _sock_read_bulk(); } sub _sock_result_bulk_list { my $self = shift; - warn "## _sock_result_bulk_list ",dump( @_ ); + warn "## _sock_result_bulk_list ",dump( @_ ) if $debug; my $size = $self->_sock_send( @_ ); confess $size unless $size > 0; @@ -92,7 +94,7 @@ sub _sock_result_bulk_list { $list[ $_ ] = _sock_read_bulk(); } - warn "## list = ", dump( @list ); + warn "## list = ", dump( @list ) if $debug; return @list; } @@ -104,21 +106,21 @@ sub __sock_ok { sub _sock_send { my $self = shift; - warn "## _sock_send ",dump( @_ ); + warn "## _sock_send ",dump( @_ ) if $debug; print $sock join(' ',@_) . "\r\n"; _sock_result(); } sub _sock_send_ok { my $self = shift; - warn "## _sock_send_ok ",dump( @_ ); + warn "## _sock_send_ok ",dump( @_ ) if $debug; print $sock join(' ',@_) . "\r\n"; __sock_ok(); } sub __sock_send_bulk_raw { my $self = shift; - warn "## _sock_send_bulk ",dump( @_ ); + warn "## _sock_send_bulk ",dump( @_ ) if $debug; my $value = pop; $value = '' unless defined $value; # FIXME errr? nil? print $sock join(' ',@_) . ' ' . length($value) . "\r\n$value\r\n"