Git-Mirrors/RetroShare
1
0
Fork 0
mirror of https://github.com/RetroShare/RetroShare.git synced 2024-10-01 02:35:48 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add some sanity check in libresapiclient

Browse Source 
This way the Android app is much more stable
This commit is contained in:
Gioacchino Mazzurco 2018-01-30 20:07:51 +01:00
parent 4d6085047a
commit 6f91b938b6
1 changed files with 37 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
retroshare-qml-app/src/libresapilocalclient.cpp
View File

@ -1,6 +1,6 @@
/* /*
* RetroShare Android QML App * RetroShare Android QML App
* Copyright (C) 2016-2017 Gioacchino Mazzurco <gio@eigenlab.org> * Copyright (C) 2016-2018 Gioacchino Mazzurco <gio@eigenlab.org>
* Copyright (C) 2016 Manu Pineda <manu@cooperativa.cat> * Copyright (C) 2016 Manu Pineda <manu@cooperativa.cat>
* *
* This program is free software: you can redistribute it and/or modify * This program is free software: you can redistribute it and/or modify
@ -41,12 +41,25 @@ int LibresapiLocalClient::request( const QString& path, const QString& jsonData,
<< callback.toString(); << callback.toString();
#endif // QT_DEBUG #endif // QT_DEBUG
int ret = -1;
if(mLocalSocket.isOpen())
{
QByteArray data; QByteArray data;
data.append(path); data.append('\n'); data.append(path); data.append('\n');
data.append(jsonData); data.append('\n'); data.append(jsonData); data.append('\n');
processingQueue.enqueue(PQRecord(path, jsonData, callback)); processingQueue.enqueue(PQRecord(path, jsonData, callback));
int ret = mLocalSocket.write(data); ret = mLocalSocket.write(data);
if(ret < 0) socketError(mLocalSocket.error()); if(ret < 0) socketError(mLocalSocket.error());
}
else
{
if(!mConnectAttemptTimer.isActive()) mConnectAttemptTimer.start();
qDebug() << __PRETTY_FUNCTION__
<< "Socket not ready yet! Ignoring request: "
<< path << jsonData;
}
return ret; return ret;
} }
@ -55,6 +68,23 @@ void LibresapiLocalClient::socketError(QLocalSocket::LocalSocketError error)
qCritical() << __PRETTY_FUNCTION__ << "Socket error! " << error qCritical() << __PRETTY_FUNCTION__ << "Socket error! " << error
<< mLocalSocket.errorString(); << mLocalSocket.errorString();
#ifdef QT_DEBUG
QString pQueueDump;
for (auto& qe: processingQueue )
{
pQueueDump.append(qe.mPath);
pQueueDump.append(QChar::Space);
pQueueDump.append(qe.mJsonData);
pQueueDump.append(QChar::LineSeparator);
}
qDebug() << __PRETTY_FUNCTION__ << "Discarded requests dump:"
<< QChar::LineSeparator << pQueueDump;
#endif //QT_DEBUG
processingQueue.clear();
if(mLocalSocket.state() == QLocalSocket::UnconnectedState && if(mLocalSocket.state() == QLocalSocket::UnconnectedState &&
!mConnectAttemptTimer.isActive()) !mConnectAttemptTimer.isActive())
{ {