修正数据保存100M问题
This commit is contained in:
@@ -172,7 +172,7 @@ void Parse::run()
|
||||
}
|
||||
*/
|
||||
|
||||
frame_data.append(frame);
|
||||
frame_data.append(frame);//超限了
|
||||
|
||||
emit frameok(ip,port,frame);
|
||||
|
||||
|
||||
+2
-1
@@ -624,13 +624,14 @@ void DLink::readPendingDatagramsClient(void)
|
||||
|
||||
clientsock->readDatagram(datagram.data(), datagram.size(),&address,&port);
|
||||
|
||||
emit recieve(address,port,datagram);
|
||||
//emit recieve(address,port,datagram);
|
||||
|
||||
foreach (clientNode node, sockets) {
|
||||
if(node.sock)
|
||||
{
|
||||
if(node.sock == clientsock)
|
||||
{
|
||||
emit recieve(node.addr,node.port,datagram);
|
||||
//qDebug() << "dlink" << QThread::currentThread();
|
||||
|
||||
node.in.count += datagram.size();
|
||||
|
||||
@@ -47,8 +47,10 @@ MainWindow::MainWindow(QWidget *parent)
|
||||
|
||||
|
||||
|
||||
|
||||
dlink->moveToThread(&dlink_thread);
|
||||
dlink_thread.start();
|
||||
dlink_thread.setPriority(QThread::TimeCriticalPriority);
|
||||
|
||||
|
||||
savethread->moveToThread(&save_thread);
|
||||
@@ -57,6 +59,7 @@ MainWindow::MainWindow(QWidget *parent)
|
||||
connect(dlink,&DLink::recieve,savethread,&SaveThread::setSave);
|
||||
// 启动线程
|
||||
save_thread.start();
|
||||
save_thread.setPriority(QThread::TimeCriticalPriority);
|
||||
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user