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

Пример использования fork, запуск команд через system, pipe

19.02.2015, 16:47. Показов 3753. Ответов 0
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Данный код был написан в рамках работы с курсом Unix-систем, решил поделиться, вдруг кому пригодится.

В программе реализовано следующее:

При запуске приложения происходит распараллеливание (средствами fork) на 2 потока.

В первом потоке запускается команда, которая передана в аргументах. Вывод "вовне" закрыт, всё общение этого потока с пользователем идёт через pipe.
Во втором, потоки ввода-вывода перенаправляются в pipe для общения с первым потоком.


Исходный файл (прикрепляю только main.c) можно скачать
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
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
#include <sys/types.h>
#include <fcntl.h>
#include <sys/wait.h>
#include <sys/stat.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <getopt.h>
#include <unistd.h>
#include <string.h>
#include <signal.h>
#include <time.h>
 
void chDie()
{
    dprintf(1, "DONE!\n");
    exit(0);
}
void sigP()
{
    dprintf(1, "DONE :(!\n");
    exit(0);
}
int main (int argc, char **argv) 
{ 
 
    int multiplex = 1;
    char * execTarget = "";
    char * logPath = "";
    
    int c;
    int digit_optind = 0;
    /* Задаём вÑ&#129;е возможные опции */
    static struct option long_options[] = {
        {"logfile", 1, 0, 0},
        {"execute", 1, 0, 0},
        {"multiplex", 2, 0, 0},   
        {0, 0, 0, 0}
    };
    while (1) 
    {
        int this_option_optind = optind ? optind : 1;
        int option_index = 0; 
        c = getopt_long (argc, argv, "abc:d:012", long_options, &option_index);
        if (c == -1)
        {
            break;
        }
        switch(c)
        {
            case 0:                                     //Ð’Ñ&#129;Ñ‘ Ñ&#129;лавно, вÑ&#129;Ñ‘ хорошо.
                if(long_options[option_index].name == "logfile")
                {
                    logPath = optarg;
                }
                else if(long_options[option_index].name == "execute")
                {
                    execTarget = optarg;
                }
                else if(long_options[option_index].name == "multiplex")
                {
                    int mult = (optarg - (int)'0');
                    if((mult == 0) || (mult == 1))
                    {
                        multiplex = mult; 
                    }
                } 
                else
                {
                    printf ("ERROR\n");
                } 
            break;
            case ':':
            break;
            case '?':
            break;   
        }
    }
    /* Ð’Ñ&#129;Ñ‘, обработали опции, теперь надо дейÑ&#129;твовать */
    if(execTarget != "")
    {
        int input[2], output[2], er[2];
        
        if (pipe(input) < 0)
        {
            printf("Can't open pipe! \n");
            exit(-1);
        }
        if (pipe(output) < 0)
        {
            printf("Can't open pipe! \n");
            exit(-1);
        }
        pid_t pID = fork();
        if (pID < 0)
        {
            //TLEN;
            printf("Cannot create child process! \n");
        }
        else if (pID == 0)
        {
            //well, this is child...  
            dup2(output[1], 1);
            dup2(input[0], 0);
            dup2(er[1], 2);
            system(execTarget);
        }
        else
        {
            //parent 
            int result;
            int n;
            char * childsOut;
            char keyboard[1024];
            char tmpStr[1024];
            fd_set readset;
            int bufSize = 64000;
            int bytes;
            char buf[bufSize];
            struct timeval timer;            
            int debugger = 0;
            int logFd;
            if (logPath != "")
            {
                logFd = open(logPath, O_CREAT, 0666);
            }
            else
            {
                logFd = 2;
            }
            if(logFd < 0)
            {
                perror("cannot open log file");
                exit(-1);
            }
            struct sigaction act;
            memset(&act, 0, sizeof(act));
            act.sa_sigaction = &chDie;
            act.sa_flags = SA_SIGINFO;
            if (sigaction(SIGCHLD, &act, NULL) < 0)
            {
        perror ("sigaction");
        return 1;
            }          
            
            n = (output[0] < 0) ? 0 + 1 : output[0] + 1 ;
 
            do
            {
                FD_ZERO(&readset);
                FD_SET(output[0], &readset); 
                FD_SET(0, &readset);
                timer.tv_sec = 1;
                timer.tv_usec = 0;
                result = select(n, &readset, NULL, NULL, &timer);
                if (result == -1)
                {
                    perror("Select Error \n");
                }
                else if (result)
                {
                    //Данные приехали :)
                    if(FD_ISSET(0, &readset))
                    {
                        // ввели Ñ&#129; клавы данные
                        memset(keyboard, 0, 1024);
                        bytes = read(0, &keyboard, 1024);
                        bytes = write(input[1], &keyboard, bytes);   
                        if(strcmp(keyboard, "exit\n") == 0)
                        {
                            exit(0);
                        }
                    }
                    if(FD_ISSET(output[0], &readset))
                    {
                        memset(keyboard, 0, 1024);
                        bytes = read(output[0], &childsOut,  bufSize);
                        dprintf(1, "%d / < 1 ", pID + 1); 
                        write(logFd, "2", strlen("2")); 
                        write(1, &childsOut, bytes);
                    }                        
                }          
                else if (result == 0)
                {
                    // NO_INPUT;
                    
                    time_t now;
                    struct tm *lcltime;
                    now = time ( NULL );
                    lcltime = localtime ( &now );
                    dprintf (logFd, "%d.%d.%d %d:%d:%d NOIO\n",lcltime->tm_mday, lcltime->tm_mon, lcltime->tm_year, lcltime->tm_hour, lcltime->tm_min,  lcltime->tm_sec );
                }
                else
                {
                    //error? 
                }
            } 
            while (1);
        }
    }
    else
    {
        printf("There is no pie for you.\n");
    }
    exit (0);
}
0
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
19.02.2015, 16:47
Ответы с готовыми решениями:

Создание новых процессов, запуск внешних программ fork(), system
Задача запустить внешнее приложение и получить его ID, для того чтобы в дальнейшем отследить живо оно или нет. Почему-то получаю _всегда_...

Pipe, fork, shared memory
Доброго времени суток. Помогите пожалуйста написать программу: Процесс читает с клавиатуры и пишет в пайп, его ребенок читает из этого...

Быстрая сортировка fork и pipe
помогите переделать данный код в быструю сортировку #include &lt;stdio.h&gt; #include &lt;unistd.h&gt; #include &lt;sys/types.h&gt; #include...

0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
19.02.2015, 16:47
Помогаю со студенческими работами здесь

Сортировка строки, используя fork() и pipe
Дали задание используя системный вызов fork() и pipe. Решить какую-то задачу. Я решил сделать &quot;сортировку пузырьком&quot;. Вот код...

Пустые строки в файле с использованием pipe, fork, exec, dup
Всем привет, для написания сабжа задумал использовать такую команду : grep -e '^$' argv | wc --lines По факту, мне нужно ручками...

Распараллелить задачу, ипользуя при системный вызов fork (), и трубу pipe
Дали задание распараллелить какую то задачу, ипользуя при этом системный вызов fork(), и трубу pipe. К примеру, что б потомке считалась...

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

Перенаправление ввода внутри команд fork() и execpv()
Пишу аналог интерпретатора bash на си (вперемешку с С++). Делаю перенаправление ввода-вывода по следующей схеме: считывается строка, в ней...


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

Или воспользуйтесь поиском по форуму:
1
Ответ Создать тему
Новые блоги и статьи
Очистка реквизитов документа при копировании
Maks 09.04.2026
Алгоритм из решения ниже применим как для типовых, так и для нетиповых документов на самых различных конфигурациях. Задача: при копировании документа очищать определенные реквизиты и табличную. . .
модель ЗдравоСохранения 8. Подготовка к разному выполнению заданий
anaschu 08.04.2026
https:/ / github. com/ shumilovas/ med2. git main ветка * содержимое блока дэлэй из старой модели теперь внутри зайца новой модели 8ATzM_2aurI
Блокировка документа от изменений, если он открыт у другого пользователя
Maks 08.04.2026
Алгоритм из решения ниже реализован на примере нетипового документа, разработанного в конфигурации КА2. Задача: запретить редактирование документа, если он открыт у другого пользователя. / / . . .
Система безопасности+живучести для сервера-слоя интернета (сети). Двойная привязка.
Hrethgir 08.04.2026
Далее были размышления о системе безопасности. Сообщения с наклонным текстом - мои. А как нам будет можно проверить, что ссылка наша, а не подделана хулиганами, которая выбросит на другую ветку и. . .
Модель ЗдрввоСохранения 7: больше работников, больше ресурсов.
anaschu 08.04.2026
работников и заданий может быть сколько угодно, но настроено всё так, что используется пока что только 20% kYBz3eJf3jQ
Дальние перспективы сервера - слоя сети с космологическим дизайном интефейса карты и логики.
Hrethgir 07.04.2026
Дальнейшее ближайшее планирование вывело к размышлениям над дальними перспективами. И вот тут может быть даже будут нужны оценки специалистов, так как в дальних перспективах всё может очень сильно. . .
Горе от ума
kumehtar 07.04.2026
Эта мне ментальная установка, что вот прямо сейчас, мол, мне для полного счастья не хватает (нужное вписать), и когда я этого достигну - тогда и полный кайф. Одна из самых сильных ловушек на пути. . . .
Использование значений реквизитов справочника в документе, с определенными условиями и правами
Maks 07.04.2026
1. Контроль срока действия договора Алгоритм из решения ниже реализован на примере нетипового документа "ЗаявкаНаРаботу", разработанного в конфигурации КА2. Задача: уведомлять пользователя, если. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru