ZaneYork
/
zoneminder
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

code style

This commit is contained in:
Isaac Connor 2020-05-09 17:21:57 -04:00
parent 1026a22e97
commit 98a112d3c0
1 changed files with 277 additions and 322 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

599
onvif/scripts/zmonvif-trigger.pl
View File

@ -76,9 +76,9 @@ my $monitor_reload_time = 0;
# this does not work on all architectures # this does not work on all architectures
my @EXTRA_SOCK_OPTS = ( my @EXTRA_SOCK_OPTS = (
'ReuseAddr' => '1', 'ReuseAddr' => '1',
# 'ReusePort' => '1', # 'ReusePort' => '1',
# 'Blocking' => '0', # 'Blocking' => '0',
); );
@ -86,19 +86,17 @@ my @EXTRA_SOCK_OPTS = (
# signal handling # signal handling
sub handler { # 1st argument is signal name sub handler { # 1st argument is signal name
my($sig) = @_; my ($sig) = @_;
Error( "Caught a SIG$sig -- shutting down\n" ); Error("Caught a SIG$sig -- shutting down");
confess(); confess();
if(defined $daemon_pid){ kill($daemon_pid) if defined $daemon_pid;
kill($daemon_pid);
}
exit(0); exit(0);
} }
$SIG{'INT'} = \&handler; $SIG{INT} = \&handler;
$SIG{'HUP'} = \&handler; $SIG{HUP} = \&handler;
$SIG{'QUIT'} = \&handler; $SIG{QUIT} = \&handler;
$SIG{'TERM'} = \&handler; $SIG{TERM} = \&handler;
$SIG{__DIE__} = \&handler; $SIG{__DIE__} = \&handler;
# ========================================================================= # =========================================================================
@ -107,23 +105,21 @@ $SIG{__DIE__} = \&handler;
use Data::Hexdumper qw(hexdump); use Data::Hexdumper qw(hexdump);
#use Devel::Peek; #use Devel::Peek;
sub dump_mapped sub dump_mapped {
{
my ($monitor) = @_; my ($monitor) = @_;
if(!zmMemVerify($monitor)) { if ( !zmMemVerify($monitor) ) {
print "Error: Mapped memory not accessible\n"; print "Error: Mapped memory not accessible\n";
} }
my $mmap = $monitor->{MMap}; my $mmap = $monitor->{MMap};
print "Size: " . $ZoneMinder::Memory::mem_size ."\n"; print 'Size: '.$ZoneMinder::Memory::mem_size ."\n";
printf("Mapped at %x\n", $monitor->{MMapAddr}); printf("Mapped at %x\n", $monitor->{MMapAddr});
# Dump($mmap); # Dump($mmap);
if($mmap && $$mmap ) if ( $mmap && $$mmap ) {
{
print hexdump( print hexdump(
data => $$mmap, # what to dump data => $$mmap, # what to dump
output_format => ' %4a : %S %S %S %S %S %S %S %S : %d', output_format => ' %4a : %S %S %S %S %S %S %S %S : %d',
# start_position => 336, # start at this offset ... # start_position => 336, # start at this offset ...
end_position => 400 # ... and end at this offset end_position => 400 # ... and end at this offset
); );
} }
@ -134,8 +130,7 @@ sub dump_mapped
# ========================================================================= # =========================================================================
# internal methods # internal methods
sub xs_duration sub xs_duration {
{
use integer; use integer;
my ($seconds) = @_; my ($seconds) = @_;
my $s = $seconds % 60; my $s = $seconds % 60;
@ -171,10 +166,10 @@ sub xs_duration
## make this a singleton ? ## make this a singleton ?
{ {
package _ZoneMinder; package _ZoneMinder;
use strict; use strict;
use bytes; use bytes;
use base qw(Class::Std::Fast); use base qw(Class::Std::Fast);
use DBI; use DBI;
@ -182,147 +177,129 @@ sub xs_duration
use Time::HiRes qw( usleep ); use Time::HiRes qw( usleep );
use ZoneMinder; use ZoneMinder;
# my %monitors = ();
# my %monitors = ();
my $dbh; my $dbh;
my %monitors_of; # :ATTR(:name<monitors> :default<{}>); my %monitors_of; # :ATTR(:name<monitors> :default<{}>);
sub init {
sub init
{
$dbh = zmDbConnect(); $dbh = zmDbConnect();
} }
sub monitors sub monitors {
{
my ($self) = @_; my ($self) = @_;
return $monitors_of{ident $self}?%{ $monitors_of{ident $self} }:undef; return $monitors_of{ident $self}?%{ $monitors_of{ident $self} }:undef;
} }
sub set_monitors sub set_monitors {
{
my ($self, %monitors_par) = @_; my ($self, %monitors_par) = @_;
$monitors_of{ident $self} = \%monitors_par; $monitors_of{ident $self} = \%monitors_par;
} }
## TODO: remember to refresh this in all threads (daemon is forked) ## TODO: remember to refresh this in all threads (daemon is forked)
sub loadMonitors sub loadMonitors {
{
my ($self) = @_; my ($self) = @_;
Info( "Loading monitors\n" ); Info("Loading monitors");
$monitor_reload_time = time(); $monitor_reload_time = time();
my %new_monitors = (); my %new_monitors = ();
# my $sql = "select * from Monitors where find_in_set( Function, 'Modect,Mocord,Nodect,ExtDect' )>0 and ConfigType='ONVIF'"; # my $sql = "select * from Monitors where find_in_set( Function, 'Modect,Mocord,Nodect,ExtDect' )>0 and ConfigType='ONVIF'";
my $sql = "select * from Monitors where ConfigType='ONVIF'"; my $sql = "SELECT * FROM Monitors WHERE ConfigType='ONVIF'";
my $sth = $dbh->prepare_cached( $sql ) or Fatal( "Can't prepare '$sql': ".$dbh->errstr() ); my $sth = $dbh->prepare_cached($sql) or Fatal("Can't prepare '$sql': ".$dbh->errstr());
my $res = $sth->execute() or Fatal( "Can't execute: ".$sth->errstr() ); my $res = $sth->execute() or Fatal("Can't execute: ".$sth->errstr());
while( my $monitor = $sth->fetchrow_hashref() ) while ( my $monitor = $sth->fetchrow_hashref() ) {
{ if ( !defined $script ) {
if(!defined $script) { if ( !zmMemVerify($monitor) ) { # Check shared memory ok
if ( !zmMemVerify( $monitor ) ) { # Check shared memory ok zmMemInvalidate($monitor);
zmMemInvalidate( $monitor ); next if !zmMemVerify($monitor);
next if ( !zmMemVerify( $monitor ) );
} }
} }
Info( "Monitor URL: " .$monitor->{ConfigURL} ."\n" ); Info('Monitor URL: '.$monitor->{ConfigURL});
## set up ONVIF client for monitor ## set up ONVIF client for monitor
next if( ! $monitor->{ConfigURL} ); next if ! $monitor->{ConfigURL};
my $soap_version; my $soap_version;
if($monitor->{ConfigOptions} =~ /SOAP1([12])/) { if ( $monitor->{ConfigOptions} =~ /SOAP1([12])/ ) {
$soap_version = "1.$1"; $soap_version = "1.$1";
} else {
$soap_version = '1.1';
} }
else { my $client = ONVIF::Client->new( {
$soap_version = "1.1"; url_svc_device => $monitor->{ConfigURL},
} soap_version => $soap_version } );
my $client = ONVIF::Client->new( {
'url_svc_device' => $monitor->{ConfigURL},
'soap_version' => $soap_version } );
if($monitor->{User}) { if ( $monitor->{User} ) {
$client->set_credentials($monitor->{User}, $monitor->{Pass}, 0); $client->set_credentials($monitor->{User}, $monitor->{Pass}, 0);
} }
$client->create_services(); $client->create_services();
$monitor->{onvif_client} = $client; $monitor->{onvif_client} = $client;
$new_monitors{$monitor->{Id}} = $monitor; $new_monitors{$monitor->{Id}} = $monitor;
} } # end foreach monitor
$self->set_monitors(%new_monitors); $self->set_monitors(%new_monitors);
} }
sub freeMonitors sub freeMonitors {
{
my ($self) = @_; my ($self) = @_;
my %monitors = $self->monitors(); my %monitors = $self->monitors();
foreach my $monitor ( values(%monitors) ) foreach my $monitor ( values %monitors ) {
{
# Free up any used memory handle # Free up any used memory handle
zmMemInvalidate( $monitor ); zmMemInvalidate($monitor);
} }
} }
sub eventOn sub eventOn {
{
my ($self, $monitorId, $score, $cause, $text, $showtext) = @_; my ($self, $monitorId, $score, $cause, $text, $showtext) = @_;
# Info( "Trigger '$trigger'\n" );
Info( "On: $monitorId, $score, $cause, $text, $showtext\n" );
my %monitors = $self->monitors();
my $monitor = $monitors{$monitorId};
if(defined $script) {
# eval {
system($script, 'On', $monitor->{Name}, $monitor->{Path}, $cause);
# this goes to "stopped" in ffmpeg when executed from shell - why?
# }
}
else {
# encode() ensures that no utf-8 is written to mmap'ed memory.
zmTriggerEventOn( $monitor, $score, encode("utf-8", $cause), encode("utf-8", $text) );
zmTriggerShowtext( $monitor, encode("utf-8", $showtext) ) if defined($showtext);
# main::dump_mapped($monitor);
}
}
sub eventOff
{
my ($self, $monitorId, $score, $cause, $text, $showtext) = @_;
Info( "Off: $monitorId, $score, $cause, $text, $showtext\n" );
my %monitors = $self->monitors();
my $monitor = $monitors{$monitorId};
if(defined $script) {
# eval {
system($script, 'Off', $monitor->{Name}, $monitor->{Path}, $cause);
# }
}
else {
my $last_event = zmGetLastEvent( $monitor );
zmTriggerEventOff( $monitor );
# encode() ensures that no utf-8 is written to mmap'ed memory.
zmTriggerShowtext( $monitor, encode("utf-8", $showtext) ) if defined($showtext);
# Info( "Trigger '$trigger'\n" ); # Info( "Trigger '$trigger'\n" );
# Wait til it's finished Info("On: $monitorId, $score, $cause, $text, $showtext");
while( zmInAlarm( $monitor ) && ($last_event == zmGetLastEvent( $monitor )) ) my %monitors = $self->monitors();
{ my $monitor = $monitors{$monitorId};
# Tenth of a second if ( defined $script ) {
usleep( 100000 ); # eval {
} system($script, 'On', $monitor->{Name}, $monitor->{Path}, $cause);
zmTriggerEventCancel( $monitor ); # this goes to "stopped" in ffmpeg when executed from shell - why?
# main::dump_mapped($monitor); # }
} else {
# encode() ensures that no utf-8 is written to mmap'ed memory.
zmTriggerEventOn($monitor, $score, encode('utf-8', $cause), encode('utf-8', $text));
zmTriggerShowtext($monitor, encode('utf-8', $showtext)) if defined($showtext);
# main::dump_mapped($monitor);
} }
} }
} sub eventOff {
my ($self, $monitorId, $score, $cause, $text, $showtext) = @_;
Info("Off: $monitorId, $score, $cause, $text, $showtext");
my %monitors = $self->monitors();
my $monitor = $monitors{$monitorId};
if ( defined $script ) {
# eval {
system($script, 'Off', $monitor->{Name}, $monitor->{Path}, $cause);
# }
} else {
my $last_event = zmGetLastEvent($monitor);
zmTriggerEventOff($monitor);
# encode() ensures that no utf-8 is written to mmap'ed memory.
zmTriggerShowtext($monitor, encode('utf-8', $showtext) ) if defined($showtext);
# Info( "Trigger '$trigger'\n" );
# Wait til it's finished
while ( zmInAlarm($monitor) && ($last_event == zmGetLastEvent($monitor)) ) {
# Tenth of a second
usleep(100000);
}
zmTriggerEventCancel($monitor);
# main::dump_mapped($monitor);
}
}
} # end package _ZoneMinder
# ========================================================================= # =========================================================================
### (experimental) send email ### (experimental) send email
sub send_picture_email sub send_picture_email {
{ # 'ffmpeg -i "rtsp://admin:admin123@192.168.0.70:554/Streaming/Channels/1?transportmode=mcast&profile=Profile_1" -y -frames 1 -vf scale=1024:-1 /tmp/pic2.jpg'
# 'ffmpeg -i "rtsp://admin:admin123@192.168.0.70:554/Streaming/Channels/1?transportmode=mcast&profile=Profile_1" -y -frames 1 -vf scale=1024:-1 /tmp/pic2.jpg'
} }
# ========================================================================= # =========================================================================
@ -336,109 +313,102 @@ $SOAP::Constants::DO_NOT_CHECK_MUSTUNDERSTAND = 1;
use strict; use strict;
use bytes; use bytes;
use base qw(Class::Std::Fast SOAP::Server::Parameters); use base qw(Class::Std::Fast SOAP::Server::Parameters);
use ZoneMinder; use ZoneMinder;
my $zm; my $zm;
sub BUILD { sub BUILD {
my ($self, $ident, $arg_ref) = @_; my ($self, $ident, $arg_ref) = @_;
# $zm_of{$ident} = check_name( $arg_ref->{zm} ); # $zm_of{$ident} = check_name( $arg_ref->{zm} );
$zm = $arg_ref->{zm}; $zm = $arg_ref->{zm};
} }
# #
# called on http://docs.oasis-open.org/wsn/bw-2/NotificationConsumer/Notify # called on http://docs.oasis-open.org/wsn/bw-2/NotificationConsumer/Notify
# #
sub Notify sub Notify {
{
my ($self, $unknown, $som) = @_; my ($self, $unknown, $som) = @_;
Debug( "### Notify\n" ); Debug('### Notify');
my $req = $som->context->request; my $req = $som->context->request;
# Data::Dump::dump($req); # Data::Dump::dump($req);
my $id = 0; my $id = 0;
if($req->uri->path =~ m|/ref_(.*)/|) { if ( $req->uri->path =~ m|/ref_(.*)/| ) {
$id = $1; $id = $1;
} else {
Warn('Unknown URL '.$req->uri->path.' called by event');
return ();
} }
else { # Data::Dump::dump($som);
Warn( "Unknown URL ". $req->uri->path . " called by event\n" ); my $action = $som->valueof('/Envelope/Header/Action');
return ( ); Debug(' Action = '.$action);
} my $msg = $som->match('/Envelope/Body/Notify/NotificationMessage');
# Data::Dump::dump($som); my $topic = $msg->valueof('Topic');
my $action = $som->valueof("/Envelope/Header/Action"); my $msg2 = $msg->match('Message/Message');
Debug( " Action = ". $action ."\n" ); # Data::Dump::dump($msg2->current());
my $msg = $som->match("/Envelope/Body/Notify/NotificationMessage");
my $topic = $msg->valueof("Topic");
my $msg2 = $msg->match("Message/Message");
# Data::Dump::dump($msg2->current());
my $time = $msg2->dataof()->attr->{'UtcTime'}; my $time = $msg2->dataof()->attr->{'UtcTime'};
my (%source, %data); my (%source, %data);
foreach my $item ($msg2->dataof('Source/SimpleItem')) { foreach my $item ($msg2->dataof('Source/SimpleItem')) {
$source{$item->attr->{Name}} = $item->attr->{Value}; $source{$item->attr->{Name}} = $item->attr->{Value};
# print $item->attr->{Name} ."=>". $item->attr->{Value} ."\n"; # print $item->attr->{Name} ."=>". $item->attr->{Value} ."\n";
} }
foreach my $item ($msg2->dataof('Data/SimpleItem')) { foreach my $item ($msg2->dataof('Data/SimpleItem')) {
$data{$item->attr->{Name}} = $item->attr->{Value}; $data{$item->attr->{Name}} = $item->attr->{Value};
} }
Debug( "Ref=$id, Topic=$topic, $time, Rule=$source{Rule}, isMotion=$data{IsMotion}\n" ); Debug("Ref=$id, Topic=$topic, $time, Rule=$source{Rule}, isMotion=$data{IsMotion}");
if(lc($data{IsMotion}) eq "true") { if ( lc($data{IsMotion}) eq 'true' ) {
$zm->eventOn($id, 100, $source{Rule}, $time); $zm->eventOn($id, 100, $source{Rule}, $time);
} } elsif ( lc($data{IsMotion}) eq 'false' ) {
elsif(lc($data{IsMotion}) eq "false") {
$zm->eventOff($id, 100, $source{Rule}, $time); $zm->eventOff($id, 100, $source{Rule}, $time);
} }
return ( ); # @results return ();
} }
} } # end Consumer
# ========================================================================= # =========================================================================
sub daemon_main sub daemon_main {
{
my ($daemon) = @_; my ($daemon) = @_;
# $daemon->handle();
# improve responsiveness with multiple clients (cameras) # $daemon->handle();
# improve responsiveness with multiple clients (cameras)
my $d = $daemon->{_daemon}; my $d = $daemon->{_daemon};
my $select = IO::Select->new(); my $select = IO::Select->new();
$select->add($d); $select->add($d);
while ($select->count()) { while ($select->count() ) {
my @ready = $select->can_read(); # blocks my @ready = $select->can_read(); # blocks
foreach my $connection (@ready) { foreach my $connection (@ready) {
if ($connection == $d) { if ( $connection == $d ) {
# on the daemon accept and add the connection # on the daemon accept and add the connection
my $client = $connection->accept(); my $client = $connection->accept();
$select->add($client); $select->add($client);
} } else {
else {
# it's a client connection # it's a client connection
my $request = $connection->get_request(); my $request = $connection->get_request();
if ($request) { if ( $request ) {
# process the request (taken from SOAP::Transport::HTTP::Daemon->handle() ) # process the request (taken from SOAP::Transport::HTTP::Daemon->handle() )
$daemon->request($request); $daemon->request($request);
$daemon->SOAP::Transport::HTTP::Server::handle(); $daemon->SOAP::Transport::HTTP::Server::handle();
eval { eval {
local $SIG{PIPE} = sub { print( "SIGPIPE\n" ) }; # die? local $SIG{PIPE} = sub { print("SIGPIPE\n") }; # die?
$connection->send_response( $daemon->response ); $connection->send_response( $daemon->response );
}; };
if ($@ && $@ !~ /^SIGPIPE/) { if ( $@ && $@ !~ /^SIGPIPE/ ) {
print( $@ ); # die? print($@); # die?
} }
} } else {
else {
# connection was closed by the client # connection was closed by the client
$select->remove($connection); $select->remove($connection);
$connection->close(); # is this necessary? $connection->close(); # is this necessary?
} }
} } # end if new connection or existing
} } # end foreach connection
} } # end while select->count
} } # end sub daemon_main
sub start_daemon sub start_daemon {
{
my ($localip, $localport, $zm) = @_; my ($localip, $localport, $zm) = @_;
=comment =comment
@ -456,39 +426,38 @@ sub start_daemon
$deserializer->set_class_resolver( $event_svc->get_class_resolver() ) $deserializer->set_class_resolver( $event_svc->get_class_resolver() )
if ( $deserializer->can('set_class_resolver') ); if ( $deserializer->can('set_class_resolver') );
=cut =cut
### daemon ### daemon
my $daemon = SOAP::Transport::HTTP::Daemon->new( my $daemon = SOAP::Transport::HTTP::Daemon->new(
'LocalAddr' => $localip, LocalAddr => $localip,
'LocalPort' => $localport, LocalPort => $localport,
# 'deserializer' => $deserializer, # 'deserializer' => $deserializer,
@EXTRA_SOCK_OPTS @EXTRA_SOCK_OPTS
); );
## handling ## handling
# we only handle one method # we only handle one method
$daemon->on_dispatch( sub { $daemon->on_dispatch( sub {
return ( "http://docs.oasis-open.org/wsn/bw-2/NotificationConsumer", "Notify" ); return ( 'http://docs.oasis-open.org/wsn/bw-2/NotificationConsumer', 'Notify' );
}); });
$daemon_pid = fork(); $daemon_pid = fork();
die "fork() failed: $!" unless defined $daemon_pid; die "fork() failed: $!" unless defined $daemon_pid;
if ($daemon_pid) { if ( $daemon_pid ) {
# this is a new process --> use new name and log file # this is a new process --> use new name and log file
$0 = "$0 [http-daemon]"; $0 = $0.' [http-daemon]';
logInit( 'id' => "zmonvif-trigger-httpd" ); logInit('id' => 'zmonvif-trigger-httpd');
logSetSignal(); logSetSignal();
# $zm is copied and the mmap'ed regions still exist # $zm is copied and the mmap'ed regions still exist
my $consumer = _Consumer->new({'zm' => $zm}); my $consumer = _Consumer->new({zm => $zm});
$daemon->dispatch_with({ $daemon->dispatch_with({
# "http://docs.oasis-open.org/wsn/bw-2" => $consumer, # "http://docs.oasis-open.org/wsn/bw-2" => $consumer,
"http://docs.oasis-open.org/wsn/bw-2/NotificationConsumer" => $consumer, "http://docs.oasis-open.org/wsn/bw-2/NotificationConsumer" => $consumer,
}); });
daemon_main($daemon); daemon_main($daemon);
} } else {
else {
return $daemon; return $daemon;
} }
} }
@ -503,76 +472,70 @@ require WSNotification::Elements::MessageContent;
require WSNotification::Types::AbsoluteOrRelativeTimeType; require WSNotification::Types::AbsoluteOrRelativeTimeType;
require WSNotification::Types::AttributedURIType; require WSNotification::Types::AttributedURIType;
sub subscribe {
sub subscribe
{
my ($client, $localaddr, $topic_str, $duration, $ref_id) = @_; my ($client, $localaddr, $topic_str, $duration, $ref_id) = @_;
# for debugging: # for debugging:
# $client->get_endpoint('events')->no_dispatch(1); # $client->get_endpoint('events')->no_dispatch(1);
my $result = $client->get_endpoint('events')->Subscribe( { my $result = $client->get_endpoint('events')->Subscribe( {
ConsumerReference => { # WSNotification::Types::EndpointReferenceType ConsumerReference => { # WSNotification::Types::EndpointReferenceType
Address => { value => 'http://' . $localaddr . '/ref_'. $ref_id . '/' }, Address => { value => 'http://' . $localaddr . '/ref_'. $ref_id . '/' },
# ReferenceParameters => { # WSNotification::Types::ReferenceParametersType # ReferenceParameters => { # WSNotification::Types::ReferenceParametersType
# }, # },
# Metadata => { # WSNotification::Types::MetadataType # Metadata => { # WSNotification::Types::MetadataType
# }, # },
},
Filter => { # WSNotification::Types::FilterType
TopicExpression => { # WSNotification::Types::TopicExpressionType
xmlattr => {
Dialect => "http://www.onvif.org/ver10/tev/topicExpression/ConcreteSet",
},
value => $topic_str,
}, },
# MessageContent => { # WSNotification::Types::QueryExpressionType Filter => { # WSNotification::Types::FilterType
# }, TopicExpression => { # WSNotification::Types::TopicExpressionType
}, xmlattr => {
InitialTerminationTime => xs_duration($duration), # AbsoluteOrRelativeTimeType Dialect => "http://www.onvif.org/ver10/tev/topicExpression/ConcreteSet",
# SubscriptionPolicy => { },
# }, value => $topic_str,
},, },
); # MessageContent => { # WSNotification::Types::QueryExpressionType
# },
},
InitialTerminationTime => xs_duration($duration), # AbsoluteOrRelativeTimeType
# SubscriptionPolicy => {
# },
},,
);
die $result if not $result; die $result if not $result;
# print $result . "\n"; # print $result . "\n";
### build Subscription Manager ### build Subscription Manager
my $submgr_addr = $result->get_SubscriptionReference()->get_Address()->get_value(); my $submgr_addr = $result->get_SubscriptionReference()->get_Address()->get_value();
Info( "Subscription Manager at $submgr_addr\n" ); Info("Subscription Manager at $submgr_addr");
my $serializer = $client->service('device', 'ep')->get_serializer(); my $serializer = $client->service('device', 'ep')->get_serializer();
my $submgr_svc = WSNotification::Interfaces::WSBaseNotificationSender::SubscriptionManagerPort->new({ my $submgr_svc = WSNotification::Interfaces::WSBaseNotificationSender::SubscriptionManagerPort->new({
serializer => $serializer, serializer => $serializer,
proxy => $submgr_addr, proxy => $submgr_addr,
}); });
return $submgr_svc; return $submgr_svc;
} } # end sub subscribe
sub unsubscribe sub unsubscribe {
{
my ($submgr_svc) = @_; my ($submgr_svc) = @_;
$submgr_svc->Unsubscribe( { },, ); $submgr_svc->Unsubscribe( { },, );
} }
sub renew sub renew {
{
my ($submgr_svc, $duration) = @_; my ($submgr_svc, $duration) = @_;
my $result = $submgr_svc->Renew( { my $result = $submgr_svc->Renew( {
TerminationTime => xs_duration($duration), # AbsoluteOrRelativeTimeType TerminationTime => xs_duration($duration), # AbsoluteOrRelativeTimeType
},, },,
); );
die $result if not $result; die $result if not $result;
} }
sub events {
sub events
{
my ($localip, $localport) = @_; my ($localip, $localport) = @_;
my $zm = _ZoneMinder->new(); my $zm = _ZoneMinder->new();
@ -581,96 +544,91 @@ sub events
my %monitors = $zm->monitors(); my %monitors = $zm->monitors();
my $monitor_count = scalar keys(%monitors); my $monitor_count = scalar keys(%monitors);
if($monitor_count == 0) { if ( $monitor_count == 0 ) {
Warn("No active ONVIF monitors found. Exiting\n"); Warn('No active ONVIF monitors found. Exiting');
return; return;
} }
else { Debug("Found $monitor_count active ONVIF monitors");
Debug( "Found $monitor_count active ONVIF monitors\n" ); Info('ONVIF Trigger daemon starting');
}
Info( "ONVIF Trigger daemon starting\n" );
if(!defined $localip) { if ( !defined $localip ) {
$localip = '192.168.0.2'; $localip = '192.168.0.2';
$localport = '0'; $localport = '0';
} }
# re-use local address/port # re-use local address/port
# @LWP::Protocol::http::EXTRA_SOCK_OPTS = # @LWP::Protocol::http::EXTRA_SOCK_OPTS =
*LWP::Protocol::http::_extra_sock_opts = sub *LWP::Protocol::http::_extra_sock_opts = sub {
{ # print "### extra_sock_opts ########################################\n";
# print "### extra_sock_opts ########################################\n"; @EXTRA_SOCK_OPTS;
@EXTRA_SOCK_OPTS; };
};
#*LWP::Protocol::http::_check_sock = sub #*LWP::Protocol::http::_check_sock = sub
#{ #{
# my($self, $req, $sock) = @_; # my($self, $req, $sock) = @_;
# print "### check_sock ########################################\n"; # print "### check_sock ########################################\n";
# dump($sock); # dump($sock);
#}; #};
my $daemon = start_daemon($localip, $localport, $zm); my $daemon = start_daemon($localip, $localport, $zm);
my $port = $daemon->url; my $port = $daemon->url;
$port =~ s|^.*:||; $port =~ s|^.*:||;
$port =~ s|/.*$||; $port =~ s|/.*$||;
my $localaddr = $localip . ':' . $port; my $localaddr = $localip . ':' . $port;
Info( "Daemon uses local address " . $localaddr ."\n" );
# This value is passed as the LocalAddr argument to IO::Socket::INET. Info('Daemon uses local address '.$localaddr);
my $transport = SOAP::Transport::HTTP::Client->new(
# 'local_address' => $localaddr ); ## REUSE port
'local_address' => $localip );
foreach my $monitor (values(%monitors)) {
my $client = $monitor->{onvif_client};
my $event_svc = $client->get_endpoint('events');
$event_svc->set_transport($transport);
# print "Sending from local address " .
# $event_svc->get_transport()->local_address . "\n";
my $submgr_svc = subscribe( # This value is passed as the LocalAddr argument to IO::Socket::INET.
$client, $localaddr, 'tns1:RuleEngine//.', my $transport = SOAP::Transport::HTTP::Client->new(
SUBSCRIPTION_RENEW_INTERVAL, $monitor->{Id}); # 'local_address' => $localaddr ); ## REUSE port
local_address => $localip );
if(!$submgr_svc) {
Warn( "Subscription failed for monitor #" .$monitor->{Id} ."\n" ); foreach my $monitor (values(%monitors)) {
next;
} my $client = $monitor->{onvif_client};
my $event_svc = $client->get_endpoint('events');
$monitor->{submgr_svc} = $submgr_svc; $event_svc->set_transport($transport);
# print "Sending from local address " .
# $event_svc->get_transport()->local_address . "\n";
my $submgr_svc = subscribe(
$client, $localaddr, 'tns1:RuleEngine//.',
SUBSCRIPTION_RENEW_INTERVAL, $monitor->{Id});
if ( !$submgr_svc ) {
Warn( "Subscription failed for monitor #" .$monitor->{Id} ."\n" );
next;
} }
while(1) {
Info( "Sleeping for " . (SUBSCRIPTION_RENEW_INTERVAL - SUBSCRIPTION_RENEW_EARLY) . " seconds\n" );
sleep(SUBSCRIPTION_RENEW_INTERVAL - SUBSCRIPTION_RENEW_EARLY);
Info( "Renewal\n" );
my %monitors = $zm->monitors();
foreach my $monitor (values(%monitors)) {
if(defined $monitor->{submgr_svc}) {
renew($monitor->{submgr_svc}, SUBSCRIPTION_RENEW_INTERVAL + SUBSCRIPTION_RENEW_EARLY);
}
}
};
Info( "ONVIF Trigger daemon exited\n" );
%monitors = $zm->monitors(); $monitor->{submgr_svc} = $submgr_svc;
} # end foreach monitor
while (1) {
Info('Sleeping for ' . (SUBSCRIPTION_RENEW_INTERVAL - SUBSCRIPTION_RENEW_EARLY).' seconds');
sleep(SUBSCRIPTION_RENEW_INTERVAL - SUBSCRIPTION_RENEW_EARLY);
Info('Renewal');
my %monitors = $zm->monitors();
foreach my $monitor (values(%monitors)) { foreach my $monitor (values(%monitors)) {
if(defined $monitor->{submgr_svc}) { if ( defined $monitor->{submgr_svc} ) {
unsubscribe($monitor->{submgr_svc}); renew($monitor->{submgr_svc}, SUBSCRIPTION_RENEW_INTERVAL + SUBSCRIPTION_RENEW_EARLY);
} }
} }
};
Info('ONVIF Trigger daemon exited');
%monitors = $zm->monitors();
foreach my $monitor (values(%monitors)) {
if ( defined $monitor->{submgr_svc} ) {
unsubscribe($monitor->{submgr_svc});
}
}
} }
# ======================================================================== # ========================================================================
# options processing # options processing
sub HELP_MESSAGE sub HELP_MESSAGE {
{
my ($fh, $pkg, $ver, $opts) = @_; my ($fh, $pkg, $ver, $opts) = @_;
print $fh "Usage: " . __FILE__ . " <parameters>\n"; print $fh "Usage: " . __FILE__ . " <parameters>\n";
print $fh <<EOF print $fh <<EOF
@ -683,7 +641,7 @@ EOF
# ======================================================================== # ========================================================================
# MAIN # MAIN
my ($localaddr, $localip, $localport); my ($localaddr, $localip, $localport);
# canonicalize command name # canonicalize command name
@ -693,25 +651,22 @@ $0 = $command;
logInit(); logInit();
logSetSignal(); logSetSignal();
if(!GetOptions( if ( !GetOptions(
'local-addr|l=s' => \$localaddr, 'local-addr|l=s' => \$localaddr,
'script|s=s' => \$script, 'script|s=s' => \$script,
'verbose|v=s' => \$verbose, 'verbose|v=s' => \$verbose,
)) { )) {
HELP_MESSAGE(\*STDOUT); HELP_MESSAGE(\*STDOUT);
exit(1); exit(1);
} }
if(defined $localaddr) { if ( defined $localaddr ) {
if($localaddr =~ /(.*):(.*)/) if ( $localaddr =~ /(.*):(.*)/ ) {
{
($localip, $localport) = ($1, $2); ($localip, $localport) = ($1, $2);
} } else {
else {
$localip = $localaddr; $localip = $localaddr;
$localport = '0'; $localport = '0';
} }
} }
{
events($localip, $localport); events($localip, $localport);
}