VPF::Проблема с именованными каналами

War_Chief

Дата 13.1.2008, 18:48 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 39
Регистрация: 10.7.2007
Где: Украина,Киев

Репутация: нет
Всего: нет

Народ спасайте!
Пытаюсь научится работать с именованными каналами но результат всегда один и тот же:"НЕМОГУ СОЗДАТЬ КАНАЛ".
Суть програмы в том что сервер создает канал и ждет пока клиент запишет туда данные а потом читает отдуда данные!
Компилятор у меня Microsoft Visual C++ 2008.

Код сервера:

Код


#include <windows.h>
#include <iostream>
using namespace std;

int main()
{
  HANDLE hNamedPipe;
  
  // создаем именованный канал для чтения
  hNamedPipe = CreateNamedPipe(
    (LPCTSTR)"\\.\pipe\demo_pipe",      // имя канала
    PIPE_ACCESS_INBOUND,           // читаем из канала
    PIPE_TYPE_MESSAGE | PIPE_WAIT, // синхронная передача сообщений
    2,         // максимальное количество экземпляров канала
    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 << "The connection failed." << endl
      << "The last error code: " << GetLastError() << endl;
    CloseHandle(hNamedPipe);
    cout << "Press any key to exit.";
    cin.get();

    return 0;
  }

  // читаем данные из канала
  for (int i = 0; i < 10; i++)
  {
    int nData;
    DWORD dwBytesRead;
    if (!ReadFile(
      hNamedPipe,    // дескриптор канала
      &nData,        // адрес буфера для ввода данных
      sizeof(nData), // число читаемых байтов
      &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 number " << nData << " was read by the server" << endl;
  }
  // закрываем дескриптор канала 
  CloseHandle(hNamedPipe);
  // завершаем процесс
  cout << "The data are read by the server."<<endl;
  cout << "Press any key to exit.";
  cin.get();

  return 0;
}

Код клиента:

Код


#include <windows.h>
#include <iostream>
using namespace std;

int main()
{
  HANDLE hNamedPipe;
  char pipeName[] = "\\.\pipe\demo_pipe";
  
  // связываемся с именованным каналом
  hNamedPipe = CreateFile(
  (LPCWSTR)pipeName,        // имя канала
    GENERIC_WRITE,   // записываем в канал
    FILE_SHARE_READ, // разрешаем одновременное чтение из канала
    NULL,            // защита по умолчанию
    OPEN_EXISTING,   // открываем существующий канал
    0,     // атрибуты по умолчанию
    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;
  }

  // пишем в именованный канал
  for (int i = 0; i < 10; i++)
  {
    DWORD dwBytesWritten;    
    if (!WriteFile(
      hNamedPipe,  // дескриптор канала
      &i,          // данные
      sizeof(i),   // размер данных
      &dwBytesWritten,   // количество записанных байтов
      NULL         // синхронная запись
      ))
    {
      // ошибка записи
      cerr << "Writing to the named pipe failed: " << endl
        << "The last error code: " << GetLastError() << endl;
      CloseHandle(hNamedPipe);
      cout << "Press any key to exit.";
      cin.get();

      return 0;
    }
    // выводим число на консоль
    cout << "The number " << i << " is written to the named pipe."
         << endl;
    Sleep(1000);
  }
  // закрываем дескриптор канала
  CloseHandle(hNamedPipe);
  // завершаем процесс
  cout << "The data are written by the client." << endl
    << "Press any key to exit.";
  cin.get();

  return 0;
}

BorisVorontsov

Дата 13.1.2008, 21:49 (ссылка)

(нет голосов)

Загрузка ...

Thinker

Профиль
Группа: Комодератор
Сообщений: 714
Регистрация: 3.11.2005
Где: Молдавия, г. Киши нёв

Репутация: 4
Всего: 10

Цитата(War_Chief @ 13.1.2008, 18:48

)

но результат всегда один и тот же

GetLastError?

--------------------

[code=cpp]
const char *out = "|*0>78-,+<|"; size_t cc = char_traits<char>::length(out);
for (size_t i=0;i<cc;i++){cout<<static_cast<char>((out[i]^89));}cout<<endl;
[/code]

War_Chief

Дата 13.1.2008, 22:12 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 39
Регистрация: 10.7.2007
Где: Украина,Киев

Репутация: нет
Всего: нет

BorisVorontsov,
да всегда одно и тоже.
Я незнаю может ето компилятор гонит, потомучто я поставил Visual Studio 2008!!

NiJazz

Дата 13.1.2008, 23:04 (ссылка)

(нет голосов)

Загрузка ...

Jazz coder

Профиль
Группа: Экс. модератор
Сообщений: 2286
Регистрация: 10.8.2003
Где: Москва

Репутация: 6
Всего: 23

Цитата

да всегда одно и тоже.
Я незнаю может ето компилятор гонит, потомучто я поставил Visual Studio 2008!!

Добавлено через 5 минут и 12 секунд
Сразу обратил внимание:

Код


(LPCTSTR)"\\.\pipe\demo_pipe"

Попробуй:

Код


(LPCTSTR)"\\\\.\\pipe\\demo_pipe"

Добавлено через 6 минут и 9 секунд
Иными словами - неверное имя пайпа, возвращает ошибку. А ты мог бы значение ошибки привести?

586

Дата 13.1.2008, 23:40 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2243
Регистрация: 8.5.2006

Репутация: 39
Всего: 146

Цитата(War_Chief @ 13.1.2008, 18:48

)

  char pipeName[] = "\\.\pipe\demo_pipe";

  // связываемся с именованным каналом
  hNamedPipe = CreateFile(
  (LPCWSTR)pipeName,        // имя канала

Так нельзя делать smile

Добавлено через 3 минуты и 10 секунд

Код

static const TCHAR pipeName[] = TEXT("\\\\.\\pipe\\demo_pipe";

hNamedPipe = CreateFile(
       pipeName,
//...

War_Chief

Дата 14.1.2008, 00:50 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 39
Регистрация: 10.7.2007
Где: Украина,Киев

Репутация: нет
Всего: нет

586,
сработало!
Огромное спасибо!))))

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| C/C++: Системное программирование и WinAPI \| Следующая тема »