zookeeper-contrib/zookeeper-contrib-zkperl/t/22_stat_tie.t - zookeeper - Git at Google

 # Net::ZooKeeper - Perl extension for Apache ZooKeeper
 #
 # Licensed to the Apache Software Foundation (ASF) under one
 # or more contributor license agreements.  See the NOTICE file
 # distributed with this work for additional information
 # regarding copyright ownership.  The ASF licenses this file
 # to you under the Apache License, Version 2.0 (the
 # "License"); you may not use this file except in compliance
 # with the License.  You may obtain a copy of the License at
 #
 #   http://www.apache.org/licenses/LICENSE-2.0
 #
 # Unless required by applicable law or agreed to in writing, software
 # distributed under the License is distributed on an "AS IS" BASIS,
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.

 use File::Spec;
 use Test::More tests => 66;

 BEGIN { use_ok('Net::ZooKeeper', qw(:all)) };


 my $test_dir;
 (undef, $test_dir, undef) = File::Spec->splitpath($0);
 require File::Spec->catfile($test_dir, 'util.pl');

 my($hosts, $root_path, $node_path) = zk_test_setup(0);


 SKIP: {
     my $zkh = Net::ZooKeeper->new($hosts);
     my $stat = $zkh->stat() if (defined($zkh));

     skip 'no valid stat handle', 4 unless (defined($stat));


     ## DESTROY()

     my $attr = tied(%{$stat});

     my $ret = $attr->DESTROY();
     ok($ret,
        'stat DESTROY(): destroyed inner stat hash');

     $ret = $attr->DESTROY();
     ok(!$ret,
        'stat DESTROY(): no action on destroyed inner stat hash');

     $ret = $stat->DESTROY();
     ok(!$ret,
        'stat DESTROY(): no action on stat handle with destroyed inner hash');

     undef $stat;
     ok(!defined($stat),
        'undef: released stat handle with destroyed inner hash');
 }

 SKIP: {
     my $zkh = Net::ZooKeeper->new($hosts);
     my $stat = $zkh->stat() if (defined($zkh));

     skip 'no valid stat handle', 61 unless (defined($stat));


     ## TIEHASH(), UNTIE()

     eval {
         tie(%{$stat}, 'Net::ZooKeeper::Stat');
     };
     like($@, qr/tying hashes of class Net::ZooKeeper::Stat not supported/,
          'tie(): tying stat hashes not supported');

     eval {
         Net::ZooKeeper::Stat::TIEHASH('Net::ZooKeeper::Stat');
     };
     like($@, qr/tying hashes of class Net::ZooKeeper::Stat not supported/,
          'stat TIEHASH(): tying stat hashes not supported');

     eval {
         untie(%{$stat});
     };
     like($@, qr/untying hashes of class Net::ZooKeeper::Stat not supported/,
          'untie(): untying stat hashes not supported');

     my $attr = tied(%{$stat});

     eval {
         $attr->UNTIE(0);
     };
     like($@, qr/untying hashes of class Net::ZooKeeper::Stat not supported/,
          'stat UNTIE(): untying stat hashes not supported');


     ## FIRSTKEY(), NEXTKEY(), SCALAR()

     my $copy_stat;
     {
         my %copy_stat = %{$stat};
         $copy_stat = \%copy_stat;
     }
     bless($copy_stat, 'Net::ZooKeeper::Stat');
     is(ref($copy_stat), 'Net::ZooKeeper::Stat',
        'stat FIRSTKEY(), NEXTKEY(): copied dereferenced stat handle');

     eval {
         my $val = $copy_stat->FIRSTKEY();
     };
     like($@, qr/invalid handle/,
          'stat FETCHKEY(): invalid stat handle');

     eval {
         my $val = $copy_stat->NEXTKEY('czxid');
     };
     like($@, qr/invalid handle/,
          'stat NEXTKEY(): invalid stat handle');

     my @keys = keys(%{$stat});
     is(scalar(@keys), 11,
        'keys(): count of keys from stat handle');

     @keys = keys(%{$copy_stat});
     is(scalar(@keys), 11,
        'keys(): count of keys from copied dereferenced stat handle');

     is($attr->FIRSTKEY(), 'czxid',
        'stat FIRSTKEY(): retrieved first key using inner stat hash');

     is($attr->NEXTKEY('num_children'), 'children_zxid',
        'stat NEXTKEY(): retrieved last key using inner stat hash');

     is($attr->NEXTKEY('children_zxid'), undef,
        'NEXTKEY(): undef returned after last key using inner stat hash');

     ok(scalar(%{$stat}),
        'scalar(): true value returned for dereferenced stat handle');

     ok($stat->SCALAR(),
        'stat SCALAR(): true value returned');


     ## FETCH()

     eval {
         my $val = $copy_stat->FETCH('version');
     };
     like($@, qr/invalid handle/,
          'stat FETCH(): invalid stat handle');

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         my $val = $stat->{'foo'};
         ok(!defined($val),
            'stat FETCH(): undef returned for invalid element');

         like($msg, qr/invalid element/,
              'stat FETCH(): invalid element');
     }

     is($stat->{'czxid'}, 0,
        'stat FETCH(): default node creation ZooKeeper transaction ID');

     is($stat->{'mzxid'}, 0,
        'stat FETCH(): default data last-modified ZooKeeper transaction ID');

     is($stat->{'ctime'}, 0,
        'stat FETCH(): default node creation time');

     is($stat->{'mtime'}, 0,
        'stat FETCH(): default data last-modified time');

     is($stat->{'version'}, 0,
        'stat FETCH(): default data version');

     is($stat->{'children_version'}, 0,
        'stat FETCH(): default child node list version');

     is($stat->{'acl_version'}, 0,
        'stat FETCH(): default ACL version');

     is($stat->{'ephemeral_owner'}, 0,
        'stat FETCH(): ephemeral node owner session ID');

     is($stat->{'data_len'}, 0,
        'stat FETCH(): default data length');

     is($stat->{'num_children'}, 0,
        'stat FETCH(): default child node list length');

     is($stat->{'children_zxid'}, 0,
        'stat FETCH(): default child node list last-modified ' .
        'ZooKeeper transaction ID');

     is($attr->FETCH('version'), 0,
        'stat FETCH(): default data version using inner stat hash');


     ## STORE()

     eval {
         my $val = $copy_stat->STORE('version', 'foo');
     };
     like($@, qr/invalid handle/,
          'stat STORE(): invalid stat handle');

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'foo'} = 'foo';
         like($msg, qr/invalid element/,
              'stat STORE(): invalid element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'czxid'} = 'foo';
         like($msg, qr/read-only element: czxid/,
              'stat STORE(): read-only node creation ' .
              'ZooKeeper transaction ID element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'mzxid'} = 'foo';
         like($msg, qr/read-only element: mzxid/,
              'stat STORE(): read-only data last-modified ' .
              'ZooKeeper transaction ID element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'ctime'} = 'foo';
         like($msg, qr/read-only element: ctime/,
              'stat STORE(): read-only node creation time element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'mtime'} = 'foo';
         like($msg, qr/read-only element: mtime/,
              'stat STORE(): read-only data last-modified time element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'version'} = 'foo';
         like($msg, qr/read-only element: version/,
              'stat STORE(): read-only data version element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'children_version'} = 'foo';
         like($msg, qr/read-only element: children_version/,
              'stat STORE(): read-only child node list version element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'acl_version'} = 'foo';
         like($msg, qr/read-only element: acl_version/,
              'stat STORE(): read-only ACL version element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'ephemeral_owner'} = 'foo';
         like($msg, qr/read-only element: ephemeral_owner/,
              'stat STORE(): read-only ephemeral node owner ' .
              'session ID element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'data_len'} = 'foo';
         like($msg, qr/read-only element: data_len/,
              'stat STORE(): read-only data length element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'num_children'} = 'foo';
         like($msg, qr/read-only element: num_children/,
              'stat STORE(): read-only child node list length element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->{'children_zxid'} = 'foo';
         like($msg, qr/read-only element: children_zxid/,
              'stat STORE(): read-only child node list last-modified ' .
              'ZooKeeper transaction ID element');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $attr->STORE('version', 'foo');
         like($msg, qr/read-only element: version/,
              'stat STORE(): read-only data version element using ' .
              'inner stat hash');
     }


     ## EXISTS()

     eval {
         my $val = $copy_stat->EXISTS('version');
     };
     like($@, qr/invalid handle/,
          'stat EXISTS(): invalid stat handle');

     ok(!exists($stat->{'foo'}),
        'exists(): invalid element of stat handle');

     ok(exists($stat->{'czxid'}),
        'exists(): node creation ZooKeeper transaction ID');

     ok(exists($stat->{'mzxid'}),
        'exists(): data last-modified ZooKeeper transaction ID');

     ok(exists($stat->{'ctime'}),
        'exists(): node creation time');

     ok(exists($stat->{'mtime'}),
        'exists(): data last-modified time');

     ok(exists($stat->{'version'}),
        'exists(): data version');

     ok(exists($stat->{'children_version'}),
        'exists(): child node list version');

     ok(exists($stat->{'acl_version'}),
        'exists(): ACL version');

     ok(exists($stat->{'ephemeral_owner'}),
        'exists(): ephemeral node owner session ID');

     ok(exists($stat->{'data_len'}),
        'exists(): data length');

     ok(exists($stat->{'num_children'}),
        'exists(): child node list length');

     ok(exists($stat->{'children_zxid'}),
        'exists(): child node list last-modified ZooKeeper transaction ID');

     ok($attr->EXISTS('version'),
        'stat EXISTS(): data version using inner stat hash');


     ## DELETE(), CLEAR()

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         delete($stat->{'version'});
         like($msg,
              qr/deleting elements from hashes of class Net::ZooKeeper::Stat not supported/,
              'delete(): deleting stat hash elements not supported');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->DELETE({'version'});
         like($msg,
              qr/deleting elements from hashes of class Net::ZooKeeper::Stat not supported/,
              'stat DELETE(): deleting stat hash elements not supported');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         %{$stat} = ();
         like($msg, qr/clearing hashes of class Net::ZooKeeper::Stat not supported/,
              'assign: clearing stat hashes not supported');
     }

     {
         my $msg;

         $SIG{'__WARN__'} = sub { $msg = $_[0]; };

         $stat->CLEAR();
         like($msg, qr/clearing hashes of class Net::ZooKeeper::Stat not supported/,
              'stat CLEAR(): clearing stat hashes not supported');
     }
 }
	# Net::ZooKeeper - Perl extension for Apache ZooKeeper
	#
	# Licensed to the Apache Software Foundation (ASF) under one
	# or more contributor license agreements. See the NOTICE file
	# distributed with this work for additional information
	# regarding copyright ownership. The ASF licenses this file
	# to you under the Apache License, Version 2.0 (the
	# "License"); you may not use this file except in compliance
	# with the License. You may obtain a copy of the License at
	#
	# http://www.apache.org/licenses/LICENSE-2.0
	#
	# Unless required by applicable law or agreed to in writing, software
	# distributed under the License is distributed on an "AS IS" BASIS,
	# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	# See the License for the specific language governing permissions and
	# limitations under the License.

	use File::Spec;
	use Test::More tests => 66;

	BEGIN { use_ok('Net::ZooKeeper', qw(:all)) };


	my $test_dir;
	(undef, $test_dir, undef) = File::Spec->splitpath($0);
	require File::Spec->catfile($test_dir, 'util.pl');

	my($hosts, $root_path, $node_path) = zk_test_setup(0);


	SKIP: {
	my $zkh = Net::ZooKeeper->new($hosts);
	my $stat = $zkh->stat() if (defined($zkh));

	skip 'no valid stat handle', 4 unless (defined($stat));


	## DESTROY()

	my $attr = tied(%{$stat});

	my $ret = $attr->DESTROY();
	ok($ret,
	'stat DESTROY(): destroyed inner stat hash');

	$ret = $attr->DESTROY();
	ok(!$ret,
	'stat DESTROY(): no action on destroyed inner stat hash');

	$ret = $stat->DESTROY();
	ok(!$ret,
	'stat DESTROY(): no action on stat handle with destroyed inner hash');

	undef $stat;
	ok(!defined($stat),
	'undef: released stat handle with destroyed inner hash');
	}

	SKIP: {
	my $zkh = Net::ZooKeeper->new($hosts);
	my $stat = $zkh->stat() if (defined($zkh));

	skip 'no valid stat handle', 61 unless (defined($stat));


	## TIEHASH(), UNTIE()

	eval {
	tie(%{$stat}, 'Net::ZooKeeper::Stat');
	};
	like($@, qr/tying hashes of class Net::ZooKeeper::Stat not supported/,
	'tie(): tying stat hashes not supported');

	eval {
	Net::ZooKeeper::Stat::TIEHASH('Net::ZooKeeper::Stat');
	};
	like($@, qr/tying hashes of class Net::ZooKeeper::Stat not supported/,
	'stat TIEHASH(): tying stat hashes not supported');

	eval {
	untie(%{$stat});
	};
	like($@, qr/untying hashes of class Net::ZooKeeper::Stat not supported/,
	'untie(): untying stat hashes not supported');

	my $attr = tied(%{$stat});

	eval {
	$attr->UNTIE(0);
	};
	like($@, qr/untying hashes of class Net::ZooKeeper::Stat not supported/,
	'stat UNTIE(): untying stat hashes not supported');


	## FIRSTKEY(), NEXTKEY(), SCALAR()

	my $copy_stat;
	{
	my %copy_stat = %{$stat};
	$copy_stat = \%copy_stat;
	}
	bless($copy_stat, 'Net::ZooKeeper::Stat');
	is(ref($copy_stat), 'Net::ZooKeeper::Stat',
	'stat FIRSTKEY(), NEXTKEY(): copied dereferenced stat handle');

	eval {
	my $val = $copy_stat->FIRSTKEY();
	};
	like($@, qr/invalid handle/,
	'stat FETCHKEY(): invalid stat handle');

	eval {
	my $val = $copy_stat->NEXTKEY('czxid');
	};
	like($@, qr/invalid handle/,
	'stat NEXTKEY(): invalid stat handle');

	my @keys = keys(%{$stat});
	is(scalar(@keys), 11,
	'keys(): count of keys from stat handle');

	@keys = keys(%{$copy_stat});
	is(scalar(@keys), 11,
	'keys(): count of keys from copied dereferenced stat handle');

	is($attr->FIRSTKEY(), 'czxid',
	'stat FIRSTKEY(): retrieved first key using inner stat hash');

	is($attr->NEXTKEY('num_children'), 'children_zxid',
	'stat NEXTKEY(): retrieved last key using inner stat hash');

	is($attr->NEXTKEY('children_zxid'), undef,
	'NEXTKEY(): undef returned after last key using inner stat hash');

	ok(scalar(%{$stat}),
	'scalar(): true value returned for dereferenced stat handle');

	ok($stat->SCALAR(),
	'stat SCALAR(): true value returned');


	## FETCH()

	eval {
	my $val = $copy_stat->FETCH('version');
	};
	like($@, qr/invalid handle/,
	'stat FETCH(): invalid stat handle');

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	my $val = $stat->{'foo'};
	ok(!defined($val),
	'stat FETCH(): undef returned for invalid element');

	like($msg, qr/invalid element/,
	'stat FETCH(): invalid element');
	}

	is($stat->{'czxid'}, 0,
	'stat FETCH(): default node creation ZooKeeper transaction ID');

	is($stat->{'mzxid'}, 0,
	'stat FETCH(): default data last-modified ZooKeeper transaction ID');

	is($stat->{'ctime'}, 0,
	'stat FETCH(): default node creation time');

	is($stat->{'mtime'}, 0,
	'stat FETCH(): default data last-modified time');

	is($stat->{'version'}, 0,
	'stat FETCH(): default data version');

	is($stat->{'children_version'}, 0,
	'stat FETCH(): default child node list version');

	is($stat->{'acl_version'}, 0,
	'stat FETCH(): default ACL version');

	is($stat->{'ephemeral_owner'}, 0,
	'stat FETCH(): ephemeral node owner session ID');

	is($stat->{'data_len'}, 0,
	'stat FETCH(): default data length');

	is($stat->{'num_children'}, 0,
	'stat FETCH(): default child node list length');

	is($stat->{'children_zxid'}, 0,
	'stat FETCH(): default child node list last-modified ' .
	'ZooKeeper transaction ID');

	is($attr->FETCH('version'), 0,
	'stat FETCH(): default data version using inner stat hash');


	## STORE()

	eval {
	my $val = $copy_stat->STORE('version', 'foo');
	};
	like($@, qr/invalid handle/,
	'stat STORE(): invalid stat handle');

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'foo'} = 'foo';
	like($msg, qr/invalid element/,
	'stat STORE(): invalid element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'czxid'} = 'foo';
	like($msg, qr/read-only element: czxid/,
	'stat STORE(): read-only node creation ' .
	'ZooKeeper transaction ID element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'mzxid'} = 'foo';
	like($msg, qr/read-only element: mzxid/,
	'stat STORE(): read-only data last-modified ' .
	'ZooKeeper transaction ID element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'ctime'} = 'foo';
	like($msg, qr/read-only element: ctime/,
	'stat STORE(): read-only node creation time element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'mtime'} = 'foo';
	like($msg, qr/read-only element: mtime/,
	'stat STORE(): read-only data last-modified time element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'version'} = 'foo';
	like($msg, qr/read-only element: version/,
	'stat STORE(): read-only data version element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'children_version'} = 'foo';
	like($msg, qr/read-only element: children_version/,
	'stat STORE(): read-only child node list version element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'acl_version'} = 'foo';
	like($msg, qr/read-only element: acl_version/,
	'stat STORE(): read-only ACL version element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'ephemeral_owner'} = 'foo';
	like($msg, qr/read-only element: ephemeral_owner/,
	'stat STORE(): read-only ephemeral node owner ' .
	'session ID element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'data_len'} = 'foo';
	like($msg, qr/read-only element: data_len/,
	'stat STORE(): read-only data length element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'num_children'} = 'foo';
	like($msg, qr/read-only element: num_children/,
	'stat STORE(): read-only child node list length element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->{'children_zxid'} = 'foo';
	like($msg, qr/read-only element: children_zxid/,
	'stat STORE(): read-only child node list last-modified ' .
	'ZooKeeper transaction ID element');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$attr->STORE('version', 'foo');
	like($msg, qr/read-only element: version/,
	'stat STORE(): read-only data version element using ' .
	'inner stat hash');
	}


	## EXISTS()

	eval {
	my $val = $copy_stat->EXISTS('version');
	};
	like($@, qr/invalid handle/,
	'stat EXISTS(): invalid stat handle');

	ok(!exists($stat->{'foo'}),
	'exists(): invalid element of stat handle');

	ok(exists($stat->{'czxid'}),
	'exists(): node creation ZooKeeper transaction ID');

	ok(exists($stat->{'mzxid'}),
	'exists(): data last-modified ZooKeeper transaction ID');

	ok(exists($stat->{'ctime'}),
	'exists(): node creation time');

	ok(exists($stat->{'mtime'}),
	'exists(): data last-modified time');

	ok(exists($stat->{'version'}),
	'exists(): data version');

	ok(exists($stat->{'children_version'}),
	'exists(): child node list version');

	ok(exists($stat->{'acl_version'}),
	'exists(): ACL version');

	ok(exists($stat->{'ephemeral_owner'}),
	'exists(): ephemeral node owner session ID');

	ok(exists($stat->{'data_len'}),
	'exists(): data length');

	ok(exists($stat->{'num_children'}),
	'exists(): child node list length');

	ok(exists($stat->{'children_zxid'}),
	'exists(): child node list last-modified ZooKeeper transaction ID');

	ok($attr->EXISTS('version'),
	'stat EXISTS(): data version using inner stat hash');


	## DELETE(), CLEAR()

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	delete($stat->{'version'});
	like($msg,
	qr/deleting elements from hashes of class Net::ZooKeeper::Stat not supported/,
	'delete(): deleting stat hash elements not supported');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->DELETE({'version'});
	like($msg,
	qr/deleting elements from hashes of class Net::ZooKeeper::Stat not supported/,
	'stat DELETE(): deleting stat hash elements not supported');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	%{$stat} = ();
	like($msg, qr/clearing hashes of class Net::ZooKeeper::Stat not supported/,
	'assign: clearing stat hashes not supported');
	}

	{
	my $msg;

	$SIG{'__WARN__'} = sub { $msg = $_[0]; };

	$stat->CLEAR();
	like($msg, qr/clearing hashes of class Net::ZooKeeper::Stat not supported/,
	'stat CLEAR(): clearing stat hashes not supported');
	}
	}