| |||
| БЕСПЛАТНАЯ ежедневная online лотерея! Выигрывай каждый день БЕСПЛАТНО! | |||
| |||
Named Pipe Client ProcessA client process uses the CreateFile function to open a handle to a named pipe. If the pipe exists but all of its instances are busy, CreateFile returns FALSE and the GetLastError function returns ERROR_PIPE_BUSY. When this happens, the client process uses the WaitNamedPipe function to wait for an instance of the pipe to be available. CreateFile fails if the access specified is incompatible with the access specified (duplex, outbound, or inbound) when the server created the pipe. For a duplex pipe (read/write), the client can specify read, write, or read/write access; for an outbound pipe (server write only), the client must specify read only; and for an inbound pipe (server read only), the client must specify write only. The handle returned by CreateFile defaults to byte-read mode, blocking-wait mode, overlapped mode disabled, and write-through mode disabled. The client process can use CreateFile to enable overlapped mode by specifying FILE_FLAG_OVERLAPPED or to enable write-through mode by specifying FILE_FLAG_WRITE_THROUGH. The client can use the SetNamedPipeHandleState function to enable nonblocking mode by specifying PIPE_WAIT or to enable message-read mode by specifying PIPE_READMODE_MESSAGE. The following example shows a client process that opens a named pipe, sets the pipe handle to message-read mode, uses WriteFile to send a request to the server, and uses ReadFile to read the server's reply. This client process can be used with any of the message-type servers shown in the previous sections. With a byte-type server, however, this client process fails when it calls SetNamedPipeHandleState to change to message-read mode. Because the client is reading from the pipe in message-read mode, it is possible for the ReadFile operation to return FALSE after reading a partial message. This happens when the message is larger than the read buffer. In this situation, GetLastError returns ERROR_MORE_DATA, and the remainder of the message is read by additional calls to ReadFile. #include DWORD main(int argc, char *argv[]) { HANDLE hPipe; LPVOID lpvMessage; CHAR chBuf[512]; BOOL fSuccess; DWORD cbRead, cbWritten, dwMode; LPTSTR lpszPipename = "\\\\.\\pipe\\mynamedpipe"; // Try to open a named pipe; wait for it, if necessary. while (1) { hPipe = CreateFile( lpszPipename, // pipe name GENERIC_READ | // read and write access GENERIC_WRITE, 0, // no sharing NULL, // no security attributes OPEN_EXISTING, // opens existing pipe 0, // default attributes NULL); // no template file // Break if the pipe handle is valid. if (hPipe != INVALID_HANDLE_VALUE) break; // Exit if an error other than ERROR_PIPE_BUSY occurs. if (GetLastError() != ERROR_PIPE_BUSY) MyErrExit("Could not open pipe"); // All pipe instances are busy, so wait for 20 seconds. if (! WaitNamedPipe(lpszPipename, 20000) ) MyErrExit("Could not open pipe"); } // The pipe connected; change to message-read mode. dwMode = PIPE_READMODE_MESSAGE; fSuccess = SetNamedPipeHandleState( hPipe, // pipe handle &dwMode, // new pipe mode NULL, // don't set max. bytes NULL); // don't set max. time if (!fSuccess) MyErrExit("SetNamedPipeHandleState"); // Send a message to the pipe server. lpvMessage = (argc > 1) ? argv[1] : "default message"; fSuccess = WriteFile( hPipe, // pipe handle lpvMessage, // message strlen(lpvMessage) + 1, // message length &cbWritten, // bytes written NULL); // not overlapped if (! fSuccess) MyErrExit("WriteFile"); do { // Read from the pipe. fSuccess = ReadFile( hPipe, // pipe handle chBuf, // buffer to receive reply 512, // size of buffer &cbRead, // number of bytes read NULL); // not overlapped if (! fSuccess && GetLastError() != ERROR_MORE_DATA) break; // Reply from the pipe is written to STDOUT. if (! WriteFile(GetStdHandle(STD_OUTPUT_HANDLE), chBuf, cbRead, &cbWritten, NULL)) break; } while (! fSuccess); // repeat loop if ERROR_MORE_DATA CloseHandle(hPipe); return 0; } | |||
| Пригласи друзей и счет твоего мобильника всегда будет положительным! | |||
| |||
| Пригласи друзей и счет твоего мобильника всегда будет положительным! | |||
Процесс Клиента Поименованной ТрубыПроцесс клиента использует функцию CreateFile, чтобы открывать ручку в поименованную трубу. Если труба существует но все примеры - занятая, ЛОЖЬ возврата CreateFile и функциональный возврат GetLastError ERROR_PIPE_BUSY. Когда это случается, процесс клиента использует функцию WaitNamedPipe, чтобы ждать пример трубы, чтобы быть доступно. CreateFile ТЕРПИТ неудачу если определенный доступ несовместимый с определенным доступом (дуплекс, уходящий, или inbound) когда сервер создавал трубу. Для дуплексной трубы (прочитавшее/запись), клиент может определить прочитанную, запись, или прочитавшую/доступ записи; для уходящей трубы (запись сервера только), клиент должен определить прочитанный только; и для трубы inbound (сервер был прочитан только), клиент должен определить запись только. Ручка возвращанная CreateFile устанавливается по умолчанию в байт-прочитавший режим, блокирующий-режим ожидания, перекрывший режим выводился из строя, и запись-через режим выводилась из строя. Процесс клиента может использовать CreateFile, чтобы приспосабливаться перекрытый режим определяя FILE_FLAG_OVERLAPPED или, чтобы приспосабливаться запись-через режим определяя FILE_FLAG_WRITE_THROUGH. Клиент может использовать функцию SetNamedPipeHandleState, чтобы приспосабливаться nonblocking режим определяя PIPE_WAIT или, чтобы приспосабливаться сообщение-прочитавшее режим определяя PIPE_READMODE_MESSAGE. Следующий пример показывает процесс клиента, который открывает поименованную трубу, устанавливает ручку трубы в сообщение-прочитавшее режим, использует WriteFile, чтобы посылать запрос в сервер и использовать ReadFile, чтобы читать ответ сервера. Этот процесс клиента может быть использован любым из сообщения-типа серверов показанного в предшествующих секциях. С байтовым типом сервера, тем не менее, этот процесс клиента терпит неудачу когда он вызывает SetNamedPipeHandleState, чтобы изменяться в сообщение-прочитавшее режим. Поскольку клиент читается из трубы в сообщении-прочитавшем режим, он возможно для операции ReadFile возвращать ЛОЖЬ после чтения частичного сообщения. Это случается когда сообщение большее чем буфер чтения. В этой ситуации, возврат GetLastError ERROR_MORE_DATA, и разность сообщения прочитана дополнительными вызовами на ReadFile. #include ОСНОВА DWORD(int argc, символ *argv[]) { ПРООПЕРИРУЙТЕ hPipe; lpvMessage LPVOID; СИМВОЛ chBuf[512]; BOOL fSuccess; DWORD cbRead, cbWritten, dwMode; LPTSTR lpszPipename = "\\\\.\\pipe\\mynamedpipe"; // Попытка, чтобы открывать поименованную трубу; подождите этого, если необходимо. пока (1) { hPipe = CreateFile( lpszPipename, // Имя трубы GENERIC_READ | // прочитанное и доступ записи GENERIC_WRITE, 0, // никакие использующие НЕДЕЙСТВИТЕЛЬНЫЕ, // никакие атрибуты безопасности OPEN_EXISTING, // открытые существуя труба 0, // по умолчанию атрибуты НЕДЕЙСТВИТЕЛЬНЫЕ); // никакой файл шаблона // Прерывание если ручка трубы в силе. если прерывание (hPipe != INVALID_HANDLE_VALUE); // Выход если ошибка кроме ERROR_PIPE_BUSY происходит. если (GetLastError() != ERROR_PIPE_BUSY) MyErrExit("Could не открытая труба"); // Все примеры трубы занятые, так что ожидание 20 секунд. если (! WaitNamedPipe(lpszPipename, 20000) ) MyErrExit("Could НЕ открытая труба"); } // Труба связывалась; изменение в сообщение-было прочитано режим. dwMode = PIPE_READMODE_MESSAGE; fSuccess = SetNamedPipeHandleState( hPipe, // Ручка трубы &dwMode, // нового режима трубы НЕДЕЙСТВИТЕЛЬНАЯ, // не делать устанавливать max. байты НЕДЕЙСТВИТЕЛЬНЫЕ); // не сделайте устанавливать max. время если (!fSuccess) MyErrExit("SetNamedPipeHandleState"); // Пошлите сообщение в сервер трубы. lpvMessage = (argc > 1)? argv[1] : "по умолчанию сообщение"; fSuccess = WriteFile( hPipe, // lpvMessage Ручки трубы, // сообщения strlen(lpvMessage) + 1, // длина сообщения &cbWritten, // байты записавшие НЕДЕЙСТВИТЕЛЬНЫМИ); // не перекрытое если (! fSuccess) MyErrExit("WriteFile"); сделайте { // Прочитанное из трубы. fSuccess = ReadFile( hPipe, // Ручка трубы chBuf, // буфер, чтобы получать ответу 512, // размер буфера &cbRead, // количество байтов было прочитано НЕДЕЙСТВИТЕЛЬНЫМ); // не перекрытое если (! fSuccess && GetLastError Прерывания() != ERROR_MORE_DATA); // Ответ из трубы записан на STDOUT. если (! WriteFile(GetStdHandle(STD_OUTPUT_HANDLE), chBuf, cbRead, &cbWritten, НЕДЕЙСТВИТЕЛЬНОЕ)) прерывание; } пока (! fSuccess); // цикл повторения если ERROR_MORE_DATA CloseHandle(hPipe); возврат 0; } | |||
| |||
 |
