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

Очередь сообщений posix

26.02.2016, 17:12. Показов 3104. Ответов 2
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
как известно для создания новой очереди сообщений существует вызов
mq_open(qmd_t *qds,o_flag,file_mode,struct mq_attr *attr)
при этом o_flag должен включать флаг 0_CREAT,
для открытия существующей очереди тот же вызов, но без флага o_creat
Правильно ли я понимаю, если пытаться открыть не существующую еще очередь mq_open должен вернуть -1, а не дескриптор очереди? Почему тогда следующий код работает?
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
#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <mqueue.h>
#include <string.h>
#include <sys/wait.h>
#include <stdlib.h>
#include <fcntl.h>
#include <time.h>
#define mqname "/mqnasdwadsd"
 
unsigned int prio = 1;
 
struct mq_attr attr;        
mqd_t msg;
struct timespec abs_timeout;
 
int main ()
{
    printf("прогон очереди сообщений\n");
    
    pid_t p;
    p = fork();
    if (p==0)
    {
        sleep(5);
        char str[] = "stroka";
        attr.mq_maxmsg = 10;//максимальное количество сообщений в очереди
        attr.mq_msgsize =100; //максимальный размер сообщений
        attr.mq_flags = 0;//флаг - 0 или O_NONBLOCK
        attr.mq_curmsgs = 0;//текущее сообщение
        
        msg = mq_open(mqname,O_CREAT|O_RDWR,0777,&attr);
        int i;long int n;
        for (i=0;i<10;i++){
            n=mq_send(msg,str,strlen(str),prio);
            printf("error send===%ld\n",n);}
        mq_close(msg);
        printf("сообщение передано в очередь\n");
        exit(0);
    }
    else if (p>0)
    {
        printf("прием сообдения в родительском процессе\n");
        
        msg = mq_open(mqname,O_RDONLY,0777,NULL);
        printf("ZNACHENIE msg:=%d\n",(int)msg);
        char buffer[100];size_t n,bufsize=100;
        abs_timeout.tv_sec=10;
        abs_timeout.tv_nsec=0;
        while (n=mq_timedreceive(msg,buffer,bufsize,&prio,&abs_timeout)>0)
            printf("принятая строка:%d\t%s\n",n,buffer);
        printf("завершение работы и закрытие очереди сообщений\n");
        mq_close(msg);
        mq_unlink(mqname);
        wait(NULL);
    }
return 0;
}
Кликните здесь для просмотра всего текста
прогон очереди сообщений
прием сообдения в родительском процессе
ZNACHENIE msg:=3
принятая строка:1 stroka
принятая строка:1 stroka
принятая строка:1 stroka
принятая строка:1 stroka
принятая строка:1 stroka
принятая строка:1 stroka
принятая строка:1 stroka
принятая строка:1 stroka
принятая строка:1 stroka
принятая строка:1 stroka
завершение работы и закрытие очереди сообщений
error send===0
error send===0
error send===0
error send===0
error send===0
error send===0
error send===0
error send===0
error send===0
error send===0
сообщение передано в очередь


Добавлено через 11 минут
вопрос снят
0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
26.02.2016, 17:12
Ответы с готовыми решениями:

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

Очередь сообщений
Здравствуйте. Изучаю межпроцессорное взаимодействие, наткнулся на проблему: имеются 3 программы, первая читает цифру с консоли, 2 или 3...

Очередь сообщений
В очередь сообщений необходимо поместить сообщение, содержащее список файлов из текущего каталога. Как лучше всего извлечь эту инфу? Все,...

2
курлык-курлык
 Аватар для Max Patsy
87 / 96 / 8
Регистрация: 26.11.2009
Сообщений: 396
Записей в блоге: 1
09.03.2016, 11:56
Почему снят? Пишите как вы решили проблему, может пригодится кому.
0
4 / 4 / 2
Регистрация: 13.11.2012
Сообщений: 253
10.03.2016, 15:01  [ТС]
да, на самом деле я тоже не люблю подобного, когда находишь такой-же или похожий вопрос на форуме, который интересовал, и вопрошающий потом пишет - решил, тема закрыта...
тут все оказалось просто - ошибка в коде, после форка дочерний процесс засыпает, очередь при этом создается в дочернем процессе, родительский же в это время, пока потомок спит, безуспешно пытается открыть несуществующую очередь сообщений и завершается, а потомок после сна создает очередь и не удаляет его. Соотвественно при повторном запуске родитель во время сна потомка уже успешно открывают созданную ранее при запуске очередь и считывает оттуда данные и удаляет ее. При последующем запуске программа опять не сработает.
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
10.03.2016, 15:01
Помогаю со студенческими работами здесь

очередь сообщений
Помогите, пожалуйста, написать программу на Си. Клиент отправляет сообщения через сокеты или SysV (или POSIX) message queue, сервер...

Потоки и очередь сообщений
Здравствуйте, форумчане. Есть необходимость в вашей помощи, натолкнуть на истину так сказать) В общем постановка задачи такая: есть...

Очередь всплывающих сообщений
Мне необходимо информировать пользователя, если произошло какое-то событие. Для этого написал что-то вроде генерации модального окна и...

Очередь сообщений mouse_event
LRESULT CALLBACK WndProc(HWND hwnd,UINT iMsg,WPARAM wParam,LPARAM lParam) { HDC hdc; PAINTSTRUCT ps; static int ccc=0; ...

Как очистить очередь сообщений на VB?
Есть долгоиграющий процесс. Пока он ... течет, злобный юзверь давит клаву. Как мне потом все эти мессаги выкинуть из очереди?


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

Или воспользуйтесь поиском по форуму:
3
Ответ Создать тему
Новые блоги и статьи
Midnight Chicago Blues
kumehtar 24.03.2026
Такой Midnight Chicago Blues, знаешь?. . Когда вечерние улицы становятся ночными, а ты не можешь уснуть. Ты идёшь в любимый старый бар, и бармен наливает тебе виски. Ты смотришь на пролетающие. . .
Контроль уникальности заводского номера - вариант №2
Maks 24.03.2026
В отличие от предыдущего варианта добавлено прерывание циклов, также добавлены новые переменные для сохранения контекста ошибки перед прерыванием цикла: Процедура ПередЗаписью(Отказ, РежимЗаписи,. . .
SDL3 для Desktop (MinGW): Вывод текста со шрифтом TTF с помощью библиотеки SDL3_ttf на Си и C++
8Observer8 24.03.2026
Содержание блога Финальные проекты на Си и на C++: finish-text-sdl3-c. zip finish-text-sdl3-cpp. zip
Жизнь в неопределённости
kumehtar 23.03.2026
Жизнь — это постоянное существование в неопределённости. Например, даже если у тебя есть список дел, невозможно дойти до точки, где всё окончательно завершено и больше ничего не осталось. В принципе,. . .
Модель здравоСохранения: работники работают быстрее после её введения.
anaschu 23.03.2026
geJalZw1fLo Корпорация до введения программа здравоохранения имела много невыполненных работниками заданий, после введения программы количество заданий выросло. Но на выплатах по больничным это. . .
Контроль уникальности заводского номера - вариант №1
Maks 23.03.2026
Алгоритм контроля уникальности заводского (или серийного) номера на примере документа выдачи шин для спецтехники с табличной частью в КА2. Данные берутся из регистра сведений, по которому настроено. . .
Хочу заставить корпорации вкладываться в здоровье сотрудников: делаю мат модель здравосохранения
anaschu 23.03.2026
e7EYtONaj8Y Z4Tv2zpXVVo https:/ / github. com/ shumilovas/ med2. git
Программный отбор элементов справочника по группе
Maks 22.03.2026
Установка программного отбора элементов справочника "Номенклатура" из модуля формы документа в КА2. В качестве фильтра для отбора справочника служит группа номенклатуры. Отбор по наименованию. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru