QuasarApp/Heart
4
1
Fork 0
mirror of https://github.com/QuasarApp/Heart.git synced 2025-04-29 19:24:38 +00:00
Code Issues Projects Releases Wiki Activity

fix tests

Browse Source
This commit is contained in:
Andrei Yankovich 2021-10-07 22:37:17 +03:00
parent 54ea89d6a6
commit 0d17b56a7c
3 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
.gitignore vendored
View File

@ -60,3 +60,6 @@ HeartTests/cmake_install.cmake
cmake_install.cmake cmake_install.cmake
docs/ docs/
Heart/heart_global.h Heart/heart_global.h
# git
*.orig

2
Heart/AbstractSpace/abstractnode.cpp
View File

@ -502,7 +502,7 @@ bool AbstractNode::registerSocket(QAbstractSocket *socket, const HostAddress* cl
_connectionsMutex.unlock(); _connectionsMutex.unlock();
connect(info, &AbstractNodeInfo::sigReadyRead, connect(info, &AbstractNodeInfo::sigReadyRead,
this, &AbstractNode::avelableBytes); this, &AbstractNode::avelableBytes, Qt::DirectConnection);
// using direct connection because socket clear all data of ip and port after disconnected. // using direct connection because socket clear all data of ip and port after disconnected.
connect(info, &AbstractNodeInfo::statusChaned, connect(info, &AbstractNodeInfo::statusChaned,

4
HeartTests/AbstractSpace/bigdatatest.cpp
View File

@ -57,6 +57,7 @@ public:
} }
const BigPackage* getData() const { const BigPackage* getData() const {
QMutexLocker locker(&_mData);
return data; return data;
} }
@ -66,12 +67,15 @@ protected:
if (pkg->cmd() == BigPackage::command()) { if (pkg->cmd() == BigPackage::command()) {
_mData.lock();
data->copy<BigPackage>(*pkg); data->copy<BigPackage>(*pkg);
_mData.unlock();
sendData(data, sender); sendData(data, sender);
} }
} }
private: private:
mutable QMutex _mData;
BigPackage *data = nullptr; BigPackage *data = nullptr;
}; };