package HH::Unispool::Config::Entry::RemoteSystem::7; use 5.006; use base qw( HH::Unispool::Config::Entry::RemoteSystem ); use strict; use warnings; use AutoLoader qw(AUTOLOAD); use Error qw(:try); # Used by _value_is_allowed our %ALLOW_ISA = ( ); # Used by _value_is_allowed our %ALLOW_REF = ( ); # Used by _value_is_allowed our %ALLOW_RX = ( 'block_delay' => [ '^\d*$' ], ); # Used by _value_is_allowed our %ALLOW_VALUE = ( ); # Used by _initialize our %DEFAULT_VALUE = ( 'block_delay' => 0, 'initially_open' => 1, ); # Package version our ($VERSION) = '$Revision: 0.3 $' =~ /\$Revision:\s+([^\s]+)/; 1; __END__ =head1 NAME HH::Unispool::Config::Entry::RemoteSystem::7 - UNISPOOL type 7 remote system =head1 SYNOPSIS use strict; use HH::Unispool::Config; use HH::Unispool::Config::OS; use HH::Unispool::Config::Scope; use HH::Unispool::Config::Entry::System; use HH::Unispool::Config::Entry::RemoteSystem::7; # Create a config from scratch with a _Local_ scope my $conf = HH::Unispool::Config->new( { scope => HH::Unispool::Config::Scope->new ( { scope => [ qw( _Local_) ], } ), } ); # Create the _Local_ system and add it to the configuration my $sysn = HH::Unispool::Config::Entry::System->new( { name => '_Local_', local_system_name => 'foo', network_name => 'foo.bar.org', os => HH::Unispool::Config::OS->new( { os => 'Solaris', } ), } ); $conf->add_system($sysn); # Add a type 7 remote system to _Local_ my $dev = HH::Unispool::Config::Entry::RemoteSystem::7->new( { name => 'rsys7', } ); $sysn->add_remote_system($dev); # Write the configuration $conf->write('t/config.sample.r7.out'); =head1 ABSTRACT UNISPOOL type 7 remote system =head1 DESCRIPTION Class C holds information for UNISPOOL type 7 remote systems =head1 CONSTRUCTOR =over =item new(OPT_HASH_REF) Creates a new C object. C is a hash reference used to pass initialization options. C is mandatory. On error an exception C is thrown. Options for C may include: =over =item B> Passed to L. Defaults to B<0>. =item B> Passed to L. Defaults to B<1>. =back Options for C inherited through package B> may include: =over =item B> Passed to L. Mandatory option. =back Options for C inherited through package B> may include: =over =item B> Passed to L. Defaults to B<0>. =item B> Passed to L. =back Options for C inherited through package B> may include: =over =item B> Passed to L. =item B> Passed to L. Defaults to Bnew( { execution_priority => '' } )>. =back =item new_from_tokenizer(TOKENIZER) This method is an implementation from package C. Constructs a new C object using tokens. C is an C reference. On error an exception C is thrown. =back =head1 METHODS =over =item diff(TO [, DIFF_NUMBER]) This method is an implementation from package C. Finds differences between two objects. In C terms, the object is the B object and the specified C parameter the B object. C is a reference to an identical object class. Returns an empty string if no difference found and a difference descritpion string otherwise. On error an exception C is thrown. Paremeter C if specified, overrules the value of C. =item get_block_delay() Returns the time in seconds UNISPOOL should pause between sending two blocks. =item get_description() This method is inherited from package C. Returns the description for the remote system. =item get_execution_priority() This method is inherited from package C. Returns the execution priority of the driver process on MPE hosts. =item get_name() This method is inherited from package C. Returns the entry name. =item get_number() This method is inherited from package C. Returns the entry number. =item is_diff_number() This method is inherited from package C. Returns whether L should consider the C attribtutes or not. =item is_initially_open() Returns whether the communication link should be opened at the moment UNISPOOL is started or not. =item set_block_delay(VALUE) Set the time in seconds UNISPOOL should pause between sending two blocks. C is the value. Default value at initialization is C<0>. On error an exception C is thrown. =over =item VALUE must match regular expression: =over =item ^\d*$ =back =back =item set_description(VALUE) This method is inherited from package C. Set the description for the remote system. C is the value. On error an exception C is thrown. =over =item VALUE must match regular expression: =over =item ^.*$ =back =back =item set_diff_number(VALUE) This method is inherited from package C. State that L should consider the C attribtutes. C is the value. Default value at initialization is C<0>. On error an exception C is thrown. =item set_execution_priority(VALUE) This method is inherited from package C. Set the execution priority of the driver process on MPE hosts. C is the value. Default value at initialization is Cnew( { execution_priority => '' } )>. On error an exception C is thrown. =over =item VALUE must be a (sub)class of: =over =item HH::Unispool::Config::ExecPri =back =back =item set_initially_open(VALUE) State that the communication link should be opened at the moment UNISPOOL is started. C is the value. Default value at initialization is C<1>. On error an exception C is thrown. =item set_name(VALUE) This method is inherited from package C. Set the entry name. C is the value. C may not be C. On error an exception C is thrown. =over =item VALUE must match regular expression: =over =item ^.+$ =back =back =item set_number(VALUE) This method is inherited from package C. Set the entry number. C is the value. On error an exception C is thrown. =over =item VALUE must match regular expression: =over =item ^\d*$ =back =back =item write(FILE_HANDLE) This method is an implementation from package C. Writes the entry to the specified file handle. C is an C reference. On error an exception C is thrown. =back =head1 SEE ALSO L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L, L =head1 BUGS None known (yet.) =head1 HISTORY First development: February 2003 Last update: September 2003 =head1 AUTHOR Vincenzo Zocca =head1 COPYRIGHT Copyright 2003 by Vincenzo Zocca =head1 LICENSE This file is part of the C module hierarchy for Perl by Vincenzo Zocca. The HH::Unispool::Config module hierarchy is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. The HH::Unispool::Config module hierarchy is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with the HH::Unispool::Config module hierarchy; if not, write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA =cut sub new_from_tokenizer { my $class = shift; my $tokenizer = shift; # First token must be a HH::Unispool::Config::File::Token::Numbered::System::7 my $s = $tokenizer->get(); $s->isa('HH::Unispool::Config::File::Token::Numbered::System::7') || throw Error::Simple("ERROR: HH::Unispool::Config::Entry::RemoteSystem::7::new_from_tokenizer, expected a first token from 'TOKENIZER' of class 'HH::Unispool::Config::File::Token::Numbered::System::7'."); # Fill the initialization option hash my %opt = (); $opt{number} = $s->get_number() if ( $s->get_number() ); $opt{name} = $s->get_remote_system_name() if ( $s->get_remote_system_name() ); $opt{block_delay} = $s->get_block_delay() if ( $s->get_block_delay() ); $opt{initially_open} = $s->is_initially_open() if ( $s->is_initially_open() ); $opt{execution_priority} = $s->get_execution_priority() if ( $s->get_execution_priority() ); # Allow an I and N token my $i = undef; while ( my $tok = $tokenizer->get() ) { if ( ! $tok->isa('HH::Unispool::Config::File::Token::Numbered') || $tok->get_number() != $s->get_number() ) { $tokenizer->unget(); last; } elsif ( $tok->isa('HH::Unispool::Config::File::Token::Numbered::System::Info') ) { defined ($i) && throw Error::Simple("ERROR: HH::Unispool::Config::Entry::RemoteSystem::7::new_from_tokenizer, multiple tokens obtained from 'TOKENIZER' for entry $opt{name}/$opt{number} from class 'HH::Unispool::Config::File::Token::Numbered::System::Info'."); $i = $tok; $opt{description} = $i->get_description() if ( $i->get_description() ); } else { throw Error::Simple("ERROR: HH::Unispool::Config::Entry::RemoteSystem::7::new_from_tokenizer, expected tokens from 'TOKENIZER' for entry $opt{name}/$opt{number} from either class 'HH::Unispool::Config::File::Token::Numbered::System::Info' or 'HH::Unispool::Config::File::Token::Numbered::Network'."); } } # Construct a new object and return it return( HH::Unispool::Config::Entry::RemoteSystem::7->new(\%opt) ); } sub _initialize { my $self = shift; my $opt = defined($_[0]) ? shift : {}; # Check $opt ref($opt) eq 'HASH' || throw Error::Simple("ERROR: HH::Unispool::Config::Entry::RemoteSystem::7::_initialize, first argument must be 'HASH' reference."); # block_delay, SINGLE, with default value $self->set_block_delay( exists( $opt->{block_delay} ) ? $opt->{block_delay} : $DEFAULT_VALUE{block_delay} ); # initially_open, BOOLEAN, with default value $self->set_initially_open( exists( $opt->{initially_open} ) ? $opt->{initially_open} : $DEFAULT_VALUE{initially_open} ); # Call the superclass' _initialize $self->SUPER::_initialize($opt); # Return $self return($self); } sub _value_is_allowed { my $name = shift; # Value is allowed if no ALLOW clauses exist for the named attribute if ( ! exists( $ALLOW_ISA{$name} ) && ! exists( $ALLOW_REF{$name} ) && ! exists( $ALLOW_RX{$name} ) && ! exists( $ALLOW_VALUE{$name} ) ) { return(1); } # At this point, all values in @_ must to be allowed CHECK_VALUES: foreach my $val (@_) { # Check ALLOW_ISA if ( ref($val) && exists( $ALLOW_ISA{$name} ) ) { foreach my $class ( @{ $ALLOW_ISA{$name} } ) { &UNIVERSAL::isa( $val, $class ) && next CHECK_VALUES; } } # Check ALLOW_REF if ( ref($val) && exists( $ALLOW_REF{$name} ) ) { exists( $ALLOW_REF{$name}{ ref($val) } ) && next CHECK_VALUES; } # Check ALLOW_RX if ( defined($val) && ! ref($val) && exists( $ALLOW_RX{$name} ) ) { foreach my $rx ( @{ $ALLOW_RX{$name} } ) { $val =~ /$rx/ && next CHECK_VALUES; } } # Check ALLOW_VALUE if ( ! ref($val) && exists( $ALLOW_VALUE{$name} ) ) { exists( $ALLOW_VALUE{$name}{$val} ) && next CHECK_VALUES; } # We caught a not allowed value return(0); } # OK, all values are allowed return(1); } sub diff { my $from = shift; my $to = shift; my $diff_number = shift; $diff_number = $from->is_diff_number() if ( ! defined( $diff_number ) ); # Reference types must be identical if ( ref($from) ne ref($to) ) { my $rf = ref($from); my $rt = ref($to); throw Error::Simple("ERROR: HH::Unispool::Config::Entry::RemoteSystem::7::diff, FROM ($rf) and TO ($rt) reference types differ."); } # Diff message my $diff = $from->SUPER::diff($to, $diff_number); # Diff the block delay if ( $from->get_block_delay() ne $to->get_block_delay() ) { my $ref = ref($from); my $vf = $from->get_block_delay(); my $vt = $to->get_block_delay(); my $name = $from->get_name(); my $number = $from->get_number(); $diff .= "$ref/$name/$number: block delay difference: $vf <-> $vt\n"; } # Diff the initially open state if ( $from->is_initially_open() != $to->is_initially_open() ) { my $ref = ref($from); my $vf = $from->is_initially_open(); my $vt = $to->is_initially_open(); my $name = $from->get_name(); my $number = $from->get_number(); $diff .= "$ref/$name/$number: initially open difference: $vf <-> $vt\n"; } # Return diff return($diff); } sub get_block_delay { my $self = shift; return( $self->{HH_Unispool_Config_Entry_RemoteSystem_7}{block_delay} ); } sub is_initially_open { my $self = shift; if ( $self->{HH_Unispool_Config_Entry_RemoteSystem_7}{initially_open} ) { return(1); } else { return(0); } } sub set_block_delay { my $self = shift; my $val = shift; # Check if isa/ref/rx/value is allowed &_value_is_allowed( 'block_delay', $val ) || throw Error::Simple("ERROR: HH::Unispool::Config::Entry::RemoteSystem::7::set_block_delay, the specified value '$val' is not allowed."); # Assignment $self->{HH_Unispool_Config_Entry_RemoteSystem_7}{block_delay} = $val; } sub set_initially_open { my $self = shift; if (shift) { $self->{HH_Unispool_Config_Entry_RemoteSystem_7}{initially_open} = 1; } else { $self->{HH_Unispool_Config_Entry_RemoteSystem_7}{initially_open} = 0; } } sub write { my $self = shift; my $fh = shift; # Make the three tokens require HH::Unispool::Config::File::Token::Numbered::System::7; my $s = HH::Unispool::Config::File::Token::Numbered::System::7->new( { number => $self->get_number(), remote_system_name => $self->get_name(), block_delay => $self->get_block_delay(), initially_open => $self->is_initially_open(), execution_priority => $self->get_execution_priority(), } ); require HH::Unispool::Config::File::Token::Numbered::System::Info; my $i = HH::Unispool::Config::File::Token::Numbered::System::Info->new( { number => $self->get_number(), description => $self->get_description(), } ); # Print the tokens $fh->print( $s->write_string() ); $fh->print( $i->write_string() ); }