Форум программистов, компьютерный форум, киберфорум
C/С++ под Linux
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск  
 
 
Рейтинг 4.79/78: Рейтинг темы: голосов - 78, средняя оценка - 4.79
0 / 0 / 0
Регистрация: 25.04.2012
Сообщений: 54

Передача данных между процессами (pipe)

25.04.2012, 19:35. Показов 16284. Ответов 29
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Всем доброго времени суток. Обращаюсь к вам с вопросиком. Передо мной стоит задача написать код, который:
1. Создавай процесс
2. организовывал между нами pipe
3. Передавал информацию от родительского процесса дочернему. Все хорошо, если бы не одно НО...Необходимо использовать ключи:
-i-ввод информации в файл (родителем). Если ключ не указан то стандартный ввод с клавиатуры
-o-вывод информации в выходной файл дочерним процессом
-r-перенаправление потока ошибок в прежде созданный текстовый файл (допустим list.txt)

ключи задаются при запуске программы, т.е. пример ./a.out -i inputfile-здесь используется входной с файл с информацией для передачи дочернему процессу

Начала писать код:
C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
#include....  
........  
int main(int argc, char *argv[]){  
 int input, output,pid  
 int fd[2]  
  
 input=0;  
 output=1;  
 for (i=1;i<argc;i++){  
  if (strcmp(argv[i],"-i")!=0){  
    i++;  
    input=open(argv[i],O_RDONLY);  
  }  
  if  (strcmp(argv[i],"-o")!=0){  
    i++;  
    unmask(0644);  
    output=open(argv[i],J_WRONLY|J_TRUNC|O_SYNC|O_CREAT,0644);  
  }  
  if  (strcmp(argv[i],"-r")!=0) {  
     fd1=open(log.txt,O_WRONLY,1);  
     dup2(fd1,2);  
  }
вот первая часть готова, в ней я проверяю введенный ключ.
Я так полагаю что дальше я создаю pipe, создаю процесс pid=fork и проверяю если pid>0, то что дальше делать????У меня есть переменные input и output нужно их как то использовать в зависимости от того дочернийй или родительский это процесс

ПОМОГИТЕ реализовать этот дальнейший код
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
25.04.2012, 19:35
Ответы с готовыми решениями:

Передача данных дочернему процессу посредством pipe(): иммитация нажатия enter через терминал
Всем привет. Столкнулся с такой проблемой: есть программа, считывающая логин и пароль (последовательно, сначала логин, после ввода запрос...

Переключение между процессами
Здравствуйте! У меня вознкла проблемка с процесами. Стоит такая задачка: Процесс 1 открывает файл, создает процесс 2, посылает...

Обмен данными между процессами
Здравствуйте. Нужно создать три процесса.(fork()). У меня есть два варианта исхода событий: 1. - Родитель (р0) создает потомка(р1),...

29
0 / 0 / 0
Регистрация: 25.04.2012
Сообщений: 54
03.05.2012, 17:48  [ТС]
Студворк — интернет-сервис помощи студентам
Спасибо
0
Эксперт С++
 Аватар для Nameless One
5828 / 3479 / 358
Регистрация: 08.02.2010
Сообщений: 7,448
03.05.2012, 17:59
Все-таки запилил программу:
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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <string.h>
 
#define clean_errno() (errno == 0 ? "None" : strerror(errno))
 
#define check(STREAM, COND, FMT, ...)                            \
    do                                                           \
    {                                                            \
        if(!(COND))                                              \
        {                                                        \
            fprintf(STREAM, "[ERROR] %s:%d (%s): " FMT "\n",     \
                    __FILE__, __LINE__, clean_errno(),           \
                    ##__VA_ARGS__);                              \
            goto error;                                          \
        }                                                        \
    } while(0)
    
void usage(FILE* out)
{
    fputs("Usage: sample [-i IN_FILE] [-o OUT_FILE] [-r ERR_FILE] [-h]\n", out);
}
 
int main(int argc, char* argv[])
{
    int in = STDIN_FILENO, out = STDOUT_FILENO;
    FILE* err = stderr;
 
    int opt;
    int pipefd[2];
    pid_t pid;
    
    while((opt = getopt(argc, argv, ":i:o:r:h")) != -1)
    {
        switch(opt)
        {
        case 'i':
            in = open(optarg, O_RDONLY);
            check(err, in != -1, "%s.", optarg);
            break;
            
        case 'o':
            out = open(optarg, O_WRONLY | O_CREAT | O_TRUNC,
                       S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
            check(err, out != -1, "%s.", optarg);
            break;
            
        case 'r':
            err = fopen(optarg, "a");
            check(stderr, err != NULL, "%s.", optarg);
            break;
            
        case 'h':
            usage(stdout);
            exit(0);
            break;
            
        case ':':
            fprintf(err, "Missing argument for option `%c'.\n", optopt);
            usage(err);
            goto error;
            break;
            
        case '?':
            fprintf(err, "Unrecognized option `%c'.\n", optopt);
            usage(err);
            goto error;
            break;
            
        }
    }
        
    if(optind != argc)
    {
        fprintf(err, "Unexpected parameter: %s.\n", argv[optind]);
        usage(err);
        goto error;
    }
    
    check(err, pipe(pipefd) == 0, "failed to open pipe.");
 
    pid = fork();
 
    check(err, pid != -1, "failed to spawn child process.");
        
    if(pid == 0)                /* child */
    {
        char buf[BUFSIZ];
        ssize_t rd;
        
        check(err, close(pipefd[1]) == 0, "failed to close unused file descriptor.");
 
        while((rd = read(pipefd[0], buf, BUFSIZ)) > 0)
            check(err, write(out, buf, rd) != -1, "failed to write to file/stdout.");
 
        check(err, rd != -1, "failed to read from pipe.");
        check(err, close(pipefd[0]) == 0, "failed to close pipe input.");
    }
    else                        /* parent */
    {
        char buf[BUFSIZ];
        ssize_t rd;
        
        check(err, close(pipefd[0]) == 0, "failed to close unused file descriptor.");
 
        while((rd = read(in, buf, BUFSIZ)) > 0)
            check(err, write(pipefd[1], buf, rd) != -1, "failed to write to pipe.");
 
        check(err, rd != -1, "failed to read from file/stdin.");
        check(err, close(pipefd[1]) == 0, "failed to close pipe output.");
    }
    
    if(out > STDERR_FILENO)
        check(err, close(out) == 0, "failed to close output file.");
    if(in > STDERR_FILENO)
        check(err, close(in) == 0, "failed to close input file.");
    if(err != stderr)
        check(stderr, fclose(err) == 0, "failed to close error file.");
    
    exit(0);
 
 error:
    exit(1);
}
Пример использования:
Bash
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
~/samples/c $ ./sample -h # показать справочное сообщение
Usage: sample [-i IN_FILE] [-o OUT_FILE] [-r ERR_FILE] [-h]
~/samples/c $ ./sample -i main.c -o out.txt -r err.log # ввод из main.c, вывод в out.txt, ошибки в err.log
~/samples/c $ head -n 10 out.txt # вывести первые 10 строк из файла
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <string.h>
 
#define clean_errno() (errno == 0 ? "None" : strerror(errno))
~/samples/c $ cat err.log # ошибок не было
~/samples/c
1
0 / 0 / 0
Регистрация: 25.04.2012
Сообщений: 54
05.05.2012, 18:11  [ТС]
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
int main(int argc, char *argv[]){  
 int input, output,pid  
 int fd[2]  
  
 input=0;  
 output=1;  
 for (i=1;i<argc;i++){  
  if (strcmp(argv[i],"-i")!=0){  
    i++;  
    input=open(argv[i],O_RDONLY);  
  }  
  if  (strcmp(argv[i],"-o")!=0){  
    i++;  
    unmask(0644);  
    output=open(argv[i],J_WRONLY|J_TRUNC|O_SYNC|O_CREAT,0644);  
  }  
  if  (strcmp(argv[i],"-r")!=0) {  
     fd1=open(log.txt,O_WRONLY,1);  
     dup2(fd1,2);  
  }  
  pipe(fd);
  pid=fork();
  if (pid==-1) {
    write(1,"Error\n",10);
    exit(-1);
  }
А вот если я введе с клавиатуры ./a.out -i -i -o то ведь будет ошибка....Как данную ошибку можно обработать в моем данном выше цикле?
0
Эксперт С++
 Аватар для Nameless One
5828 / 3479 / 358
Регистрация: 08.02.2010
Сообщений: 7,448
05.05.2012, 18:22
Цитата Сообщение от Nastya19kiss Посмотреть сообщение
А вот если я введе с клавиатуры ./a.out -i -i -o то ведь будет ошибка....Как данную ошибку можно обработать в моем данном выше цикле?
самый простой способ — это воспользоваться функцией getopt, как в приведенном мной примере. Если же хочешь сделать по-своему, то можно, к примеру, завести переменные-флаги, которые будут индикаторами того, что отдельная опция встретилась или не встретилась. Например:

C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
int inputFlag = 0;
for(i = 1; i < argc; ++i)
{
   if(strcmp(argv[i], "-i") == 0)
   {
      if(inputFlag)
         error("Already got input flag");
      else
      {
         inputFlag = 1;
         input = open(...);
      }
   }
}
Либо модифицировать сам argv.

Кстати, ты неправильно используешь функцию strcmp: она возвращает ноль, когда две строки равны
0
0 / 0 / 0
Регистрация: 25.04.2012
Сообщений: 54
05.05.2012, 18:35  [ТС]
это я уже давно исправила, спасибо. ну я прогу проверяла все работает, только осталось обработчик ошибок сделать

Добавлено через 6 минут
А что делать если файл не введен после ключа или неправильно введен, то как это обработать?
0
Эксперт С++
 Аватар для Nameless One
5828 / 3479 / 358
Регистрация: 08.02.2010
Сообщений: 7,448
05.05.2012, 18:39
Цитата Сообщение от Nameless One Посмотреть сообщение
самый простой способ — это воспользоваться функцией getopt, как в приведенном мной примере
я поторопился: getopt не обрабатывает повторяющиеся ключи, так что нужно флаги самому устанавливать

А что делать если файл не введен после ключа или неправильно введен, то как это обработать?
еще раз: простой способ — использовать getopt. Сложный способ — рассматривать следующий аргумент на предмет того, может ли он быть именем файла, либо это ключ, либо его вообще нет
0
0 / 0 / 0
Регистрация: 25.04.2012
Сообщений: 54
05.05.2012, 19:17  [ТС]
то есть если я буду использовать getopt то ошибочная ситуация с ключами невозможна?
0
Эксперт С++
 Аватар для Nameless One
5828 / 3479 / 358
Регистрация: 08.02.2010
Сообщений: 7,448
06.05.2012, 05:06
Nastya19kiss, возможна, но ее будет гораздо проще отловить. По сути, нужно будет только проверять, что одна и та же опция была не задана дважды
0
0 / 0 / 0
Регистрация: 25.04.2012
Сообщений: 54
10.05.2012, 18:38  [ТС]
Привет!!!Вот в задании у меня сказано передавать данные блоками по 1 КБ а если допустим ключи не указаны и ввести текст который будет больше 1 Кб то он просто будет утерян????Как эту проблему обработать?
0
Эксперт С++
 Аватар для Nameless One
5828 / 3479 / 358
Регистрация: 08.02.2010
Сообщений: 7,448
10.05.2012, 18:40
Nastya19kiss, нет, просто текст будет передан за несколько подходов
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
10.05.2012, 18:40

Семафоры. Работа между процессами
Пишу программу писатель-читатель на posix семафорах. Запускаю первый процесс, получаю на первой итерации w_sem = 0 и r_sem = 1 и процесс...

Обмен данными между процессами с использованием сообщений
Добрый день, форумчане! Помогите, пожалуйста, разобраться с данным видом взаимодействия процессов. Например у меня есть две программы: ...

Вызовы read/write в цикле между процессами
Необходимо реализовать два процесса: родительский считывает N чисел по одному и пишет их потомку, а потомок считывает эти числа и пишет их...

Процессы, общие файлы и синхронизация между процессами
Пишу курсовой, задание такое: Цветами отмечены процессы порожденные основной программой или др процессами, все реализовано, остался...

Передача данных между процессами. Использование каналов
Написать приложение (клиент), которое передает математическое выражение, а второе (сервер) вычисляет его и передает первому его значение.


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
30
Ответ Создать тему
Новые блоги и статьи
Установка ChatGPT (Codex) на Windows без использования Microsoft Store
Fabien159 28.10.2026
Здравствуйте всем читающим! Опишу процесс установки ChatGPT (Codex) на Windows, если по каким-то причинам у вас не получается устанавить его через Microsoft Store. И так: 1. Скачиваем с. . .
Программное добавление префикса в нумерацию документов
Maks 27.10.2026
Реализация из решения ниже выполнена в самописной конфигурации на БСП (помощь начинающему коллеге). Задача: Программно добавить префикс в нумерацию документов. Решение: В модуле объекта. . .
После закрытия оутлука продолжает висеть процесс в диспетчере задач
Maks 27.10.2026
С недавнего времени в продакшене возникла проблема: при закрытии оутлука в диспетчере задач продолжал висеть процесс outlook. exe. Проблема возникла после установки MS Office 2021 LTSC на машинах, под. . .
Baragoz - DPS/HPS бот для WoW 3.3.5a, многоязычный
AmbA 26.10.2026
Хотите ещё ботов? У меня есть один! А я пока отдохну от него. https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=12062&stc=1&d=1793007952 Инструкция внутри. https:/ / youtu. be/ VpfFZSUDGnQ. . .
Особенности gif сгенерированных в Си
russiannick 21.10.2026
Рассмотрим генерацию gif файлов, которые в Си имеют свои особенности. Gif представляет собой графический формат популярный в интернете. Посмотрим на палитру. Gif файл сгенерированный в си отличается. . .
FPS контроллер с анимированными Y-Bot и 3D-звуком miniaudio (Box3D, Recast, BehaviorTree.CPP, ozz-animation, ImGui, OpenGL и SDL3)
8Observer8 18.10.2026
Содержание блога | English Version Полное мультиплатформенное руководство по стартовому проекту с FPS-контроллером игрока, анимированными роботами Y-Bot с 4-слойным блендингом, 3D-физикой Box3D,. . .
Локальный http сервер
Argus19 17.10.2026
Локальный http сервер На работе, на двух локальных компьютерах круглосуточно работают программы опроса приборов с записью в книги Excel,которые раз в сутки записываются на сервер компании. Т. к. . . .
Копировать Windows на новый диск на UEFI
damix 17.10.2026
https:/ / uriesk. wordpress. com/ 2016/ 11/ 01/ move-window-10-to-ssd-on-a-uefi-dualboot-system-with-basic-linux-tools/ TL DR Вставляем диск, а старый подключаем через переходник, грузимся с лайва. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru