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

check if client is still connected fpr async replies

Browse Source
This commit is contained in:
Simon Stürz 2015-09-22 09:44:08 +02:00 committed by Michael Zanetti
parent 10b5d77ef6
commit 0e3ddf724b
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
plugins/deviceplugins/openweathermap/devicepluginopenweathermap.json
View File

@ -50,7 +50,7 @@
"idName": "updateTime", "idName": "updateTime",
"name": "last update", "name": "last update",
"unit": "UnixTime", "unit": "UnixTime",
"type": "uint", "type": "int",
"defaultValue": 0 "defaultValue": 0
}, },
{ {

11
server/rest/restserver.cpp
View File

@ -142,16 +142,21 @@ void RestServer::asyncReplyFinished()
m_asyncReplies.remove(clientId); m_asyncReplies.remove(clientId);
qCDebug(dcWebServer) << "Async reply finished"; qCDebug(dcWebServer) << "Async reply finished";
reply->setClientId(clientId);
// check if the reply timeouted
if (reply->timedOut()) { if (reply->timedOut()) {
reply->clear(); reply->clear();
reply->setHttpStatusCode(HttpReply::GatewayTimeout); reply->setHttpStatusCode(HttpReply::GatewayTimeout);
} }
m_webserver->sendHttpReply(reply); // check if client is still connected
if (!m_clientList.contains(clientId)) {
qCWarning(dcWebServer) << "Client for async reply not longer connected.";
} else {
reply->setClientId(clientId);
m_webserver->sendHttpReply(reply);
}
reply->deleteLater(); reply->deleteLater();
} }
} }