Именованный канал CreateFile() возвращает INVALID_HANDLE_VALUE, а GetLastError() возвращает ERROR_PIPE_BUSY.

Я написал класс для обработки соединений с именованными каналами, и если я создаю экземпляр, закрываю его, а затем пытаюсь создать другой экземпляр, вызов CreateFile() возвращает INVALID_HANDLE_VALUE, а GetLastError() возвращает ERROR_PIPE_BUSY. Что тут происходит? Что я могу сделать, чтобы вызов Connect() был успешным?

PipeAsync A, B;

A.Connect("\\\\.\\pipe\\test",5000);
A.Close();

cout << GetLastError(); // some random value
B.Connect("\\\\.\\pipe\\test",5000);
cout << GetLastError(); // 231 (ERROR_PIPE_BUSY)
B.Close();

Вот мои реализации Connect() и Close()

BOOL PipeAsync::Connect(LPCSTR pszPipeName, DWORD dwTimeout)
{
    this->pszPipeName = pszPipeName;
    this->fExisting = TRUE;
    DWORD dwMode = this->fMessageMode ? PIPE_READMODE_MESSAGE : PIPE_READMODE_BYTE;

    hPipe = CreateFile(
        this->pszPipeName,
        GENERIC_READ | GENERIC_WRITE,
        0,
        NULL,
        OPEN_EXISTING,
        FILE_FLAG_OVERLAPPED,
        NULL);

    if( INVALID_HANDLE_VALUE == hPipe )
        return FALSE; /* set break point here ; breaks here on second call to Connect() */

    if( GetLastError() == ERROR_PIPE_BUSY )
        if(!WaitNamedPipe( this->pszPipeName, dwTimeout ))
            return FALSE; /* set break point here */

    if( !SetNamedPipeHandleState( hPipe, &dwMode, NULL, NULL ) )
        return FALSE; /* set break point here */

    return TRUE;

}

VOID PipeAsync::Close()
{

    if( fExisting )
        DisconnectNamedPipe( hPipe );

    CloseHandle( hPipe );
}



РЕДАКТИРОВАТЬ: я забыл рассказать вам, как я пришел к этому выводу... Я установил точки останова, указанные в комментариях. При запуске он останавливается на первой точке останова.

EDIT: Это мой обновленный код

if( INVALID_HANDLE_VALUE == hPipe )
    if( GetLastError() == ERROR_PIPE_BUSY )
    {
        if(!WaitNamedPipe( this->pszPipeName, dwTimeout ))
            return FALSE; /* break-point: breaks here on second call */
    }
    else
        return FALSE; /* break-point /*

Теперь WaitNamedPipe() возвращает false при втором вызове Connect(), а GetLastError() возвращает 2 или ERROR_FILE_NOT_FOUND?


c++ winapi named-pipes
person Drew Chapin    schedule 16.12.2011    source источник
comment
Совет: \\ , \p и \t будут интерпретироваться как escape-символы. Либо переключитесь на прямую косую черту, либо на двойную обратную косую черту, чтобы избежать экранирования: "\\\\.\\pipe\\test".   -  person Xeo    schedule 16.12.2011
comment
Это опечатка... Исправил...   -  person Drew Chapin    schedule 16.12.2011

Ответы (1)


arrow_upward
4
arrow_downward

Из клиента именованного канала:

Если канал существует, но все его экземпляры заняты, CreateFile возвращает INVALID_HANDLE_VALUE, а функция GetLastError возвращает ERROR_PIPE_BUSY. Когда это происходит, клиент именованного канала использует функцию WaitNamedPipe для ожидания доступности экземпляра именованного канала.

По ссылке есть пример кода для работы с ERROR_PIPE_BUSY.

РЕДАКТИРОВАТЬ:

Небольшой компилируемый пример, демонстрирующий прием и подключение к именованному каналу:

const char* const PIPE_NAME = "\\\\.\\pipe\\test";
const int MAX_CONNECTIONS   = 10;

void client_main()
{
    DWORD last_error;
    unsigned int elapsed_seconds       = 0;
    const unsigned int timeout_seconds = 5;

    HANDLE handle = CreateFile(PIPE_NAME,
                               GENERIC_READ | GENERIC_WRITE,
                               0,
                               0,
                               OPEN_EXISTING,
                               FILE_ATTRIBUTE_NORMAL,
                               0);

    while (INVALID_HANDLE_VALUE == handle &&
           elapsed_seconds < timeout_seconds)
    {
        last_error = GetLastError();

        if (last_error != ERROR_PIPE_BUSY)
        {
            break;
        }

        Sleep(1 * 1000);
        elapsed_seconds++;

        handle = CreateFile(PIPE_NAME,
                            GENERIC_READ | GENERIC_WRITE,
                            0,
                            0,
                            OPEN_EXISTING,
                            FILE_ATTRIBUTE_NORMAL,
                            0);
    }

    if (INVALID_HANDLE_VALUE == handle)
    {
        std::cerr << "Failed to connect to pipe " << PIPE_NAME <<
            ": last_error=" << last_error << "\n";
    }
    else
    {
        std::cout << "Connected to pipe " << PIPE_NAME << "\n";
        CloseHandle(handle);
    }
}

HANDLE _get_server_handle()
{
    // Error handling omitted for security descriptor creation.
    SECURITY_DESCRIPTOR sd;
    InitializeSecurityDescriptor(&sd, SECURITY_DESCRIPTOR_REVISION);
    SetSecurityDescriptorDacl(&sd, TRUE, static_cast<PACL>(0), FALSE);

    SECURITY_ATTRIBUTES sa;
    sa.nLength              = sizeof(sa);
    sa.lpSecurityDescriptor = &sd;
    sa.bInheritHandle       = FALSE;

    // Create a bi-directional message pipe.
    HANDLE handle = CreateNamedPipe(PIPE_NAME,
                                    PIPE_ACCESS_DUPLEX,
                                    PIPE_TYPE_MESSAGE       |
                                      PIPE_READMODE_MESSAGE |
                                      PIPE_NOWAIT,
                                    PIPE_UNLIMITED_INSTANCES,
                                    4096,
                                    4096,
                                    0,
                                    &sa);

    if (INVALID_HANDLE_VALUE == handle)
    {
        std::cerr << "Failed to create named pipe handle: last_error=" <<
            GetLastError() << "\n";
    }

    return handle;
}

void server_main()
{
    HANDLE handle = _get_server_handle();

    if (INVALID_HANDLE_VALUE != handle)
    {
        int count = 0;
        while (count < MAX_CONNECTIONS)
        {
            BOOL result = ConnectNamedPipe(handle, 0);

            const DWORD last_error = GetLastError();

            if (ERROR_NO_DATA == last_error)
            {
                count++;
                std::cout << "A client connected and disconnected: count=" <<
                    count << "\n";
                CloseHandle(handle);
                handle = _get_server_handle();
            }
            else if (ERROR_PIPE_CONNECTED == last_error)
            {
                count++;
                std::cout << "A client connected before call to " <<
                    "ConnectNamedPipe(): count=" << count << "\n";
                CloseHandle(handle);
                handle = _get_server_handle();
            }
            else if (ERROR_PIPE_LISTENING != last_error)
            {
                std::cerr << "Failed to wait for connection: last_error=" <<
                    GetLastError() << "\n";
                CloseHandle(handle);
                break;
            }
            Sleep(100);
        }
    }
}

int main(int a_argc, char** a_argv)
{
    if (2 == a_argc)
    {
        if (std::string("client") == *(a_argv + 1))
        {
            for (int i = 0; i < MAX_CONNECTIONS; i++)
            {
                client_main();
            }
        }
        else if (std::string("server") == *(a_argv + 1))
        {
            server_main();
        }
    }
    return 0;
}

Сначала выполните на стороне сервера:

pipetest.exe server

Затем выполните на стороне клиента:

pipetest.exe client

Я не мог сказать, в чем проблема, из опубликованного кода. Надеюсь, этот небольшой пример поможет вам найти проблему.

person hmjd    schedule 16.12.2011
comment
Я изменил свой код, чтобы следовать этой логике, и теперь WaitNamedPipe() возвращает false, а GetLastError() возвращает ERROR_FILE_NOT_FOUND - person Drew Chapin; 16.12.2011
comment
Я также попробовал логику цикла в примере MSDN и получил тот же результат. CreateFile() возвращает INVALID_HANDLE_VALUE, затем GetLastError() возвращает ERROR_PIPE_BUSY, WaitNamedPipe() возвращает FALSE, а GetLastError() возвращает ERROR_FILE_NOT_FOUND. - person Drew Chapin; 16.12.2011
comment
Вы создаете именованный канал с именем \\\\.\\pipe\\test? Именованный канал создается с использованием СоздатьИменованныйКанал(). - person hmjd; 17.12.2011
comment
да. этот код из клиентского приложения. A client process connects to a named pipe by using the CreateFile - person Drew Chapin; 22.12.2011
comment
«Небольшой компилируемый пример» не демонстрирует суть. Он неправильно вызывает Sleep() вместо WaitNamedPipe(). - person user207421; 08.07.2017