FHEM/fhem-mirror
2
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-04-06 12:18:46 +00:00
Code Issues Releases Wiki Activity

PRESENCE/collectord: minor changes

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@11212 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
markusbloch 2016-04-09 16:17:29 +00:00
parent 6c353f15a2
commit 7ecbdeef3f
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
fhem/contrib/PRESENCE/collectord
View File

@ -333,7 +333,7 @@ while(1)
{ {
Log 2, "sending thread ".$handle{$uuid}{threads}{$room}->tid()." new address $address for room $room"; Log 2, "sending thread ".$handle{$uuid}{threads}{$room}->tid()." new address $address for room $room";
$queues{$handle{$uuid}{threads}{$room}->tid()}->enqueue("new|$address"); $queues{$handle{$uuid}{threads}{$room}->tid()}->enqueue("new|$address");
$state{$uuid}{rooms}{$room} = "" $state{$uuid}{rooms}{$room} = "" if(exists($state{$uuid}{rooms}{$room}));
} }
$handle{$uuid}{timeout} = $timeout; $handle{$uuid}{timeout} = $timeout;
@ -359,12 +359,11 @@ while(1)
# create a new reqester thread for each configured room to perform the query # create a new reqester thread for each configured room to perform the query
while (($room, $value) = each %config) while (($room, $value) = each %config)
{ {
$thread_counter++; $thread_counter++;
$queues{$thread_counter} = Thread::Queue->new(); $queues{$thread_counter} = Thread::Queue->new();
my $new_thread = threads->new(\&doQuery, ($value, $room, $address, $uuid)); my $new_thread = threads->new(\&doQuery, ($value, $room, $address, $uuid));
Log 1, "created thread ".$new_thread->tid()." for processing device $address in room $room for peer ".$client->peerhost()." (UUID: $uuid)"; Log 1, "created thread ".$new_thread->tid()." for processing device $address in room $room for peer ".$client->peerhost()." (UUID: $uuid)";
# detach from the thread, so the thread starts processing independantly # detach from the thread, so the thread starts processing independantly
$new_thread->detach(); $new_thread->detach();