Public/fhem-mirror
1
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-05-01 20:20:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

fhem.pl: preparing for nonblocking Http

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk/fhem@4501 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
rudolfkoenig 2013-12-29 17:59:52 +00:00
parent 0cd62935d8
commit e7a0132019
1 changed files with 33 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
fhem.pl
View File

@ -462,10 +462,12 @@ while (1) {
foreach my $p (keys %selectlist) {
my $hash = $selectlist{$p};
vec($rin, $hash->{FD}, 1) = 1
if(defined($hash->{FD}));
vec($win, $hash->{FD}, 1) = 1
if(defined($hash->{FD}) && defined($hash->{$wbName}));
if(defined($hash->{FD})) {
vec($rin, $hash->{FD}, 1) = 1
if(!defined($hash->{directWriteFn}));
vec($win, $hash->{FD}, 1) = 1
if(defined($hash->{directWriteFn}) || defined($hash->{$wbName}));
}
vec($ein, $hash->{EXCEPT_FD}, 1) = 1
if(defined($hash->{"EXCEPT_FD"}));
}
@ -511,23 +513,36 @@ while (1) {
# attached again.
foreach my $p (keys %selectlist) {
my $hash = $selectlist{$p};
next if(!$hash || !$hash->{NAME} || !$defs{$hash->{NAME}}); # due to delete
my $isDev = ($hash && $hash->{NAME} && $defs{$hash->{NAME}});
my $isDirect = ($hash && ($hash->{directReadFn} || $hash->{directWriteFn}));
next if(!$isDev && !$isDirect);
CallFn($hash->{NAME}, "ReadFn", $hash)
if(defined($hash->{FD}) && vec($rout, $hash->{FD}, 1));
my $wb = $hash->{$wbName};
if(defined($wb) && defined($hash->{FD}) && vec($wout, $hash->{FD}, 1)) {
my $ret = syswrite($hash->{CD}, $wb);
if(!$ret || $ret < 0) {
Log 4, "Write error to $p, deleting $hash->{NAME}";
CommandDelete(undef, $hash->{NAME});
if(defined($hash->{FD}) && vec($rout, $hash->{FD}, 1)) {
if($hash->{directReadFn}) {
$hash->{directReadFn}($hash);
} else {
if($ret == length($wb)) {
delete($hash->{$wbName});
CallFn($hash->{NAME}, "ReadFn", $hash);
}
}
if((defined($hash->{$wbName}) || defined($hash->{directWriteFn})) &&
defined($hash->{FD}) && vec($wout, $hash->{FD}, 1)) {
if($hash->{directWriteFn}) {
$hash->{directWriteFn}($hash);
} else {
my $wb = $hash->{$wbName};
my $ret = syswrite($hash->{CD}, $wb);
if(!$ret || $ret < 0) {
Log 4, "Write error to $p, deleting $hash->{NAME}";
CommandDelete(undef, $hash->{NAME});
} else {
$hash->{$wbName} = substr($wb, $ret);
if($ret == length($wb)) {
delete($hash->{$wbName});
} else {
$hash->{$wbName} = substr($wb, $ret);
}
}
}
}