return rsync xfer errors to client
authorDobrica Pavlinusic <dpavlin@rot13.org>
Thu, 8 Sep 2011 18:46:31 +0000 (18:46 +0000)
committerDobrica Pavlinusic <dpavlin@rot13.org>
Thu, 8 Sep 2011 18:56:36 +0000 (18:56 +0000)
by simple writing to STDOUT instead to STDERR

lib/CloudStore/Couchbase.pm
rsync-xfer-trigger.pl

index 9afb6d0..5016789 100644 (file)
@@ -28,7 +28,7 @@ sub new {
                my $port = $buckets->{$bucket};
                my $server = new Cache::Memcached {
                        'servers' => [ "127.0.0.1:$port" ],
-                       'debug' => $ENV{DEBUG},
+                       'debug' => $ENV{DEBUG} > 3,
                #       'compress_threshold' => 10_000,
                };
                #$server->set_servers($array_ref);
@@ -48,14 +48,14 @@ sub json_set {
        confess "data not ref ",dump($data) unless ref $data;
        my $json = encode_json $data;
        $self->{$bucket}->set( $key => $json );
-       warn "## $bucket set $key $json\n";
+       warn "## json_set $bucket $key $json\n";
        return $json;
 }
 
 sub json_get {
        my ($self,$bucket,$key,$data) = @_;
        if ( my $json = $self->{$bucket}->get($key) ) {
-               warn "## $bucket get $key $json\n";
+               warn "## json_get $bucket $key $json\n";
                return decode_json $json;
        }
 }
@@ -80,6 +80,7 @@ sub status {
        $login = $login->{login} if ref $login;
        if ( $message ) {
                $self->{session}->set( "$login:status" => $message );
+               return $message;
        } else {
                $self->{session}->get( "$login:status" );
        }
index a6478f5..97018e4 100755 (executable)
@@ -15,7 +15,7 @@ my $user  = $store->user_get($login);
 
 my $ok = $user->{usage} <= $user->{quota};
 
-warn $store->status( $login => sprintf 'usage: %s %d %s %d'
+print "$login ", $store->status( $login => sprintf 'quota: %s %d %s %d'
        , ( $ok ? 'OK' : 'ERROR' )
        , $user->{usage}
        , ( $ok ? '<=' : '>' )
@@ -23,5 +23,5 @@ warn $store->status( $login => sprintf 'usage: %s %d %s %d'
 ),$/;
 
 my $exit = $ok ? 0 : 1;
-warn "# exit $exit";
+warn "# exit $exit" if $ENV{DEBUG};
 exit $exit;