mirror of
https://github.com/fhem/fhem-mirror.git
synced 2025-04-10 08:04:00 +00:00
93_Log2Syslog.pm: contrib 5.12.4
git-svn-id: https://svn.fhem.de/fhem/trunk@23840 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
nasseeder1
parent
fbe935f5fc
commit
51dac06990
@ -1,9 +1,9 @@
|
||||
##########################################################################################################################
|
||||
# $Id: 93_Log2Syslog.pm 21947 2020-05-15 19:56:46Z DS_Starter $
|
||||
# $Id: 93_Log2Syslog.pm 23076 2020-11-02 18:50:38Z DS_Starter $
|
||||
##########################################################################################################################
|
||||
# 93_Log2Syslog.pm
|
||||
#
|
||||
# (c) 2017-2020 by Heiko Maaz
|
||||
# (c) 2017-2021 by Heiko Maaz
|
||||
# e-mail: Heiko dot Maaz at t-online dot de
|
||||
#
|
||||
# This script is part of fhem.
|
||||
@ -106,7 +106,8 @@ BEGIN {
|
||||
|
||||
# Versions History intern:
|
||||
my %vNotesIntern = (
|
||||
"5.12.3" => "02.11.2020 avoid HandleArchiving which was called in seldom (unknown) cases ",
|
||||
"5.12.4" => "27.02.2021 don't split data by CRLF if EOF is used (in getIfData) ",
|
||||
"5.12.3" => "02.11.2020 avoid do Logfile archiving which was executed in seldom (unknown) cases ",
|
||||
"5.12.2" => "15.05.2020 permit content of 'exclErrCond' to fhemLog strings ",
|
||||
"5.12.1" => "12.05.2020 add dev to check regex of 'exclErrCond' ",
|
||||
"5.12.0" => "16.04.2020 improve IETF octet count again, internal code changes for PBP ",
|
||||
@ -545,14 +546,16 @@ sub Read { ## no critic 'comple
|
||||
if($hash->{TEMPORARY}) {
|
||||
my $sname = $hash->{SNAME};
|
||||
$rhash = $defs{$sname};
|
||||
} else {
|
||||
}
|
||||
else {
|
||||
$rhash = $hash;
|
||||
}
|
||||
|
||||
my $pp = $rhash->{PROFILE};
|
||||
if($pp =~ /BSD/) { # Framelänge BSD-Format
|
||||
$len = $RFC3164len{DL};
|
||||
} elsif ($pp =~ /IETF/) { # Framelänge IETF-Format
|
||||
}
|
||||
elsif ($pp =~ /IETF/) { # Framelänge IETF-Format
|
||||
$len = $RFC5425len{DL};
|
||||
}
|
||||
|
||||
@ -562,9 +565,11 @@ sub Read { ## no critic 'comple
|
||||
|
||||
my $name = $hash->{NAME};
|
||||
return if(IsDisabled($name) || isMemLock($hash));
|
||||
my $mevt = AttrVal($name, "makeEvent", "intern"); # wie soll Reading/Event erstellt werden
|
||||
my $sevevt = AttrVal($name, "respectSeverity", ""); # welcher Schweregrad soll berücksichtigt werden (default: alle)
|
||||
|
||||
|
||||
my $mevt = AttrVal($name, "makeEvent", "intern"); # wie soll Reading/Event erstellt werden
|
||||
my $sevevt = AttrVal($name, "respectSeverity", "" ); # welcher Schweregrad soll berücksichtigt werden (default: alle)
|
||||
my $uef = AttrVal($name, "useEOF", 0 ); # verwende EOF
|
||||
|
||||
if($socket) {
|
||||
($st,$data,$hash) = getIfData($hash,$len,$mlen,$reread);
|
||||
}
|
||||
@ -579,9 +584,11 @@ sub Read { ## no critic 'comple
|
||||
$tail = $+{tail};
|
||||
$msg = substr($tail,0,$ocount);
|
||||
push @load, $msg;
|
||||
|
||||
if(length($tail) >= $ocount) {
|
||||
$tail = substr($tail,$ocount);
|
||||
} else {
|
||||
}
|
||||
else {
|
||||
$tail = substr($tail,length($msg));
|
||||
}
|
||||
|
||||
@ -597,9 +604,11 @@ sub Read { ## no critic 'comple
|
||||
next if(!$tail);
|
||||
$msg = substr($tail,0,$ocount);
|
||||
push @load, $msg;
|
||||
|
||||
if(length($tail) >= $ocount) {
|
||||
$tail = substr($tail,$ocount);
|
||||
} else {
|
||||
}
|
||||
else {
|
||||
$tail = substr($tail,length($msg));
|
||||
}
|
||||
|
||||
@ -607,10 +616,15 @@ sub Read { ## no critic 'comple
|
||||
Log3slog ($hash, 5, "Log2Syslog $name -> MSG$i : $msg");
|
||||
Log3slog ($hash, 5, "Log2Syslog $name -> LENGTH_MSG$i: ".length($msg));
|
||||
Log3slog ($hash, 5, "Log2Syslog $name -> TAIL$i : $tail");
|
||||
}
|
||||
|
||||
} else {
|
||||
@load = split("[\r\n]",$data);
|
||||
}
|
||||
}
|
||||
else {
|
||||
if($uef) {
|
||||
push @load, $data;
|
||||
}
|
||||
else {
|
||||
@load = split("[\r\n]",$data);
|
||||
}
|
||||
}
|
||||
|
||||
for my $line (@load) {
|
||||
@ -622,17 +636,21 @@ sub Read { ## no critic 'comple
|
||||
$pen++;
|
||||
readingsSingleUpdate($hash, 'Parse_Err_No', $pen, 1);
|
||||
$st = "parse error - see logfile";
|
||||
} elsif ($ignore) {
|
||||
}
|
||||
elsif ($ignore) {
|
||||
Log3slog ($hash, 5, "Log2Syslog $name -> dataset was ignored by parseFn");
|
||||
} else {
|
||||
}
|
||||
else {
|
||||
return if($sevevt && $sevevt !~ m/$sev/x); # Message nicht berücksichtigen
|
||||
$st = "active";
|
||||
if($mevt =~ /intern/) { # kein Reading, nur Event
|
||||
$pl = "$phost: $pl";
|
||||
Trigger($hash,$ts,$pl);
|
||||
} elsif ($mevt =~ /reading/x) { # Reading, Event abhängig von event-on-.*
|
||||
}
|
||||
elsif ($mevt =~ /reading/x) { # Reading, Event abhängig von event-on-.*
|
||||
readingsSingleUpdate($hash, "MSG_$phost", $pl, 1);
|
||||
} else { # Reading ohne Event
|
||||
}
|
||||
else { # Reading ohne Event
|
||||
readingsSingleUpdate($hash, "MSG_$phost", $pl, 0);
|
||||
}
|
||||
}
|
||||
@ -664,12 +682,15 @@ return;
|
||||
# (sSiehe auch "list TYPE=FHEMWEB", bzw. "man -s2 accept")
|
||||
#
|
||||
###############################################################################
|
||||
sub getIfData { ## no critic 'complexity'
|
||||
my ($hash,$len,$mlen,$reread) = @_;
|
||||
my $name = $hash->{NAME};
|
||||
my $socket = $hash->{SERVERSOCKET};
|
||||
my $protocol = lc(AttrVal($name, "protocol", "udp"));
|
||||
my ($eof,$buforun) = (0,0);
|
||||
sub getIfData { ## no critic 'complexity'
|
||||
my $hash = shift;
|
||||
my $len = shift;
|
||||
my $mlen = shift;
|
||||
my $reread = shift;
|
||||
my $name = $hash->{NAME};
|
||||
my $socket = $hash->{SERVERSOCKET};
|
||||
my $protocol = lc(AttrVal($name, "protocol", "udp"));
|
||||
my ($eof,$buforun) = (0,0);
|
||||
|
||||
if($hash->{TEMPORARY}) {
|
||||
# temporäre Instanz abgelegt durch TcpServer_Accept
|
||||
@ -689,7 +710,8 @@ sub getIfData { ## no critic
|
||||
Log3slog ($hash, 3, "Log2Syslog $name - Seq \"$hash->{SEQNO}\" invalid data: $data");
|
||||
$data = '' if(length($data) == 0);
|
||||
$st = "receive error - see logfile";
|
||||
} else {
|
||||
}
|
||||
else {
|
||||
my $dl = length($data);
|
||||
Log3slog ($hash, 5, "Log2Syslog $name - Buffer ".$dl." chars ready to parse:\n$data");
|
||||
}
|
||||
@ -728,21 +750,22 @@ sub getIfData { ## no critic
|
||||
$shash->{HELPER}{TCPPADDR} = $hash->{PEER};
|
||||
my $buf;
|
||||
my $off = 0;
|
||||
$ret = sysread($c, $buf, $len); # returns undef on error, 0 at end of file and Integer, number of bytes read on success.
|
||||
$ret = sysread($c, $buf, $len); # returns undef on error, 0 at end of file and Integer, number of bytes read on success.
|
||||
|
||||
if(!defined($ret) && $! == EWOULDBLOCK()){ # error
|
||||
$hash->{wantWrite} = 1 if(TcpServer_WantWrite($hash));
|
||||
$hash = $shash;
|
||||
Log3slog ($hash, 2, "Log2Syslog $sname - ERROR - TCP stack error: $!");
|
||||
return ($st,undef,$hash);
|
||||
|
||||
} elsif (!$ret) { # EOF or error
|
||||
return ($st,undef,$hash);
|
||||
}
|
||||
elsif (!$ret) { # EOF or error
|
||||
Log3slog ($shash, 4, "Log2Syslog $sname - Connection closed for $cname: ".(defined($ret) ? 'EOF' : $!));
|
||||
if(!defined($ret)) { # error
|
||||
CommandDelete(undef, $cname);
|
||||
$hash = $shash;
|
||||
return ($st,undef,$hash);
|
||||
} else { # EOF
|
||||
}
|
||||
else { # EOF
|
||||
$eof = 1;
|
||||
$data = $hash->{BUF};
|
||||
CommandDelete(undef, $cname);
|
||||
@ -2438,12 +2461,12 @@ sub setVersionInfo {
|
||||
if($modules{$type}{META}{x_prereqs_src} && !$hash->{HELPER}{MODMETAABSENT}) {
|
||||
# META-Daten sind vorhanden
|
||||
$modules{$type}{META}{version} = "v".$v; # Version aus META.json überschreiben, Anzeige mit {Dumper $modules{Log2Syslog}{META}}
|
||||
if($modules{$type}{META}{x_version}) { # {x_version} ( nur gesetzt wenn $Id: 93_Log2Syslog.pm 21947 2020-05-15 19:56:46Z DS_Starter $ im Kopf komplett! vorhanden )
|
||||
if($modules{$type}{META}{x_version}) { # {x_version} ( nur gesetzt wenn $Id: 93_Log2Syslog.pm 23076 2020-11-02 18:50:38Z DS_Starter $ im Kopf komplett! vorhanden )
|
||||
$modules{$type}{META}{x_version} =~ s/1\.1\.1/$v/gx;
|
||||
} else {
|
||||
$modules{$type}{META}{x_version} = $v;
|
||||
}
|
||||
return $@ unless (FHEM::Meta::SetInternals($hash)); # FVERSION wird gesetzt ( nur gesetzt wenn $Id: 93_Log2Syslog.pm 21947 2020-05-15 19:56:46Z DS_Starter $ im Kopf komplett! vorhanden )
|
||||
return $@ unless (FHEM::Meta::SetInternals($hash)); # FVERSION wird gesetzt ( nur gesetzt wenn $Id: 93_Log2Syslog.pm 23076 2020-11-02 18:50:38Z DS_Starter $ im Kopf komplett! vorhanden )
|
||||
if(__PACKAGE__ eq "FHEM::$type" || __PACKAGE__ eq $type) {
|
||||
# es wird mit Packages gearbeitet -> Perl übliche Modulversion setzen
|
||||
# mit {<Modul>->VERSION()} im FHEMWEB kann Modulversion abgefragt werden
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user