IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Changeset 2905


Ignore:
Timestamp:
Jan 4, 2005, 6:31:59 PM (22 years ago)
Author:
jhoblitt
Message:

always call ->finish on select sths

Location:
trunk
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • trunk/Nebulous-Server/lib/Nebulous/Server.pm

    r2904 r2905  
    11# Copyright (c) 2004  Joshua Hoblitt
    22#
    3 # $Id: Server.pm,v 1.7 2005-01-05 04:04:45 jhoblitt Exp $
     3# $Id: Server.pm,v 1.8 2005-01-05 04:31:59 jhoblitt Exp $
    44
    55package PS::IPP::IData::Server;
     
    128128            $query->execute;
    129129            ( $ins_id ) = $query->fetchrow_array;
     130
     131            $query->finish;
    130132        }
    131133    };
     
    194196
    195197            unless ( $rows > 0 ) {
     198                $query->finish;
    196199                $db->rollback;
    197200                $log->logdie( "storage object does not exist" );
     
    199202
    200203            $so_id = $query->fetchrow_hashref->{ 'so_id' };
     204            $query->finish;
    201205        }
    202206
     
    211215
    212216            ( $ins_id ) = $query->fetchrow_array;
     217
     218            $query->finish;
    213219        }
    214220
     
    263269    my $read_lock;
    264270    my $write_lock;
     271    my $query;
    265272
    266273    eval {
    267274        # this will set update locks
    268         my $query = $db->prepare_cached( $sql->get_object_locks );
     275        $query = $db->prepare_cached( $sql->get_object_locks );
    269276        my $rows = $query->execute( $key );
    270277        unless ( $rows == 1 ) {
     
    273280
    274281        my $row = $query->fetchrow_hashref;
     282        $query->finish;
    275283
    276284        $so_id      = $row->{ 'so_id' };
     
    279287    };
    280288    if ( $@ ) {
     289        $query->finish;
    281290        $db->rollback;
    282291        $log->logdie( "database error: $@" );
     
    375384    my $read_lock;
    376385    my $write_lock;
     386    my $query;
    377387
    378388    eval {
    379389        # this will set update locks
    380         my $query = $db->prepare_cached( $sql->get_object_locks );
     390        $query = $db->prepare_cached( $sql->get_object_locks );
    381391        my $rows = $query->execute( $key );
    382392        unless ( $rows == 1 ) {
     
    385395
    386396        my $row = $query->fetchrow_hashref;
     397        $query->finish;
    387398
    388399        $so_id      = $row->{ 'so_id' };
     
    391402    };
    392403    if ( $@ ) {
     404        $query->finish;
    393405        $db->rollback;
    394406        $log->logdie( "database error: $@" );
     
    538550
    539551            $so_id = $query->fetchrow_hashref->{ 'so_id' };
     552            $query->finish;
    540553        }
    541554
     
    545558
    546559            $instances = $query->fetchrow_hashref->{ 'count(ins_id)' };
     560            $query->finish;
    547561        }
    548562
     
    604618
    605619        $stat = $query->fetchrow_arrayref;
     620        $query->finish;
    606621
    607622        $db->commit;
  • trunk/Nebulous/lib/Nebulous/Server.pm

    r2904 r2905  
    11# Copyright (c) 2004  Joshua Hoblitt
    22#
    3 # $Id: Server.pm,v 1.7 2005-01-05 04:04:45 jhoblitt Exp $
     3# $Id: Server.pm,v 1.8 2005-01-05 04:31:59 jhoblitt Exp $
    44
    55package PS::IPP::IData::Server;
     
    128128            $query->execute;
    129129            ( $ins_id ) = $query->fetchrow_array;
     130
     131            $query->finish;
    130132        }
    131133    };
     
    194196
    195197            unless ( $rows > 0 ) {
     198                $query->finish;
    196199                $db->rollback;
    197200                $log->logdie( "storage object does not exist" );
     
    199202
    200203            $so_id = $query->fetchrow_hashref->{ 'so_id' };
     204            $query->finish;
    201205        }
    202206
     
    211215
    212216            ( $ins_id ) = $query->fetchrow_array;
     217
     218            $query->finish;
    213219        }
    214220
     
    263269    my $read_lock;
    264270    my $write_lock;
     271    my $query;
    265272
    266273    eval {
    267274        # this will set update locks
    268         my $query = $db->prepare_cached( $sql->get_object_locks );
     275        $query = $db->prepare_cached( $sql->get_object_locks );
    269276        my $rows = $query->execute( $key );
    270277        unless ( $rows == 1 ) {
     
    273280
    274281        my $row = $query->fetchrow_hashref;
     282        $query->finish;
    275283
    276284        $so_id      = $row->{ 'so_id' };
     
    279287    };
    280288    if ( $@ ) {
     289        $query->finish;
    281290        $db->rollback;
    282291        $log->logdie( "database error: $@" );
     
    375384    my $read_lock;
    376385    my $write_lock;
     386    my $query;
    377387
    378388    eval {
    379389        # this will set update locks
    380         my $query = $db->prepare_cached( $sql->get_object_locks );
     390        $query = $db->prepare_cached( $sql->get_object_locks );
    381391        my $rows = $query->execute( $key );
    382392        unless ( $rows == 1 ) {
     
    385395
    386396        my $row = $query->fetchrow_hashref;
     397        $query->finish;
    387398
    388399        $so_id      = $row->{ 'so_id' };
     
    391402    };
    392403    if ( $@ ) {
     404        $query->finish;
    393405        $db->rollback;
    394406        $log->logdie( "database error: $@" );
     
    538550
    539551            $so_id = $query->fetchrow_hashref->{ 'so_id' };
     552            $query->finish;
    540553        }
    541554
     
    545558
    546559            $instances = $query->fetchrow_hashref->{ 'count(ins_id)' };
     560            $query->finish;
    547561        }
    548562
     
    604618
    605619        $stat = $query->fetchrow_arrayref;
     620        $query->finish;
    606621
    607622        $db->commit;
Note: See TracChangeset for help on using the changeset viewer.