Changeset 4632
- Timestamp:
- Jul 27, 2005, 3:38:26 PM (21 years ago)
- File:
-
- 1 edited
-
trunk/Nebulous/lib/Nebulous/Client.pm (modified) (8 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Nebulous/lib/Nebulous/Client.pm
r4440 r4632 1 1 # Copyright (c) 2004 Joshua Hoblitt 2 2 # 3 # $Id: Client.pm,v 1.1 5 2005-06-30 02:35:06 jhoblitt Exp $3 # $Id: Client.pm,v 1.16 2005-07-28 01:38:26 jhoblitt Exp $ 4 4 5 5 package Nebulous::Client; … … 126 126 $log->debug( "server allocated $uri" ); 127 127 128 # unless( $self->lock( $key, "write" )) {129 # $log->debug( "can not lock object" );130 # $log->debug( "leaving" );131 #132 # return undef;133 # }134 135 128 my $fh; 136 129 eval { … … 195 188 close( $new_fh ) or $log->logdie( "can not close $key" ); 196 189 197 # unless ($self->unlock( $key, "write" )) {198 # $log->debug( "can not lock object" );199 # $log->debug( "leaving" );200 #201 # return undef;202 # }203 204 190 $log->debug( "leaving" ); 205 191 … … 234 220 } 235 221 236 # make sure nobody is reading while we are deleting237 # unless ($self->lock( $key, "write" )) {238 # $log->debug( "can not lock object" );239 # $log->debug( "leaving" );240 #241 # return undef;242 # }243 244 222 my $uri = $self->delete_instance( $locations->[0] ); 245 246 # unless ($self->unlock( $key, "write" )) {247 # $log->debug( "can not lock object" );248 # $log->debug( "leaving" );249 #250 # return undef;251 # }252 223 253 224 $log->debug( "leaving" ); … … 466 437 467 438 if ( $type eq 'write' ) { 468 # unless ($self->lock( $key, $type )) {469 # $log->debug( "can not lock object" );470 # $log->debug( "leaving" );471 #472 # return undef;473 # }474 475 439 eval { 476 440 $fh = _get_filehandle( $path, '+<' ); … … 478 442 $log->logdie( $@ ) if $@; 479 443 } elsif ( $type eq 'read' ) { 480 # unless ($self->lock( $key, $type )) {481 # $log->debug( "can not lock object" );482 # $log->debug( "leaving" );483 #484 # return undef;485 # }486 487 444 eval { 488 445 $fh = _get_filehandle( $path, '<' ); … … 507 464 $log->debug( "entered - @_" ); 508 465 509 # unless ($self->lock( $key, "write" )) {510 # $log->debug( "can not lock object" );511 # $log->debug( "leaving" );512 #513 # return undef;514 # }515 516 466 my $locations = $self->find_instances( $key ); 517 467 518 468 return undef unless $locations; 519 469 470 # a lock is implicitly removed when the last storage object is deleted 520 471 foreach my $uri ( @$locations ) { 521 472 $self->delete_instance( $uri ) or return undef; 522 473 } 523 524 # lock is implicitly removed when the last storage object is deleted525 474 526 475 $log->debug( "leaving" ); … … 563 512 close( $fh ) or $log->logdie->( "can not close $key" ); 564 513 close( $new_fh ) or $log->logdie->( "can not close $new_key" ); 565 566 # unless ($self->unlock( $key, "read" )) {567 # $log->debug( "can not lock object" );568 # $log->debug( "leaving" );569 #570 # return undef;571 # }572 #573 # unless ($self->unlock( $new_key, "write" )) {574 # $log->debug( "can not lock object" );575 # $log->debug( "leaving" );576 #577 # return undef;578 # }579 514 580 515 $log->debug( "leaving" );
Note:
See TracChangeset
for help on using the changeset viewer.
