Перекрывающийся ввод-вывод на анонимном канале

Можно ли использовать перекрывающийся ввод-вывод с анонимным каналом? CreatePipe () не имеет возможности указать FILE_FLAG_OVERLAPPED, поэтому я предполагаю, что ReadFile () заблокируется, даже если я предоставлю структуру OVERLAPPED.

Стоит ли изучать PHP в 2026-2027 годах?
Стоит ли изучать PHP в 2026-2027 годах?
Привет всем, сегодня я хочу высказать свои соображения по поводу вопроса, который я уже много раз получал в своем сообществе: "Стоит ли изучать PHP в...
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.
Приемы CSS-макетирования - floats и Flexbox
Приемы CSS-макетирования - floats и Flexbox
Здравствуйте, друзья-студенты! Готовы совершенствовать свои навыки веб-дизайна? Сегодня в нашем путешествии мы рассмотрим приемы CSS-верстки - в...
Тестирование функциональных ngrx-эффектов в Angular 16 с помощью Jest
В системе управления состояниями ngrx, совместимой с Angular 16, появились функциональные эффекты. Это здорово и делает код определенно легче для...
Концепция локализации и ее применение в приложениях React ⚡️
Концепция локализации и ее применение в приложениях React ⚡️
Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
16
0
9 712
3
Перейти к ответу Данный вопрос помечен как решенный

Ответы 3

Нет. Как объяснил здесь, анонимные каналы не поддерживают асинхронный ввод-вывод. Вам нужно использовать именованный канал. Для этого есть пример кода в MSDN здесь и здесь.

Из документов SetNamedPipeHandleState похоже, что неблокирующий ввод-вывод должен поддерживаться на анонимных каналах с флагом PIPE_NOWAIT.

anatoly techtonik 29.12.2015 08:52

@anatolytechtonik, к сожалению, это не то же самое, что перекрытый ввод-вывод.

Kenton Varda 06.11.2016 05:03

неверный ответ. анонимные каналы, конечно, поддерживают асинхронный ввод-вывод.

RbMm 20.07.2018 20:05
Ответ принят как подходящий

Вот реализация анонимной функции канала с возможностью указать FILE_FLAG_OVERLAPPED:

/******************************************************************************\
*       This is a part of the Microsoft Source Code Samples. 
*       Copyright 1995 - 1997 Microsoft Corporation.
*       All rights reserved. 
*       This source code is only intended as a supplement to 
*       Microsoft Development Tools and/or WinHelp documentation.
*       See these sources for detailed information regarding the 
*       Microsoft samples programs.
\******************************************************************************/

/*++
Copyright (c) 1997  Microsoft Corporation
Module Name:
    pipeex.c
Abstract:
    CreatePipe-like function that lets one or both handles be overlapped
Author:
    Dave Hart  Summer 1997
Revision History:
--*/

#include <windows.h>
#include <stdio.h>

static volatile long PipeSerialNumber;

BOOL
APIENTRY
MyCreatePipeEx(
    OUT LPHANDLE lpReadPipe,
    OUT LPHANDLE lpWritePipe,
    IN LPSECURITY_ATTRIBUTES lpPipeAttributes,
    IN DWORD nSize,
    DWORD dwReadMode,
    DWORD dwWriteMode
    )

/*++
Routine Description:
    The CreatePipeEx API is used to create an anonymous pipe I/O device.
    Unlike CreatePipe FILE_FLAG_OVERLAPPED may be specified for one or
    both handles.
    Two handles to the device are created.  One handle is opened for
    reading and the other is opened for writing.  These handles may be
    used in subsequent calls to ReadFile and WriteFile to transmit data
    through the pipe.
Arguments:
    lpReadPipe - Returns a handle to the read side of the pipe.  Data
        may be read from the pipe by specifying this handle value in a
        subsequent call to ReadFile.
    lpWritePipe - Returns a handle to the write side of the pipe.  Data
        may be written to the pipe by specifying this handle value in a
        subsequent call to WriteFile.
    lpPipeAttributes - An optional parameter that may be used to specify
        the attributes of the new pipe.  If the parameter is not
        specified, then the pipe is created without a security
        descriptor, and the resulting handles are not inherited on
        process creation.  Otherwise, the optional security attributes
        are used on the pipe, and the inherit handles flag effects both
        pipe handles.
    nSize - Supplies the requested buffer size for the pipe.  This is
        only a suggestion and is used by the operating system to
        calculate an appropriate buffering mechanism.  A value of zero
        indicates that the system is to choose the default buffering
        scheme.
Return Value:
    TRUE - The operation was successful.
    FALSE/NULL - The operation failed. Extended error status is available
        using GetLastError.
--*/

{
  HANDLE ReadPipeHandle, WritePipeHandle;
  DWORD dwError;
  UCHAR PipeNameBuffer[ MAX_PATH ];

  //
  // Only one valid OpenMode flag - FILE_FLAG_OVERLAPPED
  //

  if ((dwReadMode | dwWriteMode) & (~FILE_FLAG_OVERLAPPED)) {
    SetLastError(ERROR_INVALID_PARAMETER);
    return FALSE;
  }

  //
  //  Set the default timeout to 120 seconds
  //

  if (nSize == 0) {
    nSize = 4096;
  }

  sprintf( PipeNameBuffer,
           "\\.\Pipe\RemoteExeAnon.%08x.%08x",
           GetCurrentProcessId(),
           InterlockedIncrement(&PipeSerialNumber)
         );

  ReadPipeHandle = CreateNamedPipeA(
                       PipeNameBuffer,
                       PIPE_ACCESS_INBOUND | dwReadMode,
                       PIPE_TYPE_BYTE | PIPE_WAIT,
                       1,             // Number of pipes
                       nSize,         // Out buffer size
                       nSize,         // In buffer size
                       120 * 1000,    // Timeout in ms
                       lpPipeAttributes
                       );

  if (! ReadPipeHandle) {
    return FALSE;
  }

  WritePipeHandle = CreateFileA(
                      PipeNameBuffer,
                      GENERIC_WRITE,
                      0,                         // No sharing
                      lpPipeAttributes,
                      OPEN_EXISTING,
                      FILE_ATTRIBUTE_NORMAL | dwWriteMode,
                      NULL                       // Template file
                    );

  if (INVALID_HANDLE_VALUE == WritePipeHandle) {
    dwError = GetLastError();
    CloseHandle( ReadPipeHandle );
    SetLastError(dwError);
    return FALSE;
  }

  *lpReadPipe = ReadPipeHandle;
  *lpWritePipe = WritePipeHandle;
  return( TRUE );
}

Спасибо! Это как раз то, что мне было нужно.

Steve Hanov 16.07.2010 22:29

Реализация MyCreatePipeEx Дейва Харта превосходна (по сути, заимствована из самого исходного кода Windows CreatePipe), но вам следует изменить PipeSerialNumber++ на InterlockedIncrement(&PipeSerialNumber) в указанной реализации, чтобы избежать состояний гонки в коде MT.

vladr 09.10.2012 22:49

Ого, этот метод удивительно тривиален и гениален :). Вкратце: он создает пару именованных каналов (канал чтения с CreateNamedPipe и канал записи с WriteFile) со всеми параметрами Overlapped и возвращает их дескрипторы.

Fr0sT 22.12.2015 18:25

что, если я сделаю: StringCbPrintfA(pipe_name, MAX_PATH, "\\.\Pipe\%08x.%08x", rand(), time(nullptr) );, чтобы избежать InterlockedIncrement?

Adam Zahran 02.03.2020 16:46

да, неважно. Пробовал, и rand () и time () легко сталкиваются в нескольких потоках. В конце концов, это генератор псевдослучайных чисел.

Adam Zahran 03.03.2020 15:20

Прежде всего нужно понять - что такое Анонимные трубы и что вообще есть разница между анонимом и Именованные каналы.

реально существует только однотрубный тип (реализовано npfs.sys). никакой разницы, кроме имени, между именованными и анонимными каналами вообще нет. оба только трубы.

так называемые анонимные каналы - это специальные / случайные именованные каналы до win7, а истинные безымянные каналы начинаются с win7.

когда msdn пишет, что "анонимная труба - это труба с односторонним движением" - это ложь. как и любая труба, она может быть односторонней или дуплексной. когда msdn пишет, что «Асинхронные (перекрывающиеся) операции чтения и записи не поддерживаются анонимными каналами». - это ложь. конечно каналы поддерживают асинхронный io. название трубы на это не влияет.

до win7 реально безымянных пайпов даже вообще не было. Функция CreatePipe использует формат Win32Pipes.%08x.%08x для создания имени «Анонимного канала».

    static LONG PipeSerialNumber;
    WCHAR name[64];
    swprintf(name, L"\Device\NamedPipe\Win32Pipes.%08x.%08x", 
        GetCurrentProcessId(), InterlockedIncrement(&PipeSerialNumber));

начните с win7 CreatePipe используйте другую технику (относительное открытие файла) для создания пары каналов - теперь это действительно анонимно.

например, код, который создает пару каналов, где один канал является асинхронным и не наследуется. а другой канал является синхронным и наследуемым. оба канала дуплексные (поддерживают как чтение, так и запись)

ULONG CreatePipeAnonymousPair7(PHANDLE phServerPipe, PHANDLE phClientPipe)
{
    HANDLE hNamedPipe;

    IO_STATUS_BLOCK iosb;

    static UNICODE_STRING NamedPipe = RTL_CONSTANT_STRING(L"\Device\NamedPipe\");

    OBJECT_ATTRIBUTES oa = { sizeof(oa), 0, const_cast<PUNICODE_STRING>(&NamedPipe), OBJ_CASE_INSENSITIVE };

    NTSTATUS status;

    if (0 <= (status = NtOpenFile(&hNamedPipe, SYNCHRONIZE, &oa, &iosb, FILE_SHARE_VALID_FLAGS, 0)))
    {
        oa.RootDirectory = hNamedPipe;

        static LARGE_INTEGER timeout = { 0, MINLONG };
        static UNICODE_STRING empty = {};

        oa.ObjectName = &empty;

        if (0 <= (status = ZwCreateNamedPipeFile(phServerPipe,
            FILE_READ_ATTRIBUTES|FILE_READ_DATA|
            FILE_WRITE_ATTRIBUTES|FILE_WRITE_DATA|
            FILE_CREATE_PIPE_INSTANCE, 
            &oa, &iosb, FILE_SHARE_READ|FILE_SHARE_WRITE,
            FILE_CREATE, 0, FILE_PIPE_BYTE_STREAM_TYPE, FILE_PIPE_BYTE_STREAM_MODE,
            FILE_PIPE_QUEUE_OPERATION, 1, 0, 0, &timeout)))
        {
            oa.RootDirectory = *phServerPipe;
            oa.Attributes = OBJ_CASE_INSENSITIVE|OBJ_INHERIT;

            if (0 > (status = NtOpenFile(phClientPipe, SYNCHRONIZE|FILE_READ_ATTRIBUTES|FILE_READ_DATA|
                FILE_WRITE_ATTRIBUTES|FILE_WRITE_DATA, &oa, &iosb, 
                FILE_SHARE_VALID_FLAGS, FILE_SYNCHRONOUS_IO_NONALERT)))
            {
                NtClose(oa.RootDirectory);
            }
        }

        NtClose(hNamedPipe);
    }

    return RtlNtStatusToDosError(status);
}

ULONG CreatePipeAnonymousPair(PHANDLE phServerPipe, PHANDLE phClientPipe)
{
    static char flag_supported = -1;

    if (flag_supported < 0)
    {
        ULONG dwMajorVersion, dwMinorVersion;
        RtlGetNtVersionNumbers(&dwMajorVersion, &dwMinorVersion, 0);
        flag_supported = _WIN32_WINNT_WIN7 <= ((dwMajorVersion << 8)| dwMinorVersion);
    }

    if (flag_supported)
    {
        return CreatePipeAnonymousPair7(phServerPipe, phClientPipe);
    }

    static LONG PipeSerialNumber;

    WCHAR name[64];

    swprintf(name, L"\\?\pipe\Win32Pipes.%08x.%08x", GetCurrentProcessId(), InterlockedIncrement(&PipeSerialNumber));

    HANDLE hClient, hServer = CreateNamedPipeW(name, 
        PIPE_ACCESS_DUPLEX|FILE_READ_DATA|FILE_WRITE_DATA|FILE_FLAG_OVERLAPPED, 
        PIPE_TYPE_BYTE|PIPE_READMODE_BYTE, 1, 0, 0, 0, 0);

    if (hServer != INVALID_HANDLE_VALUE)
    {
        static SECURITY_ATTRIBUTES sa = { sizeof(sa), 0, TRUE };

        hClient = CreateFileW(name, FILE_GENERIC_READ|FILE_GENERIC_WRITE, 
            FILE_SHARE_READ|FILE_SHARE_WRITE, &sa, OPEN_EXISTING, 0, 0);

        if (hClient != INVALID_HANDLE_VALUE)
        {
            *phServerPipe = hServer, *phClientPipe = hClient;
            return NOERROR;
        }

        CloseHandle(hServer);
    }

    return GetLastError();
}

Что такое метод «относительного открытия файла»? Ничего не нашел в гугле. Пожалуйста, укажите на какую-нибудь документацию.

George Sovetov 07.07.2020 22:12

@GeorgeSovetov - если api принимает в качестве входного параметра OBJECT_ATTRIBUTES, он поддерживает открытие или создание файла относительно каталога RootDirectory. в моем конкретном - сначала открываем корневую папку \ на \ Устройство \ NamedPipe, затем создаем pipe с пустым именем. а затем снова создайте пару с пустым именем, но с oa.RootDirectory = *phServerPipe. это внутренне используется кодом CreatePipe, просто этот api-жесткий код синхронного ввода-вывода на каналах

RbMm 07.07.2020 22:34

Следовательно, можно ли создать много каналов в одном RootDirectory и ссылаться на них просто по их ручкам? Так достигается анонимность? Я немного озадачен тем фактом, что у нескольких объектов один и тот же путь. А также тем, что какая-то часть имени может быть пустой.

George Sovetov 07.07.2020 23:35

@GeorgeSovetov до win7 все каналы были названы, использовалось просто случайное имя, например "\Device\NamedPipe\Win32Pipes.%08x.%08x". begin from win7 был разработан этот код (требуется поддержка драйвера npfs.sys). поэтому у файлов вообще нет имени. Уловка заключается в том, как создать пара. Предположим, что мы создаем безымянный канал. как к нему "подключиться"? мы не можем использовать имя (оно пустое). так и специальный способ, разработанный внутри НПФС - используйте дескриптор RootDirectory из object_attributes для точки - к какой трубе мы хотим подключиться

RbMm 07.07.2020 23:44

Другие вопросы по теме