Создать взаимодействие клиент-сервер с помощью Канала FIFO

go · Регистрация: 16.04.2009

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

Хочу создать взаимодействие клиент-сервер с помощью Канала FIFO. Но не могу открыть файл. Решил, что ошибка не у меня. Вот нашел код на не без известном сайте. Но он не хочет работать. Не открывается файл.

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
#include <stdio.h>
#include <unistd.h>
 
#include <sys/types.h>
 
#include <sys/stat.h>
 
#include <fcntl.h>
 
#include <signal.h>
 
static volatile sig_atomic_t sflag;
 
static sigset_t signal_new, signal_old, signal_leer;
 
 
 
static void sigfunc(int sig_nr)
 
{
 
  fprintf(stderr, "SIGPIPE вызывает завершение программы\n");
 
  exit(0);
 
}
 
 
 
void signal_pipe(void)
 
{
 
  if(signal(SIGPIPE, sigfunc) == SIG_ERR)
 
  {
 
    fprintf(stderr, "Невозможно получить сигнал SIGPIPE\n");
 
    exit(0);
 
  }
 
  /*Удаляем все сигналы из множества сигналов*/
 
  sigemptyset(&signal_leer);
 
  sigemptyset(&signal_new);
 
  sigaddset(&signal_new, SIGPIPE);
 
  /*Устанавливаем signal_new и сохраняем его*/
 
  /* теперь маской сигналов будет signal_old*/
 
  if(sigprocmask(SIG_UNBLOCK, &signal_new,
 
     &signal_old) < 0)
 
  exit(0);
 
}
 
 
 
int main()
 
{
 
  int r_fifo, w_fifo; /*дескрипторы FIFO*/
 
  char buffer[]="Текстовая строка для fifo\n";
 
  char buf[100];
 
  pid_t pid;
 
  signal_pipe();
 
  unlink("/tmp/fifo0001.1");
 
  /*Создаем FIFO*/
 
  if((mkfifo("/tmp/fifo0001.1", O_RDWR)) == -1)
 
  {
 
    fprintf(stderr, "Невозможно создать fifo\n");
 
    exit(0);
 
  }
 
  pid=fork();
 
  if(pid == -1)
 
    { perror("fork"); exit(0);}
 
  else if(pid > 0) /*Родитель читает из FIFO*/
 
  {
 
    if (( r_fifo=open("/tmp/fifo0001.1", O_RDONLY))<0)
 
      { perror("r_fifo open"); exit(0); }
 
    /*Ждем окончания потомка*/
 
    while(wait(NULL)!=pid);
 
     /*Читаем из FIFO*/
 
    read(r_fifo, &buf, sizeof(buf));
 
    printf("%s\n",buf);
 
    close(r_fifo);
 
  }
 
  else /*Потомок записывает в FIFO*/
 
  {
 
    if((w_fifo=open("/tmp/fifo0001.1", O_WRONLY))<0)
 
      { perror("w_fifo open"); exit(0); }
 
    /*Записываем в FIFO*/
 
    write(w_fifo, buffer, strlen(buffer));
 
    close(w_fifo); /*EOF*/
 
    exit(0);
 
  }
 
  return 0;
 
}

@niXman · 09.05.2012, 17:36

в какой строке происходит ошибка?
что в errno ?

go · 09.05.2012, 17:50 **[ТС]**

Bash
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
andrey@andrey-VirtualBox:~$ gcc ex.c
ex.c: In function ‘sigfunc’:
ex.c:24: warning: incompatible implicit declaration of built-in function ‘exit’
ex.c: In function ‘signal_pipe’:
ex.c:40: warning: incompatible implicit declaration of built-in function ‘exit’
ex.c:60: warning: incompatible implicit declaration of built-in function ‘exit’
ex.c: In function ‘main’:
ex.c:90: warning: incompatible implicit declaration of built-in function ‘exit’
ex.c:98: warning: incompatible implicit declaration of built-in function ‘exit’
ex.c:106: warning: incompatible implicit declaration of built-in function ‘exit’
ex.c:128: warning: incompatible implicit declaration of built-in function ‘exit’
ex.c:132: warning: incompatible implicit declaration of built-in function ‘strlen’
ex.c:136: warning: incompatible implicit declaration of built-in function ‘exit’
andrey@andrey-VirtualBox:~$ ./a.out
r_fifo open: Permission denied
andrey@andrey-VirtualBox:~$ w_fifo open: Permission denied
 
andrey@andrey-VirtualBox:~$

Добавлено через 4 минуты
Очевидно, что все предупреждения возникли из-за того, что авторы кода забыли указать два хидера

C
1
2
#include <stdlib.h>
#include <string.h>

Но ошибка при выполнении почему?

@niXman · 09.05.2012, 17:58

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

ошибка при выполнении почему?

говорят же, почти по русски: Permission denied

у юзера есть права создавать в темпе? измени на домашний каталог.

go · 09.05.2012, 18:16 **[ТС]**

niXman, вот такие теперь ошибки

Bash
1
2
3
andrey@andrey-VirtualBox:~$ gcc ex.c
andrey@andrey-VirtualBox:~$ ./a.out
Невозможно создать fifo

при таком коде

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
#include <stdio.h>
#include <unistd.h>
 
#include <sys/types.h>
 
#include <sys/stat.h>
 
#include <fcntl.h>
 
#include <signal.h>
 
#include <string.h>
#include <stdlib.h>
 
static volatile sig_atomic_t sflag;
 
static sigset_t signal_new, signal_old, signal_leer;
 
 
 
static void sigfunc(int sig_nr)
 
{
 
  fprintf(stderr, "SIGPIPE вызывает завершение программы\n");
 
  exit(0);
 
}
 
 
 
void signal_pipe(void)
 
{
 
  if(signal(SIGPIPE, sigfunc) == SIG_ERR)
 
  {
 
    fprintf(stderr, "Невозможно получить сигнал SIGPIPE\n");
 
    exit(0);
 
  }
 
  /*Удаляем все сигналы из множества сигналов*/
 
  sigemptyset(&signal_leer);
 
  sigemptyset(&signal_new);
 
  sigaddset(&signal_new, SIGPIPE);
 
  /*Устанавливаем signal_new и сохраняем его*/
 
  /* теперь маской сигналов будет signal_old*/
 
  if(sigprocmask(SIG_UNBLOCK, &signal_new,
 
     &signal_old) < 0)
 
  exit(0);
 
}
 
 
 
int main()
 
{
 
  int r_fifo, w_fifo; /*дескрипторы FIFO*/
 
  char buffer[]="Текстовая строка для fifo\n";
 
  char buf[100];
 
  pid_t pid;
 
  signal_pipe();
#define DIRR "~/fifo0001.1"
  unlink(DIRR);
 
  /*Создаем FIFO*/
 
  if((mkfifo(DIRR, O_RDWR)) == -1)
 
  {
 
    fprintf(stderr, "Невозможно создать fifo\n");
 
    exit(0);
 
  }
 
  pid=fork();
 
  if(pid == -1)
 
    { perror("fork"); exit(0);}
 
  else if(pid > 0) /*Родитель читает из FIFO*/
 
  {
 
    if (( r_fifo=open(DIRR, O_RDONLY))<0)
 
      { perror("r_fifo open"); exit(0); }
 
    /*Ждем окончания потомка*/
 
    while(wait(NULL)!=pid);
 
     /*Читаем из FIFO*/
 
    read(r_fifo, &buf, sizeof(buf));
 
    printf("%s\n",buf);
 
    close(r_fifo);
 
  }
 
  else /*Потомок записывает в FIFO*/
 
  {
 
    if((w_fifo=open(DIRR, O_WRONLY))<0)
 
      { perror("w_fifo open"); exit(0); }
 
    /*Записываем в FIFO*/
 
    write(w_fifo, buffer, strlen(buffer));
 
    close(w_fifo); /*EOF*/
 
    exit(0);
 
  }
 
  return 0;
 
}

Добавлено через 7 минут
Вот такой каталог

C
1
#define DIRR "~/fifo0001.1"

@niXman · 09.05.2012, 18:20

errno кто показывать будет? я не телепат.

go · 09.05.2012, 18:53 **[ТС]**

Ладно с этим. Почему программа зависает на 95-97 строке

Bash
1
2
3
4
root@andrey-VirtualBox:/home/andrey/mydev# ./a.out
qwe
^C
root@andrey-VirtualBox:/home/andrey/mydev#

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
#include <stdio.h>
#include <unistd.h>
 
#include <sys/types.h>
 
#include <sys/stat.h>
 
#include <fcntl.h>
 
#include <signal.h>
#include <string.h>
#include <stdlib.h>
 
static volatile sig_atomic_t sflag;
 
static sigset_t signal_new, signal_old, signal_leer;
 
 
 
static void sigfunc(int sig_nr)
 
{
 
  fprintf(stderr, "SIGPIPE вызывает завершение программы\n");
 
  exit(0);
 
}
 
 
 
void signal_pipe(void)
 
{
 
  if(signal(SIGPIPE, sigfunc) == SIG_ERR)
 
  {
 
    fprintf(stderr, "Невозможно получить сигнал SIGPIPE\n");
 
    exit(0);
 
  }
 
  /*Удаляем все сигналы из множества сигналов*/
 
  sigemptyset(&signal_leer);
 
  sigemptyset(&signal_new);
 
  sigaddset(&signal_new, SIGPIPE);
 
  /*Устанавливаем signal_new и сохраняем его*/
 
  /* теперь маской сигналов будет signal_old*/
 
  if(sigprocmask(SIG_UNBLOCK, &signal_new,
 
     &signal_old) < 0)
 
  exit(0);
 
}
 
 
 
int main()
 
{
 
  int r_fifo, w_fifo; /*дескрипторы FIFO*/
 
  char buffer[]="Текстовая строка для fifo\n";
 
  char buf[100];
 
  pid_t pid;
 
  signal_pipe();
 
   unlink("/tmp/fifo0001.1");
 
  /*Создаем FIFO*/
 
  if((mkfifo("/tmp/fifo0001.1", O_RDWR)) == -1)
 
  {
 
    fprintf(stderr, "Невозможно создать fifo\n");
 
    exit(0);
 
  } printf("qwe\n");
if (( r_fifo=open("/tmp/fifo0001.1", O_RDONLY))<0)
 
      { perror("r_fifo open"); exit(0); }printf("qwerty\n");
 
  pid=fork();
 
  if(pid == -1)
 
    { perror("fork"); exit(0);}
 
  else if(pid > 0) /*Родитель читает из FIFO*/
 
  {
 
    if (( r_fifo=open("/tmp/fifo0001.1", O_RDONLY))<0)
 
      { perror("r_fifo open"); exit(0); }
 
    /*Ждем окончания потомка*/
 
    while(wait(NULL)!=pid);
 
     /*Читаем из FIFO*/
 
    read(r_fifo, &buf, sizeof(buf));
 
    printf("%s\n",buf);
 
    close(r_fifo);
 
  }
 
  else /*Потомок записывает в FIFO*/
 
  {
printf("doe\n");
                    if((w_fifo=open("/tmp/fifo0001.1", O_WRONLY))<0)
 
      { perror("w_fifo open"); exit(0); }printf("posle\n");
    
    /*Записываем в FIFO*/
 
    write(w_fifo, buffer, strlen(buffer));
 
    close(w_fifo); /*EOF*/
 
    exit(0);
 
  }
 
  return 0;
 
}

@niXman · 09.05.2012, 19:02

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

if (( r_fifo=open("/tmp/fifo0001.1", O_RDONLY))<0)

тут?

в мане же сказано, что при открытии на чтение, вторая сторона должна открыть этот же пайп на запись. потому твой код и ждет, когда вторая сторона откроет этот же пайп на запись.

go · 09.05.2012, 22:14 **[ТС]**

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

#define DIRR "~/fifo0001.1"

niXman, какой каталог указать?

Добавлено через 1 минуту

Bash
1
2
3
4
andrey@andrey-VirtualBox:~/mydev$ ./a.out
Невозможно создать fifo
errno = 2
andrey@andrey-VirtualBox:~/mydev$

Добавлено через 27 минут
Вот код

CODE

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
#include <stdio.h>
#include <unistd.h>
 
#include <sys/types.h>
 
#include <sys/stat.h>
 
#include <fcntl.h>
 
#include <signal.h>
 
#include <string.h>
#include <stdlib.h>
 
static volatile sig_atomic_t sflag;
 
static sigset_t signal_new, signal_old, signal_leer;
 
 
 
static void sigfunc(int sig_nr)
 
{
 
  fprintf(stderr, "SIGPIPE вызывает завершение программы\n");
 
  exit(0);
 
}
 
 
 
void signal_pipe(void)
 
{
 
  if(signal(SIGPIPE, sigfunc) == SIG_ERR)
 
  {
 
    fprintf(stderr, "Невозможно получить сигнал SIGPIPE\n");
 
    exit(0);
 
  }
 
  /*Удаляем все сигналы из множества сигналов*/
 
  sigemptyset(&signal_leer);
 
  sigemptyset(&signal_new);
 
  sigaddset(&signal_new, SIGPIPE);
 
  /*Устанавливаем signal_new и сохраняем его*/
 
  /* теперь маской сигналов будет signal_old*/
 
  if(sigprocmask(SIG_UNBLOCK, &signal_new,
 
     &signal_old) < 0)
 
  exit(0);
 
}
 
 
 
int main()
 
{
 
  int r_fifo, w_fifo; /*дескрипторы FIFO*/
 
  char buffer[]="Текстовая строка для fifo\n";
 
  char buf[100];
 
  pid_t pid;
 
  signal_pipe();
#define DIRR "~/fifo0001.1"
  unlink(DIRR);
 
  /*Создаем FIFO*/
 
  if((mkfifo(DIRR, O_RDWR)) == -1)
 
  {
 
    fprintf(stderr, "Невозможно создать fifo\n");
 
    exit(0);
 
  }
 
  pid=fork();
 
  if(pid == -1)
 
    { perror("fork"); exit(0);}
 
  else if(pid > 0) /*Родитель читает из FIFO*/
 
  {
 
    if (( r_fifo=open(DIRR, O_RDONLY))<0)
 
      { perror("r_fifo open"); exit(0); }
 
    /*Ждем окончания потомка*/
 
    while(wait(NULL)!=pid);
 
     /*Читаем из FIFO*/
 
    read(r_fifo, &buf, sizeof(buf));
 
    printf("%s\n",buf);
 
    close(r_fifo);
 
  }
 
  else /*Потомок записывает в FIFO*/
 
  {
 
    if((w_fifo=open(DIRR, O_WRONLY))<0)
 
      { perror("w_fifo open"); exit(0); }
 
    /*Записываем в FIFO*/
 
    write(w_fifo, buffer, strlen(buffer));
 
    close(w_fifo); /*EOF*/
 
    exit(0);
 
  }
 
  return 0;
 
}

Сам файл

C
1
    #define DIRR "~/fifo0001.1"

Добавлено через 2 часа 6 минут
А если такой путь

C
1
#define DIRR "/home/andrey/fifo0001.1"

то пишет

Bash
1
2
3
4
5
andrey@andrey-VirtualBox:~/mydev$ ./a.out
r_fifo open: Permission denied
andrey@andrey-VirtualBox:~/mydev$ w_fifo open: Permission denied
 
andrey@andrey-VirtualBox:~/mydev$

Если запускать под рутом, то работает и для тмп папки.

Добавлено через 2 минуты

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

Если запускать под рутом, то работает и для тмп папки.

Но это для меня не выход.

g_u_e_s_t · 10.05.2012, 09:40

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

#define DIRR "~/fifo0001.1"

Вы подумайте, что такое "~/" и кто это обрабатывает.

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

r_fifo open: Permission denied

что такое O_RDWR в контексте mode_t? (hint: обычно = 2).

go · 10.05.2012, 15:40 **[ТС]**

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

ы подумайте, что такое "~/" и кто это обрабатывает.

Домашняя папка, и это очевидно. Я же не под рутом запускаю

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

что такое O_RDWR в контексте mode_t? (hint: обычно = 2).

Что Вы хотели этим сказать? Как нужно тогда?

g_u_e_s_t · 10.05.2012, 16:03

1. Думайте дальше. hint: _единственный_ символ которого не бывает в именах файла \0.
Еще подсказка: почему cat *.txt выведет все файлы, а open("*.txt", ) откроет только \*.txt?

2. Прочитайте man mkfifo, обратите внимание на 2й параметр этой ф-ции. Затем прочитате man open (обычно флаги для mode_t описаны там).

go · 10.05.2012, 22:09 **[ТС]**

g_u_e_s_t, ну так правильный вариант в студию. Хватит загадками говорить. niXman с этим каждый день сталкивается. И то не знает как надо FIFO канал создавать.

g_u_e_s_t · 10.05.2012, 23:22

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

Хватит загадками говорить.

Вы реально прочитали указанные маны и не понимаете, что тильду в $HOME преобразует шелл, а 2й аргумент mkfifo() задает права доступа к создаваемому файлу или прикидываетесь?
mkfifo(FIFO_PATH, S_IRUSR | S_IWGRP | S_IRGRP | S_IWGRP); /* 0660 & ~umask(0) */

Новые блоги и статьи Все статьи Все блоги /
PhpStorm 2025.3: WSL Terminal всегда стартует в ~ and_y87 14.12.2025 PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .	Как объединить две одинаковые БД Access с разными данными VikBal 11.12.2025 Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.	Новый ноутбук volvo 07.12.2025 Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro	Музыка, написанная Искусственным Интеллектом volvo 04.12.2025 Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .	От async/await к виртуальным потокам в Python IndentationError 23.11.2025 Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов Argus19 22.11.2025 Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .	Сколько Государство потратило денег на меня, обеспечивая инсулином. Programma_Boinc 20.11.2025 Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .	Ломающие изменения в C#.NStar Alpha Etyuhibosecyu 20.11.2025 Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .	Мысли в слух kumehtar 18.11.2025 Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .	Создание Single Page Application на фреймах krapotkin 16.11.2025 Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .

@niXman 3211 / 1459 / 74 Регистрация: 09.08.2009 Сообщений: 3,441 Записей в блоге: 2
	09.05.2012, 17:36
	в какой строке происходит ошибка? что в errno ? 0

@niXman 3211 / 1459 / 74 Регистрация: 09.08.2009 Сообщений: 3,441 Записей в блоге: 2
	09.05.2012, 18:20
	errno кто показывать будет? я не телепат. 1

g_u_e_s_t 1259 / 650 / 44 Регистрация: 06.02.2011 Сообщений: 1,654
	10.05.2012, 16:03
	1. Думайте дальше. hint: _единственный_ символ которого не бывает в именах файла \0. Еще подсказка: почему cat .txt выведет все файлы, а open(".txt", ) откроет только \*.txt? 2. Прочитайте man mkfifo, обратите внимание на 2й параметр этой ф-ции. Затем прочитате man open (обычно флаги для mode_t описаны там). 1

go 3646 / 1378 / 243 Регистрация: 16.04.2009 Сообщений: 4,526
	10.05.2012, 22:09 [ТС]
	g_u_e_s_t, ну так правильный вариант в студию. Хватит загадками говорить. niXman с этим каждый день сталкивается. И то не знает как надо FIFO канал создавать. 0