Merge branch 'master' into storageareas

This commit is contained in:
Isaac Connor 2019-08-07 15:51:21 -04:00
commit b23a1d0955
3 changed files with 56 additions and 53 deletions

View File

@ -573,7 +573,9 @@ sub CopyTo {
my $moved = 0; my $moved = 0;
if ( $$NewStorage{Type} eq 's3fs' ) { if ( $$NewStorage{Type} eq 's3fs' ) {
if ( $$NewStorage{Url} ) {
my ( $aws_id, $aws_secret, $aws_host, $aws_bucket ) = ( $$NewStorage{Url} =~ /^\s*([^:]+):([^@]+)@([^\/]*)\/(.+)\s*$/ ); my ( $aws_id, $aws_secret, $aws_host, $aws_bucket ) = ( $$NewStorage{Url} =~ /^\s*([^:]+):([^@]+)@([^\/]*)\/(.+)\s*$/ );
if ( $aws_id and $aws_secret and $aws_host and $aws_bucket ) {
eval { eval {
require Net::Amazon::S3; require Net::Amazon::S3;
require File::Slurp; require File::Slurp;
@ -583,20 +585,20 @@ sub CopyTo {
( $aws_host ? ( host => $aws_host ) : () ), ( $aws_host ? ( host => $aws_host ) : () ),
}); });
my $bucket = $s3->bucket($aws_bucket); my $bucket = $s3->bucket($aws_bucket);
if ( ! $bucket ) { if ( !$bucket ) {
Error("S3 bucket $bucket not found."); Error("S3 bucket $bucket not found.");
die; die;
} }
my $event_path = 'events/'.$self->RelativePath(); my $event_path = $self->RelativePath();
Debug("Making directory $event_path/"); Debug("Making directory $event_path/");
if ( ! $bucket->add_key( $event_path.'/','' ) ) { if ( ! $bucket->add_key($event_path.'/', '') ) {
die "Unable to add key for $event_path/"; die "Unable to add key for $event_path/";
} }
my @files = glob("$OldPath/*"); my @files = glob("$OldPath/*");
Debug("Files to move @files"); Debug("Files to move @files");
for my $file (@files) { foreach my $file ( @files ) {
next if $file =~ /^\./; next if $file =~ /^\./;
( $file ) = ( $file =~ /^(.*)$/ ); # De-taint ( $file ) = ( $file =~ /^(.*)$/ ); # De-taint
my $starttime = [gettimeofday]; my $starttime = [gettimeofday];
@ -621,7 +623,11 @@ sub CopyTo {
$moved = 1; $moved = 1;
}; };
Error($@) if $@; Error($@) if $@;
die $@ if $@; } else {
Error("Unable to parse S3 Url into it's component parts.");
}
#die $@ if $@;
} # end if Url
} # end if s3 } # end if s3
my $error = ''; my $error = '';

View File

@ -114,7 +114,7 @@ class Filter extends ZM_Object {
} }
public function control($command, $server_id=null) { public function control($command, $server_id=null) {
$Servers = $server_id ? Server::find(array('Id'=>$server_id)) : Server::find(); $Servers = $server_id ? Server::find(array('Id'=>$server_id)) : Server::find(array('Status'=>'Running'));
if ( !count($Servers) and !$server_id ) { if ( !count($Servers) and !$server_id ) {
# This will be the non-multi-server case # This will be the non-multi-server case
$Servers = array(new Server()); $Servers = array(new Server());
@ -124,7 +124,7 @@ class Filter extends ZM_Object {
if ( !defined('ZM_SERVER_ID') or !$Server->Id() or ZM_SERVER_ID==$Server->Id() ) { if ( !defined('ZM_SERVER_ID') or !$Server->Id() or ZM_SERVER_ID==$Server->Id() ) {
# Local # Local
Logger::Debug("Controlling filter locally $command for server ".$Server->Id()); Logger::Debug("Controlling filter locally $command for server ".$Server->Id());
daemonControl($command, 'zmfilter.pl', '--filter_id='.$this->{'Id'}); daemonControl($command, 'zmfilter.pl', '--filter_id='.$this->{'Id'}.' --daemon');
} else { } else {
# Remote case # Remote case

View File

@ -45,9 +45,6 @@ if ( !$filter ) {
$filter = new ZM\Filter(); $filter = new ZM\Filter();
} }
ZM\Logger::Debug("Query: " . $filter->Query_json());
ZM\Logger::Debug("Query: " . print_r($filter->Query(), true));
if ( isset($_REQUEST['filter']) ) { if ( isset($_REQUEST['filter']) ) {
# Update our filter object with whatever changes we have made before saving # Update our filter object with whatever changes we have made before saving
#$filter->set($_REQUEST['filter']); #$filter->set($_REQUEST['filter']);