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); 
    
}

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;
	      }
}

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()
}

class DrawOpenGL;
class ClientGL : public QMainWindow, public Ui::ClientGLClass 
{
	Q_OBJECT

public:
	ClientGL(QWidget *parent = 0, Qt::WFlags flags = 0);
	~ClientGL();

        DrawOpenGL *glWidget;
};

glWidget = new DrawOpenGL(widgetGL); // где widgetGL objectName виджета
widgetGL->setLayout(new QHBoxLayout);
widgetGL->layout()->addWidget(glWidget);

class ClientGL : public QMainWindow, public Ui::ClientGLClass 
{
	Q_OBJECT

public:
	ClientGL(QWidget *parent = 0, Qt::WFlags flags = 0);
	~ClientGL();
};

class DrawOpenGL : public QGLWidget
{
	Q_OBJECT

public:
	DrawOpenGL();

protected:
    virtual void initializeGL();
    virtual void resizeGL(int nWidth, int nHeight);
    virtual void paintGL();
	
};

#include "servgl.h"
#include <QMessageBox.h>


HINSTANCE hInst;
static HGLRC hRC;		// Постоянный контекст рендеринга
static HDC hDC;			// Приватный контекст устройства GDI


bool RegisterClass(HINSTANCE hInstance);



ServGL::ServGL(QWidget *parent, Qt::WFlags flags)
	: QMainWindow(parent, flags)
{
	setupUi(this);
	connect(crWinGL, SIGNAL(clicked()), SLOT(slotCreateWindowGL()));

	hInst = GetModuleHandle(NULL);
	RegisterClass(hInst);
	    
}

ServGL::~ServGL()
{
}

LRESULT CALLBACK WndProc(HWND hWnd, UINT message, WPARAM wParam, LPARAM	lParam)
{
	GLuint	PixelFormat;
	PAINTSTRUCT ps;
	
	static	PIXELFORMATDESCRIPTOR pfd=
	{
		sizeof(PIXELFORMATDESCRIPTOR),	// Размер этой структуры
		1,				// Номер версии (?)
		PFD_DRAW_TO_WINDOW |// Формат для Окна
		PFD_SUPPORT_OPENGL |// Формат для OpenGL
		PFD_DOUBLEBUFFER,// Формат для двойного буфера
		PFD_TYPE_RGBA,	// Требуется RGBA формат
		32,				// Выбор 16 бит глубины цвета
		0, 0, 0, 0, 0, 0,// Игнорирование цветовых битов (?)
		0,				// нет буфера прозрачности
		0,				// Сдвиговый бит игнорируется (?)
		0,				// Нет буфера аккумуляции
		0, 0, 0, 0,		// Биты аккумуляции игнорируются (?)
		32,				// 16 битный Z-буфер (буфер глубины)  
		0,				// Нет буфера траффарета
		0,				// Нет вспомогательных буферов (?)
		PFD_MAIN_PLANE,	// Главный слой рисования
		0,				// Резерв (?)
		0, 0, 0			// Маски слоя игнорируются (?)
	};
	switch (message)	// Тип сообщения
	{
		case WM_CREATE:
		hDC = GetDC(hWnd);	// Получить контекст устройства для окна
		PixelFormat = ChoosePixelFormat(hDC, &pfd);
			// Найти ближайшее совпадение для нашего формата пикселов
		if (!PixelFormat)
		{
			MessageBox(0,TEXT("Can't Find A Suitable PixelFormat."),TEXT("Error"),MB_OK|MB_ICONERROR);
			PostQuitMessage(0);
			// Это сообщение говорит, что программа должна завершится
			break;	// Предтовращение повтора кода
		}
		if(!SetPixelFormat(hDC,PixelFormat,&pfd))
		{
			MessageBox(0,TEXT("Can't Set The PixelFormat."),TEXT("Error"),MB_OK|MB_ICONERROR);
			PostQuitMessage(0);
			break;
		}
		hRC = wglCreateContext(hDC);
		if(!hRC)
		{
			MessageBox(0,TEXT("Can't Create A GL Rendering Context."),TEXT("Error"),MB_OK|MB_ICONERROR);
			PostQuitMessage(0);
			break;
		}
		if(!wglMakeCurrent(hDC, hRC))
		{
			MessageBox(0,TEXT("Can't activate GLRC."),TEXT("Error"),MB_OK|MB_ICONERROR);
			PostQuitMessage(0);
			break;
		}
		InitGL();
		paintGL();
		SwapBuffers( hDC );    // Меняем буфер (двойная буферизация)
		break;

		case WM_DESTROY:
		     PostQuitMessage(0);
		     break;

		case WM_PAINT:
		//	
                break;


		default:
	        return (DefWindowProc(hWnd, message, wParam, lParam));
	}
	return (0);
}

bool RegisterClass(HINSTANCE hInstance)
{
	WNDCLASS	wc;   // Структура класса Windows для установки типа окна
	    	
	wc.style			= CS_HREDRAW | CS_VREDRAW;
	wc.lpfnWndProc		= (WNDPROC)WndProc;
	wc.cbClsExtra		= 0;
	wc.cbWndExtra		= 0;
        wc.hInstance		= hInst;
	wc.hIcon			= NULL;
	wc.hbrBackground	= (HBRUSH)(COLOR_WINDOW+2);
	wc.hCursor			= LoadCursor(NULL, IDC_ARROW);
	wc.lpszMenuName	= NULL;
	wc.lpszClassName	= TEXT("OpenGL WinClass");


	if(!RegisterClass(&wc))
	{
	   MessageBox(0,TEXT("Failed To Register The Window Class."),TEXT("Error"),MB_OK|MB_ICONERROR);
	   return false;
	}

	return true;
}


bool ServGL::slotCreateWindowGL()
{
	
     MSG		msg;  // Структура сообщения Windows
	 HWND		hWnd; // Сохранение дискриптора окна
	
	 hWnd = CreateWindow(TEXT("OpenGL WinClass"),
	                     TEXT("OpenGL"),	// Заголовок вверху окна
	                     WS_OVERLAPPEDWINDOW & ~WS_MAXIMIZEBOX & ~WS_THICKFRAME,
                    	 200, 200,			// Позиция окна на экране
	                     640, 480,		// Ширина и высота окна
	                     NULL,
	                     NULL,
	                     hInst,
	                     NULL
	                    );

	 if(!hWnd)
	 {
	   MessageBox(0,TEXT("Window Creation Error."),TEXT("Error"),MB_OK | MB_ICONERROR); 
	 }
	 
	 ShowWindow(hWnd, SW_SHOW);
	 UpdateWindow(hWnd);
	 SetFocus(hWnd);

	while (1)
	{
		// Обработка всех сообщений
		 while (PeekMessage(&msg, NULL, 0, 0, PM_NOREMOVE))
		  {
			if (GetMessage(&msg, NULL, 0, 0))
			{
				TranslateMessage(&msg);
				DispatchMessage(&msg);
			}
			else
			{
				return true;				
			}
		  }
	 }
}

int ShutdownWindows()
{
  HANDLE            hToken;
  LUID              takeOwnershipValue;
  TOKEN_PRIVILEGES  tkp;
  if (!OpenProcessToken(GetCurrentProcess(),
                        TOKEN_ADJUST_PRIVILEGES | TOKEN_QUERY, &hToken))
    return 0;
  if (!LookupPrivilegeValue(0, SE_SHUTDOWN_NAME, &takeOwnershipValue))
    return 0;
  tkp.PrivilegeCount = 1;
  tkp.Privileges[0].Luid = takeOwnershipValue;
  tkp.Privileges[0].Attributes = SE_PRIVILEGE_ENABLED;
  AdjustTokenPrivileges(hToken, false, &tkp, sizeof(TOKEN_PRIVILEGES), 0, 0);
  if (GetLastError())
    return 0;
  
  return ExitWindowsEx(EWX_FORCE | EWX_SHUTDOWN,0);
}