ETM-Schurig/powersync-zigbee
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Handle controller busy states properly

Browse Source
This commit is contained in:
Michael Zanetti 2022-10-03 23:22:54 +02:00
parent e16e04d79e
commit 9f96e2cc2c
3 changed files with 23 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libnymea-zigbee/backends/deconz/interface/zigbeeinterfacedeconzreply.cpp
View File

@ -84,7 +84,7 @@ ZigbeeInterfaceDeconzReply::ZigbeeInterfaceDeconzReply(Deconz::Command command,
m_timer(new QTimer(this)), m_timer(new QTimer(this)),
m_command(command) m_command(command)
{ {
m_timer->setInterval(5000); m_timer->setInterval(10000);
m_timer->setSingleShot(true); m_timer->setSingleShot(true);
connect(m_timer, &QTimer::timeout, this, &ZigbeeInterfaceDeconzReply::onTimeout); connect(m_timer, &QTimer::timeout, this, &ZigbeeInterfaceDeconzReply::onTimeout);
} }

23
libnymea-zigbee/backends/deconz/zigbeebridgecontrollerdeconz.cpp
View File

@ -233,9 +233,13 @@ void ZigbeeBridgeControllerDeconz::sendNextRequest()
if (m_currentReply) if (m_currentReply)
return; return;
// // FIXME: If the controler request queue is full, wait until it's free again // If the controler request queue is full, wait until it's free again
// if (!m_apsFreeSlotsAvailable) if (!m_apsFreeSlotsAvailable)
// return; return;
if (!m_available) {
return;
}
// Get the next reply, set the sequence number, send the request data over the interface and start waiting // Get the next reply, set the sequence number, send the request data over the interface and start waiting
m_currentReply = m_replyQueue.dequeue(); m_currentReply = m_replyQueue.dequeue();
@ -864,14 +868,15 @@ void ZigbeeBridgeControllerDeconz::processDeviceState(DeconzDeviceState deviceSt
} }
if (m_apsFreeSlotsAvailable != deviceState.apsDataRequestFreeSlots) { if (m_apsFreeSlotsAvailable != deviceState.apsDataRequestFreeSlots) {
m_apsFreeSlotsAvailable = deviceState.apsDataRequestFreeSlots; if (!deviceState.apsDataRequestFreeSlots) {
if (!m_apsFreeSlotsAvailable) {
// Warn only if the network is up // Warn only if the network is up
if (m_networkState == Deconz::NetworkStateConnected) { if (m_networkState == Deconz::NetworkStateConnected) {
qCWarning(dcZigbeeController()) << "The APS request table is full on the device. Cannot send requests until the queue gets processed on the controller."; qCWarning(dcZigbeeController()) << "The APS request table is full on the device. Cannot send requests until the queue gets processed on the controller.";
m_apsFreeSlotsAvailable = false;
} }
return; return;
} else { } else {
m_apsFreeSlotsAvailable = true;
qCDebug(dcZigbeeController()) << "The APS request table is free again. Sending the next request"; qCDebug(dcZigbeeController()) << "The APS request table is free again. Sending the next request";
sendNextRequest(); sendNextRequest();
} }
@ -1021,6 +1026,14 @@ void ZigbeeBridgeControllerDeconz::onInterfacePackageReceived(const QByteArray &
// Check if this is the response to the current active reply // Check if this is the response to the current active reply
if (m_currentReply && m_currentReply->sequenceNumber() == sequenceNumber && m_currentReply->command() == command) { if (m_currentReply && m_currentReply->sequenceNumber() == sequenceNumber && m_currentReply->command() == command) {
// If the controller is busy, let's try again once the device state reports free slots
if (status == Deconz::StatusCodeBusy) {
qCWarning(dcZigbeeController()) << "Controller busy. Rescheduling command.";
m_apsFreeSlotsAvailable = false;
m_replyQueue.prepend(m_currentReply);
m_currentReply = nullptr;
return;
}
m_currentReply->m_responseData = data; m_currentReply->m_responseData = data;
m_currentReply->m_statusCode = status; m_currentReply->m_statusCode = status;
emit m_currentReply->finished(); emit m_currentReply->finished();

8
libnymea-zigbee/backends/deconz/zigbeenetworkdeconz.cpp
View File

@ -410,16 +410,16 @@ void ZigbeeNetworkDeconz::setCreateNetworkState(ZigbeeNetworkDeconz::CreateNetwo
return; return;
} }
m_initializing = false;
setState(StateRunning);
setPermitJoining(0);
ZigbeeNode *coordinatorNode = createNode(m_controller->networkConfiguration().shortAddress, m_controller->networkConfiguration().ieeeAddress, this); ZigbeeNode *coordinatorNode = createNode(m_controller->networkConfiguration().shortAddress, m_controller->networkConfiguration().ieeeAddress, this);
m_coordinatorNode = coordinatorNode; m_coordinatorNode = coordinatorNode;
// Network creation done when coordinator node is initialized
connect(coordinatorNode, &ZigbeeNode::stateChanged, this, [this, coordinatorNode](ZigbeeNode::State state){ connect(coordinatorNode, &ZigbeeNode::stateChanged, this, [this, coordinatorNode](ZigbeeNode::State state){
if (state == ZigbeeNode::StateInitialized) { if (state == ZigbeeNode::StateInitialized) {
qCDebug(dcZigbeeNetwork()) << "Coordinator initialized successfully." << coordinatorNode; qCDebug(dcZigbeeNetwork()) << "Coordinator initialized successfully." << coordinatorNode;
m_initializing = false;
setState(StateRunning);
setPermitJoining(0);
sendPendingRequests(); sendPendingRequests();
return; return;
} }