Merge branch 'master' of github.com:ZoneMinder/ZoneMinder
This commit is contained in:
Isaac Connor
commit
234a9ce236
|
|
@ -505,6 +505,20 @@ our @options = (
|
||||||
type => $types{directory},
|
type => $types{directory},
|
||||||
category => "paths",
|
category => "paths",
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
name => "ZM_DIR_EXPORTS",
|
||||||
|
default => "@ZM_TMPDIR@",
|
||||||
|
description => "Directory where exported archives are stored",
|
||||||
|
help => qqq("
|
||||||
|
This is the path to the exports directory where exported
|
||||||
|
tar.gz and zip archives are stored. By default this points to
|
||||||
|
ZoneMinder's temp folder, which often sits in ram. Since exported
|
||||||
|
archives can potentially become large, it is a good idea to move
|
||||||
|
this folder to some other location on machines with low memory.
|
||||||
|
"),
|
||||||
|
type => $types{directory},
|
||||||
|
category => "paths",
|
||||||
|
},
|
||||||
{
|
{
|
||||||
name => "ZM_PATH_ZMS",
|
name => "ZM_PATH_ZMS",
|
||||||
default => "/cgi-bin/nph-zms",
|
default => "/cgi-bin/nph-zms",
|
||||||
|
|
|
||||||
|
|
@ -100,16 +100,15 @@ GetOptions(
|
||||||
'interactive' =>\$interactive,
|
'interactive' =>\$interactive,
|
||||||
'continuous' =>\$continuous,
|
'continuous' =>\$continuous,
|
||||||
'version' =>\$version
|
'version' =>\$version
|
||||||
) or pod2usage(-exitstatus => -1);
|
) or pod2usage(-exitstatus => -1);
|
||||||
|
|
||||||
if ( $version ) {
|
if ( $version ) {
|
||||||
print( ZoneMinder::Base::ZM_VERSION . "\n");
|
print( ZoneMinder::Base::ZM_VERSION . "\n");
|
||||||
exit(0);
|
exit(0);
|
||||||
}
|
}
|
||||||
if ( ($report + $interactive + $continuous) > 1 )
|
if ( ($report + $interactive + $continuous) > 1 ) {
|
||||||
{
|
print( STDERR "Error, only one option may be specified\n" );
|
||||||
print( STDERR "Error, only one option may be specified\n" );
|
pod2usage(-exitstatus => -1);
|
||||||
pod2usage(-exitstatus => -1);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
my $dbh = zmDbConnect();
|
my $dbh = zmDbConnect();
|
||||||
|
|
@ -123,517 +122,444 @@ my $image_path = IMAGE_PATH;
|
||||||
my $loop = 1;
|
my $loop = 1;
|
||||||
my $cleaned = 0;
|
my $cleaned = 0;
|
||||||
MAIN: while( $loop ) {
|
MAIN: while( $loop ) {
|
||||||
while ( ! ( $dbh and $dbh->ping() ) ) {
|
while ( ! ( $dbh and $dbh->ping() ) ) {
|
||||||
$dbh = zmDbConnect();
|
$dbh = zmDbConnect();
|
||||||
|
|
||||||
if ( $continuous ) {
|
if ( $continuous ) {
|
||||||
Error("Unable to connect to database");
|
Error("Unable to connect to database");
|
||||||
# if we are running continuously, then just skip to the next
|
# if we are running continuously, then just skip to the next
|
||||||
# interval, otherwise we are a one off run, so wait a second and
|
# interval, otherwise we are a one off run, so wait a second and
|
||||||
# retry until someone kills us.
|
# retry until someone kills us.
|
||||||
sleep( $Config{ZM_AUDIT_CHECK_INTERVAL} );
|
sleep( $Config{ZM_AUDIT_CHECK_INTERVAL} );
|
||||||
} else {
|
} else {
|
||||||
Fatal("Unable to connect to database");
|
Fatal("Unable to connect to database");
|
||||||
} # end if
|
} # end if
|
||||||
} # end while can't connect to the db
|
} # end while can't connect to the db
|
||||||
|
|
||||||
if ( $continuous ) {
|
if ( $continuous ) {
|
||||||
# if we are running continuously, then just skip to the next
|
# if we are running continuously, then just skip to the next
|
||||||
# interval, otherwise we are a one off run, so wait a second and
|
# interval, otherwise we are a one off run, so wait a second and
|
||||||
# retry until someone kills us.
|
# retry until someone kills us.
|
||||||
sleep( $Config{ZM_AUDIT_CHECK_INTERVAL} );
|
sleep( $Config{ZM_AUDIT_CHECK_INTERVAL} );
|
||||||
} else {
|
} else {
|
||||||
sleep 1;
|
sleep 1;
|
||||||
} # end if
|
} # end if
|
||||||
|
|
||||||
if ( ! exists $Config{ZM_AUDIT_MIN_AGE} ) {
|
if ( ! exists $Config{ZM_AUDIT_MIN_AGE} ) {
|
||||||
Fatal("ZM_AUDIT_MIN_AGE is not set in config.");
|
Fatal("ZM_AUDIT_MIN_AGE is not set in config.");
|
||||||
|
}
|
||||||
|
|
||||||
|
my $db_monitors;
|
||||||
|
my $monitorSelectSql = "select Id from Monitors order by Id";
|
||||||
|
my $monitorSelectSth = $dbh->prepare_cached( $monitorSelectSql )
|
||||||
|
or Fatal( "Can't prepare '$monitorSelectSql': ".$dbh->errstr() );
|
||||||
|
my $eventSelectSql = "SELECT Id, (unix_timestamp() - unix_timestamp(StartTime)) as Age
|
||||||
|
FROM Events WHERE MonitorId = ? ORDER BY Id";
|
||||||
|
my $eventSelectSth = $dbh->prepare_cached( $eventSelectSql )
|
||||||
|
or Fatal( "Can't prepare '$eventSelectSql': ".$dbh->errstr() );
|
||||||
|
|
||||||
|
$cleaned = 0;
|
||||||
|
my $res = $monitorSelectSth->execute()
|
||||||
|
or Fatal( "Can't execute: ".$monitorSelectSth->errstr() );
|
||||||
|
while( my $monitor = $monitorSelectSth->fetchrow_hashref() ) {
|
||||||
|
Debug( "Found database monitor '$monitor->{Id}'" );
|
||||||
|
my $db_events = $db_monitors->{$monitor->{Id}} = {};
|
||||||
|
my $res = $eventSelectSth->execute( $monitor->{Id} )
|
||||||
|
or Fatal( "Can't execute: ".$eventSelectSth->errstr() );
|
||||||
|
while ( my $event = $eventSelectSth->fetchrow_hashref() ) {
|
||||||
|
$db_events->{$event->{Id}} = $event->{Age};
|
||||||
}
|
}
|
||||||
|
Debug( "Got ".int(keys(%$db_events))." events\n" );
|
||||||
|
}
|
||||||
|
|
||||||
my $db_monitors;
|
my $fs_monitors;
|
||||||
my $monitorSelectSql = "select Id from Monitors order by Id";
|
foreach my $monitor ( glob("[0-9]*") ) {
|
||||||
my $monitorSelectSth = $dbh->prepare_cached( $monitorSelectSql )
|
# Thie glob above gives all files starting with a digit. So a monitor with a name starting with a digit will be in this list.
|
||||||
or Fatal( "Can't prepare '$monitorSelectSql': ".$dbh->errstr() );
|
next if $monitor =~ /\D/;
|
||||||
my $eventSelectSql = "SELECT Id, (unix_timestamp() - unix_timestamp(StartTime)) as Age
|
Debug( "Found filesystem monitor '$monitor'" );
|
||||||
FROM Events WHERE MonitorId = ? ORDER BY Id";
|
my $fs_events = $fs_monitors->{$monitor} = {};
|
||||||
my $eventSelectSth = $dbh->prepare_cached( $eventSelectSql )
|
( my $monitor_dir ) = ( $monitor =~ /^(.*)$/ ); # De-taint
|
||||||
or Fatal( "Can't prepare '$eventSelectSql': ".$dbh->errstr() );
|
|
||||||
|
|
||||||
$cleaned = 0;
|
if ( $Config{ZM_USE_DEEP_STORAGE} ) {
|
||||||
my $res = $monitorSelectSth->execute()
|
foreach my $day_dir ( glob("$monitor_dir/*/*/*") ) {
|
||||||
or Fatal( "Can't execute: ".$monitorSelectSth->errstr() );
|
Debug( "Checking $day_dir" );
|
||||||
while( my $monitor = $monitorSelectSth->fetchrow_hashref() )
|
( $day_dir ) = ( $day_dir =~ /^(.*)$/ ); # De-taint
|
||||||
{
|
chdir( $day_dir );
|
||||||
Debug( "Found database monitor '$monitor->{Id}'" );
|
opendir( DIR, "." )
|
||||||
my $db_events = $db_monitors->{$monitor->{Id}} = {};
|
or Fatal( "Can't open directory '$day_dir': $!" );
|
||||||
my $res = $eventSelectSth->execute( $monitor->{Id} )
|
my @event_links = sort { $b <=> $a } grep { -l $_ } readdir( DIR );
|
||||||
or Fatal( "Can't execute: ".$eventSelectSth->errstr() );
|
closedir( DIR );
|
||||||
while ( my $event = $eventSelectSth->fetchrow_hashref() )
|
my $count = 0;
|
||||||
{
|
foreach my $event_link ( @event_links ) {
|
||||||
$db_events->{$event->{Id}} = $event->{Age};
|
Debug( "Checking link $event_link" );
|
||||||
}
|
( my $event = $event_link ) =~ s/^.*\.//;
|
||||||
Debug( "Got ".int(keys(%$db_events))." events\n" );
|
my $event_path = readlink( $event_link );
|
||||||
}
|
if ( $count++ > MAX_AGED_DIRS ) {
|
||||||
|
$fs_events->{$event} = -1;
|
||||||
my $fs_monitors;
|
} else {
|
||||||
foreach my $monitor ( glob("[0-9]*") )
|
if ( !-e $event_path ) {
|
||||||
{
|
aud_print( "Event link $day_dir/$event_link does not point to valid target" );
|
||||||
# Thie glob above gives all files starting with a digit. So a monitor with a name starting with a digit will be in this list.
|
if ( confirm() ) {
|
||||||
next if $monitor =~ /\D/;
|
( $event_link ) = ( $event_link =~ /^(.*)$/ ); # De-taint
|
||||||
Debug( "Found filesystem monitor '$monitor'" );
|
unlink( $event_link );
|
||||||
my $fs_events = $fs_monitors->{$monitor} = {};
|
|
||||||
( my $monitor_dir ) = ( $monitor =~ /^(.*)$/ ); # De-taint
|
|
||||||
|
|
||||||
if ( $Config{ZM_USE_DEEP_STORAGE} )
|
|
||||||
{
|
|
||||||
foreach my $day_dir ( glob("$monitor_dir/*/*/*") )
|
|
||||||
{
|
|
||||||
Debug( "Checking $day_dir" );
|
|
||||||
( $day_dir ) = ( $day_dir =~ /^(.*)$/ ); # De-taint
|
|
||||||
chdir( $day_dir );
|
|
||||||
opendir( DIR, "." )
|
|
||||||
or Fatal( "Can't open directory '$day_dir': $!" );
|
|
||||||
my @event_links = sort { $b <=> $a } grep { -l $_ } readdir( DIR );
|
|
||||||
closedir( DIR );
|
|
||||||
my $count = 0;
|
|
||||||
foreach my $event_link ( @event_links )
|
|
||||||
{
|
|
||||||
Debug( "Checking link $event_link" );
|
|
||||||
( my $event = $event_link ) =~ s/^.*\.//;
|
|
||||||
my $event_path = readlink( $event_link );
|
|
||||||
if ( $count++ > MAX_AGED_DIRS )
|
|
||||||
{
|
|
||||||
$fs_events->{$event} = -1;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
if ( !-e $event_path )
|
|
||||||
{
|
|
||||||
aud_print( "Event link $day_dir/$event_link does not point to valid target" );
|
|
||||||
if ( confirm() )
|
|
||||||
{
|
|
||||||
( $event_link ) = ( $event_link =~ /^(.*)$/ ); # De-taint
|
|
||||||
unlink( $event_link );
|
|
||||||
$cleaned = 1;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
$fs_events->{$event} = (time() - ($^T - ((-M $event_path) * 24*60*60)));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
chdir( EVENT_PATH );
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
chdir( $monitor_dir );
|
|
||||||
opendir( DIR, "." ) or Fatal( "Can't open directory '$monitor_dir': $!" );
|
|
||||||
my @temp_events = sort { $b <=> $a } grep { -d $_ && $_ =~ /^\d+$/ } readdir( DIR );
|
|
||||||
closedir( DIR );
|
|
||||||
my $count = 0;
|
|
||||||
foreach my $event ( @temp_events )
|
|
||||||
{
|
|
||||||
if ( $count++ > MAX_AGED_DIRS )
|
|
||||||
{
|
|
||||||
$fs_events->{$event} = -1;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
$fs_events->{$event} = (time() - ($^T - ((-M $event) * 24*60*60)));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
chdir( EVENT_PATH );
|
|
||||||
}
|
|
||||||
Debug( "Got ".int(keys(%$fs_events))." events\n" );
|
|
||||||
}
|
|
||||||
redo MAIN if ( $cleaned );
|
|
||||||
|
|
||||||
$cleaned = 0;
|
|
||||||
while ( my ( $fs_monitor, $fs_events ) = each(%$fs_monitors) )
|
|
||||||
{
|
|
||||||
if ( my $db_events = $db_monitors->{$fs_monitor} )
|
|
||||||
{
|
|
||||||
if ( $fs_events )
|
|
||||||
{
|
|
||||||
while ( my ( $fs_event, $age ) = each(%$fs_events ) )
|
|
||||||
{
|
|
||||||
if ( !defined($db_events->{$fs_event}) && ($age < 0 || ($age > $Config{ZM_AUDIT_MIN_AGE})) )
|
|
||||||
{
|
|
||||||
aud_print( "Filesystem event '$fs_monitor/$fs_event' does not exist in database" );
|
|
||||||
if ( confirm() )
|
|
||||||
{
|
|
||||||
deleteEventFiles( $fs_event, $fs_monitor );
|
|
||||||
$cleaned = 1;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
aud_print( "Filesystem monitor '$fs_monitor' does not exist in database" );
|
|
||||||
if ( confirm() )
|
|
||||||
{
|
|
||||||
my $command = "rm -rf $fs_monitor";
|
|
||||||
executeShellCommand( $command );
|
|
||||||
$cleaned = 1;
|
$cleaned = 1;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
$fs_events->{$event} = (time() - ($^T - ((-M $event_path) * 24*60*60)));
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
} # end foreach event_link
|
||||||
|
chdir( EVENT_PATH );
|
||||||
|
} # end foreach day_dir
|
||||||
|
} else {
|
||||||
|
chdir( $monitor_dir );
|
||||||
|
opendir( DIR, "." ) or Fatal( "Can't open directory '$monitor_dir': $!" );
|
||||||
|
my @temp_events = sort { $b <=> $a } grep { -d $_ && $_ =~ /^\d+$/ } readdir( DIR );
|
||||||
|
closedir( DIR );
|
||||||
|
my $count = 0;
|
||||||
|
foreach my $event ( @temp_events ) {
|
||||||
|
if ( $count++ > MAX_AGED_DIRS ) {
|
||||||
|
$fs_events->{$event} = -1;
|
||||||
|
} else {
|
||||||
|
$fs_events->{$event} = (time() - ($^T - ((-M $event) * 24*60*60)));
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
chdir( EVENT_PATH );
|
||||||
}
|
}
|
||||||
|
Debug( "Got ".int(keys(%$fs_events))." events\n" );
|
||||||
|
} # end foreach monitor Id
|
||||||
|
redo MAIN if ( $cleaned );
|
||||||
|
|
||||||
my $monitor_links;
|
$cleaned = 0;
|
||||||
foreach my $link ( glob("*") )
|
while ( my ( $fs_monitor, $fs_events ) = each(%$fs_monitors) ) {
|
||||||
{
|
if ( my $db_events = $db_monitors->{$fs_monitor} ) {
|
||||||
next if ( !-l $link );
|
if ( $fs_events ) {
|
||||||
next if ( -e $link );
|
while ( my ( $fs_event, $age ) = each(%$fs_events ) ) {
|
||||||
|
if ( !defined($db_events->{$fs_event}) && ($age < 0 || ($age > $Config{ZM_AUDIT_MIN_AGE})) ) {
|
||||||
aud_print( "Filesystem monitor link '$link' does not point to valid monitor directory" );
|
aud_print( "Filesystem event '$fs_monitor/$fs_event' does not exist in database" );
|
||||||
if ( confirm() )
|
if ( confirm() ) {
|
||||||
{
|
deleteEventFiles( $fs_event, $fs_monitor );
|
||||||
( $link ) = ( $link =~ /^(.*)$/ ); # De-taint
|
$cleaned = 1;
|
||||||
my $command = qq`rm "$link"`;
|
|
||||||
executeShellCommand( $command );
|
|
||||||
$cleaned = 1;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
redo MAIN if ( $cleaned );
|
|
||||||
|
|
||||||
$cleaned = 0;
|
|
||||||
my $deleteMonitorSql = "delete low_priority from Monitors where Id = ?";
|
|
||||||
my $deleteMonitorSth = $dbh->prepare_cached( $deleteMonitorSql )
|
|
||||||
or Fatal( "Can't prepare '$deleteMonitorSql': ".$dbh->errstr() );
|
|
||||||
my $deleteEventSql = "delete low_priority from Events where Id = ?";
|
|
||||||
my $deleteEventSth = $dbh->prepare_cached( $deleteEventSql )
|
|
||||||
or Fatal( "Can't prepare '$deleteEventSql': ".$dbh->errstr() );
|
|
||||||
my $deleteFramesSql = "delete low_priority from Frames where EventId = ?";
|
|
||||||
my $deleteFramesSth = $dbh->prepare_cached( $deleteFramesSql )
|
|
||||||
or Fatal( "Can't prepare '$deleteFramesSql': ".$dbh->errstr() );
|
|
||||||
my $deleteStatsSql = "delete low_priority from Stats where EventId = ?";
|
|
||||||
my $deleteStatsSth = $dbh->prepare_cached( $deleteStatsSql )
|
|
||||||
or Fatal( "Can't prepare '$deleteStatsSql': ".$dbh->errstr() );
|
|
||||||
while ( my ( $db_monitor, $db_events ) = each(%$db_monitors) )
|
|
||||||
{
|
|
||||||
if ( my $fs_events = $fs_monitors->{$db_monitor} )
|
|
||||||
{
|
|
||||||
if ( $db_events )
|
|
||||||
{
|
|
||||||
while ( my ( $db_event, $age ) = each(%$db_events ) )
|
|
||||||
{
|
|
||||||
if ( !defined($fs_events->{$db_event}) ) {
|
|
||||||
if ( $age > $Config{ZM_AUDIT_MIN_AGE} ) {
|
|
||||||
aud_print( "Database event '$db_monitor/$db_event' does not exist in filesystem" );
|
|
||||||
if ( confirm() ) {
|
|
||||||
my $res = $deleteEventSth->execute( $db_event )
|
|
||||||
or Fatal( "Can't execute: ".$deleteEventSth->errstr() );
|
|
||||||
$res = $deleteFramesSth->execute( $db_event )
|
|
||||||
or Fatal( "Can't execute: ".$deleteFramesSth->errstr() );
|
|
||||||
$res = $deleteStatsSth->execute( $db_event )
|
|
||||||
or Fatal( "Can't execute: ".$deleteStatsSth->errstr() );
|
|
||||||
$cleaned = 1;
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
aud_print( "Database event '$db_monitor/$db_event' does not exist in filesystem but too young to delete." );
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
else
|
}
|
||||||
{
|
} else {
|
||||||
aud_print( "Database monitor '$db_monitor' does not exist in filesystem" );
|
aud_print( "Filesystem monitor '$fs_monitor' does not exist in database" );
|
||||||
#if ( confirm() )
|
if ( confirm() ) {
|
||||||
#{
|
my $command = "rm -rf $fs_monitor";
|
||||||
# We don't actually do this in case it's new
|
executeShellCommand( $command );
|
||||||
#my $res = $deleteMonitorSth->execute( $db_monitor )
|
$cleaned = 1;
|
||||||
# or Fatal( "Can't execute: ".$deleteMonitorSth->errstr() );
|
}
|
||||||
#$cleaned = 1;
|
|
||||||
#}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
redo MAIN if ( $cleaned );
|
}
|
||||||
|
|
||||||
# Remove orphaned events (with no monitor)
|
my $monitor_links;
|
||||||
$cleaned = 0;
|
foreach my $link ( glob("*") ) {
|
||||||
my $selectOrphanedEventsSql = "SELECT Events.Id, Events.Name
|
next if ( !-l $link );
|
||||||
FROM Events LEFT JOIN Monitors ON (Events.MonitorId = Monitors.Id)
|
next if ( -e $link );
|
||||||
WHERE isnull(Monitors.Id)";
|
|
||||||
my $selectOrphanedEventsSth = $dbh->prepare_cached( $selectOrphanedEventsSql )
|
aud_print( "Filesystem monitor link '$link' does not point to valid monitor directory" );
|
||||||
or Fatal( "Can't prepare '$selectOrphanedEventsSql': ".$dbh->errstr() );
|
if ( confirm() ) {
|
||||||
$res = $selectOrphanedEventsSth->execute()
|
( $link ) = ( $link =~ /^(.*)$/ ); # De-taint
|
||||||
or Fatal( "Can't execute: ".$selectOrphanedEventsSth->errstr() );
|
my $command = qq`rm "$link"`;
|
||||||
while( my $event = $selectOrphanedEventsSth->fetchrow_hashref() )
|
executeShellCommand( $command );
|
||||||
{
|
$cleaned = 1;
|
||||||
aud_print( "Found orphaned event with no monitor '$event->{Id}'" );
|
|
||||||
if ( confirm() )
|
|
||||||
{
|
|
||||||
$res = $deleteEventSth->execute( $event->{Id} )
|
|
||||||
or Fatal( "Can't execute: ".$deleteEventSth->errstr() );
|
|
||||||
$cleaned = 1;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
redo MAIN if ( $cleaned );
|
}
|
||||||
|
redo MAIN if ( $cleaned );
|
||||||
|
|
||||||
# Remove empty events (with no frames)
|
$cleaned = 0;
|
||||||
$cleaned = 0;
|
my $deleteMonitorSql = "delete low_priority from Monitors where Id = ?";
|
||||||
my $selectEmptyEventsSql = "SELECT E.Id AS Id, E.StartTime, F.EventId FROM Events as E LEFT JOIN Frames as F ON (E.Id = F.EventId)
|
my $deleteMonitorSth = $dbh->prepare_cached( $deleteMonitorSql )
|
||||||
WHERE isnull(F.EventId) AND now() - interval ".$Config{ZM_AUDIT_MIN_AGE}." second > E.StartTime";
|
or Fatal( "Can't prepare '$deleteMonitorSql': ".$dbh->errstr() );
|
||||||
my $selectEmptyEventsSth = $dbh->prepare_cached( $selectEmptyEventsSql )
|
my $deleteEventSql = "delete low_priority from Events where Id = ?";
|
||||||
or Fatal( "Can't prepare '$selectEmptyEventsSql': ".$dbh->errstr() );
|
my $deleteEventSth = $dbh->prepare_cached( $deleteEventSql )
|
||||||
$res = $selectEmptyEventsSth->execute()
|
or Fatal( "Can't prepare '$deleteEventSql': ".$dbh->errstr() );
|
||||||
or Fatal( "Can't execute: ".$selectEmptyEventsSth->errstr() );
|
my $deleteFramesSql = "delete low_priority from Frames where EventId = ?";
|
||||||
while( my $event = $selectEmptyEventsSth->fetchrow_hashref() )
|
my $deleteFramesSth = $dbh->prepare_cached( $deleteFramesSql )
|
||||||
{
|
or Fatal( "Can't prepare '$deleteFramesSql': ".$dbh->errstr() );
|
||||||
aud_print( "Found empty event with no frame records '$event->{Id}'" );
|
my $deleteStatsSql = "delete low_priority from Stats where EventId = ?";
|
||||||
if ( confirm() )
|
my $deleteStatsSth = $dbh->prepare_cached( $deleteStatsSql )
|
||||||
{
|
or Fatal( "Can't prepare '$deleteStatsSql': ".$dbh->errstr() );
|
||||||
$res = $deleteEventSth->execute( $event->{Id} )
|
while ( my ( $db_monitor, $db_events ) = each(%$db_monitors) ) {
|
||||||
or Fatal( "Can't execute: ".$deleteEventSth->errstr() );
|
if ( my $fs_events = $fs_monitors->{$db_monitor} ) {
|
||||||
$cleaned = 1;
|
if ( $db_events ) {
|
||||||
}
|
while ( my ( $db_event, $age ) = each(%$db_events ) ) {
|
||||||
}
|
if ( !defined($fs_events->{$db_event}) ) {
|
||||||
redo MAIN if ( $cleaned );
|
if ( $age > $Config{ZM_AUDIT_MIN_AGE} ) {
|
||||||
|
aud_print( "Database event '$db_monitor/$db_event' does not exist in filesystem" );
|
||||||
# Remove orphaned frame records
|
if ( confirm() ) {
|
||||||
$cleaned = 0;
|
my $res = $deleteEventSth->execute( $db_event )
|
||||||
my $selectOrphanedFramesSql = "SELECT DISTINCT EventId FROM Frames
|
or Fatal( "Can't execute: ".$deleteEventSth->errstr() );
|
||||||
WHERE EventId NOT IN (SELECT Id FROM Events)";
|
$res = $deleteFramesSth->execute( $db_event )
|
||||||
my $selectOrphanedFramesSth = $dbh->prepare_cached( $selectOrphanedFramesSql )
|
or Fatal( "Can't execute: ".$deleteFramesSth->errstr() );
|
||||||
or Fatal( "Can't prepare '$selectOrphanedFramesSql': ".$dbh->errstr() );
|
$res = $deleteStatsSth->execute( $db_event )
|
||||||
$res = $selectOrphanedFramesSth->execute()
|
or Fatal( "Can't execute: ".$deleteStatsSth->errstr() );
|
||||||
or Fatal( "Can't execute: ".$selectOrphanedFramesSth->errstr() );
|
$cleaned = 1;
|
||||||
while( my $frame = $selectOrphanedFramesSth->fetchrow_hashref() )
|
}
|
||||||
{
|
} else {
|
||||||
aud_print( "Found orphaned frame records for event '$frame->{EventId}'" );
|
aud_print( "Database event '$db_monitor/$db_event' does not exist in filesystem but too young to delete." );
|
||||||
if ( confirm() )
|
|
||||||
{
|
|
||||||
$res = $deleteFramesSth->execute( $frame->{EventId} )
|
|
||||||
or Fatal( "Can't execute: ".$deleteFramesSth->errstr() );
|
|
||||||
$cleaned = 1;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
redo MAIN if ( $cleaned );
|
|
||||||
|
|
||||||
# Remove orphaned stats records
|
|
||||||
$cleaned = 0;
|
|
||||||
my $selectOrphanedStatsSql = "SELECT DISTINCT EventId FROM Stats
|
|
||||||
WHERE EventId NOT IN (SELECT Id FROM Events)";
|
|
||||||
my $selectOrphanedStatsSth = $dbh->prepare_cached( $selectOrphanedStatsSql )
|
|
||||||
or Fatal( "Can't prepare '$selectOrphanedStatsSql': ".$dbh->errstr() );
|
|
||||||
$res = $selectOrphanedStatsSth->execute()
|
|
||||||
or Fatal( "Can't execute: ".$selectOrphanedStatsSth->errstr() );
|
|
||||||
while( my $stat = $selectOrphanedStatsSth->fetchrow_hashref() )
|
|
||||||
{
|
|
||||||
aud_print( "Found orphaned statistic records for event '$stat->{EventId}'" );
|
|
||||||
if ( confirm() )
|
|
||||||
{
|
|
||||||
$res = $deleteStatsSth->execute( $stat->{EventId} )
|
|
||||||
or Fatal( "Can't execute: ".$deleteStatsSth->errstr() );
|
|
||||||
$cleaned = 1;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
redo MAIN if ( $cleaned );
|
|
||||||
|
|
||||||
# New audit to close any events that were left open for longer than MIN_AGE seconds
|
|
||||||
my $selectUnclosedEventsSql =
|
|
||||||
"SELECT E.Id,
|
|
||||||
max(F.TimeStamp) as EndTime,
|
|
||||||
unix_timestamp(max(F.TimeStamp)) - unix_timestamp(E.StartTime) as Length,
|
|
||||||
max(F.FrameId) as Frames,
|
|
||||||
count(if(F.Score>0,1,NULL)) as AlarmFrames,
|
|
||||||
sum(F.Score) as TotScore,
|
|
||||||
max(F.Score) as MaxScore,
|
|
||||||
M.EventPrefix as Prefix
|
|
||||||
FROM Events as E
|
|
||||||
LEFT JOIN Monitors as M on E.MonitorId = M.Id
|
|
||||||
INNER JOIN Frames as F on E.Id = F.EventId
|
|
||||||
WHERE isnull(E.Frames) or isnull(E.EndTime)
|
|
||||||
GROUP BY E.Id HAVING EndTime < (now() - interval ".$Config{ZM_AUDIT_MIN_AGE}." second)"
|
|
||||||
;
|
|
||||||
my $selectUnclosedEventsSth = $dbh->prepare_cached( $selectUnclosedEventsSql )
|
|
||||||
or Fatal( "Can't prepare '$selectUnclosedEventsSql': ".$dbh->errstr() );
|
|
||||||
my $updateUnclosedEventsSql =
|
|
||||||
"UPDATE low_priority Events
|
|
||||||
SET Name = ?,
|
|
||||||
EndTime = ?,
|
|
||||||
Length = ?,
|
|
||||||
Frames = ?,
|
|
||||||
AlarmFrames = ?,
|
|
||||||
TotScore = ?,
|
|
||||||
AvgScore = ?,
|
|
||||||
MaxScore = ?,
|
|
||||||
Notes = concat_ws( ' ', Notes, ? )
|
|
||||||
WHERE Id = ?"
|
|
||||||
;
|
|
||||||
my $updateUnclosedEventsSth = $dbh->prepare_cached( $updateUnclosedEventsSql )
|
|
||||||
or Fatal( "Can't prepare '$updateUnclosedEventsSql': ".$dbh->errstr() );
|
|
||||||
$res = $selectUnclosedEventsSth->execute()
|
|
||||||
or Fatal( "Can't execute: ".$selectUnclosedEventsSth->errstr() );
|
|
||||||
while( my $event = $selectUnclosedEventsSth->fetchrow_hashref() )
|
|
||||||
{
|
|
||||||
aud_print( "Found open event '$event->{Id}'" );
|
|
||||||
if ( confirm( 'close', 'closing' ) )
|
|
||||||
{
|
|
||||||
$res = $updateUnclosedEventsSth->execute
|
|
||||||
(
|
|
||||||
sprintf("%s%d%s",
|
|
||||||
$event->{Prefix},
|
|
||||||
$event->{Id},
|
|
||||||
RECOVER_TAG
|
|
||||||
),
|
|
||||||
$event->{EndTime},
|
|
||||||
$event->{Length},
|
|
||||||
$event->{Frames},
|
|
||||||
$event->{AlarmFrames},
|
|
||||||
$event->{TotScore},
|
|
||||||
$event->{AlarmFrames}
|
|
||||||
? int($event->{TotScore} / $event->{AlarmFrames})
|
|
||||||
: 0
|
|
||||||
,
|
|
||||||
$event->{MaxScore},
|
|
||||||
RECOVER_TEXT,
|
|
||||||
$event->{Id}
|
|
||||||
) or Fatal( "Can't execute: ".$updateUnclosedEventsSth->errstr() );
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
# Now delete any old image files
|
|
||||||
if ( my @old_files = grep { -M > $max_image_age } <$image_path/*.{jpg,gif,wbmp}> )
|
|
||||||
{
|
|
||||||
aud_print( "Deleting ".int(@old_files)." old images\n" );
|
|
||||||
my $untainted_old_files = join( ";", @old_files );
|
|
||||||
( $untainted_old_files ) = ( $untainted_old_files =~ /^(.*)$/ );
|
|
||||||
unlink( split( /;/, $untainted_old_files ) );
|
|
||||||
}
|
|
||||||
|
|
||||||
# Now delete any old swap files
|
|
||||||
( my $swap_image_root ) = ( $Config{ZM_PATH_SWAP} =~ /^(.*)$/ ); # De-taint
|
|
||||||
File::Find::find( { wanted=>\&deleteSwapImage, untaint=>1 }, $swap_image_root );
|
|
||||||
|
|
||||||
# Prune the Logs table if required
|
|
||||||
if ( $Config{ZM_LOG_DATABASE_LIMIT} )
|
|
||||||
{
|
|
||||||
if ( $Config{ZM_LOG_DATABASE_LIMIT} =~ /^\d+$/ )
|
|
||||||
{
|
|
||||||
# Number of rows
|
|
||||||
my $selectLogRowCountSql = "SELECT count(*) as Rows from Logs";
|
|
||||||
my $selectLogRowCountSth = $dbh->prepare_cached( $selectLogRowCountSql )
|
|
||||||
or Fatal( "Can't prepare '$selectLogRowCountSql': ".$dbh->errstr() );
|
|
||||||
$res = $selectLogRowCountSth->execute()
|
|
||||||
or Fatal( "Can't execute: ".$selectLogRowCountSth->errstr() );
|
|
||||||
my $row = $selectLogRowCountSth->fetchrow_hashref();
|
|
||||||
my $logRows = $row->{Rows};
|
|
||||||
if ( $logRows > $Config{ZM_LOG_DATABASE_LIMIT} )
|
|
||||||
{
|
|
||||||
my $deleteLogByRowsSql = "DELETE low_priority FROM Logs ORDER BY TimeKey ASC LIMIT ?";
|
|
||||||
my $deleteLogByRowsSth = $dbh->prepare_cached( $deleteLogByRowsSql )
|
|
||||||
or Fatal( "Can't prepare '$deleteLogByRowsSql': ".$dbh->errstr() );
|
|
||||||
$res = $deleteLogByRowsSth->execute( $logRows - $Config{ZM_LOG_DATABASE_LIMIT} )
|
|
||||||
or Fatal( "Can't execute: ".$deleteLogByRowsSth->errstr() );
|
|
||||||
if ( $deleteLogByRowsSth->rows() )
|
|
||||||
{
|
|
||||||
aud_print( "Deleted ".$deleteLogByRowsSth->rows()
|
|
||||||
." log table entries by count\n" )
|
|
||||||
;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
# Time of record
|
|
||||||
my $deleteLogByTimeSql =
|
|
||||||
"DELETE low_priority FROM Logs
|
|
||||||
WHERE TimeKey < unix_timestamp(now() - interval ".$Config{ZM_LOG_DATABASE_LIMIT}.")";
|
|
||||||
my $deleteLogByTimeSth = $dbh->prepare_cached( $deleteLogByTimeSql )
|
|
||||||
or Fatal( "Can't prepare '$deleteLogByTimeSql': ".$dbh->errstr() );
|
|
||||||
$res = $deleteLogByTimeSth->execute()
|
|
||||||
or Fatal( "Can't execute: ".$deleteLogByTimeSth->errstr() );
|
|
||||||
if ( $deleteLogByTimeSth->rows() ){
|
|
||||||
aud_print( "Deleted ".$deleteLogByTimeSth->rows()
|
|
||||||
." log table entries by time\n" )
|
|
||||||
;
|
|
||||||
}
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
} # end if db_events
|
||||||
|
} else {
|
||||||
|
aud_print( "Database monitor '$db_monitor' does not exist in filesystem" );
|
||||||
|
#if ( confirm() )
|
||||||
|
#{
|
||||||
|
# We don't actually do this in case it's new
|
||||||
|
#my $res = $deleteMonitorSth->execute( $db_monitor )
|
||||||
|
# or Fatal( "Can't execute: ".$deleteMonitorSth->errstr() );
|
||||||
|
#$cleaned = 1;
|
||||||
|
#}
|
||||||
}
|
}
|
||||||
$loop = $continuous;
|
} # end foreach db_monitor
|
||||||
|
redo MAIN if ( $cleaned );
|
||||||
|
|
||||||
sleep( $Config{ZM_AUDIT_CHECK_INTERVAL} ) if $continuous;
|
# Remove orphaned events (with no monitor)
|
||||||
|
$cleaned = 0;
|
||||||
|
my $selectOrphanedEventsSql = "SELECT Events.Id, Events.Name
|
||||||
|
FROM Events LEFT JOIN Monitors ON (Events.MonitorId = Monitors.Id)
|
||||||
|
WHERE isnull(Monitors.Id)";
|
||||||
|
my $selectOrphanedEventsSth = $dbh->prepare_cached( $selectOrphanedEventsSql )
|
||||||
|
or Fatal( "Can't prepare '$selectOrphanedEventsSql': ".$dbh->errstr() );
|
||||||
|
$res = $selectOrphanedEventsSth->execute()
|
||||||
|
or Fatal( "Can't execute: ".$selectOrphanedEventsSth->errstr() );
|
||||||
|
while( my $event = $selectOrphanedEventsSth->fetchrow_hashref() ) {
|
||||||
|
aud_print( "Found orphaned event with no monitor '$event->{Id}'" );
|
||||||
|
if ( confirm() ) {
|
||||||
|
$res = $deleteEventSth->execute( $event->{Id} )
|
||||||
|
or Fatal( "Can't execute: ".$deleteEventSth->errstr() );
|
||||||
|
$cleaned = 1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
redo MAIN if ( $cleaned );
|
||||||
|
|
||||||
|
# Remove empty events (with no frames)
|
||||||
|
$cleaned = 0;
|
||||||
|
my $selectEmptyEventsSql = "SELECT E.Id AS Id, E.StartTime, F.EventId FROM Events as E LEFT JOIN Frames as F ON (E.Id = F.EventId)
|
||||||
|
WHERE isnull(F.EventId) AND now() - interval ".$Config{ZM_AUDIT_MIN_AGE}." second > E.StartTime";
|
||||||
|
my $selectEmptyEventsSth = $dbh->prepare_cached( $selectEmptyEventsSql )
|
||||||
|
or Fatal( "Can't prepare '$selectEmptyEventsSql': ".$dbh->errstr() );
|
||||||
|
$res = $selectEmptyEventsSth->execute()
|
||||||
|
or Fatal( "Can't execute: ".$selectEmptyEventsSth->errstr() );
|
||||||
|
while( my $event = $selectEmptyEventsSth->fetchrow_hashref() ) {
|
||||||
|
aud_print( "Found empty event with no frame records '$event->{Id}'" );
|
||||||
|
if ( confirm() ) {
|
||||||
|
$res = $deleteEventSth->execute( $event->{Id} )
|
||||||
|
or Fatal( "Can't execute: ".$deleteEventSth->errstr() );
|
||||||
|
$cleaned = 1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
redo MAIN if ( $cleaned );
|
||||||
|
|
||||||
|
# Remove orphaned frame records
|
||||||
|
$cleaned = 0;
|
||||||
|
my $selectOrphanedFramesSql = "SELECT DISTINCT EventId FROM Frames
|
||||||
|
WHERE EventId NOT IN (SELECT Id FROM Events)";
|
||||||
|
my $selectOrphanedFramesSth = $dbh->prepare_cached( $selectOrphanedFramesSql )
|
||||||
|
or Fatal( "Can't prepare '$selectOrphanedFramesSql': ".$dbh->errstr() );
|
||||||
|
$res = $selectOrphanedFramesSth->execute()
|
||||||
|
or Fatal( "Can't execute: ".$selectOrphanedFramesSth->errstr() );
|
||||||
|
while( my $frame = $selectOrphanedFramesSth->fetchrow_hashref() ) {
|
||||||
|
aud_print( "Found orphaned frame records for event '$frame->{EventId}'" );
|
||||||
|
if ( confirm() ) {
|
||||||
|
$res = $deleteFramesSth->execute( $frame->{EventId} )
|
||||||
|
or Fatal( "Can't execute: ".$deleteFramesSth->errstr() );
|
||||||
|
$cleaned = 1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
redo MAIN if ( $cleaned );
|
||||||
|
|
||||||
|
# Remove orphaned stats records
|
||||||
|
$cleaned = 0;
|
||||||
|
my $selectOrphanedStatsSql = "SELECT DISTINCT EventId FROM Stats
|
||||||
|
WHERE EventId NOT IN (SELECT Id FROM Events)";
|
||||||
|
my $selectOrphanedStatsSth = $dbh->prepare_cached( $selectOrphanedStatsSql )
|
||||||
|
or Fatal( "Can't prepare '$selectOrphanedStatsSql': ".$dbh->errstr() );
|
||||||
|
$res = $selectOrphanedStatsSth->execute()
|
||||||
|
or Fatal( "Can't execute: ".$selectOrphanedStatsSth->errstr() );
|
||||||
|
while( my $stat = $selectOrphanedStatsSth->fetchrow_hashref() ) {
|
||||||
|
aud_print( "Found orphaned statistic records for event '$stat->{EventId}'" );
|
||||||
|
if ( confirm() ) {
|
||||||
|
$res = $deleteStatsSth->execute( $stat->{EventId} )
|
||||||
|
or Fatal( "Can't execute: ".$deleteStatsSth->errstr() );
|
||||||
|
$cleaned = 1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
redo MAIN if ( $cleaned );
|
||||||
|
|
||||||
|
# New audit to close any events that were left open for longer than MIN_AGE seconds
|
||||||
|
my $selectUnclosedEventsSql =
|
||||||
|
"SELECT E.Id,
|
||||||
|
max(F.TimeStamp) as EndTime,
|
||||||
|
unix_timestamp(max(F.TimeStamp)) - unix_timestamp(E.StartTime) as Length,
|
||||||
|
max(F.FrameId) as Frames,
|
||||||
|
count(if(F.Score>0,1,NULL)) as AlarmFrames,
|
||||||
|
sum(F.Score) as TotScore,
|
||||||
|
max(F.Score) as MaxScore,
|
||||||
|
M.EventPrefix as Prefix
|
||||||
|
FROM Events as E
|
||||||
|
LEFT JOIN Monitors as M on E.MonitorId = M.Id
|
||||||
|
INNER JOIN Frames as F on E.Id = F.EventId
|
||||||
|
WHERE isnull(E.Frames) or isnull(E.EndTime)
|
||||||
|
GROUP BY E.Id HAVING EndTime < (now() - interval ".$Config{ZM_AUDIT_MIN_AGE}." second)"
|
||||||
|
;
|
||||||
|
my $selectUnclosedEventsSth = $dbh->prepare_cached( $selectUnclosedEventsSql )
|
||||||
|
or Fatal( "Can't prepare '$selectUnclosedEventsSql': ".$dbh->errstr() );
|
||||||
|
my $updateUnclosedEventsSql =
|
||||||
|
"UPDATE low_priority Events
|
||||||
|
SET Name = ?,
|
||||||
|
EndTime = ?,
|
||||||
|
Length = ?,
|
||||||
|
Frames = ?,
|
||||||
|
AlarmFrames = ?,
|
||||||
|
TotScore = ?,
|
||||||
|
AvgScore = ?,
|
||||||
|
MaxScore = ?,
|
||||||
|
Notes = concat_ws( ' ', Notes, ? )
|
||||||
|
WHERE Id = ?"
|
||||||
|
;
|
||||||
|
my $updateUnclosedEventsSth = $dbh->prepare_cached( $updateUnclosedEventsSql )
|
||||||
|
or Fatal( "Can't prepare '$updateUnclosedEventsSql': ".$dbh->errstr() );
|
||||||
|
$res = $selectUnclosedEventsSth->execute()
|
||||||
|
or Fatal( "Can't execute: ".$selectUnclosedEventsSth->errstr() );
|
||||||
|
while( my $event = $selectUnclosedEventsSth->fetchrow_hashref() ) {
|
||||||
|
aud_print( "Found open event '$event->{Id}'" );
|
||||||
|
if ( confirm( 'close', 'closing' ) ) {
|
||||||
|
$res = $updateUnclosedEventsSth->execute(
|
||||||
|
sprintf("%s%d%s",
|
||||||
|
$event->{Prefix},
|
||||||
|
$event->{Id},
|
||||||
|
RECOVER_TAG
|
||||||
|
),
|
||||||
|
$event->{EndTime},
|
||||||
|
$event->{Length},
|
||||||
|
$event->{Frames},
|
||||||
|
$event->{AlarmFrames},
|
||||||
|
$event->{TotScore},
|
||||||
|
$event->{AlarmFrames}
|
||||||
|
? int($event->{TotScore} / $event->{AlarmFrames})
|
||||||
|
: 0
|
||||||
|
,
|
||||||
|
$event->{MaxScore},
|
||||||
|
RECOVER_TEXT,
|
||||||
|
$event->{Id}
|
||||||
|
) or Fatal( "Can't execute: ".$updateUnclosedEventsSth->errstr() );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
# Now delete any old image files
|
||||||
|
my @old_files = grep { -M > $max_image_age } <$image_path/*.{jpg,gif,wbmp}>;
|
||||||
|
if ( @old_files ) {
|
||||||
|
aud_print( "Deleting ".int(@old_files)." old images\n" );
|
||||||
|
my $untainted_old_files = join( ";", @old_files );
|
||||||
|
( $untainted_old_files ) = ( $untainted_old_files =~ /^(.*)$/ );
|
||||||
|
unlink( split( /;/, $untainted_old_files ) );
|
||||||
|
}
|
||||||
|
|
||||||
|
# Now delete any old swap files
|
||||||
|
( my $swap_image_root ) = ( $Config{ZM_PATH_SWAP} =~ /^(.*)$/ ); # De-taint
|
||||||
|
File::Find::find( { wanted=>\&deleteSwapImage, untaint=>1 }, $swap_image_root );
|
||||||
|
|
||||||
|
# Prune the Logs table if required
|
||||||
|
if ( $Config{ZM_LOG_DATABASE_LIMIT} ) {
|
||||||
|
if ( $Config{ZM_LOG_DATABASE_LIMIT} =~ /^\d+$/ ) {
|
||||||
|
# Number of rows
|
||||||
|
my $selectLogRowCountSql = "SELECT count(*) as Rows from Logs";
|
||||||
|
my $selectLogRowCountSth = $dbh->prepare_cached( $selectLogRowCountSql )
|
||||||
|
or Fatal( "Can't prepare '$selectLogRowCountSql': ".$dbh->errstr() );
|
||||||
|
$res = $selectLogRowCountSth->execute()
|
||||||
|
or Fatal( "Can't execute: ".$selectLogRowCountSth->errstr() );
|
||||||
|
my $row = $selectLogRowCountSth->fetchrow_hashref();
|
||||||
|
my $logRows = $row->{Rows};
|
||||||
|
if ( $logRows > $Config{ZM_LOG_DATABASE_LIMIT} ) {
|
||||||
|
my $deleteLogByRowsSql = "DELETE low_priority FROM Logs ORDER BY TimeKey ASC LIMIT ?";
|
||||||
|
my $deleteLogByRowsSth = $dbh->prepare_cached( $deleteLogByRowsSql )
|
||||||
|
or Fatal( "Can't prepare '$deleteLogByRowsSql': ".$dbh->errstr() );
|
||||||
|
$res = $deleteLogByRowsSth->execute( $logRows - $Config{ZM_LOG_DATABASE_LIMIT} )
|
||||||
|
or Fatal( "Can't execute: ".$deleteLogByRowsSth->errstr() );
|
||||||
|
if ( $deleteLogByRowsSth->rows() ) {
|
||||||
|
aud_print( "Deleted ".$deleteLogByRowsSth->rows() ." log table entries by count\n" );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
# Time of record
|
||||||
|
my $deleteLogByTimeSql =
|
||||||
|
"DELETE low_priority FROM Logs
|
||||||
|
WHERE TimeKey < unix_timestamp(now() - interval ".$Config{ZM_LOG_DATABASE_LIMIT}.")";
|
||||||
|
my $deleteLogByTimeSth = $dbh->prepare_cached( $deleteLogByTimeSql )
|
||||||
|
or Fatal( "Can't prepare '$deleteLogByTimeSql': ".$dbh->errstr() );
|
||||||
|
$res = $deleteLogByTimeSth->execute()
|
||||||
|
or Fatal( "Can't execute: ".$deleteLogByTimeSth->errstr() );
|
||||||
|
if ( $deleteLogByTimeSth->rows() ){
|
||||||
|
aud_print( "Deleted ".$deleteLogByTimeSth->rows() ." log table entries by time\n" );
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} # end if ( $Config{ZM_LOG_DATABASE_LIMIT} )
|
||||||
|
$loop = $continuous;
|
||||||
|
|
||||||
|
sleep( $Config{ZM_AUDIT_CHECK_INTERVAL} ) if $continuous;
|
||||||
};
|
};
|
||||||
|
|
||||||
exit( 0 );
|
exit( 0 );
|
||||||
|
|
||||||
sub aud_print
|
sub aud_print {
|
||||||
{
|
my $string = shift;
|
||||||
my $string = shift;
|
if ( ! $continuous ) {
|
||||||
if ( !$continuous )
|
print( $string );
|
||||||
{
|
} else {
|
||||||
print( $string );
|
Info( $string );
|
||||||
}
|
}
|
||||||
else
|
|
||||||
{
|
|
||||||
Info( $string );
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
sub confirm
|
sub confirm {
|
||||||
{
|
my $prompt = shift || "delete";
|
||||||
my $prompt = shift || "delete";
|
my $action = shift || "deleting";
|
||||||
my $action = shift || "deleting";
|
|
||||||
|
|
||||||
my $yesno = 0;
|
my $yesno = 0;
|
||||||
if ( $report )
|
if ( $report ) {
|
||||||
{
|
print( "\n" );
|
||||||
print( "\n" );
|
} elsif ( $interactive ) {
|
||||||
|
print( ", $prompt y/n: " );
|
||||||
|
my $char = <>;
|
||||||
|
chomp( $char );
|
||||||
|
if ( $char eq 'q' ) {
|
||||||
|
exit( 0 );
|
||||||
}
|
}
|
||||||
elsif ( $interactive )
|
if ( !$char ) {
|
||||||
{
|
$char = 'y';
|
||||||
print( ", $prompt y/n: " );
|
|
||||||
my $char = <>;
|
|
||||||
chomp( $char );
|
|
||||||
if ( $char eq 'q' )
|
|
||||||
{
|
|
||||||
exit( 0 );
|
|
||||||
}
|
|
||||||
if ( !$char )
|
|
||||||
{
|
|
||||||
$char = 'y';
|
|
||||||
}
|
|
||||||
$yesno = ( $char =~ /[yY]/ );
|
|
||||||
}
|
}
|
||||||
else
|
$yesno = ( $char =~ /[yY]/ );
|
||||||
{
|
} else {
|
||||||
if ( !$continuous )
|
if ( !$continuous ) {
|
||||||
{
|
print( ", $action\n" );
|
||||||
print( ", $action\n" );
|
} else {
|
||||||
}
|
Info( $action );
|
||||||
else
|
|
||||||
{
|
|
||||||
Info( $action );
|
|
||||||
}
|
|
||||||
$yesno = 1;
|
|
||||||
}
|
}
|
||||||
return( $yesno );
|
$yesno = 1;
|
||||||
|
}
|
||||||
|
return( $yesno );
|
||||||
}
|
}
|
||||||
|
|
||||||
sub deleteSwapImage
|
sub deleteSwapImage {
|
||||||
{
|
my $file = $_;
|
||||||
my $file = $_;
|
|
||||||
|
|
||||||
if ( $file !~ /^zmswap-/ )
|
if ( $file !~ /^zmswap-/ ) {
|
||||||
{
|
return;
|
||||||
return;
|
}
|
||||||
}
|
|
||||||
|
|
||||||
# Ignore directories
|
# Ignore directories
|
||||||
if ( -d $file )
|
if ( -d $file ) {
|
||||||
{
|
return;
|
||||||
return;
|
}
|
||||||
}
|
|
||||||
|
|
||||||
if ( -M $file > $max_swap_age )
|
if ( -M $file > $max_swap_age ) {
|
||||||
{
|
Debug( "Deleting $file" );
|
||||||
Debug( "Deleting $file" );
|
#unlink( $file );
|
||||||
#unlink( $file );
|
}
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
1;
|
||||||
|
__END__
|
||||||
|
|
|
||||||
File diff suppressed because it is too large
Load Diff
|
|
@ -24,6 +24,7 @@
|
||||||
define( "ZM_CONFIG", "@ZM_CONFIG@" ); // Path to config file
|
define( "ZM_CONFIG", "@ZM_CONFIG@" ); // Path to config file
|
||||||
// Define, and override any given in config file
|
// Define, and override any given in config file
|
||||||
define( "ZM_VERSION", "@VERSION@" ); // Version
|
define( "ZM_VERSION", "@VERSION@" ); // Version
|
||||||
|
define( "ZM_DIR_TEMP", "@ZM_TMPDIR@" );
|
||||||
|
|
||||||
$configFile = ZM_CONFIG;
|
$configFile = ZM_CONFIG;
|
||||||
$localConfigFile = basename($configFile);
|
$localConfigFile = basename($configFile);
|
||||||
|
|
|
||||||
|
|
@ -890,7 +890,7 @@ function exportEvents( $eids, $exportDetail, $exportFrames, $exportImages, $expo
|
||||||
{
|
{
|
||||||
$eids = array($eids);
|
$eids = array($eids);
|
||||||
}
|
}
|
||||||
$monitorPath = 'events/';
|
$monitorPath = ZM_DIR_EVENTS."/";
|
||||||
$html_eventMaster = 'zmEventImagesMaster_'.date('Ymd_His'). '.html';
|
$html_eventMaster = 'zmEventImagesMaster_'.date('Ymd_His'). '.html';
|
||||||
if ( !($fp = fopen( $monitorPath."/".$html_eventMaster, "w" )) ) Fatal( "Can't open event images export file '$html_eventMaster'" );
|
if ( !($fp = fopen( $monitorPath."/".$html_eventMaster, "w" )) ) Fatal( "Can't open event images export file '$html_eventMaster'" );
|
||||||
fwrite( $fp, exportEventImagesMaster( $eids ) );
|
fwrite( $fp, exportEventImagesMaster( $eids ) );
|
||||||
|
|
@ -898,7 +898,7 @@ function exportEvents( $eids, $exportDetail, $exportFrames, $exportImages, $expo
|
||||||
$exportFileList[] = $monitorPath."/".$html_eventMaster;
|
$exportFileList[] = $monitorPath."/".$html_eventMaster;
|
||||||
}
|
}
|
||||||
|
|
||||||
$listFile = "temp/".$export_listFile;
|
$listFile = ZM_DIR_EXPORTS."/".$export_listFile;
|
||||||
if ( !($fp = fopen( $listFile, "w" )) )
|
if ( !($fp = fopen( $listFile, "w" )) )
|
||||||
{
|
{
|
||||||
Fatal( "Can't open event export list file '$listFile'" );
|
Fatal( "Can't open event export list file '$listFile'" );
|
||||||
|
|
@ -911,7 +911,7 @@ function exportEvents( $eids, $exportDetail, $exportFrames, $exportImages, $expo
|
||||||
$archive = "";
|
$archive = "";
|
||||||
if ( $exportFormat == "tar" )
|
if ( $exportFormat == "tar" )
|
||||||
{
|
{
|
||||||
$archive = "temp/".$export_root.".tar.gz";
|
$archive = ZM_DIR_EXPORTS."/".$export_root.".tar.gz";
|
||||||
@unlink( $archive );
|
@unlink( $archive );
|
||||||
$command = "tar --create --gzip --file=$archive --files-from=$listFile";
|
$command = "tar --create --gzip --file=$archive --files-from=$listFile";
|
||||||
exec( escapeshellcmd( $command ), $output, $status );
|
exec( escapeshellcmd( $command ), $output, $status );
|
||||||
|
|
@ -925,8 +925,7 @@ function exportEvents( $eids, $exportDetail, $exportFrames, $exportImages, $expo
|
||||||
}
|
}
|
||||||
elseif ( $exportFormat == "zip" )
|
elseif ( $exportFormat == "zip" )
|
||||||
{
|
{
|
||||||
$archive = "temp/zm_export.zip";
|
$archive = ZM_DIR_EXPORTS."/".$export_root.".zip";
|
||||||
$archive = "temp/".$export_root.".zip";
|
|
||||||
@unlink( $archive );
|
@unlink( $archive );
|
||||||
$command = "cat ".escapeshellarg($listFile)." | zip -q ".escapeshellarg($archive)." -@";
|
$command = "cat ".escapeshellarg($listFile)." | zip -q ".escapeshellarg($archive)." -@";
|
||||||
//cat zmFileList.txt | zip -q zm_export.zip -@
|
//cat zmFileList.txt | zip -q zm_export.zip -@
|
||||||
|
|
@ -948,7 +947,7 @@ function exportEvents( $eids, $exportDetail, $exportFrames, $exportImages, $expo
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
return( $archive );
|
return( '?view=archive%26type='.$exportFormat );
|
||||||
}
|
}
|
||||||
function mygetEventPath( $event )
|
function mygetEventPath( $event )
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,62 @@
|
||||||
|
<?php
|
||||||
|
//
|
||||||
|
// ZoneMinder file view file, $Date: 2008-09-29 14:15:13 +0100 (Mon, 29 Sep 2008) $, $Revision: 2640 $
|
||||||
|
// Copyright (C) 2001-2008 Philip Coombes
|
||||||
|
//
|
||||||
|
// This program is free software; you can redistribute it and/or
|
||||||
|
// modify it under the terms of the GNU General Public License
|
||||||
|
// as published by the Free Software Foundation; either version 2
|
||||||
|
// of the License, or (at your option) any later version.
|
||||||
|
//
|
||||||
|
// This program is distributed in the hope that it will be useful,
|
||||||
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||||
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||||
|
// GNU General Public License for more details.
|
||||||
|
//
|
||||||
|
// You should have received a copy of the GNU General Public License
|
||||||
|
// along with this program; if not, write to the Free Software
|
||||||
|
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
||||||
|
//
|
||||||
|
|
||||||
|
if ( !canView( 'Events' ) )
|
||||||
|
{
|
||||||
|
$view = "error";
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
$archivetype = $_REQUEST['type'];
|
||||||
|
|
||||||
|
if ( $archivetype ) {
|
||||||
|
switch ($archivetype) {
|
||||||
|
case "tar":
|
||||||
|
$mimetype = "gzip";
|
||||||
|
$file_ext = "tar.gz";
|
||||||
|
break;
|
||||||
|
case "zip":
|
||||||
|
$mimetype = "zip";
|
||||||
|
$file_ext = "zip";
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
$mimetype = NULL;
|
||||||
|
$file_ext = NULL;
|
||||||
|
}
|
||||||
|
|
||||||
|
if ( $mimetype ) {
|
||||||
|
$filename = "zmExport.$file_ext";
|
||||||
|
$filename_path = ZM_DIR_TEMP."/".$filename;
|
||||||
|
if ( is_readable($filename_path) ) {
|
||||||
|
header( "Content-type: application/$mimetype" );
|
||||||
|
header( "Content-Disposition: attachment; filename=$filename");
|
||||||
|
readfile( $filename_path );
|
||||||
|
} else {
|
||||||
|
Error("$filename_path does not exist or is not readable.");
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
Error("Unsupported archive type specified. Supported archives are tar and zip");
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
Error("No archive type given to archive.php. Please specify a tar or zip archive.");
|
||||||
|
}
|
||||||
|
|
||||||
|
?>
|
||||||
|
|
||||||
Loading…
Reference in New Issue