Russian Qt Forum
Март 29, 2024, 13:02 *
Добро пожаловать, Гость. Пожалуйста, войдите или зарегистрируйтесь.
Вам не пришло письмо с кодом активации?

Войти
 
  Начало   Форум  WIKI (Вики)FAQ Помощь Поиск Войти Регистрация  

Страниц: [1]   Вниз
  Печать  
Автор Тема: Статистика переданных байтов при передаче от сервера клиенту  (Прочитано 3907 раз)
demaker
Птица говорун
*****
Offline Offline

Сообщений: 960


Просмотр профиля
« : Август 09, 2017, 18:02 »

Посылаю файл с клиента на сервер все вроде Ок доходит.
Во время приема файла сервер посылает посылку клиенту о том сколько сейчас он принял байт передаваемого файла.
И вот тут какая-то ерунда.
Посылаю клиенту информ посылку
Код:
TYPE_INFO_PROCESS
Все хорошо посылка приходит.
И значение байт увеличивается(сервер отправляет) на стороне клиента, но когда дело доходит до 262144 - все дальше как будто ничего не происходит.
Хоя процесс передачи файла идет и переменная blockSize в коде сервера увеличивается.
Не могу понять что делаю не то Непонимающий
Подскажите пожалуйста.

Вот код сервера и клиента.

Код сервера
Код
C++ (Qt)
//сервер
 
#define TYPE_INFO_FILE      1
#define TYPE_DATA_FILE      2
#define TYPE_COMMAND        3
#define TYPE_INFO_PROCESS   4
#define TYPE_PING           255
 
typedef struct{
   int nFileSize;
   char pFileName[max_char];
} sFileData;
 
 
typedef struct {
   unsigned int sizePack;
   unsigned short typePack;
   unsigned int sizePack2;
} head_pack;
 
 
void ThreadServer::ParsDataRes()
{
   static int blockSize = 0;
 
   m_pTcpSocket->waitForReadyRead(1);
   pData.append( m_pTcpSocket->readAll() );
 
   while(pData.size() != 0)
   {
       if(pData.size() < sizeof(head_pack))
           return ;
 
       //m_iPingCounting = 0;
 
       head_pack headPack;
       memcpy((void*)(&headPack), (void *)(&pData.data()[0]), sizeof(head_pack));
 
       if ( headPack.sizePack != headPack.sizePack2 )
       {
           pData = pData.mid( 1 );
           continue;
       }
 
       //std::cout<<"headPack.typePack = "<<headPack.typePack<<"\n";
       switch(headPack.typePack)
       {
       case TYPE_INFO_FILE:
           if(headPack.sizePack + sizeof(head_pack) <= pData.size())
           {
               pData = pData.mid(sizeof(head_pack));
               if( sizeof(sfiledata) <= headPack.sizePack ){
                   memcpy((char *)&sfiledata,&pData.data()[0],headPack.sizePack);
                   pData = pData.mid(headPack.sizePack);
               }
               else{
 
               }
           }
           else{
               return;
           }
           break;
 
       case TYPE_DATA_FILE:
           if(headPack.sizePack + sizeof(head_pack) <= pData.size())
           {
               pData = pData.mid(sizeof(head_pack));
               QFile file;
               file.write(&pData.data()[0],headPack.sizePack);
               blockSize += headPack.sizePack;
               pData = pData.mid(headPack.sizePack);
 
               {// !!! формируем информ посылку и отправляем !!!
                   head_pack headpck;
                   headpck.sizePack = sizeof(int);
                   headpck.typePack = TYPE_INFO_PROCESS;
                   headpck.sizePack2 = sizeof(int);
                   QByteArray ba_progress;
                   ba_progress.append((char*)&headpck,sizeof(head_pack));
                   std::cout<<"blockSize = "<<blockSize;
                   ba_progress.append((char*)(&blockSize),sizeof(int));
                   m_pTcpSocket->write(ba_progress);
                   m_pTcpSocket->waitForBytesWritten(1);
               }
 
               if(sfiledata.nFileSize <= blockSize)
               {
                   head_pack headpck;
                   headpck.sizePack = 1;
                   headpck.typePack = TYPE_COMMAND;
                   headpck.sizePack2 = 1;
                   QByteArray ba_success;
                   ba_success.append((char*)&headpck,sizeof(head_pack));
                   ba_success.append(CMD_SUCCESS_RECEIVE_FILE);
                   m_pTcpSocket->write(ba_success);
                   m_pTcpSocket->waitForBytesWritten(1);
                   blockSize = 0;
                   //std::cout<<"ôàéë óñïåøíî ïŵèíÿò\n";
               }
           }
           else{
               return;
           }
           break;
       case TYPE_COMMAND:
           break;
       default:
           pData = pData.mid( 1 );
           continue;
       };
   }
   return ;
 
}
 

Код клиента
Код
C++ (Qt)
void ThreadClient::run()
{
   m_pTcpSocket = new QTcpSocket();
   m_pTcpSocket->connectToHost("127.0.0.1",80);
 
 
   while( !m_bStopThread )
   {
       msleep(5);
 
       ParsDataRes();
       if(m_bSendFile) TransmiteFile();
 
   }
}
 
void ThreadClient::ParsDataRes()
{
   static int blockSize = 0;
 
   m_pTcpSocket->waitForReadyRead(1);
   pData.append( m_pTcpSocket->readAll() );
 
   while(pData.size() != 0)
   {
       if(pData.size() < sizeof(head_pack))
           return ;
 
       //m_iPingCounting = 0;
 
       head_pack headPack;
       memcpy((void*)(&headPack), (void *)(&pData.data()[0]), sizeof(head_pack));
 
       if ( headPack.sizePack != headPack.sizePack2 )
       {
           pData = pData.mid( 1 );
           continue;
       }
 
       switch(headPack.typePack)
       {
       // èíôîŵìàöèÿ î ôàéëå
       case TYPE_INFO_FILE:
           if(headPack.sizePack + sizeof(head_pack) <= pData.size())
           {//ŵàçìåŵ ïàêåòà + çàãîëîâîê
               pData = pData.mid(sizeof(head_pack));
               if( sizeof(sfiledata) <= headPack.sizePack ){
                   memcpy((char *)&sfiledata,&pData.data()[0],headPack.sizePack);
                   pData = pData.mid(headPack.sizePack);
               }
               else{
 
               }
 
           }
           else{
               return;
           }
           break;
 
       case TYPE_DATA_FILE:
           if(headPack.sizePack + sizeof(head_pack) <= pData.size())
           {
               pData = pData.mid(sizeof(head_pack));
               QFile file;
               file.write(&pData.data()[0],headPack.sizePack);
               blockSize += headPack.sizePack;
               pData = pData.mid(headPack.sizePack);
 
               //std::cout<<"blockSize = "<<blockSize;
 
               if(sfiledata.nFileSize <= blockSize)
               {
                   head_pack headpck;
                   headpck.sizePack = 1;
                   headpck.typePack = TYPE_COMMAND;
                   headpck.sizePack2 = 1;
                   QByteArray ba_success;
                   ba_success.append((char*)&headpck,sizeof(head_pack));
                   ba_success.append(CMD_SUCCESS_RECEIVE_FILE);
                   m_pTcpSocket->write(ba_success);
                   m_pTcpSocket->waitForBytesWritten(1);
               }
           }
           else{
               return;
           }
           break;
       case TYPE_COMMAND:      
           if(headPack.sizePack + sizeof(head_pack) <= pData.size()){
               pData = pData.mid(sizeof(head_pack));
               if(pData.data()[0] == CMD_SUCCESS_RECEIVE_FILE){
                   setStatusTransmite(SUCCESS);
               }
           }
           else{
               return;
           }
           break;
       case TYPE_INFO_PROCESS:   //Разбираем посылку с количеством принятых байт сервером на данный момент
           if(headPack.sizePack + sizeof(head_pack) <= pData.size()){
               pData = pData.mid(sizeof(head_pack));
               if( sizeof(int) <= headPack.sizePack ){
                   int progress;
                   memcpy((void *)(&progress),(void *)(&pData.data()[0]),sizeof(int));
                   setProgress(progress);
               }
           }
           else{
               return;
           }
           break;
       default:
           pData = pData.mid( 1 );
           continue;
       };
   }
   return ;
}
 
void ThreadClient::TransmiteFile()
{
   QFile file;
   file.setFileName(m_sFilePath);
   QFileInfo fi(m_sFilePath);
 
   {
       sfiledata.nFileSize = fi.size();
       //for(int i = 0; i < max_char; i++)
       //    sfileData.pFileName[i] = filePath.toAscii().data()[i];
 
       QByteArray ba;
       head_pack headPack;
       headPack.sizePack = sizeof(sFileData);
       qDebug()<<"headPack.sizePack = "<<headPack.sizePack;
       headPack.typePack = TYPE_INFO_FILE;
       headPack.sizePack2 = sizeof(sFileData);
       qDebug()<<"headPack.sizePack2 = "<<headPack.sizePack2;
       ba.append((char *)(&headPack),sizeof(head_pack));
       ba.append((char*)(&sfiledata),sizeof(sFileData));
       m_pTcpSocket->write(ba);
       m_pTcpSocket->waitForBytesWritten(1);      
       setStatusTransmite(IN_PROCESS);
   }
 
   {
 
   if(file.open(QFile::ReadWrite)){
       file.seek(0);
       while(!file.atEnd())
       {
         const QByteArray buf = file.read(MAX_SIZE_FRAME); //1024
         head_pack headPack;
         headPack.sizePack = buf.size();
         headPack.typePack = TYPE_DATA_FILE;
         headPack.sizePack2 = buf.size();
 
         QByteArray ba;
         ba.append((char *)(&headPack),sizeof(headPack));
         ba.append(buf);
         m_pTcpSocket->write(ba);
         m_pTcpSocket->waitForBytesWritten(1);
 
         ParsDataRes();
       }
   }
 
   }
   m_bSendFile = false;
}
 
« Последнее редактирование: Август 09, 2017, 18:50 от demaker » Записан
qate
Супер
******
Offline Offline

Сообщений: 1175


Просмотр профиля
« Ответ #1 : Август 10, 2017, 00:10 »

жуткая мешанина сишного кода, брр

и зачем вообще это всё ?
ведь в начале файла можно передать размер, а на приеме и так ясно сколько принято
Записан
demaker
Птица говорун
*****
Offline Offline

Сообщений: 960


Просмотр профиля
« Ответ #2 : Август 10, 2017, 06:39 »

жуткая мешанина сишного кода, брр

и зачем вообще это всё ?
ведь в начале файла можно передать размер, а на приеме и так ясно сколько принято


ну чтобы была обратная связь, и отображать на стороне клиента в прогресс баре процесс передачи.
Не получается примерно вот что
Код:
static int blocksize;
blocksize++;
socket->write((char*)&blocksize,sizeof(int));
Записан
qate
Супер
******
Offline Offline

Сообщений: 1175


Просмотр профиля
« Ответ #3 : Август 10, 2017, 09:14 »

переписывай на события readyread чтобы никаких waitForReadyRead и waitForBytesWritten небыло
для прогресса можно обойтись штатными средствами: отправляющий смотрит QTcpSocket::bytesWritten а приемник и так знает сколько принял в событиях QTcpSocket::readyRead
для отмены закрой сокет
Записан
demaker
Птица говорун
*****
Offline Offline

Сообщений: 960


Просмотр профиля
« Ответ #4 : Август 10, 2017, 15:46 »

Спасибо разобрался
Записан
Страниц: [1]   Вверх
  Печать  
 
Перейти в:  


Страница сгенерирована за 0.137 секунд. Запросов: 24.