/[cvs]/nfo/perl/libs/Data/Transfer/Sync/StorageInterface.pm
ViewVC logotype

Diff of /nfo/perl/libs/Data/Transfer/Sync/StorageInterface.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.2 by joko, Sun Feb 9 05:05:58 2003 UTC revision 1.7 by joko, Thu Mar 27 15:31:16 2003 UTC
# Line 6  Line 6 
6  ##  ##
7  ##    ----------------------------------------------------------------------------------------  ##    ----------------------------------------------------------------------------------------
8  ##    $Log$  ##    $Log$
9    ##    Revision 1.7  2003/03/27 15:31:16  joko
10    ##    fixes to modules regarding new namespace(s) below Data::Mungle::*
11    ##
12    ##    Revision 1.6  2003/02/21 01:47:53  joko
13    ##    renamed core function
14    ##
15    ##    Revision 1.5  2003/02/20 20:24:33  joko
16    ##    + additional pre-flight checks
17    ##
18    ##    Revision 1.4  2003/02/14 14:14:38  joko
19    ##    + new code refactored here
20    ##
21    ##    Revision 1.3  2003/02/11 07:54:55  joko
22    ##    + modified module usage
23    ##    + debugging trials
24    ##
25  ##    Revision 1.2  2003/02/09 05:05:58  joko  ##    Revision 1.2  2003/02/09 05:05:58  joko
26  ##    + major structure changes  ##    + major structure changes
27  ##    - refactored code to sister modules  ##    - refactored code to sister modules
# Line 32  use mixin::with qw( Data::Transfer::Sync Line 48  use mixin::with qw( Data::Transfer::Sync
48    
49  use Data::Dumper;  use Data::Dumper;
50  use Hash::Merge qw( merge );  use Hash::Merge qw( merge );
51  use libdb qw( quotesql hash2Sql );  use libdb qw( hash2Sql );
52  use Data::Transform::Deep qw( hash2object refexpr2perlref );  use Data::Mungle::Transform::Deep qw( merge_to );
53    
54    
55  # get logger instance  # get logger instance
# Line 57  sub _resolveNodeIdent { Line 73  sub _resolveNodeIdent {
73    my $self = shift;    my $self = shift;
74    my $descent = shift;    my $descent = shift;
75        
76    #print Dumper($self->{node}->{$descent});    # trace
77    #print Dumper($self);      #print Dumper($self->{node}->{$descent});
78        #print Dumper($self);
79        #exit;
80        
81    $logger->debug( __PACKAGE__ . "->_resolveNodeIdent( descent=$descent, accessorName=$self->{meta}->{$descent}->{accessorName} )" );    $logger->debug( __PACKAGE__ . "->_resolveNodeIdent( descent=$descent, accessorName=$self->{meta}->{$descent}->{accessorName} )" );
82        
83    # get to the payload    # get to the payload
# Line 70  sub _resolveNodeIdent { Line 89  sub _resolveNodeIdent {
89      #my $ident = $self->{$descent}->id($item);      #my $ident = $self->{$descent}->id($item);
90      #my $ident = $self->{meta}->{$descent}->{storage}->id($item);      #my $ident = $self->{meta}->{$descent}->{storage}->id($item);
91    
92      # trace
93        #print Dumper($self->{meta}->{$descent});
94        #exit;
95    
96      my $ident;      my $ident;
97      my $provider_method = $self->{meta}->{$descent}->{IdentProvider}->{method};      my $provider_method = $self->{meta}->{$descent}->{IdentProvider}->{method};
98      my $provider_arg = $self->{meta}->{$descent}->{IdentProvider}->{arg};      my $provider_arg = $self->{meta}->{$descent}->{IdentProvider}->{arg};
# Line 116  sub _statloadNode { Line 139  sub _statloadNode {
139    my $ident = shift;    my $ident = shift;
140    my $force = shift;    my $force = shift;
141    
142    $logger->debug( __PACKAGE__ . "->_statloadNode( descent=$descent ident=$ident )" );  =pod
143      #print "isa: ", UNIVERSAL::isa($self->{meta}->{$descent}->{storage}), "\n";
144    
145      # this seems to be the first time we access this side,
146      # so just check (again) for a valid storage handle
147      if (! ref $self->{meta}->{$descent}->{storage}) {
148        $logger->critical( __PACKAGE__ . "->_statloadNode( descent=$descent ident=$ident ): Storage handle undefined!" );
149        return;
150      }
151    =cut
152    
153      #$logger->debug( __PACKAGE__ . "->_statloadNode( descent=$descent ident=$ident )" );
154    
155    # fetch entry to retrieve checksum from    # fetch entry to retrieve checksum from
156    # was:    # was:
# Line 223  sub _touchNodeSet { Line 257  sub _touchNodeSet {
257          next;          next;
258        }        }
259            
260        # 2.b check storage handle type
261          my $dbType = $self->{meta}->{$descent}->{storage}->{locator}->{type};
262          if (!$dbType) {
263            $logger->critical( __PACKAGE__ . "->touchNodeSet: Storage ( descent='$descent', dbKey='$dbkey' ) has no 'dbType' - configuration-error?" );
264            next;
265          }
266    
267      # 3. check if descents (and nodes?) are actually available....      # 3. check if descents (and nodes?) are actually available....
268        # TODO:        # TODO:
269        # eventually pre-check mode of access-attempt (read/write) here to provide an "early-croak" if possible        # eventually pre-check mode of access-attempt (read/write) here to provide an "early-croak" if possible
# Line 231  sub _touchNodeSet { Line 272  sub _touchNodeSet {
272        # print Dumper($self->{meta}->{$descent}->{storage}->{locator});        # print Dumper($self->{meta}->{$descent}->{storage}->{locator});
273    
274    
       my $dbType = $self->{meta}->{$descent}->{storage}->{locator}->{type};  
275        my $nodeName = $self->{meta}->{$descent}->{nodeName};        my $nodeName = $self->{meta}->{$descent}->{nodeName};
276        my $accessorType = $self->{meta}->{$descent}->{accessorType};        my $accessorType = $self->{meta}->{$descent}->{accessorType};
277        my $accessorName = $self->{meta}->{$descent}->{accessorName};        my $accessorName = $self->{meta}->{$descent}->{accessorName};
# Line 437  sub _modifyNode { Line 477  sub _modifyNode {
477          # mix in (merge) values ...          # mix in (merge) values ...
478            # TODO: use Hash::Merge here? benchmark!            # TODO: use Hash::Merge here? benchmark!
479            # no! we'd need a Object::Merge here! it's *...2object*            # no! we'd need a Object::Merge here! it's *...2object*
480            hash2object($object, $map);            merge_to($object, $map);
481        
482          # trace          # trace
483            #print Dumper($object);            #print Dumper($object);
# Line 469  sub _modifyNode { Line 509  sub _modifyNode {
509        # mix in values        # mix in values
510          #print Dumper($object);          #print Dumper($object);
511          # TODO: use Hash::Merge here???          # TODO: use Hash::Merge here???
512          hash2object($object, $map);          merge_to($object, $map);
513          #print Dumper($object);          #print Dumper($object);
514          #exit;          #exit;
515    
# Line 488  sub _modifyNode { Line 528  sub _modifyNode {
528      #print Dumper($map_callbacks);      #print Dumper($map_callbacks);
529      foreach my $node (keys %{$map_callbacks->{write}}) {      foreach my $node (keys %{$map_callbacks->{write}}) {
530        #print Dumper($node);        #print Dumper($node);
531        my $perl_callback = $self->{meta}->{$descent}->{node} . '::' . $node . '_write';  
532          # ------------  half-redundant: make $self->callCallback($object, $value, $opts)
533          my $perl_callback = $self->{meta}->{$descent}->{nodeType} . '::' . $node . '_write';
534        my $evalstring = $perl_callback . '( { object => $object, value => $map_callbacks->{write}->{$node}, storage => $self->{meta}->{$descent}->{storage} } );';        my $evalstring = $perl_callback . '( { object => $object, value => $map_callbacks->{write}->{$node}, storage => $self->{meta}->{$descent}->{storage} } );';
535        #print $evalstring, "\n"; exit;        #print $evalstring, "\n"; exit;
536        eval($evalstring);        eval($evalstring);
537        if ($@) {        if ($@) {
538          $error = 1;          $error = 1;
539          print $@, "\n";          $logger->error( __PACKAGE__ . "->_modifyNode: $@" );
540            next;
541        }        }
542          # ------------  half-redundant: make $self->callCallback($object, $value, $opts)
543                
544        #print "after eval", "\n";        #print "after eval", "\n";
545                
# Line 530  sub _modifyNode { Line 574  sub _modifyNode {
574    
575  }  }
576    
577    sub _erase_all {
578      my $self = shift;
579      my $descent = shift;
580      #my $node = shift;
581      #print Dumper($self->{meta}->{$descent});
582      #my $node = $self->{meta}->{$descent}->{nodeName};
583      my $node = $self->{meta}->{$descent}->{accessorName};
584      $logger->debug( __PACKAGE__ . "->_erase_all( node $node )" );
585      $self->{meta}->{$descent}->{storage}->eraseAll($node);
586    }
587    
588  1;  1;
589    __END__
Legend:
Removed from v.1.2  
changed lines
  Added in v.1.7
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed