diff --git a/scripts/ZoneMinder/lib/ZoneMinder/Storage.pm b/scripts/ZoneMinder/lib/ZoneMinder/Storage.pm index b6924c4e9..134752594 100644 --- a/scripts/ZoneMinder/lib/ZoneMinder/Storage.pm +++ b/scripts/ZoneMinder/lib/ZoneMinder/Storage.pm @@ -53,64 +53,65 @@ $primary_key = 'Id'; #__PACKAGE__->primary_key('Id'); sub find { - shift if $_[0] eq 'ZoneMinder::Storage'; - my %sql_filters = @_; + shift if $_[0] eq 'ZoneMinder::Storage'; + my %sql_filters = @_; - my $sql = 'SELECT * FROM Storage'; - my @sql_filters; - my @sql_values; + my $sql = 'SELECT * FROM Storage'; + my @sql_filters; + my @sql_values; - if ( exists $sql_filters{Id} ) { - push @sql_filters , ' Id=? '; - push @sql_values, $sql_filters{Id}; - } - if ( exists $sql_filters{Name} ) { - push @sql_filters , ' Name = ? '; - push @sql_values, $sql_filters{Name}; - } - if ( exists $sql_filters{ServerId} ) { - push @sql_filters, ' Id IN ( SELECT StorageId FROM Monitors WHERE ServerId=? )'; - push @sql_values, $sql_filters{ServerId}; - } + if ( exists $sql_filters{Id} ) { + push @sql_filters , ' Id=? '; + push @sql_values, $sql_filters{Id}; + } + if ( exists $sql_filters{Name} ) { + push @sql_filters , ' Name = ? '; + push @sql_values, $sql_filters{Name}; + } + if ( exists $sql_filters{ServerId} ) { + push @sql_filters, ' ServerId = ?'; + push @sql_values, $sql_filters{ServerId}; + } - $sql .= ' WHERE ' . join(' AND ', @sql_filters ) if @sql_filters; - $sql .= ' LIMIT ' . $sql_filters{limit} if $sql_filters{limit}; + $sql .= ' WHERE ' . join(' AND ', @sql_filters) if @sql_filters; + $sql .= ' LIMIT ' . $sql_filters{limit} if $sql_filters{limit}; - my $sth = $ZoneMinder::Database::dbh->prepare_cached( $sql ) - or Fatal( "Can't prepare '$sql': ".$ZoneMinder::Database::dbh->errstr() ); - my $res = $sth->execute( @sql_values ) - or Fatal( "Can't execute '$sql': ".$sth->errstr() ); + my $sth = $ZoneMinder::Database::dbh->prepare_cached( $sql ) + or Fatal( "Can't prepare '$sql': ".$ZoneMinder::Database::dbh->errstr() ); + my $res = $sth->execute( @sql_values ) + or Fatal( "Can't execute '$sql': ".$sth->errstr() ); - my @results; + my @results; - while( my $db_filter = $sth->fetchrow_hashref() ) { - my $filter = new ZoneMinder::Storage( $$db_filter{Id}, $db_filter ); - push @results, $filter; - } # end while - return @results; + while( my $db_filter = $sth->fetchrow_hashref() ) { + my $filter = new ZoneMinder::Storage( $$db_filter{Id}, $db_filter ); + push @results, $filter; + } # end while + Debug("SQL: $sql returned " . @results . ' results'); + return @results; } sub find_one { - my @results = find(@_); - return $results[0] if @results; + my @results = find(@_); + return $results[0] if @results; } sub Path { - if ( @_ > 1 ) { - $_[0]{Path} = $_[1]; - } - if ( ! ( $_[0]{Id} or $_[0]{Path} ) ) { - $_[0]{Path} = ($Config{ZM_DIR_EVENTS}=~/^\//) ? $Config{ZM_DIR_EVENTS} : ($Config{ZM_PATH_WEB}.'/'.$Config{ZM_DIR_EVENTS}) - } - return $_[0]{Path}; + if ( @_ > 1 ) { + $_[0]{Path} = $_[1]; + } + if ( ! ( $_[0]{Id} or $_[0]{Path} ) ) { + $_[0]{Path} = ($Config{ZM_DIR_EVENTS}=~/^\//) ? $Config{ZM_DIR_EVENTS} : ($Config{ZM_PATH_WEB}.'/'.$Config{ZM_DIR_EVENTS}) + } + return $_[0]{Path}; } # end sub Path sub Name { - if ( @_ > 1 ) { - $_[0]{Name} = $_[1]; - } - return $_[0]{Name}; + if ( @_ > 1 ) { + $_[0]{Name} = $_[1]; + } + return $_[0]{Name}; } # end sub Path sub DoDelete { diff --git a/scripts/zmaudit.pl.in b/scripts/zmaudit.pl.in index 28a505801..dbe480d28 100644 --- a/scripts/zmaudit.pl.in +++ b/scripts/zmaudit.pl.in @@ -382,7 +382,7 @@ MAIN: while( $loop ) { } # if USE_DEEP_STORAGE Debug( 'Got '.int(keys(%$fs_events))." filesystem events for monitor $monitor_dir\n" ); - #delete_empty_directories( $monitor_dir ); + delete_empty_directories($monitor_dir); } # end foreach monitor if ( $cleaned ) { @@ -879,26 +879,30 @@ sub deleteSwapImage { sub delete_empty_directories { my $DIR; - Debug("delete_empty_directories $_[0]"); - if ( ! opendir( $DIR, $_[0] ) ) { - Error( "delete_empty_directories: Can't open directory '".getcwd()."/$_[0]': $!" ); + if ( !opendir($DIR, $_[0]) ) { + Error("delete_empty_directories: Can't open directory '".getcwd()."/$_[0]': $!" ); return; } - my @contents = map { $_ eq '.' or $_ eq '..' ? () : $_ } readdir( $DIR ); + my @contents = map { ( $_ eq '.' or $_ eq '..' ) ? () : $_ } readdir( $DIR ); + Debug("delete_empty_directories $_[0] has " . @contents .' entries:' . ( @contents < 2 ? join(',',@contents) : '' )); my @dirs = map { -d $_[0].'/'.$_ ? $_ : () } @contents; if ( @dirs ) { + Debug("Have " . @dirs . " dirs"); foreach ( @dirs ) { delete_empty_directories( $_[0].'/'.$_ ); } #Reload, since we may now be empty rewinddir $DIR; - @contents = map { $_ eq '.' or $_ eq '..' ? () : $_ } readdir( $DIR ); + @contents = map { ($_ eq '.' or $_ eq '..') ? () : $_ } readdir( $DIR ); } + closedir($DIR); if ( ! @contents ) { ( my $dir ) = ( $_[0] =~ /^(.*)$/ ); - unlink $dir; + Debug("Unlinking $dir because it's empty"); + if ( ! rmdir $dir ) { + Error("Unable to unlink $dir: $!"); + } } - closedir( $DIR ); } # end sub delete_empty_directories 1; diff --git a/src/zm_videostore.cpp b/src/zm_videostore.cpp index 18ffc47e7..36cc6c45f 100644 --- a/src/zm_videostore.cpp +++ b/src/zm_videostore.cpp @@ -353,6 +353,9 @@ VideoStore::~VideoStore() { // The codec queues data. We need to send a flush command and out // whatever we get. Failures are not fatal. AVPacket pkt; + // Without these we seg fault I don't know why. + pkt.data = NULL; + pkt.size = 0; av_init_packet(&pkt); while (1) { diff --git a/web/includes/Event.php b/web/includes/Event.php index 7a5b74440..4ca0d8c33 100644 --- a/web/includes/Event.php +++ b/web/includes/Event.php @@ -532,7 +532,7 @@ class Event { $file = $backTrace[1]['file']; $line = $backTrace[1]['line']; Error("Invalid value for limit($limit) passed to Event::find from $file:$line"); - return; + return array(); } } } diff --git a/web/includes/Filter.php b/web/includes/Filter.php index f65399320..099307276 100644 --- a/web/includes/Filter.php +++ b/web/includes/Filter.php @@ -145,7 +145,7 @@ public $defaults = array( $file = $backTrace[1]['file']; $line = $backTrace[1]['line']; Error("Invalid value for limit($limit) passed to Filter::find from $file:$line"); - return; + return array(); } } } diff --git a/web/includes/Group.php b/web/includes/Group.php index 4cbdaa83b..dae1acb6a 100644 --- a/web/includes/Group.php +++ b/web/includes/Group.php @@ -91,7 +91,7 @@ class Group { $file = $backTrace[1]['file']; $line = $backTrace[1]['line']; Error("Invalid value for limit($limit) passed to Group::find from $file:$line"); - return; + return array(); } } } # end if options diff --git a/web/includes/Monitor.php b/web/includes/Monitor.php index 19aaf920b..f6ceca734 100644 --- a/web/includes/Monitor.php +++ b/web/includes/Monitor.php @@ -312,7 +312,7 @@ private $control_fields = array( $file = $backTrace[1]['file']; $line = $backTrace[1]['line']; Error("Invalid value for limit($limit) passed to Control::find from $file:$line"); - return; + return array(); } } } diff --git a/web/includes/Server.php b/web/includes/Server.php index f9a82c9bb..1da08c56a 100644 --- a/web/includes/Server.php +++ b/web/includes/Server.php @@ -98,7 +98,7 @@ class Server { $file = $backTrace[1]['file']; $line = $backTrace[1]['line']; Error("Invalid value for limit($limit) passed to Server::find from $file:$line"); - return; + return array(); } } } @@ -106,6 +106,7 @@ class Server { if ( $results ) { return array_map( function($id){ return new Server($id); }, $results ); } + return array(); } public static function find_one( $parameters = array() ) { diff --git a/web/includes/Storage.php b/web/includes/Storage.php index bdd4bdf26..c4be3ae7e 100644 --- a/web/includes/Storage.php +++ b/web/includes/Storage.php @@ -117,7 +117,7 @@ class Storage { $file = $backTrace[1]['file']; $line = $backTrace[1]['line']; Error("Invalid value for limit($limit) passed to Control::find from $file:$line"); - return; + return array(); } } # end if limit } # end if options diff --git a/web/skins/classic/views/storage.php b/web/skins/classic/views/storage.php index 0608ef139..dafd7bb67 100644 --- a/web/skins/classic/views/storage.php +++ b/web/skins/classic/views/storage.php @@ -48,7 +48,7 @@ $scheme_options = array( 'Shallow' => translate('Shallow'), ); -$servers = Server::find_all( null, array('order'=>'lower(Name)') ); +$servers = Server::find( null, array('order'=>'lower(Name)') ); $ServersById = array(); foreach ( $servers as $S ) { $ServersById[$S->Id()] = $S;