Передача сообщений через pipe

// gClient.cpp: определяет точку входа для консольного приложения.
//
 
#include "stdafx.h"
#include <windows.h>
#include <iostream>
#include <string.h>
using namespace std;
int main()
{
  TCHAR   pipeName[80] = L"\\\\.\\pipe\\demo_pipe";
  HANDLE   hNamedPipe;
  DWORD   dwBytesWritten;    // для количества записанных байтов
  DWORD   dwBytesRead;       // для количества прочитанных байтов
  double     pchMessage[5] = {};   // для сообщения
  int    nMessageLength;     // длина сообщения
  char  pchResponse[80];
  
  // связываемся с именованным каналом
  hNamedPipe = CreateFile(
    pipeName,          // имя канала
    GENERIC_READ | GENERIC_WRITE,       // читаем и записываем в канал
    FILE_SHARE_READ | FILE_SHARE_WRITE, // разрешаем чтение и запись 
    NULL,                  // безопасность по умолчанию
    OPEN_EXISTING,         // открываем существующий канал
    FILE_ATTRIBUTE_NORMAL, // атрибуты по умолчанию
    NULL);                 // дополнительных атрибутов нет
  
  // проверяем связь с каналом
  if (hNamedPipe==INVALID_HANDLE_VALUE)
  {
    cerr << "Connection with the named pipe failed." << endl
      << "The last error code: " << GetLastError() << endl;
    cout << "Press any key to exit.";
    cin.get();
 
    return 0;
  }
 
  // вводим строку
  cout << "Input an array: ";
  for (int i=0; i<5; i++)
  { 
    cin>>pchMessage[i];
  }
  nMessageLength=sizeof(pchMessage)+1;
  //cout << nMessageLength<< endl;
  // пишем в именованный канал
  if (!WriteFile(
    hNamedPipe,      // дескриптор канала
    pchMessage,      // данные
    nMessageLength,  // размер данных
    &dwBytesWritten, // количество записанных байтов
    NULL))           // синхронная запись
  {
    // ошибка записи
    cerr << "Write file failed: " << endl
      << "The last error code: " << GetLastError() << endl;
    CloseHandle(hNamedPipe);
    cout << "Press any key to exit.";
    cin.get();
 
    return 0;
  }
  // выводим посланное сообщение на консоль
  cout << "The client sent the message to a server: "<< endl;
     for (int i=0; i<5; i++)
  { 
    cout<<pchMessage[i]<< endl;
  }
  // читаем из именованного канала
  if (!ReadFile(
    hNamedPipe,      // дескриптор канала
    pchResponse,      // данные
    sizeof(pchResponse),  // размер данных
    &dwBytesRead,    // количество записанных байтов
    NULL))           // синхронное чтение
  {
    // ошибка чтения
    cerr << "Read file failed: " << endl
      << "The last error code: " << GetLastError() << endl;
    CloseHandle(hNamedPipe);
    cout << "Press any key to exit.";
    cin.get();
 
    return 0;
  }
  // выводим полученное сообщение на консоль
  cout << "The client received the message from a server: "
    << endl << '\t' << pchResponse << endl;
  // закрываем дескриптор канала
  CloseHandle(hNamedPipe);
  // завершаем процесс
  cout << "Press any key to exit.";
  cin.get();
 
  return 0;
}

// gServer.cpp: определяет точку входа для консольного приложения.
//
 
#include "stdafx.h"
#include <windows.h>
#include <iostream>
#include <string.h>
#include <algorithm>
#include <math.h>
using namespace std;
bool wayToSort(double i, double j) { return i > j; }
int main()
{
  HANDLE   hNamedPipe;
  DWORD   dwBytesRead;     // для количества прочитанных байтов
  DWORD   dwBytesWrite;    // для количества записанных байтов
  double     pchMessage[5] = {};   // для сообщения
  int    nMessageLength;   // длина сообщения
  char  pchResponse[80];
  double arrsum = 0;
  double arrmult = 1;
  double arrminabs = DBL_MAX;
  double arrmaxabs = DBL_MIN;
  int iminabs;
  int imaxabs;
 
  // создаем именованный канал для чтения и записи
  hNamedPipe = CreateNamedPipe(
    L"\\\\.\\pipe\\demo_pipe",  // имя канала
    PIPE_ACCESS_DUPLEX,        // читаем из канала и пишем в канал
    PIPE_TYPE_MESSAGE | PIPE_WAIT,   // синхронная передача сообщений
    1,         // максимальное количество экземпляров канала 
    0,         // размер выходного буфера по умолчанию
    0,         // размер входного буфера по умолчанию
    INFINITE,  // клиент ждет связь бесконечно долго
    NULL       // безопасность по умолчанию
    );
  // проверяем на успешное создание
  if (hNamedPipe == INVALID_HANDLE_VALUE)
  {
    cerr << "Create named pipe failed." << endl
      << "The last error code: " << GetLastError() << endl;
    cout << "Press any key to exit.";
    cin.get();
 
    return 0;
  }
  
  // ждем, пока клиент свяжется с каналом
  cout << "The server is waiting for connection with a client." << endl;
  if(!ConnectNamedPipe(
    hNamedPipe,    // дескриптор канала
    NULL      // связь синхронная
    ))
  {
    cerr << "Connect named pipe failed." << endl
      << "The last error code: "<<GetLastError() << endl;
    CloseHandle(hNamedPipe);
    cout << "Press any key to exit.";
    cin.get();
 
    return 0;
  }
  // читаем сообщение от клиента
  if (!ReadFile(
    hNamedPipe,      // дескриптор канала
    pchMessage,      // адрес буфера для ввода данных
    sizeof(pchMessage),  // количество читаемых байтов
    &dwBytesRead,    // количество прочитанных байтов
    NULL))           // передача данных синхронная
  {
    cerr << "Data reading from the named pipe failed." << endl
      << "The last error code: "<< GetLastError() << endl;
    CloseHandle(hNamedPipe);
    cout << "Press any key to exit.";
    cin.get();
 
    return 0;
  }
 
  // выводим полученное от клиента сообщение на консоль
  sort(pchMessage,pchMessage+5,wayToSort);
  cout << "The server received the message from a client: "<< endl;
    for (int i=0; i<5; i++)
  { 
    cout<<pchMessage[i]<< endl;
    if (pchMessage[i]<0)
    {
        arrsum+=pchMessage[i];
    }
    if (abs(pchMessage[i])<arrminabs)
    {
        arrminabs=abs(pchMessage[i]);
        iminabs = i;
    }
    if (abs(pchMessage[i])>arrmaxabs)
    {
        arrmaxabs=abs(pchMessage[i]);
        imaxabs = i;
    }
  }
  if (imaxabs>iminabs)
    {
        swap(imaxabs,iminabs);
    }
   for (int i=imaxabs+1; i<iminabs; i++)
  {
      arrmult*=pchMessage[i];
  }
   sprintf_s(pchResponse, "%f", arrsum);
   nMessageLength = strlen(pchResponse) + 1;
  // cout<<pchResponse<< endl;
  // отвечаем клиенту
  if (!WriteFile(
    hNamedPipe,      // дескриптор канала
    pchResponse,      // адрес буфера для вывода данных
    nMessageLength,  // количество записываемых байтов
    &dwBytesWrite,   // количество записанных байтов
    NULL             // передача данных синхронная
    ))
  {
    cerr << "Write file failed." << endl
      << "The last error code: " << GetLastError() << endl;
    CloseHandle(hNamedPipe);
    cout << "Press any key to exit.";
    cin.get();
 
    return 0;
  }
 
  // выводим посланное клиенту сообщение на консоль
  cout << "The server sent the message to a client: "
    << endl << '\t' << pchResponse << endl;
 
  // закрываем дескриптор канала 
  CloseHandle(hNamedPipe);
  // завершаем процесс
  cout << "Press any key to exit.";
  cin.get();
 
  return 0;
}