note:new func request.
This commit is contained in:
@@ -8,6 +8,9 @@
|
|||||||
|
|
||||||
| 序号 | 类型 | 内容 | 说明 | 基于版本 | 完成版本 |
|
| 序号 | 类型 | 内容 | 说明 | 基于版本 | 完成版本 |
|
||||||
| :--: | :--: | ------------------------------------------------------------ | :--: | :------: | :------: |
|
| :--: | :--: | ------------------------------------------------------------ | :--: | :------: | :------: |
|
||||||
|
| 24 | 问题 | 发送端如果发送的数据比较大,会卡住(功能是正常的)。 | | 0.2.2 | |
|
||||||
|
| 23 | 问题 | 作为接收端如果对方断联要处理这个情况。 | | 0.2.2 | |
|
||||||
|
| 22 | 功能 | 配置可以切组。 | | 0.2.2 | |
|
||||||
| 21 | 功能 | 可以传输文件夹。 | | 0.2.2 | |
|
| 21 | 功能 | 可以传输文件夹。 | | 0.2.2 | |
|
||||||
| 20 | 功能 | 对照传输可以打开本地文件夹。 | | 0.2.2 | |
|
| 20 | 功能 | 对照传输可以打开本地文件夹。 | | 0.2.2 | |
|
||||||
| 19 | 问题 | 客户之间心跳包,被动/主动失联后断开,清除相关内容,终止相关任务。 | | 0.2.2 | 0.2.3 |
|
| 19 | 问题 | 客户之间心跳包,被动/主动失联后断开,清除相关内容,终止相关任务。 | | 0.2.2 | 0.2.3 |
|
||||||
|
|||||||
@@ -169,6 +169,7 @@ void Server::replyRequest(QSharedPointer<ClientInfo> client, QSharedPointer<Fram
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (cl) {
|
if (cl) {
|
||||||
|
//qDebug() << "Client" << cl->id << "heartbeat received";
|
||||||
cl->connectTime = QDateTime::currentDateTime().toMSecsSinceEpoch() / 1000;
|
cl->connectTime = QDateTime::currentDateTime().toMSecsSinceEpoch() / 1000;
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
@@ -238,7 +239,7 @@ void Server::monitorClients()
|
|||||||
{
|
{
|
||||||
QReadLocker locker(&rwLock_);
|
QReadLocker locker(&rwLock_);
|
||||||
for (auto& c : clients_) {
|
for (auto& c : clients_) {
|
||||||
if (now - c->connectTime > NO_HEATBEAT_TIMEOUT) {
|
if ((now - c->connectTime) > NO_HEATBEAT_TIMEOUT) {
|
||||||
prepareRemove.push_back(c->socket);
|
prepareRemove.push_back(c->socket);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user