информационная безопасность
без паники и всерьез
 подробно о проектеRambler's Top100
Страшный баг в WindowsГде водятся OGRыSpanning Tree Protocol: недокументированное применение
BugTraq.Ru
Русский BugTraq
 Анализ криптографических сетевых... 
 Модель надежности двухузлового... 
 Специальные марковские модели надежности... 
 Phrack #70/0x46 
 Возможно, Facebook наступил на... 
 50 лет электронной почте 
главная обзор RSN блог библиотека закон бред форум dnet о проекте
bugtraq.ru / форум / programming
Имя Пароль
ФОРУМ
все доски
FAQ
IRC
новые сообщения
site updates
guestbook
beginners
sysadmin
programming
operating systems
theory
web building
software
hardware
networking
law
hacking
gadgets
job
dnet
humor
miscellaneous
scrap
регистрация





Легенда:
  новое сообщение
  закрытая нитка
  новое сообщение
  в закрытой нитке
  старое сообщение
  • Напоминаю, что масса вопросов по функционированию форума снимается после прочтения его описания.
  • Новичкам также крайне полезно ознакомиться с данным документом.
В общем потестил. Как я и ожидал, всё работает так как надо... 27.08.07 12:15  Число просмотров: 2426
Автор: IgorR <Igor Razin> Статус: Member
<"чистая" ссылка>
В общем потестил. Как я и ожидал, всё работает так как надо и как должно работать. Твоих граблей вроде не наблюдается.

Сервер:
==================================================================
HANDLE hPipe = CreateNamedPipe( T("\\\\.\\PIPE\\IOCP_TEST"),
PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED,
PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
PIPE_UNLIMITED_INSTANCES,
1024, 1024,
NMPWAIT_WAIT_FOREVER, NULL );

CIOCP iocp;

iocp.Init();
iocp.AssociateDevice( hPipe, 123 /* key */ );

OVERLAPPED op = {0};

ConnectNamedPipe( hPipe, &op );

DWORD dwKey = 0;
DWORD dwBytes = 0;
LPOVERLAPPED pop = NULL;

// Ждем коннекта.
iocp.GetStatus( &dwKey, &dwBytes, &pop );

BYTE bData[1024] = {0};

// Отправим данные 2 раза, при этом клиент данные не читает.
// Первый раз вернется 1 - операция завершилась синхронно.
// Второй раз вернется 0 - асинхронно, т.к. клиент не вычитал первую партию.
ZeroMemory( &op, sizeof( op ) );
DWORD dwRet = WriteFile( hPipe, bData, 1024, NULL, &op ); // 1
DWORD dwError = GetLastError();

ZeroMemory( &op, sizeof( op ) );
dwRet = WriteFile( hPipe, bData, 1024, NULL, &op ); // 0
dwError = GetLastError();

// Завершенка на первую посылку будет сразу.
iocp.GetStatus( &dwKey, &dwBytes, &pop );

// Ждем пока клиент прочтет 1-ю партию.
// Если сейчас вырубить клиента, то завершенка ПРИДЕТ.
iocp.GetStatus( &dwKey, &dwBytes, &pop );

iocp.Release();

CloseHandle( hPipe );
==================================================================

Клиент:
==================================================================
HANDLE hPipe = CreateFile( T("\\\\.\\PIPE\\IOCP_TEST"),
GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, NULL );

/*
BYTE bBuffer[1024] = {0};
DWORD dwRead = 0;
ReadFile( hPipe, bBuffer, 1024, &dwRead, NULL );
ReadFile( hPipe, bBuffer, 1024, &dwRead, NULL );
*/

CloseHandle( hPipe );
==================================================================
<programming> Поиск 








Rambler's Top100
Рейтинг@Mail.ru


  Copyright © 2001-2021 Dmitry Leonov   Page build time: 0 s   Design: Vadim Derkach