Исправляем ошибку блокировки функции `ReadFile` в именованных каналах

Delphi , Синтаксис , Справочник по API-функциям

Исправление ошибки блокировки функции ReadFile в именованных каналах

При работе с именованными каналами в операционных системах семейства Windows, функция ReadFile может заблокироваться, если процесс, выполняющий запись, не завершил операцию записи или буфер для чтения не заполнен. Это происходит, так как родительский процесс держит открытый дескриптор записи, что не позволяет ReadFile завершиться с кодом ошибки. Важно закрыть дескриптор hWrite перед чтением из канала.

Подтвержденный ответ

Чтобы избежать блокировки, необходимо закрыть дескриптор записи hWrite до вызова функции ReadFile. Это позволит корректно обработать ситуацию, когда процесс еще не выполнил запись в канал, и ReadFile правильно завершится с ошибкой ERROR_BROKEN_PIPE, которую можно обнаружить с помощью функции GetLastError. В случае получения этой ошибки, рекомендуется завершить чтение из канала.

Альтернативный ответ

В качестве альтернативы, можно дождаться завершения процесса, который выполняет запись, и только после этого начать чтение из канала. Такой подход исключит риск блокировки ReadFile, поскольку дескрипторы, открытые в дочернем процессе, будут закрыты.

Пример кода на Object Pascal (Delphi)

uses
  SysUtils, Windows;

var
  hRead, hWrite: THandle;
  piProcess: TProcInfo;
  suiStartup: TStartupInfo;
  pBuffer: array[0..MaxBufferSize] of Byte;
  dRunning, dRead: DWORD;
  flags: DWORD;
  saSecurity: TSecurityAttributes;
begin
  // Инициализация безопасности для дескрипторов
  saSecurity.nLength := SizeOf(TSecurityAttributes);
  saSecurity.bInheritHandle := True;
  saSecurity.lpSecurityDescriptor := nil;

  // Создание именованного канала
  if CreatePipe(hRead, hWrite, @saSecurity, 0) then
  begin
    try
      // Инициализация структуры TStartupInfo
      FillChar(suiStartup, SizeOf(TStartupInfo), #0);
      suiStartup.cb := SizeOf(TStartupInfo);
      suiStartup.hStdInput := hRead;
      suiStartup.hStdOutput := hWrite;
      suiStartup.hStdError := hWrite;
      suiStartup.dwFlags := STARTF_USESTDHANDLES or STARTF_USESHOWWINDOW;
      suiStartup.wShowWindow := SW_HIDE;

      // Запуск нового процесса с использованием канала
      if CreateProcess(nil, PChar(ACommand + ' ' + AParameters), @saSecurity,
                      @saSecurity, True, NORMAL_PRIORITY_CLASS, nil, nil,
                      suiStartup, piProcess) then
      begin
        CloseHandle(hWrite); // Закрытие дескриптора записи
        try
          repeat
            dRunning := WaitForSingleObject(piProcess.hProcess, 100);
            Application.ProcessMessages();
            // Проверка на завершение процесса
            if dRunning <> WAIT_TIMEOUT then
              Break; // Выход из цикла, если процесс завершен

            repeat
              dRead := 0;
              // Чтение из канала
              if ReadFile(hRead, pBuffer[0], CReadBuffer, dRead, nil) then
              begin
                pBuffer[dRead] := #0;
                // Обработка данных
                // ...
              end;
            until dRead < CReadBuffer; // Продолжать чтение, пока буфер не заполнен
          until True; // Добавляем условный выход из цикла после Break
        finally
          CloseHandle(piProcess.hProcess);
          CloseHandle(piProcess.hThread);
        end;
      end;
    finally
      CloseHandle(hRead);
      if GetHandleInformation(hWrite, flags) then
        CloseHandle(hWrite);
    end;
  end;
end;

Обратите внимание, что в приведенном коде используется механизм ожидания завершения процесса с помощью функции WaitForSingleObject, а также чтение из канала осуществляется в цикле до заполнения буфера чтения. Это позволяет корректно обрабатывать ситуацию, когда процесс еще не завершил запись в канал, и избежать блокировки ReadFile.

Создано по материалам из источника по ссылке.

В контексте обсуждается проблема блокировки функции `ReadFile` при использовании именованных каналов в Windows и предоставляются способы её решения.

Комментарии и вопросы

Получайте свежие новости и обновления по Object Pascal, Delphi и Lazarus прямо в свой смартфон. Подпишитесь на наш Telegram-канал delphi_kansoftware и будьте в курсе последних тенденций в разработке под Linux, Windows, Android и iOS

:: Главная :: Справочник по API-функциям ::