Russian Qt Forum

void FortuneServer::incomingConnection(int socketDescriptor)
 {
     
     QString fortune = fortunes.at(qrand() % fortunes.size());
     FortuneThread *thread = new FortuneThread(socketDescriptor, fortune, this);
     connect(thread, SIGNAL(msgToGUI(QString,int)), SIGNAL(MessageS(QString,int)));
	     
     connect(thread, SIGNAL(finished()), SLOT(deleteLater()));

     thread->start();
 }

void FortuneThread::run()
 {
     tcpSocket = new QTcpSocket(this); // для каждого подключенного клиента свой СОКЕТ

     if(!tcpSocket->setSocketDescriptor(socketDescriptor)) {
        emit error(tcpSocket->error());
        emit MessageClient(tcpSocket, "<b>SERVER:</b>Error to initialization Socket!",2);
	 }
  
	 while(true)
	 {
    	         if(tcpSocket->state() == QAbstractSocket::UnconnectedState) 
                     {
		        tcpSocket->disconnectFromHost();
	                tcpSocket->waitForDisconnected();
			return;                                           // ??????!!!!!!!!!!          
 		     }
		
		 if(tcpSocket->waitForReadyRead(3000)) 
		     {
			// .... принимаем данные от клиента
				 
		     } // waitForReadyRead()
		 
	 } // while()
}

QTread *QObject::thread() const
{
   return d_func()->threadData->thread;  // на этой строке вылетала ошибка !!!
}

void FortuneThread::run()
 {
     headl objHead; 
     IDThr = (int)currentThreadId();
	
     tcpSocket = new QTcpSocket(this);

     if(!tcpSocket->setSocketDescriptor(socketDescriptor)) {
        emit error(tcpSocket->error());
        emit MessageClient(tcpSocket, "<b>SERVER:</b>Error to initialization Socket!",2);
	 }
     
        emit MessageClient(tcpSocket, "<b>SERVER:</b>Client was connected!",2);
	    emit msgToGUI(QTime::currentTime().toString()+" <b>Client</b> " + QString().setNum(numCl) + " CONNECTED!",2);

   QFile file("MatrixData_" + QString().setNum(IDThr));
   if(file.open(QIODevice::WriteOnly))
    {
	 while(true)
	 {
		 if(tcpSocket->state() == QAbstractSocket::UnconnectedState) {
			  delete tcpSocket;
			  emit msgToGUI("<b>Client</b> DISCONNECTED!",2);
			  
			  return;
			 }

		 if(tcpSocket->waitForReadyRead(1000)) 
		     {
			  if(!flag) // false ; чтение заголовка
			  {  
				 timer.start(); 
			     retrRead = tcpSocket->read((char*)&objHead,sizeof(objHead)); // читаем переданную стуктуру!                                

				 if( retrRead == -1)  return; 
				 if( retrRead ==  0)  return;
			   }
			  
			      
					       if(tcpSocket->bytesAvailable() != objHead.sizeData)
						   {
						     flag = true;
						     continue;
						   }
						
						   file.write(tcpSocket->read(objHead.sizeData));

						   emit MessageClient(tcpSocket, "<b>\nSize file: </b>" + QString().setNum(objHead.sizeData) + " Byte", 2);
						   emit msgToGUI(QTime::currentTime().toString()+" <b>File is sent - </b>" + QString().setNum(timer.elapsed(),10) + " ms",2);
                           
						   flag = false;
						   file.close();
					  
					  
		 } // waitForReadyRead()
	 } // while()
       }
        else { // если нельзя прочитать файл
		 msgToGUI("<b>Error</b> of the determination of the file!",2);
		 return;
	      }
}

FortuneServer::FortuneServer() : QTcpServer()
 {
     fortunes << tr("You've been leading a dog's life. Stay off the furniture.")
              << tr("You've got to think about tomorrow.")
              << tr("You will be surprised by a loud noise.")
              << tr("You will feel hungry again in another hour.")
              << tr("You might have mail.")
              << tr("You cannot kill time without injuring eternity.")
              << tr("Computers are not intelligent. They only think they are.");
	  
	 numCl = 0;
 }

bool FortuneServer::InitializeServer(int port)
{
	 QString nP;
	 nP.setNum(port);
	 nPort = port;
	 if (!listen(QHostAddress::Any, nPort)) {
           QMessageBox::critical(0,"Server Error","Unable to start the server");
           return false;
          }
	 emit MessageS("TCP-Server is listen <b>Port</b> " + nP,2);
	 return true;
}


void FortuneServer::incomingConnection(int socketDescriptor)
 {
     
	 QString fortune = fortunes.at(qrand() % fortunes.size());
     FortuneThread *thread = new FortuneThread(socketDescriptor, fortune, this);
	 connect(thread, SIGNAL(msgToGUI(QString,int)), SIGNAL(MessageS(QString,int)));
	 thread->numCl = ++numCl;
     connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()));

     thread->start();
 }

// ================================= Thread() ============================================================
// конструктор !
FortuneThread::FortuneThread(int socketDescriptor, const QString &fortune, QObject *parent)
     : QThread(parent), socketDescriptor(socketDescriptor), text(fortune), tcpSocket(NULL)
{
     connect(this, SIGNAL(MessageClient(QTcpSocket*,QString,int)),SLOT(sendToClient(QTcpSocket*,QString,int)));
	 flag = false;
	 numCl = 0;
}

void FortuneThread::run()
 {
	 headl objHead; 
     IDThr = (int)currentThreadId();
	
     tcpSocket = new QTcpSocket(this);

     if(!tcpSocket->setSocketDescriptor(socketDescriptor)) {
        emit error(tcpSocket->error());
        emit MessageClient(tcpSocket, "<b>SERVER:</b>Error to initialization Socket!",2);
	 }
     
        emit MessageClient(tcpSocket, "<b>SERVER:</b>Client was connected!",2);
	    emit msgToGUI(QTime::currentTime().toString()+" <b>Client</b> " + QString().setNum(numCl) + " CONNECTED!",2);

	
	 while(!tcpSocket->waitForReadyRead(1))
	  {
	      if(tcpSocket->state() == QAbstractSocket::UnconnectedState) {
 			  emit msgToGUI("<b>Client</b> DISCONNECTED!",2);
			  delete tcpSocket;
		  
			  return;
		   }
	  }
	 		
	 QFile file("MatrixData_" + QString().setNum(IDThr));
	 if(file.open(QIODevice::WriteOnly))
	  {
	    while(true)
	     {
		  
		   if(tcpSocket->state() == QAbstractSocket::UnconnectedState) {
		      if(file.isOpen()) file.close();
			  emit msgToGUI("<b>Client</b> DISCONNECTED!",2);
			  delete tcpSocket;
			  			  
			  return;
		   }

		   if(tcpSocket->waitForReadyRead(1000)) 
		     {
			    if(!flag) // false 
			     {  
				 timer.start(); 
			     retrRead = tcpSocket->read((char*)&objHead,sizeof(objHead)); // читаем переданную стуктуру!                                

				 if( retrRead == -1)  return; 
				 if( retrRead ==  0)  return;
			     }

			    if(tcpSocket->bytesAvailable() != objHead.sizeData)
				 {
				   flag = true;
			       continue;
			     }
						
			    file.write(tcpSocket->read(objHead.sizeData));

			    emit MessageClient(tcpSocket, "<b>\nSize file: </b>" + QString().setNum(objHead.sizeData) + " Byte", 2);
				emit msgToGUI(QTime::currentTime().toString()+" <b>File is sent - </b>" +  QString().setNum(timer.elapsed(),10) + " ms",2);
                           
				flag = false;
				file.close();
					  
		   } // waitForReadyRead()
	    } // while()
     } // if() file.open()
	 else 
	 {   // если нельзя открыть файл
	     msgToGUI("<b>Error</b> of the determination of the file!",2);
	     return;
	 }
} // run()

void FortuneThread::sendToClient(QTcpSocket* pSocket, QString str, int num) // отправить Клиенту
{
    QByteArray  arrBlock;
	
	headl objHeadSendCl;
	objHeadSendCl.sizeData = str.size();
	
	arrBlock.append((const char*)&objHeadSendCl, sizeof(objHeadSendCl));
	arrBlock.append(str);
  
    pSocket->write(arrBlock);
}

FormServ::FormServ(QWidget *parent) : QDialog(parent)
{
   setupUi(this); // инициализация формы

   editServ->setFocus();
   QRegExp regExp("[0-9]{1,5}"); // ограниченный ввод данных
   editServ->setValidator(new QRegExpValidator(regExp,this));
  
   connect(butServ, SIGNAL(clicked()), SLOT(lineEd_textPORT()));
   
   m_Serv = new FortuneServer;
   
   connect(m_Serv, SIGNAL(MessageS(QString,int)), SLOT(slotShowMessage(QString,int)));
};

void FormServ::lineEd_textPORT()
{
	  bool ok;
      m_Serv->InitializeServer(editServ->text().toInt(&ok,10));
}

void FormServ::slotShowMessage(QString mess,int id)
{
	if(id == 2) textEditServ->append(mess); 
    
}