Описание тега mqueue

Вопросы с тегом
1 ответ

Плохой дескриптор файла в posix mqueue

Кто-нибудь может помочь мне решить проблему плохого дескриптора файла в posix mqueue. Я пытаюсь прочитать пакеты сокетов RAW и поместить их в mqueue. #include<stdlib.h> #include<stdio.h> #include<string.h> #include<sys/stat.h&gt…
12 дек '14 в 13:15
1 ответ

Не может создать более 10 mqueues

Я использую модуль python, который упаковывает расширения реального времени posix для получения MessageQueues. Это код питона #!/usr/bin env python import uuid import posix_ipc import time def spawn(): return posix_ipc.MessageQueue("/%s" % uuid.uuid…
31 окт '16 в 12:52
1 ответ

mqueue получает неверные данные

Ниже приведен код для задания по переработке сельхозпродукции. Основное внимание уделяется комментариям: "ЗДЕСЬ $ или всегда одинаковые / разные". Это моя проблема: когда рабочий процесс выполняет свою работу и отправляет данные ответа фермеру, ферм…
23 сен '16 в 19:36
1 ответ

Папка очередей сообщений POSIX

Я работал удаленно с очередями сообщений POSIX в течение нескольких дней. Теперь я хочу сделать это на своем ПК, но я обнаружил, что нет папок /dev/mqueue, в которых создаются очереди; Это означает, что я не знаю, где они находятся (есть или нет), п…
15 дек '15 в 15:29
1 ответ

Система QNX зависает при завершении работы с помощью phshutdown

При выключении QNX нейтрино с помощью phshutdown(либо перезагрузка, либо выключение) система зависает при уничтожении очередей сообщений (mqueue). Сообщение, отображаемое на экране: Отключение поставщиков услуг (mqueue) Что может быть причиной этого?
29 ноя '12 в 09:58
1 ответ

Прохождение структур в сообщениях mqueue

Я пытаюсь прочитать пакет сокета IP/RAW с его параметрами (такими как символьный указатель на IP-пакет и его размер), поместить его в mqueue в режиме WRONLY и получить те же параметры из очереди в режиме RDONLY. Я использую структуры для сообщения (…
15 дек '14 в 09:26
0 ответов

Как перенести последние удаленные изменения в удаленное хранилище (при использовании mqueues)

Книга hg рекомендует следующий рабочий процесс для обновления патчей mqueue после обновления удаленного репозитория. Ссылка: hg qpush --all # QSave is now depricated (according to hg qsave --help). It appears to have been # depricated since at least…
22 апр '15 в 15:09
2 ответа

mqueue: сообщение слишком длинное

Когда я запускаю следующую программу, у меня всегда появляется сообщение об ошибке "Сообщение слишком длинное". Зачем? это источник: #define NAME "/q" #define SIZE 16 void main() { mqd_t mq; char buffer[SIZE+1]; struct mq_attr attr; attr.mq_flags = …
01 сен '13 в 10:43
0 ответов

Как ждать, пока создание mqueue станет доступным?

Я должен написать программу, которая интенсивно использует очереди из mqueue.h. Проблема в том, что он может легко достичь /proc/sys/fs/mqueue/queues_max предел, который я не могу изменить. Можно ли подождать, пока создание новой очереди станет дост…
18 янв '18 в 23:16
1 ответ

Найти и закрыть / отменить связь между сообщениями в системе

У меня есть машина SLES-11, на которой я не являюсь корнем, где я создаю программный код, который широко использует очереди сообщений. Из-за некоторых ошибок, теперь есть ошибка: mq_open: Too many open files Я использую команду ipcs -a но я не вижу …
26 мар '14 в 19:38
1 ответ

Отправка void* объекта через очередь сообщений [linux]

Итак, я реализовал свою собственную библиотеку mpi (упрощенную версию), и мне нужно отправлять / получать между процессами некоторые данные. MPI_Send выглядит следующим образом (void *buf,int count, данные типа данных и т. Д...). Так что это означае…
10 апр '13 в 16:14
1 ответ

mq_receive возвращает EAGAIN при наличии данных

У меня есть mqueue, в котором есть 2 сообщения, но вызов mq_receive не будет тянуть данные. У меня нет опыта работы с этой очередью сообщений, так что прости меня за невежество. Я полагаю, что отправляющая сторона работает нормально, так как эхо "фа…
16 май '14 в 13:15
0 ответов

URL-адрес конечной точки JMS отсутствует

Мы обновили сервисы с оси до jax-ws, и все веб-сервисы работают нормально, кроме одного, который является SOAP поверх JMS. мы сделали изменения кода в обработчике для URL. Ось (существующая): в BasicHandler String url = (String) messageContext.getPr…
18 июн '18 в 09:23
0 ответов

Обработка сбоев mq_open после mq_unlink

Я пишу клиент-серверный процесс в Suse Linux, используя для связи очереди сообщений Posix, аналогично принятому ответу в разделе " Как использовать mqueue в программе ac в системе на основе Linux? ". Когда сервер умирает, он выполняет mq_close и mq_…
30 янв '14 в 19:28
1 ответ

linux mq_open игнорирует атрибут mq_msgsize

Все, раньше думали, что я в здравом уме, теперь не так уверены.Я пытаюсь создать очередь сообщений с атрибутом mq_msgsize ДРУГОГО, чем 8192, который, по-видимому, используется по умолчанию. Я приложил свой код ниже - в нем есть несколько printf, пок…
25 сен '12 в 18:57
1 ответ

Невозможно создать более 5 Mqueues

У меня проблема с созданием mqueues, а именно моя система блокирует мне создание более 5 mqueues, хотя для /proc/sys/fs/mqueue/queues_max установлено значение 256. Я использую сервер Ubuntu 13.04 на модульная система Q7 с Atom E680T, я также использ…
29 май '13 в 14:18
0 ответов

mq_receive: размер буфера

Что -то я не смог увидеть? Мой проект падает каждый раз, когда доходит до этой функции: #define SMW 29 float smw getWert(&smw, SMW, rsq,rrq) SMW - это номер порта (канала), я хочу получить "smw" int MainWindow::getWert(float *erg, int kanal, mqd…
19 сен '14 в 00:59
1 ответ

Проблема при чтении данных в буфер с помощью mqqueue

Я использую mqueue для связи между потоками, и у меня возникают проблемы при передаче объектов. mq_send а также mq_receive взять char* в качестве параметра для объекта. Я использую их следующим образом. foo* foo = new foo(); foo->set_id(3); mq_se…
05 дек '16 в 16:28
0 ответов

Невозможно создать многопоточность после увеличения размера сообщения mqueue

В моем программном обеспечении C я создал 10 потоков (многопоточность) и записывал сообщения в очередь сообщений. Я также создал еще 1 поток для мониторинга очереди и вывода данных из другого конца очереди. Он работал нормально, но размер сообщения …
29 дек '16 в 15:42
0 ответов

Настройка ceedling с помощью mqueue.h и -lrt

Я пишу модульные тесты для проекта на C, используя комбинацию Cellling / Unity / CMock от Throw The Switch в качестве основы для модульного тестирования. Я столкнулся с интересной дилеммой, где я использую mqueue.h в одном из моих модульных тестов. …
30 сен '16 в 19:40