--- lib/Redis.pm 2009/03/22 13:44:19 27 +++ lib/Redis.pm 2009/03/22 17:02:46 30 @@ -63,8 +63,10 @@ warn "## bulk len: ",dump($len); return undef if $len eq "nil\r\n"; my $v; - read($sock, $v, $len) || die $!; - warn "## bulk v: ",dump($v); + if ( $len > 0 ) { + read($sock, $v, $len) || die $!; + warn "## bulk v: ",dump($v); + } my $crlf; read($sock, $crlf, 2); # skip cr/lf return $v; @@ -79,6 +81,7 @@ sub __sock_ok { my $ok = <$sock>; + return undef if $ok eq "nil\r\n"; confess dump($ok) unless $ok eq "+OK\r\n"; } @@ -100,7 +103,8 @@ my $self = shift; warn "## _sock_send_bulk ",dump( @_ ); my $value = pop; - print $sock join(' ',@_) . ' ' . length($value) . "\r\n$value\r\n"; + $value = '' unless defined $value; # FIXME errr? nil? + print $sock join(' ',@_) . ' ' . length($value) . "\r\n$value\r\n" } sub _sock_send_bulk { @@ -379,7 +383,7 @@ sub lpop { my ( $self, $key ) = @_; - $self->_sock_result_bulk( 'lpop', $key ); + $self->_sock_result_bulk( 'LPOP', $key ); } =head2 rpop @@ -390,7 +394,31 @@ sub rpop { my ( $self, $key ) = @_; - $self->_sock_result_bulk( 'rpop', $key ); + $self->_sock_result_bulk( 'RPOP', $key ); +} + +=head1 Commands operating on sets + +=head2 sadd + + $r->sadd( $key, $member ); + +=cut + +sub sadd { + my ( $self, $key, $member ) = @_; + $self->_sock_send_bulk_number( 'SADD', $key, $member ); +} + +=head2 srem + + $r->srem( $key, $member ); + +=cut + +sub srem { + my ( $self, $key, $member ) = @_; + $self->_sock_send_bulk_number( 'SREM', $key, $member ); } =head1 AUTHOR