device: put initial ping of direct-connected devices inside listener thread
This commit is contained in:
parent
79de531858
commit
5657c1ac99
|
@ -168,6 +168,10 @@ class EventsListener(_threading.Thread):
|
||||||
# idle reads for multiple receivers
|
# idle reads for multiple receivers
|
||||||
# idle_reads = _IDLE_READS + (ihandle % 5) * 2
|
# idle_reads = _IDLE_READS + (ihandle % 5) * 2
|
||||||
|
|
||||||
|
if self.receiver.isDevice: # ping (wired or BT) devices to see if they are really online
|
||||||
|
if self.receiver.ping():
|
||||||
|
self.receiver.status.changed(True, reason='initialization')
|
||||||
|
|
||||||
while self._active:
|
while self._active:
|
||||||
if self._queued_notifications.empty():
|
if self._queued_notifications.empty():
|
||||||
try:
|
try:
|
||||||
|
|
|
@ -85,9 +85,6 @@ class ReceiverListener(_listener.EventsListener):
|
||||||
assert status_changed_callback
|
assert status_changed_callback
|
||||||
self.status_changed_callback = status_changed_callback
|
self.status_changed_callback = status_changed_callback
|
||||||
_status.attach_to(receiver, self._status_changed)
|
_status.attach_to(receiver, self._status_changed)
|
||||||
if receiver.isDevice: # ping (wired) devices to see if they are really online
|
|
||||||
if receiver.ping():
|
|
||||||
receiver.status.changed(True, reason='initialization')
|
|
||||||
|
|
||||||
def has_started(self):
|
def has_started(self):
|
||||||
if _log.isEnabledFor(_INFO):
|
if _log.isEnabledFor(_INFO):
|
||||||
|
|
Loading…
Reference in New Issue