X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FRoute%2FNode.pm;h=9e1f3c04fecf7ba100ca35ed4c5594dc82578e91;hb=b67b50de92dbf61ce939b42f7c74e30dc58eba41;hp=2fee0acd40042365d5d494679c6b8cc6ac2aa435;hpb=fdc49835d7dc5573453567bd41e52c5e580ad8e7;p=spider.git diff --git a/perl/Route/Node.pm b/perl/Route/Node.pm index 2fee0acd..9e1f3c04 100644 --- a/perl/Route/Node.pm +++ b/perl/Route/Node.pm @@ -10,35 +10,158 @@ package Route::Node; use DXDebug; use Route; +use Route::User; use strict; -use vars qw(%list %valid @ISA $me); +use vars qw(%list %valid @ISA $max); @ISA = qw(Route); %valid = ( - dxchancall => '0,DXChannel Calls,parray', parent => '0,Parent Calls,parray', + nodes => '0,Nodes,parray', + users => '0,Users,parray', version => '0,Version', ); %list = (); +$max = 0; -sub init +sub count { - $me = Route::Node->new(@_); + my $n = scalar %list; + $max = $n if $n > $max; + return $n; +} + +sub max +{ + return $max; +} + +# +# this routine handles the possible adding of an entry in the routing +# table. It will only add an entry if it is new. It may have all sorts of +# other side effects which may include fixing up other links. +# +# It will return a node object if (and only if) it is a completely new +# object with that callsign. The upper layers are expected to do something +# sensible with this! +# +# called as $parent->add(call, dxchan, version, flags) +# + +sub add +{ + my $parent = shift; + my $call = uc shift; + my $self = get($call); + if ($self) { + $self->_addparent($parent->{call}); + return undef; + } + $parent->_addnode($call); + $self = $parent->new($call, @_); + return $self; +} + +# +# this routine is the opposite of 'add' above. +# +# It will return an object if (and only if) this 'del' will remove +# this object completely +# + +sub del +{ + my $self = shift; + my $pref = shift; + + # delete parent from this call's parent list + my $pcall = $pref->{call}; + my $ref = $self->_delparent($pcall); + my @nodes; + + # is this the last connection? + $self->_del_users; + unless (@$ref) { + push @nodes, $self->del_nodes; + delete $list{$self->{call}}; + } + push @nodes, $self; + return @nodes; +} + + +sub _del_users +{ + my $self = shift; + for (@{$self->{users}}) { + my $ref = Route::User::get($_); + $ref->del($self) if $ref; + } + $self->{users} = []; +} + +# remove all sub nodes from this parent +sub del_nodes +{ + my $self = shift; + my @nodes; + + for (@{$self->{nodes}}) { + next if $self->{call} eq $_; + push @nodes, $self->del_node($_); + } + return @nodes; +} + +# add a user to this node +sub add_user +{ + my $self = shift; + my $ucall = shift; + $self->_adduser($ucall); + + my $uref = Route::User::get($ucall); + return $uref ? () : (Route::User->new($ucall, $self->{call}, @_)); +} + +# delete a user from this node +sub del_user +{ + my $self = shift; + my $ucall = shift; + my $ref = Route::User::get($ucall); + $self->_deluser($ucall); + return ($ref->del($self)) if $ref; + return (); +} + +# delete a node from this node (ie I am a parent) +sub del_node +{ + my $self = shift; + my $ncall = shift; + $self->_delnode($ncall); + my $ref = get($ncall); + return ($ref->del($self)) if $ref; + return (); } sub new { my $pkg = shift; my $call = uc shift; + confess "already have $call in $pkg" if $list{$call}; my $self = $pkg->SUPER::new($call); - $self->{dxchancall} = [ ]; - $self->{parent} = [ ]; + $self->{parent} = ref $pkg ? [ $pkg->{call} ] : [ ]; $self->{version} = shift; + $self->{flags} = shift; + $self->{users} = []; + $self->{nodes} = []; $list{$call} = $self; @@ -52,28 +175,73 @@ sub get return $list{uc $call}; } -sub adddxchan +sub _addparent { my $self = shift; - $self->_addlist('dxchancall', @_); + return $self->_addlist('parent', @_); } -sub deldxchan +sub _delparent { my $self = shift; - $self->_dellist('dxchancall', @_); + return $self->_dellist('parent', @_); } -sub addparent + +sub _addnode { my $self = shift; - $self->_addlist('parent', @_); + return $self->_addlist('nodes', @_); } -sub delparent +sub _delnode { my $self = shift; - $self->_dellist('parent', @_); + return $self->_dellist('nodes', @_); +} + + +sub _adduser +{ + my $self = shift; + return $self->_addlist('users', @_); +} + +sub _deluser +{ + my $self = shift; + return $self->_dellist('users', @_); +} + +sub DESTROY +{ + my $self = shift; + my $pkg = ref $self; + my $call = $self->{call} || "Unknown"; + + dbg('route', "destroying $pkg with $call"); +} + +# +# generic AUTOLOAD for accessors +# + +sub AUTOLOAD +{ + no strict; + + my $self = shift; + $name = $AUTOLOAD; + return if $name =~ /::DESTROY$/; + $name =~ s/.*:://o; + + confess "Non-existant field '$AUTOLOAD'" unless $valid{$name} || $Route::valid{$name}; + + # this clever line of code creates a subroutine which takes over from autoload + # from OO Perl - Conway +# print "AUTOLOAD: $AUTOLOAD\n"; +# *{$AUTOLOAD} = sub {my $self = shift; @_ ? $self->{$name} = shift : $self->{$name}} ; + @_ ? $self->{$name} = shift : $self->{$name} ; } 1;