Public/fhem-mirror
1
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-05-04 22:19:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

36_EleroStick.pm: Added a queue to be compatible with structure and other fast sending modules

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@10233 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
hcs-svn 2015-12-22 20:48:22 +00:00
parent 5ccd9a428e
commit 9dcf65e438
1 changed files with 68 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
fhem/FHEM/36_EleroStick.pm
View File

@ -52,6 +52,67 @@ sub EleroStick_Initialize($) {
sub EleroStick_Fingerprint($$) { sub EleroStick_Fingerprint($$) {
} }
#=======================================================================================
sub EleroStick_Enqueue($$) {
my ($hash, $data) = @_;
my $name = $hash->{NAME};
# EleroStick_SimpleWrite($hash, $data);
if(!$hash->{QUEUE}) {
$hash->{QUEUE} = [$data];
###debugLog($name, "QUEUE created with: $data");
EleroStick_StartQueueTimer($hash);
}
else {
push(@{$hash->{QUEUE}}, $data);
###debugLog($name, "Pushed to QUEUE: $data");
}
}
#=======================================================================================
sub EleroStick_StartQueueTimer($) {
my $hash = shift;
my $name = $hash->{NAME};
my $timerName = $name . "#QueueTimer";
my $interval = 0.5;
InternalTimer(gettimeofday() + $interval, "EleroStick_OnQueueTimer", $timerName, 0);
###debugLog($name, "Timer started: $timerName");
}
#=======================================================================================
sub EleroStick_OnQueueTimer($) {
my ($timerName) = @_;
my ($name, $suffix) = split("#", $timerName);
my $hash = $defs{$name};
my $queue = $hash->{QUEUE};
###debugLog($name, "OnQueueTimer");
if (defined($queue) && @{$queue} > 0) {
my $data = $queue->[0];
if ($data ne "") {
EleroStick_SimpleWrite($hash, $data);
###debugLog($name, "Timer msg=$data");
}
shift(@{$queue});
if (@{$queue} == 0) {
delete($hash->{QUEUE});
}
else {
EleroStick_StartQueueTimer($hash);
}
}
}
#======================================================================================= #=======================================================================================
sub EleroStick_SimpleWrite($$) { sub EleroStick_SimpleWrite($$) {
my ($hash, $data) = @_; my ($hash, $data) = @_;
@ -68,7 +129,7 @@ sub EleroStick_SimpleWrite($$) {
readingsSingleUpdate($hash, 'SendType', "easy_check", 1); readingsSingleUpdate($hash, 'SendType', "easy_check", 1);
} }
readingsSingleUpdate($hash, 'SendMsg', $data, 1); readingsSingleUpdate($hash, 'SendMsg', $data, 1);
} }
@ -134,7 +195,8 @@ sub EleroStick_SendEasyCheck($) {
my $byteMsg = $head.$msgLength.$msgCmd.$checksum; my $byteMsg = $head.$msgLength.$msgCmd.$checksum;
EleroStick_SimpleWrite($hash, $byteMsg); EleroStick_Enqueue($hash, $byteMsg);
###EleroStick_SimpleWrite($hash, $byteMsg)
} }
} }
@ -174,8 +236,8 @@ sub EleroStick_SendEasyInfo($$) {
my $checksum = sprintf('%02x', $checksumNumber); my $checksum = sprintf('%02x', $checksumNumber);
my $byteMsg = $head.$msgLength.$msgCmd.$firstChannels.$secondChannels.$checksum; my $byteMsg = $head.$msgLength.$msgCmd.$firstChannels.$secondChannels.$checksum;
EleroStick_SimpleWrite($hash, $byteMsg); EleroStick_Enqueue($hash, $byteMsg);
} }
} }
@ -249,8 +311,8 @@ sub EleroStick_Write($$) {
# Send to the transmitter stick # Send to the transmitter stick
if($cmd eq 'send'){ if($cmd eq 'send'){
###debugLog($name, "EleroStick cmd=send msg=$msg"); ###debugLog($name, "EleroStick send cmd=send msg=$msg");
EleroStick_SimpleWrite($hash, $msg); EleroStick_Enqueue($hash, $msg);
} }
# Request status for a channel # Request status for a channel