mqueue

1熱度

1回答

當我使用檢查消息隊列的QSIZE「貓的/ dev/mqueue中/ myQueue中」前後做則mq_send（）/則mq_receive（後）似乎被留在隊列中一些殘餘的字節在mq_recieve（）之後。我的小的測試程序是如下： #include <stdio.h> #include <stdlib.h> #include <mqueue.h> #define MSG_LEN 8192

0熱度

1回答

你能像在Mqueue一樣閱讀camunda的消息嗎？

我們可以像在Mqueue一樣閱讀camunda的消息嗎？ camunda可以替代Apache駱駝路由框架嗎？

1熱度

1回答

POSIX消息隊列文件夾

我一直在POSIX消息隊列遠程工作幾天。現在我想在我自己的PC中執行它，但是我發現沒有/ dev/mqueue文件夾創建隊列;這意味着我不知道它們在哪裏（是否有），所以我不能訪問那裏刪除他們，以防萬一我的程序意外結束。我注意到由於'zombie'隊列，我的代碼沒有正常運行，但我無法像從信號量和共享內存（託管在/ dev/shm）中那樣將它們從該文件夾中刪除。我懷疑可以用下面的命令完成一些關於這

1熱度

1回答

使用mqqueue將數據讀入緩衝區時遇到問題

我正在使用mqueue在線程之間進行通信，而且我在傳遞對象時遇到問題。 mq_send和mq_receive以char*作爲對象的參數。我以如下方式使用它們。 foo* foo = new foo(); foo->set_id(3); mq_send(myQueue, (char*)foo, 1024, 1); 然後 char* buffer; while(true) {

0熱度

2回答

mqueue：消息太長

當我運行以下程序時，我總是出現錯誤消息「Message too long」。爲什麼？這是源： #define NAME "/q" #define SIZE 16 void main() { mqd_t mq; char buffer[SIZE+1]; struct mq_attr attr; attr.mq_flags = 0; attr.mq_maxmsg = 10; a

3熱度

1回答

無法創建超過5 Mqueues

我有一個創建mqueues的問題，即我的系統似乎阻止我創建超過5個mqueue，即使/ proc/sys/fs/mqueue/queues_max設置爲256我在運行Atom E680T的Q7模塊系統上運行Ubuntu 13.04服務器，我還運行一個自定義編譯的內核（3.8.0）來減少內核大小並添加缺少的watchdog和i2c訪問默認。我已經檢查，以確保只有5 mqueue正在使用通過安裝mq

2熱度

1回答

linux mq_open忽略mq_msgsize屬性

所有的，過去認爲我是理智的，現在不太確定。我想創建一個消息隊列，其mq_msgsize屬性不是8192，這似乎是默認值。我在下面附上我的代碼 - 它有一些printf顯示值。如果你能指出我做錯了什麼，我會永遠感激。 bool Subscriber::Subscribe(void) { mqd_t qid; bool brv = false; msg_topic_t

0熱度

1回答

在系統中查找並關閉/取消鏈接消息隊列

我有一臺SLES-11計算機，在這臺計算機上，我不是構建廣泛使用消息隊列的軟件代碼的根。由於一些錯誤，現在有一個錯誤： mq_open: Too many open files 我使用的命令ipcs -a，但我看不到我的消息隊列。所以我不能使用ipcrm命令。所以，現在我根本無法使用機器。有沒有辦法在系統中查找消息隊列（由我打開）並關閉它們？信息：我的系統中沒有/dev/mqueue。我也不

8熱度

1回答

無法創建超過10個mqueue

我正在使用一個python模塊來包裝posix實時擴展以獲取MessageQueues。這是報告OSError: This process already has the maximum number of files open 我看着MQ限制和RLIMIT並檢查它們都設定非常高的前Python代碼 #!/usr/bin env python import uuid import posix

2熱度

5回答

Pthread win32 libraray，PTHREAD_PROCESS_SHARED不支持

我使用pthread win32庫來實現mqueue。但是當它運行到下面的代碼時，它拋出＃40錯誤應該是ENOSYS，意味着系統不支持。 pthread_mutexattr_setpshared(&mattr, PTHREAD_PROCESS_SHARED); i = pthread_mutex_init(&mqhdr->mqh_lock, &mattr); pthread_mutexatt