Changeset 4440 for trunk/Nebulous-Server
- Timestamp:
- Jun 29, 2005, 4:35:06 PM (21 years ago)
- Location:
- trunk/Nebulous-Server
- Files:
-
- 42 edited
-
Build.PL (modified) (1 diff)
-
MANIFEST (modified) (3 diffs)
-
Todo (modified) (1 diff)
-
docs/apache_setup.txt (modified) (4 diffs)
-
docs/setup.txt (modified) (1 diff)
-
lib/Nebulous/Server.pm (modified) (3 diffs)
-
lib/Nebulous/Server.pod (modified) (2 diffs)
-
lib/Nebulous/Server/Apache.pm (modified) (2 diffs)
-
lib/Nebulous/Server/Log.pm (modified) (2 diffs)
-
lib/Nebulous/Server/SOAP.pm (modified) (3 diffs)
-
lib/Nebulous/Server/SQL.pm (modified) (1 diff)
-
nebulous.wsdl (modified) (2 diffs)
-
scripts/bench_test.pl (modified) (2 diffs)
-
scripts/imageserver.pl (modified) (1 diff)
-
scripts/ptest.pl (modified) (3 diffs)
-
scripts/stest.pl (modified) (2 diffs)
-
t/01_load.t (modified) (2 diffs)
-
t/02_server_setup.t (modified) (4 diffs)
-
t/03_server_create_object.t (modified) (7 diffs)
-
t/04_server_replicate_object.t (modified) (6 diffs)
-
t/05_server_lock_object.t (modified) (3 diffs)
-
t/06_server_unlock_object.t (modified) (3 diffs)
-
t/07_server_find_instances.t (modified) (4 diffs)
-
t/08_server_delete_instance.t (modified) (3 diffs)
-
t/09_server_stat_object.t (modified) (4 diffs)
-
t/10_client_new.t (modified) (3 diffs)
-
t/11_client_create.t (modified) (2 diffs)
-
t/12_client_replicate.t (modified) (5 diffs)
-
t/13_client_cull.t (modified) (8 diffs)
-
t/14_client_lock.t (modified) (10 diffs)
-
t/15_client_unlock.t (modified) (2 diffs)
-
t/16_client_find_instances.t (modified) (6 diffs)
-
t/17_client_find.t (modified) (2 diffs)
-
t/18_client_open.t (modified) (2 diffs)
-
t/19_client_delete.t (modified) (2 diffs)
-
t/20_client_copy.t (modified) (3 diffs)
-
t/21_client_move.t (modified) (3 diffs)
-
t/22_client_delete_instance.t (modified) (4 diffs)
-
t/23_client_stat.t (modified) (3 diffs)
-
t/apache_03_server_create_object.x (modified) (5 diffs)
-
t/apache_04_server_replicate_object.x (modified) (4 diffs)
-
t/apache_05_server_lock_object.x (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Nebulous-Server/Build.PL
r3004 r4440 7 7 8 8 $build_pkg->new( 9 module_name => ' PS::IPP::IData',10 dist_version_from => 'lib/ PS/IPP/IData/Server.pm',9 module_name => 'Nebulous', 10 dist_version_from => 'lib/Nebulous/Server.pm', 11 11 author => 'Joshua Hoblitt <jhoblitt@cpan.org>', 12 12 license => 'gpl', -
trunk/Nebulous-Server/MANIFEST
r4118 r4440 7 7 README 8 8 Todo 9 bootstrap.sh10 9 docs/apache_setup.txt 11 10 docs/c_api.h … … 16 15 docs/setup.txt 17 16 docs/tmp.txt 18 gsoap/ idata.wsdl19 lib/ PS/IPP/IData/Client.pm20 lib/ PS/IPP/IData/Client/HTTP.pm21 lib/ PS/IPP/IData/Client/Log.pm22 lib/ PS/IPP/IData/Server.pm23 lib/ PS/IPP/IData/Server/Apache.pm24 lib/ PS/IPP/IData/Server/Log.pm25 lib/ PS/IPP/IData/Server/SQL.pm26 lib/ PS/IPP/IData/Util.pm17 gsoap/nebulous.wsdl 18 lib/Nebulous/Client.pm 19 lib/Nebulous/Client/HTTP.pm 20 lib/Nebulous/Client/Log.pm 21 lib/Nebulous/Server.pm 22 lib/Nebulous/Server/Apache.pm 23 lib/Nebulous/Server/Log.pm 24 lib/Nebulous/Server/SQL.pm 25 lib/Nebulous/Util.pm 27 26 scripts/bench_test.pl 28 27 scripts/imageserver.pl … … 45 44 t/15_client_unlock.t 46 45 t/16_client_find_instances.t 46 t/17_client_find.t 47 t/18_client_open.t 48 t/19_client_delete.t 49 t/20_client_copy.t 50 t/21_client_move.t 51 t/22_client_delete_instance.t 52 t/23_client_stat.t 47 53 t/TEST.PL 48 t/Test/ IData.pm54 t/Test/Nebulous.pm 49 55 t/apache_03_server_create_object.x 50 56 t/apache_04_server_replicate_object.x 51 57 t/apache_05_server_lock_object.x 52 58 t/conf/extra.conf.in 59 t/conf/startup.pl.in -
trunk/Nebulous-Server/Todo
r3013 r4440 1 TODO list for Perl module PS::IPP::IData1 TODO list for Perl module Nebulous 2 2 3 3 - redo database scheme with foreign keys -
trunk/Nebulous-Server/docs/apache_setup.txt
r2997 r4440 1 1 # Copyright (C) 2004-2005 Joshua Hoblitt 2 2 # 3 # $Id: apache_setup.txt,v 1. 2 2005-01-14 21:23:35 jhoblitt Exp $3 # $Id: apache_setup.txt,v 1.3 2005-06-30 02:35:05 jhoblitt Exp $ 4 4 5 5 - mod_perl-1.29 install … … 8 8 #MP_TRACE = 1 MP_DEBUG = 1 MP_USE_DSO = 1 MP_INST_APACHE2 = 1 MP_APXS = /usr/sbin/apxs2 9 9 10 - add the "idata" group to /etc/group 11 - configure Apache to run as the idata group. 10 - add the "nebulous" group to /etc/group 11 - configure Apache to run as the nebulous group. 12 13 # out of data from here down... 12 14 13 15 # … … 15 17 # 16 18 17 ScriptAlias / idata/usr/local/apache/perl/imageserver.pl19 ScriptAlias /nebulous /usr/local/apache/perl/imageserver.pl 18 20 19 21 <Directory "/usr/local/apache/perl"> … … 34 36 35 37 # 36 # PS::IPP::IData::Apache interface38 # Nebulous::Apache interface 37 39 # 38 40 39 41 PerlModule Apache::DBI 40 PerlModule PS::IPP::IData::Apache42 PerlModule Nebulous::Apache 41 43 42 <Location / idata>44 <Location /nebulous> 43 45 SetHandler perl-script 44 PerlHandler PS::IPP::IData::Apache46 PerlHandler Nebulous::Apache 45 47 </Location> 46 48 -
trunk/Nebulous-Server/docs/setup.txt
r4119 r4440 33 33 34 34 35 mkdir /po01/ idata36 chown root: idata /po01/idata37 chmod 0770 /po01/ idata35 mkdir /po01/nebulous 36 chown root:nebulous /po01/nebulous 37 chmod 0770 /po01/nebulous 38 38 39 39 in /etc/mysql/my.cnf -
trunk/Nebulous-Server/lib/Nebulous/Server.pm
r2905 r4440 1 1 # Copyright (c) 2004 Joshua Hoblitt 2 2 # 3 # $Id: Server.pm,v 1. 8 2005-01-05 04:31:59jhoblitt Exp $4 5 package PS::IPP::IData::Server;3 # $Id: Server.pm,v 1.9 2005-06-30 02:35:06 jhoblitt Exp $ 4 5 package Nebulous::Server; 6 6 7 7 use strict; … … 11 11 12 12 use DBI; 13 use PS::IPP::IData::Util qw( :standard );14 use PS::IPP::IData::Server::Log;15 use PS::IPP::IData::Server::SQL;13 use Nebulous::Util qw( :standard ); 14 use Nebulous::Server::Log; 15 use Nebulous::Server::SQL; 16 16 use Log::Log4perl; 17 17 use Params::Validate qw( validate_pos SCALAR ); … … 40 40 ); 41 41 42 $log = Log::Log4perl::get_logger( " PS::IPP::IData::Server" );43 $sql = PS::IPP::IData::Server::SQL->new;42 $log = Log::Log4perl::get_logger( "Nebulous::Server" ); 43 $sql = Nebulous::Server::SQL->new; 44 44 45 45 $log->debug( "entered - @_" ); -
trunk/Nebulous-Server/lib/Nebulous/Server.pod
r2863 r4440 3 3 =head1 NAME 4 4 5 PS::IPP::IData::Server - iDataserver component5 Nebulous::Server - Nebulous server component 6 6 7 7 =head1 SYNOPSIS 8 8 9 use PS::IPP::IData::Server;9 use Nebulous::Server; 10 10 11 PS::IPP::IData::Server->setup( $dsn, $username, $passwd );12 PS::IPP::IData::Server->create_object( $key, $class, $volume, $comment );13 PS::IPP::IData::Server->replicate_object( $key, $volume );14 PS::IPP::IData::Server->lock_object( $key, $type );15 PS::IPP::IData::Server->unlock_object( $key, $type );16 PS::IPP::IData::Server->find_instance( $key, $volume );17 PS::IPP::IData::Server->delete_instance( $uri );18 PS::IPP::IData::Server->stat_object( $key );11 Nebulous::Server->setup( $dsn, $username, $passwd ); 12 Nebulous::Server->create_object( $key, $class, $volume, $comment ); 13 Nebulous::Server->replicate_object( $key, $volume ); 14 Nebulous::Server->lock_object( $key, $type ); 15 Nebulous::Server->unlock_object( $key, $type ); 16 Nebulous::Server->find_instance( $key, $volume ); 17 Nebulous::Server->delete_instance( $uri ); 18 Nebulous::Server->stat_object( $key ); 19 19 20 20 =head1 DESCRIPTION 21 21 22 This is the server side component of the iDatasystem. It is primarily a22 This is the server side component of the Nebulous system. It is primarily a 23 23 middle-ware abstraction of an SQL database. 24 24 … … 120 120 =head1 SEE ALSO 121 121 122 L< PS::IPP::IData::Client>122 L<Nebulous::Client> 123 123 124 124 =cut -
trunk/Nebulous-Server/lib/Nebulous/Server/Apache.pm
r2918 r4440 3 3 # $Id 4 4 5 package PS::IPP::IData::Server::Apache;5 package Nebulous::Server::Apache; 6 6 7 7 use strict; … … 10 10 our $VERSION = 0.01; 11 11 12 use PS::IPP::IData::Server::SOAP;12 use Nebulous::Server::SOAP; 13 13 use SOAP::Transport::HTTP; 14 14 15 15 my $server = SOAP::Transport::HTTP::Apache 16 ->dispatch_to( ' PS::IPP::IData::Server::SOAP' )16 ->dispatch_to( 'Nebulous::Server::SOAP' ) 17 17 ->options({ compress_threshold => 10 * 1024 }); 18 18 -
trunk/Nebulous-Server/lib/Nebulous/Server/Log.pm
r2898 r4440 1 1 # Copyright (c) 2004 Joshua Hoblitt 2 2 # 3 # $Id: Log.pm,v 1. 2 2005-01-05 02:44:54jhoblitt Exp $3 # $Id: Log.pm,v 1.3 2005-06-30 02:35:06 jhoblitt Exp $ 4 4 5 package PS::IPP::IData::Server::Log;5 package Nebulous::Server::Log; 6 6 7 7 use strict; … … 13 13 14 14 my $conf = q( 15 log4perl.category. PS.IPP.IData.Server = DEBUG, SERVERLOGFILE15 log4perl.category.Nebulous.Server = DEBUG, SERVERLOGFILE 16 16 17 17 log4perl.appender.SERVERLOGFILE = Log::Log4perl::Appender::File 18 log4perl.appender.SERVERLOGFILE.filename = /tmp/ idata_server.log18 log4perl.appender.SERVERLOGFILE.filename = /tmp/nebulous_server.log 19 19 log4perl.appender.SERVERLOGFILE.mode = append 20 20 log4perl.appender.SERVERLOGFILE.layout = Log::Log4perl::Layout::PatternLayout -
trunk/Nebulous-Server/lib/Nebulous/Server/SOAP.pm
r2917 r4440 1 1 # Copyright (c) 2004 Joshua Hoblitt 2 2 # 3 # $Id: SOAP.pm,v 1. 1 2005-01-06 03:56:43jhoblitt Exp $3 # $Id: SOAP.pm,v 1.2 2005-06-30 02:35:06 jhoblitt Exp $ 4 4 5 package PS::IPP::IData::Server::SOAP;5 package Nebulous::Server::SOAP; 6 6 7 7 use strict; … … 10 10 our $VERSION = '0.01'; 11 11 12 use PS::IPP::IData::Server;12 use Nebulous::Server; 13 13 use SOAP::Lite; 14 14 import SOAP::Data 'name'; … … 22 22 return undef if $method eq 'DESTROY'; 23 23 24 return name( result => PS::IPP::IData::Server->$method( @_ ) );24 return name( result => Nebulous::Server->$method( @_ ) ); 25 25 } 26 26 -
trunk/Nebulous-Server/lib/Nebulous/Server/SQL.pm
r3016 r4440 1 1 # Copyright (c) 2004 Joshua Hoblitt 2 2 # 3 # $Id: SQL.pm,v 1. 4 2005-01-15 04:02:12jhoblitt Exp $3 # $Id: SQL.pm,v 1.5 2005-06-30 02:35:06 jhoblitt Exp $ 4 4 5 package PS::IPP::IData::Server::SQL;5 package Nebulous::Server::SQL; 6 6 7 7 use strict; -
trunk/Nebulous-Server/nebulous.wsdl
r2785 r4440 1 1 <?xml version="1.0"?> 2 2 3 <definitions name=" idata" targetNamespace="http://pan-starrs.ifa.hawaii.edu/PS/IPP/IData/Server">3 <definitions name="nebulous" targetNamespace="http://pan-starrs.ifa.hawaii.edu/Nebulous/Server"> 4 4 5 5 <types> 6 <schema targetNamespace="http://pan-starrs.ifa.hawaii.edu/ PS/IPP/IData/Server"6 <schema targetNamespace="http://pan-starrs.ifa.hawaii.edu/Nebulous/Server" 7 7 xmlns="http://www.w3.org/1999/XMLSchema"> 8 8 … … 53 53 </portType> 54 54 55 <binding name=" idataSoapBinding"56 type="es:Get idatarPortType">55 <binding name="nebulousSoapBinding" 56 type="es:GetnebulousrPortType"> 57 57 58 58 <soap:binding style="document" 59 59 transport="http://schemas.xmlsoap.org/soap/http"/> 60 60 61 <operation name="Get idata">61 <operation name="Getnebulous"> 62 62 <soap:operation 63 63 soapAction="http://www.snowboard-info.com/EndorsementSearch"/> -
trunk/Nebulous-Server/scripts/bench_test.pl
r3014 r4440 7 7 8 8 use Benchmark qw( timethese ); 9 use PS::IPP::IData::Client;9 use Nebulous::Client; 10 10 11 my $ idata = PS::IPP::IData::Client->new(12 proxy => 'http://localhost:80/ idata'11 my $neb = Nebulous::Client->new( 12 proxy => 'http://localhost:80/nebulous' 13 13 ); 14 14 … … 18 18 { 19 19 'create/delete' => sub { 20 my $fh = $ idata->create( $key );20 my $fh = $neb->create( $key ); 21 21 close $fh; 22 $ idata->delete( $key );22 $neb->delete( $key ); 23 23 }, 24 24 } -
trunk/Nebulous-Server/scripts/imageserver.pl
r2785 r4440 8 8 9 9 use SOAP::Transport::HTTP; 10 use PS::IPP::IData::Server;10 use Nebulous::Server; 11 11 12 12 SOAP::Transport::HTTP::CGI 13 -> dispatch_to( ' PS::IPP::IData::Server' )13 -> dispatch_to( 'Nebulous::Server' ) 14 14 -> handle; -
trunk/Nebulous-Server/scripts/ptest.pl
r2785 r4440 6 6 use lib "./lib"; 7 7 8 use PS::IPP::IData::Client;8 use Nebulous::Client; 9 9 10 my $idata = PS::IPP::IData::Client->new( 11 uri => 'http://localhost:80/PS/IPP/IData/Server', 12 proxy => 'http://localhost:80/idata' 10 my $neb = Nebulous::Client->new( 11 proxy => 'http://localhost:80/nebulous' 13 12 ); 14 13 … … 22 21 unless ( $pid ) { 23 22 my $fname = "${key}_$id"; 24 my $fh = $ idata->create( $fname );23 my $fh = $neb->create( $fname ); 25 24 die "can't create file $fname" unless $fh; 26 25 … … 28 27 29 28 close $fh; 30 $ idata->unlock( $fname, 'write' );29 $neb->unlock( $fname, 'write' ); 31 30 32 $fh = $ idata->open( $fname, 'read' ) or die "can't open file";31 $fh = $neb->open( $fname, 'read' ) or die "can't open file"; 33 32 close $fh; 34 $ idata->unlock( $fname, 'read' );33 $neb->unlock( $fname, 'read' ); 35 34 36 $ idata->replicate( $fname );37 $ idata->cull( $fname );38 $ idata->find( $fname );39 $ idata->copy( $fname, $fname . "_copy" );40 $ idata->move( $fname, $fname . "_move" );41 $ idata->delete( $fname . "_copy" );42 $ idata->delete( $fname . "_move" );35 $neb->replicate( $fname ); 36 $neb->cull( $fname ); 37 $neb->find( $fname ); 38 $neb->copy( $fname, $fname . "_copy" ); 39 $neb->move( $fname, $fname . "_move" ); 40 $neb->delete( $fname . "_copy" ); 41 $neb->delete( $fname . "_move" ); 43 42 44 43 exit 0; -
trunk/Nebulous-Server/scripts/stest.pl
r2785 r4440 6 6 use lib "./lib"; 7 7 8 use PS::IPP::IData::Client; # trace => 'debug';8 use Nebulous::Client; # trace => 'debug'; 9 9 10 my $ idata = PS::IPP::IData::Client->new(11 proxy => 'http://localhost:80/ idata'10 my $neb = Nebulous::Client->new( 11 proxy => 'http://localhost:80/nebulous' 12 12 ); 13 13 14 14 my $fname = shift; 15 15 16 #my $fh = $ idata->create( $fname );17 #$ idata->unlock( $fname, 'write' );16 #my $fh = $neb->create( $fname ); 17 #$neb->unlock( $fname, 'write' ); 18 18 19 $ idata->create( $fname, 1 );20 $ idata->unlock( $fname, 'write' );21 $ idata->delete( $fname );19 $neb->create( $fname, 1 ); 20 $neb->unlock( $fname, 'write' ); 21 $neb->delete( $fname ); 22 22 23 23 __END__ … … 28 28 print $fh "fooby\n"; 29 29 close $fh; 30 #$ idata->unlock( $fname, 'write' );30 #$neb->unlock( $fname, 'write' ); 31 31 my $filesize = (stat( $key ))[7]; 32 32 print "created file $key, ${filesize}bytes\n"; -
trunk/Nebulous-Server/t/01_load.t
r4436 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 01_load.t,v 1. 6 2005-06-30 01:37:16 jhoblitt Exp $5 # $Id: 01_load.t,v 1.7 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 12 12 use Test::More tests => 8; 13 13 14 BEGIN { use_ok( ' PS::IPP::IData::Client' ); }15 BEGIN { use_ok( ' PS::IPP::IData::Client::Log' ); }16 BEGIN { use_ok( ' PS::IPP::IData::Client::HTTP' ); }17 BEGIN { use_ok( ' PS::IPP::IData::Util' ); }18 BEGIN { use_ok( ' PS::IPP::IData::Server' ); }19 BEGIN { use_ok( ' PS::IPP::IData::Server::SQL' ); }20 BEGIN { use_ok( ' PS::IPP::IData::Server::Log' ); }21 BEGIN { use_ok( ' PS::IPP::IData::Server::SOAP' ); }14 BEGIN { use_ok( 'Nebulous::Client' ); } 15 BEGIN { use_ok( 'Nebulous::Client::Log' ); } 16 BEGIN { use_ok( 'Nebulous::Client::HTTP' ); } 17 BEGIN { use_ok( 'Nebulous::Util' ); } 18 BEGIN { use_ok( 'Nebulous::Server' ); } 19 BEGIN { use_ok( 'Nebulous::Server::SQL' ); } 20 BEGIN { use_ok( 'Nebulous::Server::Log' ); } 21 BEGIN { use_ok( 'Nebulous::Server::SOAP' ); } -
trunk/Nebulous-Server/t/02_server_setup.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 02_server_setup.t,v 1. 2 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 02_server_setup.t,v 1.3 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 12 12 use lib qw( ./t ./lib ); 13 13 14 use PS::IPP::IData::Server;15 use Test:: IData;14 use Nebulous::Server; 15 use Test::Nebulous; 16 16 17 Test:: IData->setup;17 Test::Nebulous->setup; 18 18 19 19 ok( 20 PS::IPP::IData::Server->setup(20 Nebulous::Server->setup( 21 21 "DBI:mysql:database=test:host=localhost", 22 22 "test", … … 26 26 ); 27 27 28 Test:: IData->setup;28 Test::Nebulous->setup; 29 29 30 30 eval { 31 PS::IPP::IData::Server->setup(31 Nebulous::Server->setup( 32 32 "DBI:mysql:database=foobar:host=localhost", 33 33 "baz", … … 37 37 like( $@, qr/DBI connect.*? failed/, "bad dsn/user/pass" ); 38 38 39 Test:: IData->cleanup;39 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/03_server_create_object.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 03_server_create_object.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 03_server_create_object.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 12 12 use lib qw( ./t ./lib ); 13 13 14 use PS::IPP::IData::Server;15 use PS::IPP::IData::Util qw( :standard );16 use Test:: IData;14 use Nebulous::Server; 15 use Nebulous::Util qw( :standard ); 16 use Test::Nebulous; 17 17 18 my $ idata = "PS::IPP::IData::Server";18 my $neb = "Nebulous::Server"; 19 19 20 $ idata->setup(20 $neb->setup( 21 21 "DBI:mysql:database=test:host=localhost", 22 22 "test", … … 24 24 ); 25 25 26 Test:: IData->setup;26 Test::Nebulous->setup; 27 27 28 28 { 29 29 # key 30 my $uri = $ idata->create_object( "foo" );30 my $uri = $neb->create_object( "foo" ); 31 31 32 32 ok( -e _get_file_path( $uri ), "file exists" ); … … 34 34 } 35 35 36 Test:: IData->setup;36 Test::Nebulous->setup; 37 37 38 38 { 39 39 # key, class 40 my $uri = $ idata->create_object( "foo", 0 );40 my $uri = $neb->create_object( "foo", 0 ); 41 41 42 42 ok( -e _get_file_path( $uri ), "file exists" ); … … 44 44 } 45 45 46 Test:: IData->setup;46 Test::Nebulous->setup; 47 47 48 48 { 49 49 # key, class, volume 50 my $uri = $ idata->create_object( "foo", 0, "node01" );50 my $uri = $neb->create_object( "foo", 0, "node01" ); 51 51 52 52 ok( -e _get_file_path( $uri ), "file exists" ); … … 54 54 } 55 55 56 Test:: IData->setup;56 Test::Nebulous->setup; 57 57 58 58 { 59 59 # key, class, volume, comment 60 my $uri = $ idata->create_object( "foo", 0, "node01", "this is foo" );60 my $uri = $neb->create_object( "foo", 0, "node01", "this is foo" ); 61 61 62 62 ok( -e _get_file_path( $uri ), "file exists" ); … … 64 64 } 65 65 66 Test:: IData->setup;66 Test::Nebulous->setup; 67 67 68 68 eval { 69 $ idata->create_object( "foo" );70 $ idata->create_object( "foo" );69 $neb->create_object( "foo" ); 70 $neb->create_object( "foo" ); 71 71 }; 72 72 like( $@, qr/Duplicate entry/, "object already exists" ); 73 73 74 Test:: IData->setup;74 Test::Nebulous->setup; 75 75 76 76 eval { 77 $ idata->create_object();77 $neb->create_object(); 78 78 }; 79 79 like( $@, qr/2 - 4 were expected/, "no params" ); 80 80 81 Test:: IData->setup;81 Test::Nebulous->setup; 82 82 83 83 eval { 84 $ idata->create_object( 1, 2, 3, 4, 5 );84 $neb->create_object( 1, 2, 3, 4, 5 ); 85 85 }; 86 86 like( $@, qr/2 - 4 were expected/, "too many params" ); 87 87 88 Test:: IData->cleanup;88 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/04_server_replicate_object.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 04_server_replicate_object.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 04_server_replicate_object.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 12 12 use lib qw( ./t ./lib ); 13 13 14 use PS::IPP::IData::Server;15 use PS::IPP::IData::Util qw( :standard );16 use Test:: IData;14 use Nebulous::Server; 15 use Nebulous::Util qw( :standard ); 16 use Test::Nebulous; 17 17 18 my $ idata = "PS::IPP::IData::Server";18 my $neb = "Nebulous::Server"; 19 19 20 $ idata->setup(20 $neb->setup( 21 21 "DBI:mysql:database=test:host=localhost", 22 22 "test", … … 24 24 ); 25 25 26 Test:: IData->setup;26 Test::Nebulous->setup; 27 27 28 28 { 29 29 # key 30 $ idata->create_object( "foo" );31 my $uri = $ idata->replicate_object( "foo" );30 $neb->create_object( "foo" ); 31 my $uri = $neb->replicate_object( "foo" ); 32 32 33 33 ok( -e _get_file_path( $uri ), "file exists" ); … … 35 35 } 36 36 37 Test:: IData->setup;37 Test::Nebulous->setup; 38 38 39 39 { 40 40 # key, $volume 41 $ idata->create_object( "foo" );42 my $uri = $ idata->replicate_object( "foo", "node01" );41 $neb->create_object( "foo" ); 42 my $uri = $neb->replicate_object( "foo", "node01" ); 43 43 44 44 ok( -e _get_file_path( $uri ), "file exists" ); … … 46 46 } 47 47 48 Test:: IData->setup;48 Test::Nebulous->setup; 49 49 50 50 { 51 51 # key, $volume 52 $ idata->create_object( "foo" );53 my $uri1 = $ idata->replicate_object( "foo", "node01" );54 my $uri2 = $ idata->replicate_object( "foo", "node02" );52 $neb->create_object( "foo" ); 53 my $uri1 = $neb->replicate_object( "foo", "node01" ); 54 my $uri2 = $neb->replicate_object( "foo", "node02" ); 55 55 56 56 ok( -e _get_file_path( $uri1 ), "file exists" ); … … 60 60 } 61 61 62 Test:: IData->setup;62 Test::Nebulous->setup; 63 63 64 64 eval { 65 $ idata->replicate_object( "foo" );65 $neb->replicate_object( "foo" ); 66 66 }; 67 67 like( $@, qr/storage object does not exist/, "storage object does not exist" ); 68 68 69 Test:: IData->setup;69 Test::Nebulous->setup; 70 70 71 71 eval { 72 $ idata->replicate_object();72 $neb->replicate_object(); 73 73 }; 74 74 like( $@, qr/1 - 2 were expected/, "no params" ); 75 75 76 Test:: IData->setup;76 Test::Nebulous->setup; 77 77 78 78 eval { 79 $ idata->replicate_object( 1, 2, 3 );79 $neb->replicate_object( 1, 2, 3 ); 80 80 }; 81 81 like( $@, qr/1 - 2 were expected/, "too many params" ); 82 82 83 Test:: IData->cleanup;83 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/05_server_lock_object.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 05_server_lock_object.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 05_server_lock_object.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 12 12 use lib qw( ./t ./lib ); 13 13 14 use PS::IPP::IData::Server;15 use PS::IPP::IData::Util qw( :standard );16 use Test:: IData;14 use Nebulous::Server; 15 use Nebulous::Util qw( :standard ); 16 use Test::Nebulous; 17 17 18 my $ idata = "PS::IPP::IData::Server";18 my $neb = "Nebulous::Server"; 19 19 20 $ idata->setup(20 $neb->setup( 21 21 "DBI:mysql:database=test:host=localhost", 22 22 "test", … … 24 24 ); 25 25 26 Test:: IData->setup;26 Test::Nebulous->setup; 27 27 28 28 { 29 $ idata->create_object( "foo" );29 $neb->create_object( "foo" ); 30 30 31 ok( $ idata->lock_object( "foo", "read" ), "read lock" );31 ok( $neb->lock_object( "foo", "read" ), "read lock" ); 32 32 } 33 33 34 Test:: IData->setup;34 Test::Nebulous->setup; 35 35 36 36 { 37 $ idata->create_object( "foo" );37 $neb->create_object( "foo" ); 38 38 39 ok( $ idata->lock_object( "foo", "read" ), "read lock" );40 ok( $ idata->lock_object( "foo", "read" ), "read lock" );39 ok( $neb->lock_object( "foo", "read" ), "read lock" ); 40 ok( $neb->lock_object( "foo", "read" ), "read lock" ); 41 41 } 42 42 43 Test:: IData->setup;43 Test::Nebulous->setup; 44 44 45 45 { 46 $ idata->create_object( "foo" );46 $neb->create_object( "foo" ); 47 47 48 ok( $ idata->lock_object( "foo", "write" ), "write lock" );48 ok( $neb->lock_object( "foo", "write" ), "write lock" ); 49 49 } 50 50 51 Test:: IData->setup;51 Test::Nebulous->setup; 52 52 53 53 eval { 54 $ idata->lock_object( "foo", "read" );54 $neb->lock_object( "foo", "read" ); 55 55 }; 56 56 like( $@, qr/storage object does not exist/, "storage object does not exist" ); 57 57 58 Test:: IData->setup;58 Test::Nebulous->setup; 59 59 60 60 eval { 61 $ idata->lock_object( "foo", "write" );61 $neb->lock_object( "foo", "write" ); 62 62 }; 63 63 like( $@, qr/storage object does not exist/, "storage object does not exist" ); 64 64 65 Test:: IData->setup;65 Test::Nebulous->setup; 66 66 67 67 eval { 68 $ idata->create_object( "foo" );68 $neb->create_object( "foo" ); 69 69 70 $ idata->lock_object( "foo", "write" );71 $ idata->lock_object( "foo", "write" );70 $neb->lock_object( "foo", "write" ); 71 $neb->lock_object( "foo", "write" ); 72 72 }; 73 73 like( $@, qr/can not write lock twice/, "can not write lock twice" ); 74 74 75 Test:: IData->setup;75 Test::Nebulous->setup; 76 76 77 77 eval { 78 $ idata->create_object( "foo" );78 $neb->create_object( "foo" ); 79 79 80 $ idata->lock_object( "foo", "read" );81 $ idata->lock_object( "foo", "write" );80 $neb->lock_object( "foo", "read" ); 81 $neb->lock_object( "foo", "write" ); 82 82 }; 83 83 like( $@, qr/can not write lock after read lock/, "can not write lock after read lock" ); 84 84 85 Test:: IData->setup;85 Test::Nebulous->setup; 86 86 87 87 eval { 88 $ idata->create_object( "foo" );88 $neb->create_object( "foo" ); 89 89 90 $ idata->lock_object( "foo", "write" );91 $ idata->lock_object( "foo", "read" );90 $neb->lock_object( "foo", "write" ); 91 $neb->lock_object( "foo", "read" ); 92 92 }; 93 93 like( $@, qr/can not read lock after write lock/, "can not read lock after write lock" ); 94 94 95 Test:: IData->setup;95 Test::Nebulous->setup; 96 96 97 97 eval { 98 $ idata->lock_object();98 $neb->lock_object(); 99 99 }; 100 100 like( $@, qr/2 were expected/, "no params" ); 101 101 102 Test:: IData->setup;102 Test::Nebulous->setup; 103 103 104 104 eval { 105 $ idata->lock_object( "foo" );105 $neb->lock_object( "foo" ); 106 106 }; 107 107 like( $@, qr/2 were expected/, "not enough params" ); 108 108 109 Test:: IData->setup;109 Test::Nebulous->setup; 110 110 111 111 eval { 112 $ idata->lock_object( "foo", "both" );112 $neb->lock_object( "foo", "both" ); 113 113 }; 114 114 like( $@, qr/is read or write/, "not read or write" ); 115 115 116 Test:: IData->setup;116 Test::Nebulous->setup; 117 117 118 118 eval { 119 $ idata->lock_object( "foo", 'read', 3 );119 $neb->lock_object( "foo", 'read', 3 ); 120 120 }; 121 121 like( $@, qr/2 were expected/, "too many params" ); 122 122 123 Test:: IData->cleanup;123 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/06_server_unlock_object.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 06_server_unlock_object.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 06_server_unlock_object.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 12 12 use lib qw( ./t ./lib ); 13 13 14 use PS::IPP::IData::Server;15 use PS::IPP::IData::Util qw( :standard );16 use Test:: IData;14 use Nebulous::Server; 15 use Nebulous::Util qw( :standard ); 16 use Test::Nebulous; 17 17 18 my $ idata = "PS::IPP::IData::Server";18 my $neb = "Nebulous::Server"; 19 19 20 $ idata->setup(20 $neb->setup( 21 21 "DBI:mysql:database=test:host=localhost", 22 22 "test", … … 24 24 ); 25 25 26 Test:: IData->setup;26 Test::Nebulous->setup; 27 27 28 28 { 29 $ idata->create_object( "foo" );29 $neb->create_object( "foo" ); 30 30 31 $ idata->lock_object( "foo", "read" );31 $neb->lock_object( "foo", "read" ); 32 32 33 ok( $ idata->unlock_object( "foo", "read" ), "read unlock" );33 ok( $neb->unlock_object( "foo", "read" ), "read unlock" ); 34 34 } 35 35 36 Test:: IData->setup;36 Test::Nebulous->setup; 37 37 38 38 { 39 $ idata->create_object( "foo" );39 $neb->create_object( "foo" ); 40 40 41 $ idata->lock_object( "foo", "read" );42 $ idata->lock_object( "foo", "read" );41 $neb->lock_object( "foo", "read" ); 42 $neb->lock_object( "foo", "read" ); 43 43 44 ok( $ idata->unlock_object( "foo", "read" ), "read unlock" );45 ok( $ idata->unlock_object( "foo", "read" ), "read unlock" );44 ok( $neb->unlock_object( "foo", "read" ), "read unlock" ); 45 ok( $neb->unlock_object( "foo", "read" ), "read unlock" ); 46 46 } 47 47 48 Test:: IData->setup;48 Test::Nebulous->setup; 49 49 50 50 { 51 $ idata->create_object( "foo" );51 $neb->create_object( "foo" ); 52 52 53 $ idata->lock_object( "foo", "write" );53 $neb->lock_object( "foo", "write" ); 54 54 55 ok( $ idata->unlock_object( "foo", "write" ), "write unlock" );55 ok( $neb->unlock_object( "foo", "write" ), "write unlock" ); 56 56 } 57 57 58 Test:: IData->setup;58 Test::Nebulous->setup; 59 59 60 60 eval { 61 $ idata->unlock_object( "foo", "read" );61 $neb->unlock_object( "foo", "read" ); 62 62 }; 63 63 like( $@, qr/storage object does not exist/, "storage object does not exist" ); 64 64 65 Test:: IData->setup;65 Test::Nebulous->setup; 66 66 67 67 eval { 68 $ idata->unlock_object( "foo", "write" );68 $neb->unlock_object( "foo", "write" ); 69 69 }; 70 70 like( $@, qr/storage object does not exist/, "storage object does not exist" ); 71 71 72 Test:: IData->setup;72 Test::Nebulous->setup; 73 73 74 74 eval { 75 $ idata->create_object( "foo" );75 $neb->create_object( "foo" ); 76 76 77 $ idata->unlock_object( "foo", "read" );77 $neb->unlock_object( "foo", "read" ); 78 78 }; 79 79 like( $@, qr/can not remove non-existant read lock/, "no lock set" ); 80 80 81 Test:: IData->setup;81 Test::Nebulous->setup; 82 82 83 83 eval { 84 $ idata->create_object( "foo" );84 $neb->create_object( "foo" ); 85 85 86 $ idata->unlock_object( "foo", "write" );86 $neb->unlock_object( "foo", "write" ); 87 87 }; 88 88 like( $@, qr/can not remove non-existant write lock/, "no lock set" ); 89 89 90 Test:: IData->setup;90 Test::Nebulous->setup; 91 91 92 92 eval { 93 $ idata->create_object( "foo" );94 $ idata->lock_object( "foo", "write" );93 $neb->create_object( "foo" ); 94 $neb->lock_object( "foo", "write" ); 95 95 96 $ idata->unlock_object( "foo", "read" );96 $neb->unlock_object( "foo", "read" ); 97 97 }; 98 98 like( $@, qr/can not have a read lock under a write lock/, "read unlock under write lock" ); 99 99 100 Test:: IData->setup;100 Test::Nebulous->setup; 101 101 102 102 eval { 103 $ idata->create_object( "foo" );104 $ idata->lock_object( "foo", "read" );103 $neb->create_object( "foo" ); 104 $neb->lock_object( "foo", "read" ); 105 105 106 $ idata->unlock_object( "foo", "write" );106 $neb->unlock_object( "foo", "write" ); 107 107 }; 108 108 like( $@, qr/can not have a write lock under a read lock/, "write unlock under read lock" ); 109 109 110 Test:: IData->setup;110 Test::Nebulous->setup; 111 111 112 112 eval { 113 $ idata->unlock_object();113 $neb->unlock_object(); 114 114 }; 115 115 like( $@, qr/2 were expected/, "no params" ); 116 116 117 Test:: IData->setup;117 Test::Nebulous->setup; 118 118 119 119 eval { 120 $ idata->unlock_object( "foo" );120 $neb->unlock_object( "foo" ); 121 121 }; 122 122 like( $@, qr/2 were expected/, "not enough params" ); 123 123 124 Test:: IData->setup;124 Test::Nebulous->setup; 125 125 126 126 eval { 127 $ idata->unlock_object( "foo", "both" );127 $neb->unlock_object( "foo", "both" ); 128 128 }; 129 129 like( $@, qr/is read or write/, "not read or write" ); 130 130 131 Test:: IData->setup;131 Test::Nebulous->setup; 132 132 133 133 eval { 134 $ idata->unlock_object( "foo", 'read', 3 );134 $neb->unlock_object( "foo", 'read', 3 ); 135 135 }; 136 136 like( $@, qr/2 were expected/, "too many params" ); 137 137 138 Test:: IData->cleanup;138 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/07_server_find_instances.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 07_server_find_instances.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 07_server_find_instances.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 12 12 use lib qw( ./t ./lib ); 13 13 14 use PS::IPP::IData::Server;15 use PS::IPP::IData::Util qw( :standard );16 use Test:: IData;14 use Nebulous::Server; 15 use Nebulous::Util qw( :standard ); 16 use Test::Nebulous; 17 17 18 my $ idata = "PS::IPP::IData::Server";18 my $neb = "Nebulous::Server"; 19 19 20 $ idata->setup(20 $neb->setup( 21 21 "DBI:mysql:database=test:host=localhost", 22 22 "test", … … 24 24 ); 25 25 26 Test:: IData->setup;26 Test::Nebulous->setup; 27 27 28 28 { 29 29 # key 30 my $uri = $ idata->create_object( "foo" );30 my $uri = $neb->create_object( "foo" ); 31 31 32 my $locations = $ idata->find_instances( "foo" );32 my $locations = $neb->find_instances( "foo" ); 33 33 34 34 is( $uri, $locations->[0], "URIs match" ); 35 35 } 36 36 37 Test:: IData->setup;37 Test::Nebulous->setup; 38 38 39 39 { 40 40 # key 41 my $uri1 = $ idata->create_object( "foo" );42 my $uri2 = $ idata->replicate_object( "foo" );41 my $uri1 = $neb->create_object( "foo" ); 42 my $uri2 = $neb->replicate_object( "foo" ); 43 43 44 my $locations = $ idata->find_instances( "foo" );44 my $locations = $neb->find_instances( "foo" ); 45 45 46 46 ok( eq_set( [$uri1, $uri2], $locations ), "URIs match" ); 47 47 } 48 48 49 Test:: IData->setup;49 Test::Nebulous->setup; 50 50 51 51 { 52 52 # key, volume 53 my $uri = $ idata->create_object( "foo" );53 my $uri = $neb->create_object( "foo" ); 54 54 55 my $locations = $ idata->find_instances( "foo", "node01" );55 my $locations = $neb->find_instances( "foo", "node01" ); 56 56 57 57 is( $uri, $locations->[0], "URIs match" ); 58 58 } 59 59 60 Test:: IData->setup;60 Test::Nebulous->setup; 61 61 62 62 { 63 63 # key 64 my $uri1 = $ idata->create_object( "foo" );65 my $uri2 = $ idata->replicate_object( "foo" );64 my $uri1 = $neb->create_object( "foo" ); 65 my $uri2 = $neb->replicate_object( "foo" ); 66 66 67 my $locations = $ idata->find_instances( "foo", "node01" );67 my $locations = $neb->find_instances( "foo", "node01" ); 68 68 69 69 ok( eq_set( [$uri1, $uri2], $locations ), "URIs match" ); … … 71 71 72 72 73 Test:: IData->setup;73 Test::Nebulous->setup; 74 74 75 75 eval { 76 $ idata->find_instances( "foo" );76 $neb->find_instances( "foo" ); 77 77 }; 78 78 like( $@, qr/no instances found/, "storage object does not exist" ); 79 79 80 Test:: IData->setup;80 Test::Nebulous->setup; 81 81 82 82 eval { 83 $ idata->find_instances();83 $neb->find_instances(); 84 84 }; 85 85 like( $@, qr/1 - 2 were expected/, "no params" ); 86 86 87 Test:: IData->setup;87 Test::Nebulous->setup; 88 88 89 89 eval { 90 $ idata->find_instances( "foo", 'read', 3 );90 $neb->find_instances( "foo", 'read', 3 ); 91 91 }; 92 92 like( $@, qr/1 - 2 were expected/, "too many params" ); 93 93 94 Test:: IData->cleanup;94 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/08_server_delete_instance.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 08_server_delete_instance.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 08_server_delete_instance.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 12 12 use lib qw( ./t ./lib ); 13 13 14 use PS::IPP::IData::Server;15 use PS::IPP::IData::Util qw( :standard );16 use Test:: IData;14 use Nebulous::Server; 15 use Nebulous::Util qw( :standard ); 16 use Test::Nebulous; 17 17 18 my $ idata = "PS::IPP::IData::Server";18 my $neb = "Nebulous::Server"; 19 19 20 $ idata->setup(20 $neb->setup( 21 21 "DBI:mysql:database=test:host=localhost", 22 22 "test", … … 24 24 ); 25 25 26 Test:: IData->setup;26 Test::Nebulous->setup; 27 27 28 28 { 29 my $uri = $ idata->create_object( "foo" );29 my $uri = $neb->create_object( "foo" ); 30 30 31 ok( $ idata->delete_instance( $uri ), "delete instance" );31 ok( $neb->delete_instance( $uri ), "delete instance" ); 32 32 } 33 33 34 Test:: IData->setup;34 Test::Nebulous->setup; 35 35 36 36 { 37 my $uri1 = $ idata->create_object( "foo" );38 my $uri2 = $ idata->replicate_object( "foo" );37 my $uri1 = $neb->create_object( "foo" ); 38 my $uri2 = $neb->replicate_object( "foo" ); 39 39 40 ok( $ idata->delete_instance( $uri1 ), "delete instance" );40 ok( $neb->delete_instance( $uri1 ), "delete instance" ); 41 41 42 my $locations = $ idata->find_instances( "foo" );42 my $locations = $neb->find_instances( "foo" ); 43 43 44 44 is( $locations->[0], $uri2, "instance remains" ); 45 45 46 ok( $ idata->delete_instance( $uri2 ), "delete instance" );46 ok( $neb->delete_instance( $uri2 ), "delete instance" ); 47 47 48 48 eval { 49 $ idata->find_instances( "foo" );49 $neb->find_instances( "foo" ); 50 50 }; 51 51 like( $@, qr/no instances found/, "storage object was deleted" ); 52 52 } 53 53 54 Test:: IData->setup;54 Test::Nebulous->setup; 55 55 56 56 eval { 57 $ idata->delete_instance( "file:/foo" );57 $neb->delete_instance( "file:/foo" ); 58 58 }; 59 59 like( $@, qr/no instance is associated with uri/, "uri does not exist" ); 60 60 61 Test:: IData->setup;61 Test::Nebulous->setup; 62 62 63 63 eval { 64 $ idata->delete_instance();64 $neb->delete_instance(); 65 65 }; 66 66 like( $@, qr/1 was expected/, "no params" ); 67 67 68 Test:: IData->setup;68 Test::Nebulous->setup; 69 69 70 70 eval { 71 $ idata->delete_instance( "foo", 2 );71 $neb->delete_instance( "foo", 2 ); 72 72 }; 73 73 like( $@, qr/1 was expected/, "too many params" ); 74 74 75 Test:: IData->cleanup;75 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/09_server_stat_object.t
r3016 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 09_server_stat_object.t,v 1. 4 2005-01-15 04:02:12jhoblitt Exp $5 # $Id: 09_server_stat_object.t,v 1.5 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 12 12 use lib qw( ./t ./lib ); 13 13 14 use PS::IPP::IData::Server;15 use PS::IPP::IData::Util qw( :standard );16 use Test:: IData;14 use Nebulous::Server; 15 use Nebulous::Util qw( :standard ); 16 use Test::Nebulous; 17 17 18 my $ idata = "PS::IPP::IData::Server";18 my $neb = "Nebulous::Server"; 19 19 20 $ idata->setup(20 $neb->setup( 21 21 "DBI:mysql:database=test:host=localhost", 22 22 "test", … … 24 24 ); 25 25 26 Test:: IData->setup;26 Test::Nebulous->setup; 27 27 28 28 { 29 my $uri = $ idata->create_object( "foo" );29 my $uri = $neb->create_object( "foo" ); 30 30 31 my $info = $ idata->stat_object( "foo" );31 my $info = $neb->stat_object( "foo" ); 32 32 33 33 is( scalar @$info, 8, "number of columns" ); 34 34 } 35 35 36 Test:: IData->setup;36 Test::Nebulous->setup; 37 37 38 38 { 39 my $uri = $ idata->create_object( "foo", 9, "node01", "foobar" );39 my $uri = $neb->create_object( "foo", 9, "node01", "foobar" ); 40 40 41 my $info = $ idata->stat_object( "foo" );41 my $info = $neb->stat_object( "foo" ); 42 42 43 43 is( scalar @$info, 8, "number of columns" ); … … 52 52 } 53 53 54 Test:: IData->setup;54 Test::Nebulous->setup; 55 55 56 56 eval { 57 $ idata->stat_object( "foo" );57 $neb->stat_object( "foo" ); 58 58 }; 59 59 like( $@, qr/no storage object found/, "object does not exist" ); 60 60 61 Test:: IData->setup;61 Test::Nebulous->setup; 62 62 63 63 eval { 64 $ idata->stat_object();64 $neb->stat_object(); 65 65 }; 66 66 like( $@, qr/1 was expected/, "no params" ); 67 67 68 Test:: IData->setup;68 Test::Nebulous->setup; 69 69 70 70 eval { 71 $ idata->stat_object( "foo", 2 );71 $neb->stat_object( "foo", 2 ); 72 72 }; 73 73 like( $@, qr/1 was expected/, "too many params" ); 74 74 75 Test:: IData->cleanup;75 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/10_client_new.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 10_client_new.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 10_client_new.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 my $ idata = PS::IPP::IData::Client->new(26 proxy => "http://$hostport/ idata",25 my $neb = Nebulous::Client->new( 26 proxy => "http://$hostport/nebulous", 27 27 ); 28 28 29 isa_ok( $ idata, "PS::IPP::IData::Client" );29 isa_ok( $neb, "Nebulous::Client" ); 30 30 } 31 31 32 Test:: IData->setup;32 Test::Nebulous->setup; 33 33 34 34 { 35 my $ idata = PS::IPP::IData::Client->new(36 proxy => "http://$hostport/ idata",37 uri => "http://example.com/PS/IPP/ IData/Client",35 my $neb = Nebulous::Client->new( 36 proxy => "http://$hostport/nebulous", 37 uri => "http://example.com/PS/IPP/Nebulous/Client", 38 38 ); 39 39 40 isa_ok( $ idata, "PS::IPP::IData::Client" );40 isa_ok( $neb, "Nebulous::Client" ); 41 41 } 42 42 43 Test:: IData->setup;43 Test::Nebulous->setup; 44 44 45 45 eval { 46 PS::IPP::IData::Client->new;46 Nebulous::Client->new; 47 47 }; 48 48 like( $@, qr/Mandatory parameter/, "no proxy" ); 49 49 50 Test:: IData->setup;50 Test::Nebulous->setup; 51 51 52 52 eval { 53 PS::IPP::IData::Client->new(53 Nebulous::Client->new( 54 54 proxy => "foo", 55 55 dog => "do" … … 58 58 like( $@, qr/not listed in the validation options/, "bad param" ); 59 59 60 Test:: IData->cleanup;60 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/11_client_create.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 11_client_create.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 11_client_create.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 25 # key 26 my $ idata = PS::IPP::IData::Client->new(27 proxy => "http://$hostport/ idata",26 my $neb = Nebulous::Client->new( 27 proxy => "http://$hostport/nebulous", 28 28 ); 29 29 30 my $fh = $ idata->create( "foo" );30 my $fh = $neb->create( "foo" ); 31 31 32 32 is( ref $fh, 'GLOB', "good filehandle" ); 33 33 } 34 34 35 Test:: IData->setup;35 Test::Nebulous->setup; 36 36 37 37 { 38 38 # key, class 39 my $ idata = PS::IPP::IData::Client->new(40 proxy => "http://$hostport/ idata",39 my $neb = Nebulous::Client->new( 40 proxy => "http://$hostport/nebulous", 41 41 ); 42 42 43 my $fh = $ idata->create( "foo", 0 );43 my $fh = $neb->create( "foo", 0 ); 44 44 45 45 is( ref $fh, 'GLOB', "good filehandle" ); 46 46 } 47 47 48 Test:: IData->setup;48 Test::Nebulous->setup; 49 49 50 50 { 51 51 # key, class, volume 52 my $ idata = PS::IPP::IData::Client->new(53 proxy => "http://$hostport/ idata",52 my $neb = Nebulous::Client->new( 53 proxy => "http://$hostport/nebulous", 54 54 ); 55 55 56 my $fh = $ idata->create( "foo", 0, "node01" );56 my $fh = $neb->create( "foo", 0, "node01" ); 57 57 58 58 is( ref $fh, 'GLOB', "good filehandle" ); 59 59 } 60 60 61 Test:: IData->setup;61 Test::Nebulous->setup; 62 62 63 63 { 64 64 # key, class, volume, comment 65 my $ idata = PS::IPP::IData::Client->new(66 proxy => "http://$hostport/ idata",65 my $neb = Nebulous::Client->new( 66 proxy => "http://$hostport/nebulous", 67 67 ); 68 68 69 my $fh = $ idata->create( "foo", 0, "node01", "this is foo" );69 my $fh = $neb->create( "foo", 0, "node01", "this is foo" ); 70 70 71 71 is( ref $fh, 'GLOB', "good filehandle" ); 72 72 } 73 73 74 Test:: IData->setup;74 Test::Nebulous->setup; 75 75 76 76 { 77 my $ idata = PS::IPP::IData::Client->new(78 proxy => "http://$hostport/ idata",77 my $neb = Nebulous::Client->new( 78 proxy => "http://$hostport/nebulous", 79 79 ); 80 80 81 $ idata->create( "foo" );82 is( $ idata->create( "foo" ), undef, "object already exists" );81 $neb->create( "foo" ); 82 is( $neb->create( "foo" ), undef, "object already exists" ); 83 83 } 84 84 85 Test:: IData->setup;85 Test::Nebulous->setup; 86 86 87 87 eval { 88 my $ idata = PS::IPP::IData::Client->new(89 proxy => "http://$hostport/ idata",88 my $neb = Nebulous::Client->new( 89 proxy => "http://$hostport/nebulous", 90 90 ); 91 91 92 $ idata->create();92 $neb->create(); 93 93 }; 94 94 like( $@, qr/2 - 4 were expected/, "no params" ); 95 95 96 Test:: IData->setup;96 Test::Nebulous->setup; 97 97 98 98 eval { 99 my $ idata = PS::IPP::IData::Client->new(100 proxy => "http://$hostport/ idata",99 my $neb = Nebulous::Client->new( 100 proxy => "http://$hostport/nebulous", 101 101 ); 102 102 103 $ idata->create( 1, 2, 3, 4, 5 );103 $neb->create( 1, 2, 3, 4, 5 ); 104 104 }; 105 105 like( $@, qr/2 - 4 were expected/, "too many params" ); 106 106 107 Test:: IData->cleanup;107 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/12_client_replicate.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 12_client_replicate.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 12_client_replicate.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 25 # key 26 my $ idata = PS::IPP::IData::Client->new(27 proxy => "http://$hostport/ idata",26 my $neb = Nebulous::Client->new( 27 proxy => "http://$hostport/nebulous", 28 28 ); 29 $ idata->create( "foo" );29 $neb->create( "foo" ); 30 30 31 my $uri = $ idata->replicate( "foo" );31 my $uri = $neb->replicate( "foo" ); 32 32 33 33 ok( $uri, "good replication" ); … … 35 35 } 36 36 37 Test:: IData->setup;37 Test::Nebulous->setup; 38 38 39 39 { 40 40 # key, $volume 41 my $ idata = PS::IPP::IData::Client->new(42 proxy => "http://$hostport/ idata",41 my $neb = Nebulous::Client->new( 42 proxy => "http://$hostport/nebulous", 43 43 ); 44 $ idata->create( "foo" );44 $neb->create( "foo" ); 45 45 46 my $uri = $ idata->replicate( "foo", "node01" );46 my $uri = $neb->replicate( "foo", "node01" ); 47 47 48 48 ok( $uri, "good replication" ); … … 50 50 } 51 51 52 Test:: IData->setup;52 Test::Nebulous->setup; 53 53 54 54 { 55 55 # key, $volume 56 my $ idata = PS::IPP::IData::Client->new(57 proxy => "http://$hostport/ idata",56 my $neb = Nebulous::Client->new( 57 proxy => "http://$hostport/nebulous", 58 58 ); 59 $ idata->create( "foo" );59 $neb->create( "foo" ); 60 60 61 my $uri1 = $ idata->replicate( "foo", "node01" );62 my $uri2 = $ idata->replicate( "foo", "node02" );61 my $uri1 = $neb->replicate( "foo", "node01" ); 62 my $uri2 = $neb->replicate( "foo", "node02" ); 63 63 64 64 ok( $uri1, "good replication" ); … … 68 68 } 69 69 70 Test:: IData->setup;70 Test::Nebulous->setup; 71 71 72 72 { 73 my $ idata = PS::IPP::IData::Client->new(74 proxy => "http://$hostport/ idata",73 my $neb = Nebulous::Client->new( 74 proxy => "http://$hostport/nebulous", 75 75 ); 76 my $uri = $ idata->replicate( "foo" );76 my $uri = $neb->replicate( "foo" ); 77 77 78 78 is( $uri, undef, "storage object does not exist" ); 79 79 } 80 80 81 Test:: IData->setup;81 Test::Nebulous->setup; 82 82 83 83 eval { 84 my $ idata = PS::IPP::IData::Client->new(85 proxy => "http://$hostport/ idata",84 my $neb = Nebulous::Client->new( 85 proxy => "http://$hostport/nebulous", 86 86 ); 87 $ idata->replicate();87 $neb->replicate(); 88 88 }; 89 89 like( $@, qr/1 - 2 were expected/, "no params" ); 90 90 91 Test:: IData->setup;91 Test::Nebulous->setup; 92 92 93 93 eval { 94 my $ idata = PS::IPP::IData::Client->new(95 proxy => "http://$hostport/ idata",94 my $neb = Nebulous::Client->new( 95 proxy => "http://$hostport/nebulous", 96 96 ); 97 $ idata->replicate( 1, 2, 3 );97 $neb->replicate( 1, 2, 3 ); 98 98 }; 99 99 like( $@, qr/1 - 2 were expected/, "too many params" ); 100 100 101 Test:: IData->cleanup;101 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/13_client_cull.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 13_client_cull.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 13_client_cull.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 25 # key 26 my $ idata = PS::IPP::IData::Client->new(27 proxy => "http://$hostport/ idata",26 my $neb = Nebulous::Client->new( 27 proxy => "http://$hostport/nebulous", 28 28 ); 29 $ idata->create( "foo" );30 $ idata->replicate( "foo" );29 $neb->create( "foo" ); 30 $neb->replicate( "foo" ); 31 31 32 my $uri = $ idata->cull( "foo" );32 my $uri = $neb->cull( "foo" ); 33 33 34 34 ok( $uri, "good cull" ); … … 36 36 } 37 37 38 Test:: IData->setup;38 Test::Nebulous->setup; 39 39 40 40 SKIP: { … … 42 42 43 43 # key, $volume 44 my $ idata = PS::IPP::IData::Client->new(45 proxy => "http://$hostport/ idata",44 my $neb = Nebulous::Client->new( 45 proxy => "http://$hostport/nebulous", 46 46 ); 47 $ idata->create( "foo" );48 $ idata->replicate( "foo", "node01" );47 $neb->create( "foo" ); 48 $neb->replicate( "foo", "node01" ); 49 49 50 my $uri = $ idata->cull( "foo", "node01" );50 my $uri = $neb->cull( "foo", "node01" ); 51 51 52 52 ok( $uri, "good cull" ); … … 54 54 } 55 55 56 Test:: IData->setup;56 Test::Nebulous->setup; 57 57 58 58 { 59 59 # key 60 my $ idata = PS::IPP::IData::Client->new(61 proxy => "http://$hostport/ idata",60 my $neb = Nebulous::Client->new( 61 proxy => "http://$hostport/nebulous", 62 62 ); 63 $ idata->create( "foo" );63 $neb->create( "foo" ); 64 64 65 $ idata->replicate( "foo", "node01" );66 $ idata->replicate( "foo", "node02" );65 $neb->replicate( "foo", "node01" ); 66 $neb->replicate( "foo", "node02" ); 67 67 68 my $uri1 = $ idata->cull( "foo" );69 my $uri2 = $ idata->cull( "foo" );68 my $uri1 = $neb->cull( "foo" ); 69 my $uri2 = $neb->cull( "foo" ); 70 70 71 71 ok( $uri1, "good cull" ); … … 75 75 } 76 76 77 Test:: IData->setup;77 Test::Nebulous->setup; 78 78 79 79 SKIP: { … … 81 81 82 82 # key, $volume 83 my $ idata = PS::IPP::IData::Client->new(84 proxy => "http://$hostport/ idata",83 my $neb = Nebulous::Client->new( 84 proxy => "http://$hostport/nebulous", 85 85 ); 86 $ idata->create( "foo" );86 $neb->create( "foo" ); 87 87 88 $ idata->replicate( "foo", "node01" );89 $ idata->replicate( "foo", "node02" );88 $neb->replicate( "foo", "node01" ); 89 $neb->replicate( "foo", "node02" ); 90 90 91 my $uri1 = $ idata->cull( "foo", "node01" );92 my $uri2 = $ idata->cull( "foo", "node02" );91 my $uri1 = $neb->cull( "foo", "node01" ); 92 my $uri2 = $neb->cull( "foo", "node02" ); 93 93 94 94 ok( $uri1, "good cull" ); … … 98 98 } 99 99 100 Test:: IData->setup;100 Test::Nebulous->setup; 101 101 102 102 { 103 my $ idata = PS::IPP::IData::Client->new(104 proxy => "http://$hostport/ idata",103 my $neb = Nebulous::Client->new( 104 proxy => "http://$hostport/nebulous", 105 105 ); 106 my $uri = $ idata->cull( "foo" );106 my $uri = $neb->cull( "foo" ); 107 107 108 108 is( $uri, undef, "storage object does not exist" ); 109 109 } 110 110 111 Test:: IData->setup;111 Test::Nebulous->setup; 112 112 113 113 eval { 114 my $ idata = PS::IPP::IData::Client->new(115 proxy => "http://$hostport/ idata",114 my $neb = Nebulous::Client->new( 115 proxy => "http://$hostport/nebulous", 116 116 ); 117 $ idata->cull();117 $neb->cull(); 118 118 }; 119 119 like( $@, qr/1 was expected/, "no params" ); 120 120 121 Test:: IData->setup;121 Test::Nebulous->setup; 122 122 123 123 eval { 124 my $ idata = PS::IPP::IData::Client->new(125 proxy => "http://$hostport/ idata",124 my $neb = Nebulous::Client->new( 125 proxy => "http://$hostport/nebulous", 126 126 ); 127 $ idata->cull( 1, 2 );127 $neb->cull( 1, 2 ); 128 128 }; 129 129 like( $@, qr/1 was expected/, "too many params" ); 130 130 131 Test:: IData->cleanup;131 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/14_client_lock.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 14_client_lock.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 14_client_lock.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 25 # key, type 26 my $ idata = PS::IPP::IData::Client->new(27 proxy => "http://$hostport/ idata",28 ); 29 $ idata->create( "foo" );30 31 ok( $ idata->lock( "foo", "read" ), "read lock" );32 } 33 34 Test:: IData->setup;35 36 { 37 # key, type, timeout 38 my $ idata = PS::IPP::IData::Client->new(39 proxy => "http://$hostport/ idata",40 ); 41 $ idata->create( "foo" );42 43 ok( $ idata->lock( "foo", "read", 10 ), "read lock" );44 } 45 46 Test:: IData->setup;47 48 { 49 my $ idata = PS::IPP::IData::Client->new(50 proxy => "http://$hostport/ idata",51 ); 52 $ idata->create( "foo" );53 54 ok( $ idata->lock( "foo", "read" ), "read lock" );55 ok( $ idata->lock( "foo", "read" ), "read lock" );56 } 57 58 Test:: IData->setup;26 my $neb = Nebulous::Client->new( 27 proxy => "http://$hostport/nebulous", 28 ); 29 $neb->create( "foo" ); 30 31 ok( $neb->lock( "foo", "read" ), "read lock" ); 32 } 33 34 Test::Nebulous->setup; 35 36 { 37 # key, type, timeout 38 my $neb = Nebulous::Client->new( 39 proxy => "http://$hostport/nebulous", 40 ); 41 $neb->create( "foo" ); 42 43 ok( $neb->lock( "foo", "read", 10 ), "read lock" ); 44 } 45 46 Test::Nebulous->setup; 47 48 { 49 my $neb = Nebulous::Client->new( 50 proxy => "http://$hostport/nebulous", 51 ); 52 $neb->create( "foo" ); 53 54 ok( $neb->lock( "foo", "read" ), "read lock" ); 55 ok( $neb->lock( "foo", "read" ), "read lock" ); 56 } 57 58 Test::Nebulous->setup; 59 59 60 60 { 61 61 # key, type 62 my $ idata = PS::IPP::IData::Client->new(63 proxy => "http://$hostport/ idata",64 ); 65 $ idata->create( "foo" );66 67 ok( $ idata->lock( "foo", "write" ), "write lock" );68 } 69 70 Test:: IData->setup;71 72 { 73 # key, type, timeout 74 my $ idata = PS::IPP::IData::Client->new(75 proxy => "http://$hostport/ idata",76 ); 77 $ idata->create( "foo" );78 79 ok( $ idata->lock( "foo", "write", 10 ), "write lock" );80 } 81 82 Test:: IData->setup;83 84 { 85 my $ idata = PS::IPP::IData::Client->new(86 proxy => "http://$hostport/ idata",87 ); 88 89 is( $ idata->lock( "foo", "read" ), undef, "storage object does not exist" );90 } 91 92 Test:: IData->setup;93 94 { 95 my $ idata = PS::IPP::IData::Client->new(96 proxy => "http://$hostport/ idata",97 ); 98 99 is( $ idata->lock( "foo", "write" ), undef, "storage object does not exist" );100 } 101 102 Test:: IData->setup;62 my $neb = Nebulous::Client->new( 63 proxy => "http://$hostport/nebulous", 64 ); 65 $neb->create( "foo" ); 66 67 ok( $neb->lock( "foo", "write" ), "write lock" ); 68 } 69 70 Test::Nebulous->setup; 71 72 { 73 # key, type, timeout 74 my $neb = Nebulous::Client->new( 75 proxy => "http://$hostport/nebulous", 76 ); 77 $neb->create( "foo" ); 78 79 ok( $neb->lock( "foo", "write", 10 ), "write lock" ); 80 } 81 82 Test::Nebulous->setup; 83 84 { 85 my $neb = Nebulous::Client->new( 86 proxy => "http://$hostport/nebulous", 87 ); 88 89 is( $neb->lock( "foo", "read" ), undef, "storage object does not exist" ); 90 } 91 92 Test::Nebulous->setup; 93 94 { 95 my $neb = Nebulous::Client->new( 96 proxy => "http://$hostport/nebulous", 97 ); 98 99 is( $neb->lock( "foo", "write" ), undef, "storage object does not exist" ); 100 } 101 102 Test::Nebulous->setup; 103 103 104 104 diag "testing a spinlock, this will be a litle slow..."; … … 109 109 110 110 # key, type, timeout 111 my $ idata = PS::IPP::IData::Client->new(112 proxy => "http://$hostport/ idata",113 ); 114 $ idata->create( "foo" );115 116 $ idata->lock( "foo", "read" );117 $ idata->lock( "foo", "write" );111 my $neb = Nebulous::Client->new( 112 proxy => "http://$hostport/nebulous", 113 ); 114 $neb->create( "foo" ); 115 116 $neb->lock( "foo", "read" ); 117 $neb->lock( "foo", "write" ); 118 118 119 119 alarm 0; … … 121 121 like( $@, qr/timeout/, "default spinlock" ); 122 122 123 Test:: IData->setup;123 Test::Nebulous->setup; 124 124 125 125 diag "testing a spinlock, this will be a litle slow..."; … … 130 130 131 131 # key, type, timeout 132 my $ idata = PS::IPP::IData::Client->new(133 proxy => "http://$hostport/ idata",134 ); 135 $ idata->create( "foo" );136 137 $ idata->lock( "foo", "read" );138 unless ( $ idata->lock( "foo", "write" ) ) {132 my $neb = Nebulous::Client->new( 133 proxy => "http://$hostport/nebulous", 134 ); 135 $neb->create( "foo" ); 136 137 $neb->lock( "foo", "read" ); 138 unless ( $neb->lock( "foo", "write" ) ) { 139 139 alarm 0; 140 140 die "gaveup"; … … 145 145 like( $@, qr/gaveup/, "default spinlock" ); 146 146 147 Test:: IData->setup;147 Test::Nebulous->setup; 148 148 149 149 diag "testing a spinlock, this will be a litle slow..."; … … 154 154 155 155 # key, type, timeout 156 my $ idata = PS::IPP::IData::Client->new(157 proxy => "http://$hostport/ idata",158 ); 159 $ idata->create( "foo" );160 161 $ idata->lock( "foo", "read" );162 $ idata->lock( "foo", "write", 5 );156 my $neb = Nebulous::Client->new( 157 proxy => "http://$hostport/nebulous", 158 ); 159 $neb->create( "foo" ); 160 161 $neb->lock( "foo", "read" ); 162 $neb->lock( "foo", "write", 5 ); 163 163 164 164 alarm 0; … … 166 166 like( $@, qr/timeout/, "specified spinlock" ); 167 167 168 Test:: IData->setup;168 Test::Nebulous->setup; 169 169 170 170 diag "testing a spinlock, this will be a litle slow..."; … … 175 175 176 176 # key, type, timeout 177 my $ idata = PS::IPP::IData::Client->new(178 proxy => "http://$hostport/ idata",179 ); 180 $ idata->create( "foo" );181 182 $ idata->lock( "foo", "read" );183 unless ( $ idata->lock( "foo", "write", 5 ) ) {177 my $neb = Nebulous::Client->new( 178 proxy => "http://$hostport/nebulous", 179 ); 180 $neb->create( "foo" ); 181 182 $neb->lock( "foo", "read" ); 183 unless ( $neb->lock( "foo", "write", 5 ) ) { 184 184 alarm 0; 185 185 die "gaveup"; … … 191 191 like( $@, qr/gaveup/, "specified spinlock" ); 192 192 193 Test:: IData->setup;194 195 { 196 my $ idata = PS::IPP::IData::Client->new(197 proxy => "http://$hostport/ idata",198 ); 199 $ idata->create( "foo" );200 201 $ idata->lock( "foo", "write" );202 is( $ idata->lock( "foo", "write", 1 ), undef, "can not write lock twice" );203 } 204 205 Test:: IData->setup;206 207 { 208 my $ idata = PS::IPP::IData::Client->new(209 proxy => "http://$hostport/ idata",210 ); 211 $ idata->create( "foo" );212 213 $ idata->lock( "foo", "read" );214 is( $ idata->lock( "foo", "write", 1 ), undef, "can not write lock after read lock" );215 } 216 217 Test:: IData->setup;218 219 { 220 my $ idata = PS::IPP::IData::Client->new(221 proxy => "http://$hostport/ idata",222 ); 223 $ idata->create( "foo" );224 225 $ idata->lock( "foo", "write" );226 is( $ idata->lock( "foo", "read", 1 ), undef, "can not read lock after write lock" );227 } 228 229 Test:: IData->setup;230 231 eval { 232 my $ idata = PS::IPP::IData::Client->new(233 proxy => "http://$hostport/ idata",234 ); 235 236 $ idata->lock();193 Test::Nebulous->setup; 194 195 { 196 my $neb = Nebulous::Client->new( 197 proxy => "http://$hostport/nebulous", 198 ); 199 $neb->create( "foo" ); 200 201 $neb->lock( "foo", "write" ); 202 is( $neb->lock( "foo", "write", 1 ), undef, "can not write lock twice" ); 203 } 204 205 Test::Nebulous->setup; 206 207 { 208 my $neb = Nebulous::Client->new( 209 proxy => "http://$hostport/nebulous", 210 ); 211 $neb->create( "foo" ); 212 213 $neb->lock( "foo", "read" ); 214 is( $neb->lock( "foo", "write", 1 ), undef, "can not write lock after read lock" ); 215 } 216 217 Test::Nebulous->setup; 218 219 { 220 my $neb = Nebulous::Client->new( 221 proxy => "http://$hostport/nebulous", 222 ); 223 $neb->create( "foo" ); 224 225 $neb->lock( "foo", "write" ); 226 is( $neb->lock( "foo", "read", 1 ), undef, "can not read lock after write lock" ); 227 } 228 229 Test::Nebulous->setup; 230 231 eval { 232 my $neb = Nebulous::Client->new( 233 proxy => "http://$hostport/nebulous", 234 ); 235 236 $neb->lock(); 237 237 }; 238 238 like( $@, qr/2 - 3 were expected/, "no params" ); 239 239 240 Test:: IData->setup;241 242 eval { 243 my $ idata = PS::IPP::IData::Client->new(244 proxy => "http://$hostport/ idata",245 ); 246 247 $ idata->lock( "foo" );240 Test::Nebulous->setup; 241 242 eval { 243 my $neb = Nebulous::Client->new( 244 proxy => "http://$hostport/nebulous", 245 ); 246 247 $neb->lock( "foo" ); 248 248 }; 249 249 like( $@, qr/2 - 3 were expected/, "not enough params" ); 250 250 251 Test:: IData->setup;252 253 eval { 254 my $ idata = PS::IPP::IData::Client->new(255 proxy => "http://$hostport/ idata",256 ); 257 258 $ idata->lock( "foo", "both" );251 Test::Nebulous->setup; 252 253 eval { 254 my $neb = Nebulous::Client->new( 255 proxy => "http://$hostport/nebulous", 256 ); 257 258 $neb->lock( "foo", "both" ); 259 259 }; 260 260 like( $@, qr/is read or write/, "not read or write" ); 261 261 262 Test:: IData->setup;263 264 eval { 265 my $ idata = PS::IPP::IData::Client->new(266 proxy => "http://$hostport/ idata",267 ); 268 269 $ idata->lock( "foo", 'read', 3, "bar" );262 Test::Nebulous->setup; 263 264 eval { 265 my $neb = Nebulous::Client->new( 266 proxy => "http://$hostport/nebulous", 267 ); 268 269 $neb->lock( "foo", 'read', 3, "bar" ); 270 270 }; 271 271 like( $@, qr/2 - 3 were expected/, "too many params" ); 272 272 273 Test:: IData->cleanup;273 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/15_client_unlock.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 15_client_unlock.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 15_client_unlock.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 my $ idata = PS::IPP::IData::Client->new(26 proxy => "http://$hostport/ idata",25 my $neb = Nebulous::Client->new( 26 proxy => "http://$hostport/nebulous", 27 27 ); 28 $ idata->create( "foo" );29 $ idata->lock( "foo", "read" );28 $neb->create( "foo" ); 29 $neb->lock( "foo", "read" ); 30 30 31 ok( $ idata->unlock( "foo", "read" ), "read unlock" );31 ok( $neb->unlock( "foo", "read" ), "read unlock" ); 32 32 } 33 33 34 Test:: IData->setup;34 Test::Nebulous->setup; 35 35 36 36 { 37 my $ idata = PS::IPP::IData::Client->new(38 proxy => "http://$hostport/ idata",37 my $neb = Nebulous::Client->new( 38 proxy => "http://$hostport/nebulous", 39 39 ); 40 $ idata->create( "foo" );41 $ idata->lock( "foo", "read" );42 $ idata->lock( "foo", "read" );40 $neb->create( "foo" ); 41 $neb->lock( "foo", "read" ); 42 $neb->lock( "foo", "read" ); 43 43 44 ok( $ idata->unlock( "foo", "read" ), "read unlock" );45 ok( $ idata->unlock( "foo", "read" ), "read unlock" );44 ok( $neb->unlock( "foo", "read" ), "read unlock" ); 45 ok( $neb->unlock( "foo", "read" ), "read unlock" ); 46 46 } 47 47 48 Test:: IData->setup;48 Test::Nebulous->setup; 49 49 50 50 { 51 my $ idata = PS::IPP::IData::Client->new(52 proxy => "http://$hostport/ idata",51 my $neb = Nebulous::Client->new( 52 proxy => "http://$hostport/nebulous", 53 53 ); 54 $ idata->create( "foo" );55 $ idata->lock( "foo", "write" );54 $neb->create( "foo" ); 55 $neb->lock( "foo", "write" ); 56 56 57 ok( $ idata->unlock( "foo", "write" ), "write unlock" );57 ok( $neb->unlock( "foo", "write" ), "write unlock" ); 58 58 } 59 59 60 Test:: IData->setup;60 Test::Nebulous->setup; 61 61 62 62 { 63 my $ idata = PS::IPP::IData::Client->new(64 proxy => "http://$hostport/ idata",63 my $neb = Nebulous::Client->new( 64 proxy => "http://$hostport/nebulous", 65 65 ); 66 66 67 is( $ idata->unlock( "foo", "read" ), undef, "storage object does not exist" );67 is( $neb->unlock( "foo", "read" ), undef, "storage object does not exist" ); 68 68 } 69 69 70 Test:: IData->setup;70 Test::Nebulous->setup; 71 71 72 72 { 73 my $ idata = PS::IPP::IData::Client->new(74 proxy => "http://$hostport/ idata",73 my $neb = Nebulous::Client->new( 74 proxy => "http://$hostport/nebulous", 75 75 ); 76 76 77 is( $ idata->unlock( "foo", "write" ), undef, "storage object does not exist" );77 is( $neb->unlock( "foo", "write" ), undef, "storage object does not exist" ); 78 78 } 79 79 80 Test:: IData->setup;80 Test::Nebulous->setup; 81 81 82 82 { 83 my $ idata = PS::IPP::IData::Client->new(84 proxy => "http://$hostport/ idata",83 my $neb = Nebulous::Client->new( 84 proxy => "http://$hostport/nebulous", 85 85 ); 86 $ idata->create( "foo" );86 $neb->create( "foo" ); 87 87 88 is( $ idata->unlock( "foo", "read" ), undef, "no lock set" );88 is( $neb->unlock( "foo", "read" ), undef, "no lock set" ); 89 89 } 90 90 91 Test:: IData->setup;91 Test::Nebulous->setup; 92 92 93 93 { 94 my $ idata = PS::IPP::IData::Client->new(95 proxy => "http://$hostport/ idata",94 my $neb = Nebulous::Client->new( 95 proxy => "http://$hostport/nebulous", 96 96 ); 97 $ idata->create( "foo" );97 $neb->create( "foo" ); 98 98 99 is( $ idata->unlock( "foo", "write" ), undef, "no lock set" );99 is( $neb->unlock( "foo", "write" ), undef, "no lock set" ); 100 100 } 101 101 102 Test:: IData->setup;102 Test::Nebulous->setup; 103 103 104 104 { 105 my $ idata = PS::IPP::IData::Client->new(106 proxy => "http://$hostport/ idata",105 my $neb = Nebulous::Client->new( 106 proxy => "http://$hostport/nebulous", 107 107 ); 108 $ idata->create( "foo" );109 $ idata->lock( "foo", "write" );108 $neb->create( "foo" ); 109 $neb->lock( "foo", "write" ); 110 110 111 is( $ idata->unlock( "foo", "read" ), undef, "read unlock under write lock" );111 is( $neb->unlock( "foo", "read" ), undef, "read unlock under write lock" ); 112 112 } 113 113 114 Test:: IData->setup;114 Test::Nebulous->setup; 115 115 116 116 { 117 my $ idata = PS::IPP::IData::Client->new(118 proxy => "http://$hostport/ idata",117 my $neb = Nebulous::Client->new( 118 proxy => "http://$hostport/nebulous", 119 119 ); 120 $ idata->create( "foo" );121 $ idata->lock( "foo", "read" );120 $neb->create( "foo" ); 121 $neb->lock( "foo", "read" ); 122 122 123 is( $ idata->unlock( "foo", "write" ), undef, "write unlock under read lock" );123 is( $neb->unlock( "foo", "write" ), undef, "write unlock under read lock" ); 124 124 } 125 125 126 Test:: IData->setup;126 Test::Nebulous->setup; 127 127 128 128 eval { 129 my $ idata = PS::IPP::IData::Client->new(130 proxy => "http://$hostport/ idata",129 my $neb = Nebulous::Client->new( 130 proxy => "http://$hostport/nebulous", 131 131 ); 132 132 133 $ idata->unlock();133 $neb->unlock(); 134 134 }; 135 135 like( $@, qr/2 were expected/, "no params" ); 136 136 137 Test:: IData->setup;137 Test::Nebulous->setup; 138 138 139 139 eval { 140 my $ idata = PS::IPP::IData::Client->new(141 proxy => "http://$hostport/ idata",140 my $neb = Nebulous::Client->new( 141 proxy => "http://$hostport/nebulous", 142 142 ); 143 143 144 $ idata->unlock( "foo" );144 $neb->unlock( "foo" ); 145 145 }; 146 146 like( $@, qr/2 were expected/, "not enough params" ); 147 147 148 Test:: IData->setup;148 Test::Nebulous->setup; 149 149 150 150 eval { 151 my $ idata = PS::IPP::IData::Client->new(152 proxy => "http://$hostport/ idata",151 my $neb = Nebulous::Client->new( 152 proxy => "http://$hostport/nebulous", 153 153 ); 154 154 155 $ idata->unlock( "foo", "both" );155 $neb->unlock( "foo", "both" ); 156 156 }; 157 157 like( $@, qr/is read or write/, "not read or write" ); 158 158 159 Test:: IData->setup;159 Test::Nebulous->setup; 160 160 161 161 eval { 162 my $ idata = PS::IPP::IData::Client->new(163 proxy => "http://$hostport/ idata",162 my $neb = Nebulous::Client->new( 163 proxy => "http://$hostport/nebulous", 164 164 ); 165 165 166 $ idata->unlock( "foo", 'read', 3 );166 $neb->unlock( "foo", 'read', 3 ); 167 167 }; 168 168 like( $@, qr/2 were expected/, "too many params" ); 169 169 170 Test:: IData->cleanup;170 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/16_client_find_instances.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 16_client_find_instances.t,v 1. 5 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 16_client_find_instances.t,v 1.6 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 25 # key 26 my $ idata = PS::IPP::IData::Client->new(27 proxy => "http://$hostport/ idata",26 my $neb = Nebulous::Client->new( 27 proxy => "http://$hostport/nebulous", 28 28 ); 29 $ idata->create( "foo" );29 $neb->create( "foo" ); 30 30 31 my $locations = $ idata->find_instances( "foo" );31 my $locations = $neb->find_instances( "foo" ); 32 32 33 33 is( scalar @$locations, 1, "found 1" ); … … 36 36 } 37 37 38 Test:: IData->setup;38 Test::Nebulous->setup; 39 39 40 40 { 41 41 # key 42 my $ idata = PS::IPP::IData::Client->new(43 proxy => "http://$hostport/ idata",42 my $neb = Nebulous::Client->new( 43 proxy => "http://$hostport/nebulous", 44 44 ); 45 $ idata->create( "foo" );46 $ idata->replicate( "foo" );45 $neb->create( "foo" ); 46 $neb->replicate( "foo" ); 47 47 48 my $locations = $ idata->find_instances( "foo" );48 my $locations = $neb->find_instances( "foo" ); 49 49 50 50 is( scalar @$locations, 2, "found 2" ); … … 55 55 } 56 56 57 Test:: IData->setup;57 Test::Nebulous->setup; 58 58 59 59 { 60 60 # key, volume 61 my $ idata = PS::IPP::IData::Client->new(62 proxy => "http://$hostport/ idata",61 my $neb = Nebulous::Client->new( 62 proxy => "http://$hostport/nebulous", 63 63 ); 64 $ idata->create( "foo" );64 $neb->create( "foo" ); 65 65 66 my $locations = $ idata->find_instances( "foo", "node01" );66 my $locations = $neb->find_instances( "foo", "node01" ); 67 67 68 68 is( scalar @$locations, 1, "found 1" ); … … 71 71 } 72 72 73 Test:: IData->setup;73 Test::Nebulous->setup; 74 74 75 75 { 76 76 # key 77 my $ idata = PS::IPP::IData::Client->new(78 proxy => "http://$hostport/ idata",77 my $neb = Nebulous::Client->new( 78 proxy => "http://$hostport/nebulous", 79 79 ); 80 $ idata->create( "foo" );81 $ idata->replicate( "foo" );80 $neb->create( "foo" ); 81 $neb->replicate( "foo" ); 82 82 83 my $locations = $ idata->find_instances( "foo", "node01" );83 my $locations = $neb->find_instances( "foo", "node01" ); 84 84 85 85 is( scalar @$locations, 2, "found 2" ); … … 90 90 } 91 91 92 Test:: IData->setup;92 Test::Nebulous->setup; 93 93 94 94 { 95 my $ idata = PS::IPP::IData::Client->new(96 proxy => "http://$hostport/ idata",95 my $neb = Nebulous::Client->new( 96 proxy => "http://$hostport/nebulous", 97 97 ); 98 98 99 is( $ idata->find_instances( "foo" ), undef, "storage object does not exist" );99 is( $neb->find_instances( "foo" ), undef, "storage object does not exist" ); 100 100 } 101 101 102 Test:: IData->setup;102 Test::Nebulous->setup; 103 103 104 104 eval { 105 my $ idata = PS::IPP::IData::Client->new(106 proxy => "http://$hostport/ idata",105 my $neb = Nebulous::Client->new( 106 proxy => "http://$hostport/nebulous", 107 107 ); 108 108 109 $ idata->find_instances();109 $neb->find_instances(); 110 110 }; 111 111 like( $@, qr/1 - 2 were expected/, "no params" ); 112 112 113 Test:: IData->setup;113 Test::Nebulous->setup; 114 114 115 115 eval { 116 my $ idata = PS::IPP::IData::Client->new(117 proxy => "http://$hostport/ idata",116 my $neb = Nebulous::Client->new( 117 proxy => "http://$hostport/nebulous", 118 118 ); 119 119 120 $ idata->find_instances( "foo", 'read', 3 );120 $neb->find_instances( "foo", 'read', 3 ); 121 121 }; 122 122 like( $@, qr/1 - 2 were expected/, "too many params" ); 123 123 124 Test:: IData->cleanup;124 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/17_client_find.t
r2872 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 17_client_find.t,v 1. 3 2005-01-03 23:55:29jhoblitt Exp $5 # $Id: 17_client_find.t,v 1.4 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 25 # key 26 my $ idata = PS::IPP::IData::Client->new(27 proxy => "http://$hostport/ idata",26 my $neb = Nebulous::Client->new( 27 proxy => "http://$hostport/nebulous", 28 28 ); 29 my $uri = $ idata->create( "foo" );29 my $uri = $neb->create( "foo" ); 30 30 31 my $path = $ idata->find( "foo" );31 my $path = $neb->find( "foo" ); 32 32 33 33 ok( -e $path, "file exists" ); 34 34 } 35 35 36 Test:: IData->setup;36 Test::Nebulous->setup; 37 37 38 38 { 39 my $ idata = PS::IPP::IData::Client->new(40 proxy => "http://$hostport/ idata",39 my $neb = Nebulous::Client->new( 40 proxy => "http://$hostport/nebulous", 41 41 ); 42 42 43 my $path = $ idata->find( "foo" );43 my $path = $neb->find( "foo" ); 44 44 45 45 ok( ! -e $path, "file doesn't exist" ); 46 46 } 47 47 48 Test:: IData->setup;48 Test::Nebulous->setup; 49 49 50 50 eval { 51 my $ idata = PS::IPP::IData::Client->new(52 proxy => "http://$hostport/ idata",51 my $neb = Nebulous::Client->new( 52 proxy => "http://$hostport/nebulous", 53 53 ); 54 54 55 $ idata->find();55 $neb->find(); 56 56 }; 57 57 like( $@, qr/1 was expected/, "no params" ); 58 58 59 Test:: IData->setup;59 Test::Nebulous->setup; 60 60 61 61 eval { 62 my $ idata = PS::IPP::IData::Client->new(63 proxy => "http://$hostport/ idata",62 my $neb = Nebulous::Client->new( 63 proxy => "http://$hostport/nebulous", 64 64 ); 65 65 66 $ idata->find( "foo", "bar" );66 $neb->find( "foo", "bar" ); 67 67 }; 68 68 like( $@, qr/1 was expected/, "too many params" ); 69 69 70 Test:: IData->cleanup;70 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/18_client_open.t
r2896 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 18_client_open.t,v 1. 1 2005-01-05 01:41:05jhoblitt Exp $5 # $Id: 18_client_open.t,v 1.2 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 25 # key 26 my $ idata = PS::IPP::IData::Client->new(27 proxy => "http://$hostport/ idata",26 my $neb = Nebulous::Client->new( 27 proxy => "http://$hostport/nebulous", 28 28 ); 29 $ idata->create( "foo" );30 my $fh = $ idata->open( "foo", 'read' );29 $neb->create( "foo" ); 30 my $fh = $neb->open( "foo", 'read' ); 31 31 32 32 is( ref $fh, 'GLOB', "good filehandle" ); 33 33 } 34 34 35 Test:: IData->setup;35 Test::Nebulous->setup; 36 36 37 37 { 38 38 # key 39 my $ idata = PS::IPP::IData::Client->new(40 proxy => "http://$hostport/ idata",39 my $neb = Nebulous::Client->new( 40 proxy => "http://$hostport/nebulous", 41 41 ); 42 $ idata->create( "foo" );43 my $fh = $ idata->open( "foo", 'write' );42 $neb->create( "foo" ); 43 my $fh = $neb->open( "foo", 'write' ); 44 44 45 45 is( ref $fh, 'GLOB', "good filehandle" ); 46 46 } 47 47 48 Test:: IData->setup;48 Test::Nebulous->setup; 49 49 50 50 { 51 my $ idata = PS::IPP::IData::Client->new(52 proxy => "http://$hostport/ idata",51 my $neb = Nebulous::Client->new( 52 proxy => "http://$hostport/nebulous", 53 53 ); 54 54 55 is( ref $ idata->open( "foo", 'write' ), 'GLOB', "create new object" );55 is( ref $neb->open( "foo", 'write' ), 'GLOB', "create new object" ); 56 56 } 57 57 58 Test:: IData->setup;58 Test::Nebulous->setup; 59 59 60 60 { 61 my $ idata = PS::IPP::IData::Client->new(62 proxy => "http://$hostport/ idata",61 my $neb = Nebulous::Client->new( 62 proxy => "http://$hostport/nebulous", 63 63 ); 64 64 65 is( $ idata->open( "foo", 'read' ), undef, "can't create new object" );65 is( $neb->open( "foo", 'read' ), undef, "can't create new object" ); 66 66 } 67 67 68 Test:: IData->setup;68 Test::Nebulous->setup; 69 69 70 70 eval { 71 my $ idata = PS::IPP::IData::Client->new(72 proxy => "http://$hostport/ idata",71 my $neb = Nebulous::Client->new( 72 proxy => "http://$hostport/nebulous", 73 73 ); 74 $ idata->open( "foo", 'bar' );74 $neb->open( "foo", 'bar' ); 75 75 }; 76 76 like( $@, qr/is read or write/, "2nd params not read or write" ); 77 77 78 Test:: IData->setup;78 Test::Nebulous->setup; 79 79 80 80 eval { 81 my $ idata = PS::IPP::IData::Client->new(82 proxy => "http://$hostport/ idata",81 my $neb = Nebulous::Client->new( 82 proxy => "http://$hostport/nebulous", 83 83 ); 84 $ idata->open();84 $neb->open(); 85 85 }; 86 86 like( $@, qr/2 were expected/, "no params" ); 87 87 88 Test:: IData->setup;88 Test::Nebulous->setup; 89 89 90 90 eval { 91 my $ idata = PS::IPP::IData::Client->new(92 proxy => "http://$hostport/ idata",91 my $neb = Nebulous::Client->new( 92 proxy => "http://$hostport/nebulous", 93 93 ); 94 $ idata->open( 1, 'read', 3 );94 $neb->open( 1, 'read', 3 ); 95 95 }; 96 96 like( $@, qr/2 were expected/, "too many params" ); 97 97 98 Test:: IData->cleanup;98 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/19_client_delete.t
r2913 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 19_client_delete.t,v 1. 2 2005-01-05 22:27:22jhoblitt Exp $5 # $Id: 19_client_delete.t,v 1.3 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 my $ idata = PS::IPP::IData::Client->new(26 proxy => "http://$hostport/ idata",25 my $neb = Nebulous::Client->new( 26 proxy => "http://$hostport/nebulous", 27 27 ); 28 $ idata->create( "foo" );28 $neb->create( "foo" ); 29 29 30 ok( $ idata->delete( "foo" ), "delete object" );30 ok( $neb->delete( "foo" ), "delete object" ); 31 31 32 my $locations = $ idata->find_instances( "foo" );32 my $locations = $neb->find_instances( "foo" ); 33 33 34 34 is( $locations, undef, "no instances" ); 35 35 } 36 36 37 Test:: IData->setup;37 Test::Nebulous->setup; 38 38 39 39 { 40 my $ idata = PS::IPP::IData::Client->new(41 proxy => "http://$hostport/ idata",40 my $neb = Nebulous::Client->new( 41 proxy => "http://$hostport/nebulous", 42 42 ); 43 $ idata->create( "foo" );44 $ idata->replicate( "foo" );43 $neb->create( "foo" ); 44 $neb->replicate( "foo" ); 45 45 46 ok( $ idata->delete( "foo" ), "delete object" );46 ok( $neb->delete( "foo" ), "delete object" ); 47 47 48 my $locations = $ idata->find_instances( "foo" );48 my $locations = $neb->find_instances( "foo" ); 49 49 50 50 is( $locations, undef, "no instances" ); 51 51 } 52 52 53 Test:: IData->setup;53 Test::Nebulous->setup; 54 54 55 55 { 56 my $ idata = PS::IPP::IData::Client->new(57 proxy => "http://$hostport/ idata",56 my $neb = Nebulous::Client->new( 57 proxy => "http://$hostport/nebulous", 58 58 ); 59 59 60 is( $ idata->delete( "foo" ), undef, "delete non-existant object" );60 is( $neb->delete( "foo" ), undef, "delete non-existant object" ); 61 61 } 62 62 63 Test:: IData->setup;63 Test::Nebulous->setup; 64 64 65 65 eval { 66 my $ idata = PS::IPP::IData::Client->new(67 proxy => "http://$hostport/ idata",66 my $neb = Nebulous::Client->new( 67 proxy => "http://$hostport/nebulous", 68 68 ); 69 $ idata->delete();69 $neb->delete(); 70 70 }; 71 71 like( $@, qr/1 was expected/, "no params" ); 72 72 73 Test:: IData->setup;73 Test::Nebulous->setup; 74 74 75 75 eval { 76 my $ idata = PS::IPP::IData::Client->new(77 proxy => "http://$hostport/ idata",76 my $neb = Nebulous::Client->new( 77 proxy => "http://$hostport/nebulous", 78 78 ); 79 $ idata->delete( "foo", 2 );79 $neb->delete( "foo", 2 ); 80 80 }; 81 81 like( $@, qr/1 was expected/, "too many params" ); 82 82 83 Test:: IData->cleanup;83 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/20_client_copy.t
r2878 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 20_client_copy.t,v 1. 1 2005-01-04 02:13:21jhoblitt Exp $5 # $Id: 20_client_copy.t,v 1.2 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 my $ idata = PS::IPP::IData::Client->new(26 proxy => "http://$hostport/ idata",25 my $neb = Nebulous::Client->new( 26 proxy => "http://$hostport/nebulous", 27 27 ); 28 $ idata->create( "foo" );28 $neb->create( "foo" ); 29 29 30 ok( $ idata->copy( "foo", "foobar" ), "copied object" );30 ok( $neb->copy( "foo", "foobar" ), "copied object" ); 31 31 32 my $locations1 = $ idata->find_instances( "foobar" );33 my $locations2 = $ idata->find_instances( "foobar" );32 my $locations1 = $neb->find_instances( "foobar" ); 33 my $locations2 = $neb->find_instances( "foobar" ); 34 34 35 35 is( scalar @$locations1, 1, "old object has an instances" ); … … 37 37 } 38 38 39 Test:: IData->setup;39 Test::Nebulous->setup; 40 40 41 41 { 42 my $ idata = PS::IPP::IData::Client->new(43 proxy => "http://$hostport/ idata",42 my $neb = Nebulous::Client->new( 43 proxy => "http://$hostport/nebulous", 44 44 ); 45 45 46 ok( ! $ idata->copy( "foo", "foobar" ), "copy non-existant object" );46 ok( ! $neb->copy( "foo", "foobar" ), "copy non-existant object" ); 47 47 48 my $locations = $ idata->find_instances( "foobar" );48 my $locations = $neb->find_instances( "foobar" ); 49 49 50 50 is( $locations, undef, "new object has no instances" ); 51 51 } 52 52 53 Test:: IData->setup;53 Test::Nebulous->setup; 54 54 55 55 eval { 56 my $ idata = PS::IPP::IData::Client->new(57 proxy => "http://$hostport/ idata",56 my $neb = Nebulous::Client->new( 57 proxy => "http://$hostport/nebulous", 58 58 ); 59 $ idata->copy();59 $neb->copy(); 60 60 }; 61 61 like( $@, qr/2 were expected/, "no params" ); 62 62 63 Test:: IData->setup;63 Test::Nebulous->setup; 64 64 65 65 eval { 66 my $ idata = PS::IPP::IData::Client->new(67 proxy => "http://$hostport/ idata",66 my $neb = Nebulous::Client->new( 67 proxy => "http://$hostport/nebulous", 68 68 ); 69 $ idata->copy( "foo" );69 $neb->copy( "foo" ); 70 70 }; 71 71 like( $@, qr/2 were expected/, "not enough params" ); 72 72 73 Test:: IData->setup;73 Test::Nebulous->setup; 74 74 75 75 eval { 76 my $ idata = PS::IPP::IData::Client->new(77 proxy => "http://$hostport/ idata",76 my $neb = Nebulous::Client->new( 77 proxy => "http://$hostport/nebulous", 78 78 ); 79 $ idata->copy( "foo", "bar", "baz" );79 $neb->copy( "foo", "bar", "baz" ); 80 80 }; 81 81 like( $@, qr/2 were expected/, "too many params" ); 82 82 83 Test:: IData->cleanup;83 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/21_client_move.t
r2881 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 21_client_move.t,v 1. 1 2005-01-04 02:48:31jhoblitt Exp $5 # $Id: 21_client_move.t,v 1.2 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 my $ idata = PS::IPP::IData::Client->new(26 proxy => "http://$hostport/ idata",25 my $neb = Nebulous::Client->new( 26 proxy => "http://$hostport/nebulous", 27 27 ); 28 $ idata->create( "foo" );28 $neb->create( "foo" ); 29 29 30 ok( $ idata->move( "foo", "foobar" ), "move object" );30 ok( $neb->move( "foo", "foobar" ), "move object" ); 31 31 32 my $locations1 = $ idata->find_instances( "foo" );33 my $locations2 = $ idata->find_instances( "foobar" );32 my $locations1 = $neb->find_instances( "foo" ); 33 my $locations2 = $neb->find_instances( "foobar" ); 34 34 35 35 is( $locations1, undef, "old object has no instances" ); … … 37 37 } 38 38 39 Test:: IData->setup;39 Test::Nebulous->setup; 40 40 41 41 { 42 my $ idata = PS::IPP::IData::Client->new(43 proxy => "http://$hostport/ idata",42 my $neb = Nebulous::Client->new( 43 proxy => "http://$hostport/nebulous", 44 44 ); 45 45 46 ok( ! $ idata->move( "foo", "foobar" ), "move non-existant object" );46 ok( ! $neb->move( "foo", "foobar" ), "move non-existant object" ); 47 47 48 my $locations = $ idata->find_instances( "foobar" );48 my $locations = $neb->find_instances( "foobar" ); 49 49 50 50 is( $locations, undef, "new object has no instances" ); 51 51 } 52 52 53 Test:: IData->setup;53 Test::Nebulous->setup; 54 54 55 55 eval { 56 my $ idata = PS::IPP::IData::Client->new(57 proxy => "http://$hostport/ idata",56 my $neb = Nebulous::Client->new( 57 proxy => "http://$hostport/nebulous", 58 58 ); 59 $ idata->move();59 $neb->move(); 60 60 }; 61 61 like( $@, qr/2 were expected/, "no params" ); 62 62 63 Test:: IData->setup;63 Test::Nebulous->setup; 64 64 65 65 eval { 66 my $ idata = PS::IPP::IData::Client->new(67 proxy => "http://$hostport/ idata",66 my $neb = Nebulous::Client->new( 67 proxy => "http://$hostport/nebulous", 68 68 ); 69 $ idata->move( "foo" );69 $neb->move( "foo" ); 70 70 }; 71 71 like( $@, qr/2 were expected/, "not enough params" ); 72 72 73 Test:: IData->setup;73 Test::Nebulous->setup; 74 74 75 75 eval { 76 my $ idata = PS::IPP::IData::Client->new(77 proxy => "http://$hostport/ idata",76 my $neb = Nebulous::Client->new( 77 proxy => "http://$hostport/nebulous", 78 78 ); 79 $ idata->move( "foo", "bar", "baz" );79 $neb->move( "foo", "bar", "baz" ); 80 80 }; 81 81 like( $@, qr/2 were expected/, "too many params" ); 82 82 83 Test:: IData->cleanup;83 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/22_client_delete_instance.t
r2882 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 22_client_delete_instance.t,v 1. 1 2005-01-04 03:14:19jhoblitt Exp $5 # $Id: 22_client_delete_instance.t,v 1.2 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 my $ idata = PS::IPP::IData::Client->new(26 proxy => "http://$hostport/ idata",25 my $neb = Nebulous::Client->new( 26 proxy => "http://$hostport/nebulous", 27 27 ); 28 $ idata->create( "foo" );28 $neb->create( "foo" ); 29 29 30 my $locations = $ idata->find_instances( "foo" );30 my $locations = $neb->find_instances( "foo" ); 31 31 32 my $uri = $ idata->delete_instance( @$locations[0] );32 my $uri = $neb->delete_instance( @$locations[0] ); 33 33 34 34 is( $uri, @$locations[0], "delete instance" ); … … 37 37 } 38 38 39 Test:: IData->setup;39 Test::Nebulous->setup; 40 40 41 41 { 42 my $ idata = PS::IPP::IData::Client->new(43 proxy => "http://$hostport/ idata",42 my $neb = Nebulous::Client->new( 43 proxy => "http://$hostport/nebulous", 44 44 ); 45 $ idata->create( "foo" );46 $ idata->replicate( "foo" );45 $neb->create( "foo" ); 46 $neb->replicate( "foo" ); 47 47 48 my $uri1 = $ idata->find_instances( "foo" )->[0];48 my $uri1 = $neb->find_instances( "foo" )->[0]; 49 49 50 ok( $ idata->delete_instance( $uri1 ), "delete instance" );50 ok( $neb->delete_instance( $uri1 ), "delete instance" ); 51 51 52 my $uri2 = $ idata->find_instances( "foo" )->[0];52 my $uri2 = $neb->find_instances( "foo" )->[0]; 53 53 54 54 isnt( $uri1, $uri2, "other instance remains" ); 55 55 56 ok( $ idata->delete_instance( $uri2 ), "delete instance" );56 ok( $neb->delete_instance( $uri2 ), "delete instance" ); 57 57 58 my $locations = $ idata->find_instances( "foo" );58 my $locations = $neb->find_instances( "foo" ); 59 59 60 60 is( $locations, undef, "no remaning instances" ); … … 62 62 63 63 { 64 my $ idata = PS::IPP::IData::Client->new(65 proxy => "http://$hostport/ idata",64 my $neb = Nebulous::Client->new( 65 proxy => "http://$hostport/nebulous", 66 66 ); 67 my $uri = $ idata->delete_instance( "file:/foo" );67 my $uri = $neb->delete_instance( "file:/foo" ); 68 68 69 69 is( $uri, undef, "uri does not exist" ); 70 70 } 71 71 72 Test:: IData->setup;72 Test::Nebulous->setup; 73 73 74 74 eval { 75 my $ idata = PS::IPP::IData::Client->new(76 proxy => "http://$hostport/ idata",75 my $neb = Nebulous::Client->new( 76 proxy => "http://$hostport/nebulous", 77 77 ); 78 $ idata->delete_instance();78 $neb->delete_instance(); 79 79 }; 80 80 like( $@, qr/1 was expected/, "no params" ); 81 81 82 Test:: IData->setup;82 Test::Nebulous->setup; 83 83 84 84 eval { 85 my $ idata = PS::IPP::IData::Client->new(86 proxy => "http://$hostport/ idata",85 my $neb = Nebulous::Client->new( 86 proxy => "http://$hostport/nebulous", 87 87 ); 88 $ idata->delete_instance( "foo", 2 );88 $neb->delete_instance( "foo", 2 ); 89 89 }; 90 90 like( $@, qr/1 was expected/, "too many params" ); 91 91 92 Test:: IData->cleanup;92 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/23_client_stat.t
r3016 r4440 3 3 # Copryight (C) 2004-2005 Joshua Hoblitt 4 4 # 5 # $Id: 23_client_stat.t,v 1. 2 2005-01-15 04:02:12jhoblitt Exp $5 # $Id: 23_client_stat.t,v 1.3 2005-06-30 02:35:06 jhoblitt Exp $ 6 6 7 7 use strict; … … 14 14 use lib qw( ./t ./lib ); 15 15 16 use PS::IPP::IData::Client;17 use PS::IPP::IData::Util qw( :standard );18 use Test:: IData;16 use Nebulous::Client; 17 use Nebulous::Util qw( :standard ); 18 use Test::Nebulous; 19 19 20 20 my $hostport = Apache::Test->config->{ 'hostport' }; 21 21 22 Test:: IData->setup;22 Test::Nebulous->setup; 23 23 24 24 { 25 my $ idata = PS::IPP::IData::Client->new(26 proxy => "http://$hostport/ idata",25 my $neb = Nebulous::Client->new( 26 proxy => "http://$hostport/nebulous", 27 27 ); 28 $ idata->create( "foo" );28 $neb->create( "foo" ); 29 29 30 my $info = $ idata->stat( "foo" );30 my $info = $neb->stat( "foo" ); 31 31 32 32 is( scalar @$info, 8, "number of columns" ); 33 33 } 34 34 35 Test:: IData->setup;35 Test::Nebulous->setup; 36 36 37 37 { 38 my $ idata = PS::IPP::IData::Client->new(39 proxy => "http://$hostport/ idata",38 my $neb = Nebulous::Client->new( 39 proxy => "http://$hostport/nebulous", 40 40 ); 41 $ idata->create( "foo", 9, "node01", "foobar" );41 $neb->create( "foo", 9, "node01", "foobar" ); 42 42 43 my $info = $ idata->stat( "foo" );43 my $info = $neb->stat( "foo" ); 44 44 45 45 is( scalar @$info, 8, "number of columns" ); … … 54 54 } 55 55 56 Test:: IData->setup;56 Test::Nebulous->setup; 57 57 58 58 { 59 my $ idata = PS::IPP::IData::Client->new(60 proxy => "http://$hostport/ idata",59 my $neb = Nebulous::Client->new( 60 proxy => "http://$hostport/nebulous", 61 61 ); 62 my $info = $ idata->stat( "foo" );62 my $info = $neb->stat( "foo" ); 63 63 64 64 is( $info, undef, "object does not exist" ); 65 65 } 66 66 67 Test:: IData->setup;67 Test::Nebulous->setup; 68 68 69 69 eval { 70 my $ idata = PS::IPP::IData::Client->new(71 proxy => "http://$hostport/ idata",70 my $neb = Nebulous::Client->new( 71 proxy => "http://$hostport/nebulous", 72 72 ); 73 $ idata->stat();73 $neb->stat(); 74 74 }; 75 75 like( $@, qr/1 was expected/, "no params" ); 76 76 77 Test:: IData->setup;77 Test::Nebulous->setup; 78 78 79 79 eval { 80 my $ idata = PS::IPP::IData::Client->new(81 proxy => "http://$hostport/ idata",80 my $neb = Nebulous::Client->new( 81 proxy => "http://$hostport/nebulous", 82 82 ); 83 $ idata->stat( "foo", 2 );83 $neb->stat( "foo", 2 ); 84 84 }; 85 85 like( $@, qr/1 was expected/, "too many params" ); 86 86 87 Test:: IData->cleanup;87 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/apache_03_server_create_object.x
r2785 r4440 11 11 12 12 use Apache::TestUtil; 13 use PS::IPP::IData::Util qw( :standard );13 use Nebulous::Util qw( :standard ); 14 14 use SOAP::Lite; 15 use Test:: IData;15 use Test::Nebulous; 16 16 17 17 my $hostport = Apache::Test::config()->{ 'hostport' }; 18 my $ idata= SOAP::Lite->new(19 proxy => "http://$hostport/ idata",20 uri => "http://pan-starrs.ifa.hawaii.edu/PS/IPP/ IData/Server",18 my $neb = SOAP::Lite->new( 19 proxy => "http://$hostport/nebulous", 20 uri => "http://pan-starrs.ifa.hawaii.edu/PS/IPP/Nebulous/Server", 21 21 ); 22 22 23 Test:: IData->setup;23 Test::Nebulous->setup; 24 24 25 25 { 26 26 # key 27 my $uri = $ idata->create_object( "foo" )->result;27 my $uri = $neb->create_object( "foo" )->result; 28 28 29 29 ok( -e _get_file_path( $uri ), "file exists" ); … … 32 32 } 33 33 34 Test:: IData->setup;34 Test::Nebulous->setup; 35 35 36 36 { 37 37 # key, class 38 my $uri = $ idata->create_object( "foo", 0 )->result;39 $ idata->delete_instance( $uri );38 my $uri = $neb->create_object( "foo", 0 )->result; 39 $neb->delete_instance( $uri ); 40 40 41 41 ok( -e _get_file_path( $uri ), "file exists" ); … … 44 44 } 45 45 46 Test:: IData->setup;46 Test::Nebulous->setup; 47 47 48 48 { 49 49 # key, class, volume 50 my $uri = $ idata->create_object( "foo", 0, "node01" )->result;51 $ idata->delete_instance( $uri );50 my $uri = $neb->create_object( "foo", 0, "node01" )->result; 51 $neb->delete_instance( $uri ); 52 52 53 53 ok( -e _get_file_path( $uri ), "file exists" ); … … 56 56 } 57 57 58 Test:: IData->setup;58 Test::Nebulous->setup; 59 59 60 60 { 61 61 # key, class, volume, comment 62 my $uri = $ idata->create_object( "foo", 0, "node01", "this is foo" )->result;63 $ idata->delete_instance( $uri );62 my $uri = $neb->create_object( "foo", 0, "node01", "this is foo" )->result; 63 $neb->delete_instance( $uri ); 64 64 65 65 ok( -e _get_file_path( $uri ), "file exists" ); … … 68 68 } 69 69 70 Test:: IData->setup;70 Test::Nebulous->setup; 71 71 72 72 { 73 $ idata->create_object( "foo" );74 my $response = $ idata->create_object( "foo" );73 $neb->create_object( "foo" ); 74 my $response = $neb->create_object( "foo" ); 75 75 76 76 like( $response->faultstring, qr/Duplicate entry/, "object already exists" ); 77 77 } 78 78 79 Test:: IData->setup;79 Test::Nebulous->setup; 80 80 81 81 { 82 my $response = $ idata->create_object();82 my $response = $neb->create_object(); 83 83 84 84 like( $response->faultstring, qr/2 - 4 were expected/, "no params" ); 85 85 } 86 86 87 Test:: IData->setup;87 Test::Nebulous->setup; 88 88 89 89 { 90 my $response = $ idata->create_object( 1, 2, 3, 4, 5 );90 my $response = $neb->create_object( 1, 2, 3, 4, 5 ); 91 91 92 92 like( $response->faultstring, qr/2 - 4 were expected/, "too many params" ); 93 93 } 94 94 95 Test:: IData->cleanup;95 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/apache_04_server_replicate_object.x
r2785 r4440 11 11 12 12 use Apache::TestUtil; 13 use PS::IPP::IData::Util qw( :standard );13 use Nebulous::Util qw( :standard ); 14 14 use SOAP::Lite; 15 use Test:: IData;15 use Test::Nebulous; 16 16 17 17 my $hostport = Apache::Test::config()->{ 'hostport' }; 18 my $ idata= SOAP::Lite->new(19 proxy => "http://$hostport/ idata",20 uri => "http://pan-starrs.ifa.hawaii.edu/PS/IPP/ IData/Server",18 my $neb = SOAP::Lite->new( 19 proxy => "http://$hostport/nebulous", 20 uri => "http://pan-starrs.ifa.hawaii.edu/PS/IPP/Nebulous/Server", 21 21 ); 22 22 23 Test:: IData->setup;23 Test::Nebulous->setup; 24 24 25 25 { 26 26 # key 27 $ idata->create_object( "foo" );28 my $uri = $ idata->replicate_object( "foo" )->result;27 $neb->create_object( "foo" ); 28 my $uri = $neb->replicate_object( "foo" )->result; 29 29 30 30 ok( -e _get_file_path( $uri ), "file exists" ); … … 33 33 } 34 34 35 Test:: IData->setup;35 Test::Nebulous->setup; 36 36 37 37 { 38 38 # key, $volume 39 $ idata->create_object( "foo" );40 my $uri = $ idata->replicate_object( "foo", "node01" )->result;39 $neb->create_object( "foo" ); 40 my $uri = $neb->replicate_object( "foo", "node01" )->result; 41 41 42 42 ok( -e _get_file_path( $uri ), "file exists" ); … … 45 45 } 46 46 47 Test:: IData->setup;47 Test::Nebulous->setup; 48 48 49 49 { 50 50 # key, $volume 51 $ idata->create_object( "foo" );52 my $uri1 = $ idata->replicate_object( "foo", "node01" )->result;53 my $uri2 = $ idata->replicate_object( "foo", "node02" )->result;51 $neb->create_object( "foo" ); 52 my $uri1 = $neb->replicate_object( "foo", "node01" )->result; 53 my $uri2 = $neb->replicate_object( "foo", "node02" )->result; 54 54 55 55 ok( -e _get_file_path( $uri1 ), "file exists" ); … … 60 60 } 61 61 62 Test:: IData->setup;62 Test::Nebulous->setup; 63 63 64 64 { 65 my $response = $ idata->replicate_object();65 my $response = $neb->replicate_object(); 66 66 67 67 like( $response->faultstring, qr/1 - 2 were expected/, "no params" ); 68 68 } 69 69 70 Test:: IData->setup;70 Test::Nebulous->setup; 71 71 72 72 { 73 my $response = $ idata->replicate_object( 1, 2, 3 );73 my $response = $neb->replicate_object( 1, 2, 3 ); 74 74 75 75 like( $response->faultstring, qr/1 - 2 were expected/, "too many params" ); 76 76 } 77 77 78 Test:: IData->setup;78 Test::Nebulous->setup; 79 79 80 80 { 81 my $response = $ idata->replicate_object( "foo" );81 my $response = $neb->replicate_object( "foo" ); 82 82 83 83 like( $response->faultstring, qr/storage object does not exist/, "storage object does not exist" ); 84 84 } 85 85 86 Test:: IData->cleanup;86 Test::Nebulous->cleanup; -
trunk/Nebulous-Server/t/apache_05_server_lock_object.x
r2785 r4440 11 11 12 12 use Apache::TestUtil; 13 use PS::IPP::IData::Util qw( :standard );13 use Nebulous::Util qw( :standard ); 14 14 use SOAP::Lite; 15 use Test:: IData;15 use Test::Nebulous; 16 16 17 17 my $hostport = Apache::Test::config()->{ 'hostport' }; 18 my $ idata= SOAP::Lite->new(19 proxy => "http://$hostport/ idata",20 uri => "http://pan-starrs.ifa.hawaii.edu/PS/IPP/ IData/Server",18 my $neb = SOAP::Lite->new( 19 proxy => "http://$hostport/nebulous", 20 uri => "http://pan-starrs.ifa.hawaii.edu/PS/IPP/Nebulous/Server", 21 21 ); 22 22 23 Test:: IData->setup;23 Test::Nebulous->setup; 24 24 25 25 { 26 $ idata->create_object( "foo" );26 $neb->create_object( "foo" ); 27 27 28 ok( $ idata->lock_object( "foo", "read" )->result, "read lock" );28 ok( $neb->lock_object( "foo", "read" )->result, "read lock" ); 29 29 } 30 30 31 Test:: IData->setup;31 Test::Nebulous->setup; 32 32 33 33 { 34 $ idata->create_object( "foo" );34 $neb->create_object( "foo" ); 35 35 36 ok( $ idata->lock_object( "foo", "read" )->result, "read lock" );37 ok( $ idata->lock_object( "foo", "read" )->result, "read lock" );36 ok( $neb->lock_object( "foo", "read" )->result, "read lock" ); 37 ok( $neb->lock_object( "foo", "read" )->result, "read lock" ); 38 38 } 39 39 40 Test:: IData->setup;40 Test::Nebulous->setup; 41 41 42 42 { 43 $ idata->create_object( "foo" );43 $neb->create_object( "foo" ); 44 44 45 ok( $ idata->lock_object( "foo", "write" )->result, "write lock" );45 ok( $neb->lock_object( "foo", "write" )->result, "write lock" ); 46 46 } 47 47 48 Test:: IData->setup;48 Test::Nebulous->setup; 49 49 50 50 { 51 my $result = $ idata->lock_object( "foo", "read" );51 my $result = $neb->lock_object( "foo", "read" ); 52 52 53 53 like( $result->faultstring, qr/storage object does not exist/, "storage object does not exist" ); 54 54 } 55 55 56 Test:: IData->setup;56 Test::Nebulous->setup; 57 57 58 58 { 59 my $result = $ idata->lock_object( "foo", "write" );59 my $result = $neb->lock_object( "foo", "write" ); 60 60 61 61 like( $result->faultstring, qr/storage object does not exist/, "storage object does not exist" ); 62 62 } 63 63 64 Test:: IData->setup;64 Test::Nebulous->setup; 65 65 66 66 { 67 $ idata->create_object( "foo" );67 $neb->create_object( "foo" ); 68 68 69 $ idata->lock_object( "foo", "write" );70 my $result = $ idata->lock_object( "foo", "write" );69 $neb->lock_object( "foo", "write" ); 70 my $result = $neb->lock_object( "foo", "write" ); 71 71 72 72 like( $result->faultstring, qr/can not write lock twice/, "can not write lock twice" ); 73 73 } 74 74 75 Test:: IData->setup;75 Test::Nebulous->setup; 76 76 77 77 { 78 $ idata->create_object( "foo" );78 $neb->create_object( "foo" ); 79 79 80 $ idata->lock_object( "foo", "read" );81 my $result = $ idata->lock_object( "foo", "write" );80 $neb->lock_object( "foo", "read" ); 81 my $result = $neb->lock_object( "foo", "write" ); 82 82 83 83 like( $result->faultstring, qr/can not write lock after read lock/, "can not write lock after read lock" ); 84 84 } 85 85 86 Test:: IData->setup;86 Test::Nebulous->setup; 87 87 88 88 { 89 $ idata->create_object( "foo" );89 $neb->create_object( "foo" ); 90 90 91 $ idata->lock_object( "foo", "write" );92 my $result = $ idata->lock_object( "foo", "read" );91 $neb->lock_object( "foo", "write" ); 92 my $result = $neb->lock_object( "foo", "read" ); 93 93 94 94 like( $result->faultstring, qr/can not read lock after write lock/, "can not read lock after write lock" ); 95 95 } 96 96 97 Test:: IData->setup;97 Test::Nebulous->setup; 98 98 99 99 { 100 my $result = $ idata->lock_object();100 my $result = $neb->lock_object(); 101 101 102 102 like( $result->faultstring, qr/2 were expected/, "no params" ); 103 103 } 104 104 105 Test:: IData->setup;105 Test::Nebulous->setup; 106 106 107 107 { 108 my $result = $ idata->lock_object( "foo" );108 my $result = $neb->lock_object( "foo" ); 109 109 110 110 like( $result->faultstring, qr/2 were expected/, "not enough params" ); 111 111 } 112 112 113 Test:: IData->setup;113 Test::Nebulous->setup; 114 114 115 115 { 116 my $result = $ idata->lock_object( "foo", "both" );116 my $result = $neb->lock_object( "foo", "both" ); 117 117 118 118 like( $result->faultstring, qr/is read or write/, "not read or write" ); 119 119 } 120 120 121 Test:: IData->setup;121 Test::Nebulous->setup; 122 122 123 123 { 124 my $result = $ idata->lock_object( "foo", 'read', 3 );124 my $result = $neb->lock_object( "foo", 'read', 3 ); 125 125 126 126 like( $result->faultstring, qr/2 were expected/, "too many params" ); 127 127 } 128 128 129 Test:: IData->cleanup;129 Test::Nebulous->cleanup;
Note:
See TracChangeset
for help on using the changeset viewer.
