Pipes not working

@addedie · Регистрация: 07.09.2019

Студворк — интернет-сервис помощи студентам

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
    HANDLE g_hChildStd_IN_Rd;
    HANDLE g_hChildStd_IN_Wr;
    HANDLE g_hChildStd_OUT_Rd;
    HANDLE g_hChildStd_OUT_Wr;
    HANDLE hNamedPipe=0;
 
    SECURITY_ATTRIBUTES saAttr;
 
    saAttr.nLength = sizeof(SECURITY_ATTRIBUTES);
    saAttr.bInheritHandle = TRUE;
    saAttr.lpSecurityDescriptor = NULL;
 
 
    if (!CreatePipe(&g_hChildStd_OUT_Rd, &g_hChildStd_OUT_Wr, &saAttr, 0))
        ExitProcess(-1);
 
 
    if (!CreatePipe(&g_hChildStd_IN_Rd, &g_hChildStd_IN_Wr, &saAttr, 0))
        ExitProcess(-2);
 
    
    HANDLE hHeap = HeapCreate(0, 0x10000, 0);
    LPSTR szCmdline = HeapAlloc(hHeap, HEAP_ZERO_MEMORY, 256);
    lstrcpy(szCmdline, "C:\\Windows\\System32\\cmd.exe");
    
 
    PROCESS_INFORMATION piProcInfo = { 0 };
    STARTUPINFO siStartInfo = { 0 };
 
    siStartInfo.cb = sizeof(STARTUPINFO);
    siStartInfo.hStdError = g_hChildStd_OUT_Wr;
    siStartInfo.hStdOutput = g_hChildStd_OUT_Wr;
    siStartInfo.hStdInput = g_hChildStd_IN_Rd;
    siStartInfo.dwFlags |= STARTF_USESTDHANDLES;
    SECURITY_ATTRIBUTES sa;
 
    if (!CreateProcess(NULL, szCmdline, &sa, NULL, TRUE, 0, NULL, NULL, &siStartInfo, &piProcInfo)) {
        MessageBox(0, szCmdline, szCmdline, 0);
        ExitProcess(-3);
    }
    else
    {
 
        CloseHandle(piProcInfo.hProcess);
        CloseHandle(piProcInfo.hThread);
    }
    hNamedPipe = CreateFileA(szCmdline, GENERIC_READ,
        0,
        NULL,
        OPEN_EXISTING,
        FILE_ATTRIBUTE_READONLY,
        NULL);
 
    if (hNamedPipe == INVALID_HANDLE_VALUE) {
        MessageBox(0, szCmdline, szCmdline, 0);
        HeapDestroy(hHeap);
        ExitProcess(-4);
    }
    char   szBuf[BUFSIZE];
 
    DWORD  cbRead; DWORD  cbWritten;
 
    HANDLE hParentStdOut = GetStdHandle(STD_OUTPUT_HANDLE);
 
    ReadFile(hNamedPipe, szBuf, sizeof(szBuf), &cbRead, NULL);
    if (cbRead > 0)return -5;
    while (TRUE)
    {
        MessageBox(0, szBuf, szBuf, 0);
        WriteFile(hParentStdOut, szBuf, strlen(szBuf) + 1, &cbWritten, NULL);
        ReadFile(hNamedPipe, szBuf, strlen(szBuf), &cbRead, NULL);
    }
    HeapDestroy(hHeap);
    return 0;

выходит с кодом "-4" что я нетак делаю?

@addedie · 05.10.2019, 12:18 **[ТС]**

опять ошибки на этот раз очевидно я намудрил с кучей или с пайпами, вот код

C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
// PipesLib.cpp : Определяет функции для статической библиотеки.
//
 
#include "pch.h"
#include "PipeLib.h"
 
 
#define BUFSIZE 4096
 
// TODO: Это пример библиотечной функции.
void WINAPI fnPipesLib()
{
    HANDLE g_hChildStd_IN_Rd;
    HANDLE g_hChildStd_IN_Wr;
    HANDLE g_hChildStd_OUT_Rd;
    HANDLE g_hChildStd_OUT_Wr;
    HANDLE hNamedPipe = 0;
 
    SECURITY_ATTRIBUTES saAttr;
 
    saAttr.nLength = sizeof(SECURITY_ATTRIBUTES);
    saAttr.bInheritHandle = TRUE;
    saAttr.lpSecurityDescriptor = NULL;
 
 
    if (!CreatePipe(&g_hChildStd_OUT_Rd, &g_hChildStd_OUT_Wr, &saAttr, 0))
        ExitProcess(-1);
 
 
    if (!CreatePipe(&g_hChildStd_IN_Rd, &g_hChildStd_IN_Wr, &saAttr, 0))
        ExitProcess(-2);
 
 
    HANDLE hHeap = HeapCreate(0, 0x10000, 0);
    LPSTR szCmdline = (LPSTR*)HeapAlloc(hHeap, HEAP_ZERO_MEMORY, 256);
    lstrcpy(szCmdline, "C:\\Windows\\System32\\cmd.exe");
 
 
    PROCESS_INFORMATION piProcInfo = { 0 };
    STARTUPINFO siStartInfo = { 0 };
 
    siStartInfo.cb = sizeof(STARTUPINFO);
    siStartInfo.hStdError = g_hChildStd_OUT_Wr;
    siStartInfo.hStdOutput = g_hChildStd_OUT_Wr;
    siStartInfo.hStdInput = g_hChildStd_IN_Rd;
    siStartInfo.dwFlags |= STARTF_USESTDHANDLES;
    SECURITY_ATTRIBUTES sa;
 
    if (!CreateProcess(NULL, szCmdline, &sa, NULL, TRUE, 0, NULL, NULL, &siStartInfo, &piProcInfo)) {
        MessageBox(0, szCmdline, szCmdline, 0);
        ExitProcess(-3);
    }
    else
    {
 
        CloseHandle(piProcInfo.hProcess);
        CloseHandle(piProcInfo.hThread);
    }
    char   szBuf[BUFSIZE];
 
    DWORD  cbRead; DWORD  cbWritten;
 
    HANDLE hParentStdOut = GetStdHandle(STD_OUTPUT_HANDLE);
 
    ReadFile(g_hChildStd_IN_Rd, szBuf, strlen(szBuf), &cbRead, NULL);
    if (cbRead > 0)ExitProcess(-5);
    while (TRUE)
    {
        //MessageBox(0, szBuf, szBuf, 0);
        WriteFile(g_hChildStd_IN_Rd, szBuf, strlen(szBuf) + 1, &cbWritten, NULL);
        ReadFile(g_hChildStd_OUT_Wr, szBuf, strlen(szBuf), &cbRead, NULL);
    }
    HeapDestroy(hHeap);
    return;
}

выходит с кодом -3 неможет создать процесс или еще чего непонятно, может CreateProcess в данном случае недолжен возвращать значение отличное от нуля

Добавлено через 16 минут
попробовал вот так

C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
    PROCESS_INFORMATION piProcInfo;
    STARTUPINFO siStartInfo;
    ZeroMemory(&siStartInfo, sizeof(STARTUPINFO));
    siStartInfo.cb = sizeof(STARTUPINFO);
    siStartInfo.hStdError = g_hChildStd_OUT_Wr;
    siStartInfo.hStdOutput = g_hChildStd_OUT_Wr;
    siStartInfo.hStdInput = g_hChildStd_IN_Rd;
    siStartInfo.dwFlags |= STARTF_USESTDHANDLES;
    SECURITY_ATTRIBUTES sa;
 
    if (!CreateProcess(NULL, szCmdline, /*&sa*/NULL, NULL, TRUE, 0, NULL, NULL, &siStartInfo, &piProcInfo)) {
        MessageBox(0, szCmdline, szCmdline, 0);
        ExitProcess(-3);
    }
    else
    {
 
        CloseHandle(piProcInfo.hProcess);
        CloseHandle(piProcInfo.hThread);
    }
    char   szBuf[BUFSIZE] = { 0 };
 
    DWORD  cbRead; DWORD  cbWritten;
 
    HANDLE hParentStdOut = GetStdHandle(STD_OUTPUT_HANDLE);
 
    ReadFile(g_hChildStd_IN_Rd, szBuf, strlen(szBuf), &cbRead, NULL);
    if (cbRead > 0)ExitProcess(-5);
    else MessageBox(0, "ALert", szBuf, 0);
    while (TRUE)
    {
        //MessageBox(0, szBuf, szBuf, 0);
        WriteFile(g_hChildStd_IN_Rd, szBuf, strlen(szBuf) + 1, &cbWritten, NULL);
        ReadFile(g_hChildStd_OUT_Wr, szBuf, strlen(szBuf), &cbRead, NULL);
    }
    HeapDestroy(hHeap);
    return;

но консоль висит пустая и ничего непоказывается,

Добавлено через 31 минуту
немного переделал и заработало уже лучше,но недоконца

C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
    char   szBuf[BUFSIZE] = { 0 };
 
    DWORD  cbRead; DWORD  cbWritten;
 
    HANDLE hParentStdOut = GetStdHandle(STD_OUTPUT_HANDLE);
 
    ReadFile(g_hChildStd_OUT_Rd, szBuf, sizeof(szBuf), &cbRead, NULL);
    if (cbRead == 0)ExitProcess(-5);
    else MessageBox(0, szBuf, "ALert", 0);
    while (TRUE)
    {
        //MessageBox(0, szBuf, szBuf, 0);
        WriteFile(g_hChildStd_IN_Rd, "dir\r\n", 5 + 1, &cbWritten, NULL);
        ReadFile(g_hChildStd_OUT_Wr, szBuf, sizeof(szBuf), &cbRead, NULL);
        MessageBox(0, szBuf, "ALert", 0);
    }
    HeapDestroy(hHeap);
    return;

выводит один и тотже месаджбокс с строкой из стандартного приглашения вввода [Microsoft Version.....] вот такое, но все остальное опускается и несрабатывает команда dir

Добавлено через 2 минуты
всё разобрался вот так надо

C
1
2
3
4
5
6
7
8
9
10
11
12
    ReadFile(g_hChildStd_OUT_Rd, szBuf, sizeof(szBuf), &cbRead, NULL);
    if (cbRead == 0)ExitProcess(-5);
    else MessageBox(0, szBuf, "ALert", 0);
    while (TRUE)
    {
        //MessageBox(0, szBuf, szBuf, 0);
        WriteFile(g_hChildStd_IN_Wr, "dir\r\n", 5 + 1, &cbWritten, NULL);
        ReadFile(g_hChildStd_OUT_Rd, szBuf, sizeof(szBuf), &cbRead, NULL);
        MessageBox(0, szBuf, "ALert", 0);
    }
    HeapDestroy(hHeap);
    return;

дальше кодировку меняем на codepage 866 или 1251

@addedie · 06.10.2019, 21:06 **[ТС]**

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

C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
    
    WSADATA wsadata;
    SOCKET shellsock, sendsock;
    SOCKADDR_IN sin;
    HANDLE hPipeRead1, hPipeWrite1, hPipeRead2, hPipeWrite2;
    char szBuffer[4096], szCmdPath[MAX_PATH];
    int i;
    DWORD lpNumberOfBytesRead;
    SECURITY_ATTRIBUTES secu =
    {
        (DWORD)sizeof(SECURITY_ATTRIBUTES), NULL, TRUE
    };
    STARTUPINFO sInfo;
    PROCESS_INFORMATION pInfo;
    WSAStartup(MAKEWORD(2, 2), &wsadata);
    sin.sin_family = AF_INET;
    sin.sin_addr.s_addr = 0;
    sin.sin_port = htons(port);
    i = sizeof(sin);
    shellsock = socket(AF_INET, SOCK_STREAM, 0);
    bind(shellsock, (SOCKADDR*)& sin, sizeof(sin));
    listen(shellsock, 0);
    sendsock = accept(shellsock, (SOCKADDR*)& sin, &i);
    if (sendsock == INVALID_SOCKET) ExitProcess(0);
    CreatePipe(&hPipeRead1, &hPipeWrite1, &secu, 0);
    CreatePipe(&hPipeRead2, &hPipeWrite2, &secu, 0);
    GetEnvironmentVariable("ComSpec", szCmdPath, sizeof(szCmdPath));
    memset(&sInfo, 0, sizeof(sInfo));
    memset(&pInfo, 0, sizeof(pInfo));
    sInfo.cb = sizeof(STARTUPINFO);
    sInfo.dwFlags = STARTF_USESHOWWINDOW + STARTF_USESTDHANDLES;
    sInfo.wShowWindow = SW_HIDE;
    sInfo.hStdInput = hPipeRead2;
    sInfo.hStdOutput = hPipeWrite1;
    sInfo.hStdError = hPipeWrite1;
    CreateProcess(NULL, szCmdPath, &secu, &secu, TRUE, 0, NULL, NULL, &sInfo, &pInfo);
    memset(szBuffer, 0, sizeof(szBuffer));
    while (sendsock != SOCKET_ERROR)
    {
        PeekNamedPipe(hPipeRead1, NULL, NULL, NULL, &lpNumberOfBytesRead, NULL);
        while (lpNumberOfBytesRead)
        {
            if(ReadFile(hPipeRead1, szBuffer, sizeof(szBuffer), &lpNumberOfBytesRead, NULL))
            {
                send(sendsock, szBuffer, lpNumberOfBytesRead, 0);
                PeekNamedPipe(hPipeRead1, NULL, NULL, NULL, &lpNumberOfBytesRead, NULL);
                break;
            }
        }
        memset(szBuffer, 0, sizeof(szBuffer));
        i = recv(sendsock, szBuffer, sizeof(szBuffer), 0);
        if(i>0)
        {
            WriteFile(hPipeWrite2, szBuffer, i, &lpNumberOfBytesRead, 0);
            i=0;
            memset(szBuffer, 0, sizeof(szBuffer));
        }
        else continue;
    }
    closesocket(sendsock);
    closesocket(shellsock);
    TerminateProcess(pInfo.hProcess, 0);
    ExitProcess(0);
    return;

@oleg-m1973 · 07.10.2019, 09:07

Сообщение от addedie

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

Которое соединение?

Сообщение от addedie

while (sendsock != SOCKET_ERROR)

Здесь ты сравниваешь номер соединения с кодом ошибки, это немного разные вещи.
Здесь, наверное надо while (i != SOCKET_ERROR)

Новые блоги и статьи Все статьи Все блоги /
Знаете, от чего появляется стресс? kumehtar 15.07.2026 Стресс появляется оттого, что вы, зная как поступить правильно, делаете наоборот. Ларри Уингет	Нас бьют, а мы крепчаем? Какая чушь! kumehtar 15.07.2026 Вот это вот бытующее мнение, что человек меняется только под действием проблем, всегда считал вредоносным. Поверь, от проблем у людей появляются не изменения, а нервное расстройство и ПТСР. А. . .	сукцессия 29. Переход от одних деревьев на другие делать более или менее вероятностным? anaschu 12.07.2026 Насколько смена типов микоризы — исключительное событие в двухвековой сукцессии? Оценка вероятности в пространстве параметров В текущей версии модели успешно реализован ключевой механизм. . .	сукцессия 27. Думаю, как переделывать уже написанную статью с планами на сукцессию. anaschu 12.07.2026 Анализ соответствия модели требованиям Реализованные компоненты: Механизм закисления почвы через протонную помпу Конкуренция между типами микориз pH как триггер сукцессии C/ P соотношение. . .
Сукцессия 26. Мат модель создана. anaschu 12.07.2026 Модель смены растительных сукцессий посредством управления грибами работает внутри небольшой ячейки почвы, восстанавливающейся после пожара, где ненадолго бывшее царство хвойных снова захватили. . .	Решил проблему с ошибкой пагинации сообщений с сервера на алгоритме обхода дерева "Эстафета хвоста". Hrethgir 12.07.2026 Проблема была в том, что удалялась именно новая кнопка, а не старая. Ни один ИИ не обнаружил это, а сам я смог только когда с работой стало попроще и когда заставил работать будущее автономное. . .	сукцессия 25. Хронология ошибок anaschu 12.07.2026 # От 50-тонного гриба до устойчивого леса: хроника ошибок при построении модели вековой сукцессии микоризы ## О чём эта статья В процессе построения ОДУ-модели (система дифференциальных. . .	сукцессия 24. Промежуточное общее описание модели anaschu 12.07.2026 Хендофф: модель АМ→ЭКМ сукцессии микоризы (ризосфера, 50 лет) Содержание проекта Симуляция вековой (50 лет) экологической сукцессии в почве леса Основные участники: АМ-гриб, ЭКМ-гриб,. . .