FHEM/fhem-mirror
2
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-01-31 12:49:34 +00:00
Code Issues Releases Wiki Activity

add windows support

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@191 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
tdressler 2008-05-12 16:55:19 +00:00
parent 662916d4de
commit 3b3742d051
1 changed files with 90 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

126
fhem/FHEM/80_M232.pm
View File

@ -9,10 +9,12 @@ package main;
use strict; use strict;
use warnings; use warnings;
use Device::SerialPort;
sub M232Write($$); sub M232Write($$);
sub M232GetData($$); sub M232GetData($$);
sub Log($$);
use vars qw {%attr %defs};
##################################### #####################################
sub sub
@ -53,8 +55,31 @@ M232_Define($$)
} }
Log 3, "M232 opening device $dev"; Log 3, "M232 opening device $dev";
my $po = new Device::SerialPort ($dev); my $po;
return "Can't open $dev: $!" if(!$po); if ($^O eq 'MSWin32') {
eval ("use Win32::SerialPort;");
if ($@) {
$hash->{STATE} = "error using Modul Win32::SerialPort";
Log 1,"Error using Device::SerialPort";
return "Can't use Win32::SerialPort $@\n";
}
$po = new Win32::SerialPort ($dev, 1);
} else {
eval ("use Device::SerialPort;");
if ($@) {
$hash->{STATE} = "error using Modul Device::SerialPort";
Log 1,"Error using Device::SerialPort";
return "Can't Device::SerialPort $@\n";
}
$po = new Device::SerialPort ($dev, 1);
}
if (!$po) {
$hash->{STATE} = "error opening device";
Log 1,"Error opening Serial Device $dev";
return "Can't open Device $dev: $^E\n";
}
Log 3, "M232 opened device $dev"; Log 3, "M232 opened device $dev";
$po->close(); $po->close();
@ -80,6 +105,20 @@ M232_Undef($$)
} }
return undef; return undef;
} }
#####################################
# M232_Ready
# implement ReadyFn
# only used for Win32
#
sub
M232_Ready($$)
{
my ($hash, $dev) = @_;
my $po=$dev||$hash->{po};
return 0 if !$po;
my ($BlockingFlags, $InBytes, $OutBytes, $ErrorFlags)=$po->status;
return ($InBytes>0);
}
##################################### #####################################
@ -97,12 +136,13 @@ M232_Set($@)
return $u1 if(int(@a) < 2); return $u1 if(int(@a) < 2);
my $msg; my $msg;
my $reading= $a[1]; my $reading= $a[1];
my $value;
my @legal;
if($reading eq "auto") { if($reading eq "auto") {
return $u1 if(int(@a) !=3); return $u1 if(int(@a) !=3);
my $value= $a[2]; $value= $a[2];
my @legal= (0..5,"none"); @legal= (0..5,"none");
if(!grep($value eq $_, @legal)) { if(!grep($value eq $_, @legal)) {
return "Illegal value $value, possible values: @legal"; return "Illegal value $value, possible values: @legal";
} }
@ -122,8 +162,8 @@ M232_Set($@)
elsif($reading eq "octet") { elsif($reading eq "octet") {
return $u1 if(int(@a) !=3); return $u1 if(int(@a) !=3);
my $value= $a[2]; $value= $a[2];
my @legal= (0..255); @legal= (0..255);
if(!grep($value eq $_, @legal)) { if(!grep($value eq $_, @legal)) {
return "Illegal value $value, possible values: 0..255"; return "Illegal value $value, possible values: 0..255";
} }
@ -132,14 +172,14 @@ M232_Set($@)
elsif($reading =~ /^io[0-7]$/) { elsif($reading =~ /^io[0-7]$/) {
return $u1 if(int(@a) !=3); return $u1 if(int(@a) !=3);
my $value= $a[2]; $value= $a[2];
return $u1 unless($value eq "0" || $value eq "1"); return $u1 unless($value eq "0" || $value eq "1");
$msg= "D" . substr($reading,2,1) . $value; $msg= "D" . substr($reading,2,1) . $value;
} }
else { return $u1; } else { return $u1; }
my $d = M232GetData($hash->{DeviceName}, $msg); my $d = M232GetData($hash, $msg);
return "Read error" if(!defined($d)); return "Read error" if(!defined($d));
return $d; return $d;
} }
@ -161,38 +201,39 @@ M232_Get($@)
my $reading= $a[1]; my $reading= $a[1];
my $msg; my $msg;
my $retval; my $retval;
my ($count,$d,$state,$iscurrent,$voltage);
if($reading eq "counter") { if($reading eq "counter") {
$msg= "z"; $msg= "z";
my $d = M232GetData($hash->{DeviceName}, $msg); $d = M232GetData($hash, $msg);
return "Read error" if(!defined($d)); return "Read error" if(!defined($d));
my $count= hex $d; $count= hex $d;
$retval= $count; $retval= $count;
} }
elsif($reading =~ /^an[0-5]$/) { elsif($reading =~ /^an[0-5]$/) {
$msg= "a" . substr($reading,2,1); $msg= "a" . substr($reading,2,1);
my $d = M232GetData($hash->{DeviceName}, $msg); $d = M232GetData($hash, $msg);
return "Read error" if(!defined($d)); return "Read error" if(!defined($d));
my $voltage= (hex substr($d,0,3))*5.00/1024.0; $voltage= (hex substr($d,0,3))*5.00/1024.0;
my $iscurrent= substr($d,3,1); $iscurrent= substr($d,3,1);
$retval= $voltage; # . " " . $iscurrent; $retval= $voltage; # . " " . $iscurrent;
} }
elsif($reading =~ /^io[0-7]$/) { elsif($reading =~ /^io[0-7]$/) {
$msg= "d" . substr($reading,2,1); $msg= "d" . substr($reading,2,1);
my $d = M232GetData($hash->{DeviceName}, $msg); $d = M232GetData($hash, $msg);
return "Read error" if(!defined($d)); return "Read error" if(!defined($d));
my $state= hex $d; $state= hex $d;
$retval= $state; $retval= $state;
} }
elsif($reading eq "octet") { elsif($reading eq "octet") {
$msg= "w"; $msg= "w";
my $d = M232GetData($hash->{DeviceName}, $msg); $d = M232GetData($hash, $msg);
return "Read error" if(!defined($d)); return "Read error" if(!defined($d));
my $state= hex $d; $state= hex $d;
$retval= $state; $retval= $state;
} }
@ -211,7 +252,7 @@ M232_Write($$)
{ {
my ($hash,$msg) = @_; my ($hash,$msg) = @_;
return M232GetData($hash->{DeviceName}, $msg); return M232GetData($hash, $msg);
} }
@ -219,16 +260,20 @@ M232_Write($$)
sub sub
M232GetData($$) M232GetData($$)
{ {
my ($dev, $d) = @_; my ($hash, $data) = @_;
my $dev=$hash->{DeviceName};
my $MSGSTART= chr 1; my $MSGSTART= chr 1;
my $MSGEND= chr 13; my $MSGEND= chr 13;
my $MSGACK= chr 6; my $MSGACK= chr 6;
my $MSGNACK= chr 21; my $MSGNACK= chr 21;
my $serport;
my $d = $MSGSTART . $data . $MSGEND;
$d = $MSGSTART . $d . $MSGEND; if ($^O eq 'MSWin32') {
$serport=new Win32::SerialPort ($dev, 1);
my $serport = new Device::SerialPort ($dev); }else{
$serport=new Device::SerialPort ($dev, 1);
}
if(!$serport) { if(!$serport) {
Log 3, "M232: Can't open $dev: $!"; Log 3, "M232: Can't open $dev: $!";
return undef; return undef;
@ -239,7 +284,8 @@ M232GetData($$)
$serport->parity('none'); $serport->parity('none');
$serport->stopbits(1); $serport->stopbits(1);
$serport->handshake('none'); $serport->handshake('none');
$serport->write_settings;
$hash->{po}=$serport;
Log 4, "M232: Sending $d"; Log 4, "M232: Sending $d";
my $rm = "M232: ?"; my $rm = "M232: ?";
@ -249,22 +295,29 @@ M232GetData($$)
my $retval = ""; my $retval = "";
my $status = ""; my $status = "";
my $nfound=0;
my $ret=undef;
sleep(1);
for(;;) { for(;;) {
if ($^O eq 'MSWin32') {
$nfound=M232_Ready($hash,undef);
}else{
my ($rout, $rin) = ('', ''); my ($rout, $rin) = ('', '');
vec($rin, $serport->FILENO, 1) = 1; vec($rin, $serport->FILENO, 1) = 1;
my $nfound = select($rout=$rin, undef, undef, 1.0); $nfound = select($rin, undef, undef, 1.0); # 3 seconds timeout
if($nfound < 0) { if($nfound < 0) {
$rm = "M232: Select error $nfound / $!"; next if ($! == EAGAIN() || $! == EINTR() || $! == 0);
goto DONE; $rm="M232:Select error $nfound / $!";
last;
} }
}
last if($nfound == 0); last if($nfound == 0);
my $out = $serport->read(1); my $out = $serport->read(1);
if(!defined($out) || length($out) == 0) { if(!defined($out) || length($out) == 0) {
$rm = "M232 EOF on $dev"; $rm = "M232 EOF on $dev";
goto DONE; last;
} }
if($out eq $MSGACK) { if($out eq $MSGACK) {
@ -280,17 +333,18 @@ M232GetData($$)
} }
if($status) { if($status) {
$serport->close(); $ret=$retval;
Log 4, $rm; last;
return $retval;
} }
} }
DONE: DONE:
$serport->close(); $serport->close();
undef $serport;
delete $hash->{po} if exists($hash->{po});
Log 4, $rm; Log 4, $rm;
return undef; return $ret;
} }
1; 1;