VPF::Проблемы с anonimous pipes - Форум программистов

Lotrex

Дата 21.3.2008, 16:47 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 95
Регистрация: 9.2.2006
Где: Казань

Репутация: нет
Всего: 3

Суть в следующем. Я перенаправляю stdin , stdout & stderr дочернего процесса способом, описанным в этой статье, то есть использую безымянные (anonumous) пайпы. Но в моем случае имеется такая особенность:
мне не известно, сколько байт мне пришлет дочерний процесс. И нет никакого способа узнать, послал он что-то или нет (по крайней мере, я такого способа не знаю). Если на данный момент все байты, переданные дочерним процессом, уже прочитаны, а я делаю еще одну попытку чтения (поскольку мне не известно, все я прочитал или нет), то программа подвисает.

Код


int RedirReadAnswer( char *buf,           //Буфер для приема ответа.
                     long buflen)         //Длина буфера.
{
    unsigned long bread, offset=0;
    OVERLAPPED ovr;
    ovr.hEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
    while(1)
    {
        printf("\nRequest to %i symbols\n", buflen-offset-1);
    //Попытка чтения:
        ReadFile( ParentRead, (void *)(buf+offset), buflen-offset-1, NULL, &ovr);
        int k, maxtry=10;//максимальное число попыток.
        int dT = 1;
   //Ждем:
        for(k = 0; k < maxtry; k++)
        {
            if(GetOverlappedResult(ParentRead, &ovr, &bread, FALSE) == TRUE)
                break;
            WaitForSingleObject(ovr.hEvent, dT); //Ждем dT миллисекунд;
        }
   //Если не прочитали данные за отведенное время
        if(k == maxtry)
        {
            CancelIo(ParentRead);
            printf("/nIO failed/n");
            return offset;
        }
        offset += bread;
        buf[offset] = '\0';
    //
        printf("\nRead %i symbols\n", bread);
    //
        if(offset >= buflen-1)
            return 0;
    }
}

То есть даже использование структуры OVERLAPPED в вызове ф-ции ReadFile не спасает от подвисания. Что с ней, что без нее - одинаково.
Если есть у кого какие соображения - поделитесь, плиз.

Fazil6

Дата 21.3.2008, 17:33 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1653
Регистрация: 3.5.2006
Где: Минск

Репутация: нет
Всего: 60

вот пример рабочий

consoleredirect.h

Код


#ifndef ConsRedirectH
#define ConsRedirectH
//---------------------------------------------------------------------------

#include <string>
#define   OUT_BUFF_SIZE 512

namespace REDIRECTEDSTD
{
    void RedirectStd();

    std::string  ReadAll();
    std::string  ReadStdErr();
    std::string  ReadStdOut();

    const char * ConsoleDfnTitle();

    int GetStdOutWriteEnd();
    int GetStdErrWriteEnd();



};

#endif

impl

Код


//---------------------------------------------------------------------------


#pragma hdrstop

#include "ConsRedirect.h"


#include <windows.h>
#include <stdio.h>
#include <io.h>
#include <fcntl.h>
#include <string>

#include "LastError.h"

//#pragma package(smart_init)

#define   MY_PIPE_SIZE  1024
#define   OUT_BUFF_SIZE 512
#define   READ_FD 0
#define   WRITE_FD 1
#define   BEEP_CHAR 7

char szBuffer[OUT_BUFF_SIZE];

int fdStdErrPipe[2] = {-100,-100};
int fdStdOutPipe[2] = {-100, -100};

class Sincro
{
    CRITICAL_SECTION cs;
public:
    Sincro()
    {
        InitializeCriticalSection(&cs);
        EnterCriticalSection(&cs);
    }

    ~Sincro()
    {
        LeaveCriticalSection(&cs);
        DeleteCriticalSection(&cs);
    }
};

//---------------------------------------------------------------------------

const char * REDIRECTEDSTD::ConsoleDfnTitle()
{
    return  "FOR_HIDE";
}

int REDIRECTEDSTD::GetStdOutWriteEnd()
{
    return   fdStdOutPipe[WRITE_FD];
}
int REDIRECTEDSTD::GetStdErrWriteEnd()
{
     return fdStdErrPipe[WRITE_FD];
}

void REDIRECTEDSTD::RedirectStd()
{

    int fdStdOut;
    int fdStdErr;

    Sincro sinc;

    _pipe(fdStdOutPipe, MY_PIPE_SIZE, _O_BINARY );
    _pipe(fdStdErrPipe, MY_PIPE_SIZE, _O_BINARY );

    fdStdOut = _dup(_fileno(stdout));
    fdStdErr = _dup(_fileno(stderr));

#ifdef __BORLANDC__
    dup2(fdStdOutPipe[WRITE_FD], _fileno(stdout));
    dup2(fdStdErrPipe[WRITE_FD], _fileno(stderr));
#else
    _dup2(fdStdOutPipe[WRITE_FD], _fileno(stdout));
    _dup2(fdStdErrPipe[WRITE_FD], _fileno(stderr));
#endif
//    _close(fdStdOutPipe[WRITE_FD]);
//    _close(fdStdErrPipe[WRITE_FD]);

    _close(fdStdOut);
    _close(fdStdErr);
    SetConsoleTitle(ConsoleDfnTitle());
    HWND h = FindWindow(NULL, ConsoleDfnTitle());
    if(h)
    {
        ShowWindow(h, false);
    }
}

std::string  REDIRECTEDSTD::ReadStdErr()
{
    if(fdStdErrPipe[READ_FD] == -100) return "";
    Sincro sinc;
    szBuffer[0] = 0;
    int nOutRead = 0;

    fflush(stderr);

    if(!_eof(fdStdErrPipe[READ_FD]))
    {
        nOutRead = _read(fdStdErrPipe[READ_FD],
                            szBuffer, OUT_BUFF_SIZE);
        if(nOutRead)
        {
            szBuffer[nOutRead] = 0;
        }
    }

    return  std::string(szBuffer);
}

std::string  REDIRECTEDSTD::ReadStdOut()
{
    if(fdStdOutPipe[READ_FD] == -100) return "";
    Sincro sinc;
    szBuffer[0] = 0;
    int nOutRead = 0;

    fflush(stdout);

    if(!_eof(fdStdOutPipe[READ_FD]))
    {
        nOutRead = _read(fdStdOutPipe[READ_FD],
                            szBuffer, OUT_BUFF_SIZE);
        if(nOutRead)
        {
            szBuffer[nOutRead] = 0;
        }
    }
    return  std::string(szBuffer);
}

std::string REDIRECTEDSTD::ReadAll()
{
    std::string s  = ReadStdErr();
    std::string s1 = ReadStdOut();

    if( !s1.empty() ) s = s + "\n" + s1;
    return s;
}

Это сообщение отредактировал(а) Fazil6 - 21.3.2008, 17:35

korian

Дата 22.3.2008, 04:34 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 651
Регистрация: 8.3.2008
Где: Украина, Харьков

Репутация: 4
Всего: 17

Lotrex,
PeekNamedPipe может помочь, для определения сколько байт в буфере осталось.
или чтение в отдельный поток.

Цитата(Fazil6 @ 21.3.2008, 16:33

)

Код


class Sincro
{
    CRITICAL_SECTION cs;
public:
    Sincro()
    {
        InitializeCriticalSection(&cs);
        EnterCriticalSection(&cs);
    }

    ~Sincro()
    {
        LeaveCriticalSection(&cs);
        DeleteCriticalSection(&cs);
    }
};

так вроде нельзя синхронизировать. надо чтобы был "глобальный" объект CRITICAL_SECTION.

Lotrex

Дата 24.3.2008, 08:05 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 95
Регистрация: 9.2.2006
Где: Казань

Репутация: нет
Всего: 3

Спасиб, я уже на собственном опыте понял, что лучше использовать для моей задачи именованные (named) pipes. За подсказку про PeekNamedPipe - большое спасибо!!! Это очень поможет. Потом, когда доведу до ума код, выложу тут то, что у меня получилось.

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| C/C++: Системное программирование и WinAPI \| Следующая тема »