From 078303e4e488c1fdb431815f2fff85b7f0597397 Mon Sep 17 00:00:00 2001 From: Mattias Andrée Date: Sat, 14 Jun 2014 19:43:37 +0200 Subject: finish common api for mqueue MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Mattias Andrée --- src/unified_sysv_ipc.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/unified_sysv_ipc.py') diff --git a/src/unified_sysv_ipc.py b/src/unified_sysv_ipc.py index f8738fa..538cb99 100644 --- a/src/unified_sysv_ipc.py +++ b/src/unified_sysv_ipc.py @@ -53,14 +53,14 @@ class SharedMemory(sysv_ipc.SharedMemory): pass class MessageQueue(sysv_ipc.MessageQueue): - def __init__(self, *args, **kwargs): - sysv_ipc.MessageQueue.__init__(self, *args, **kwargs) + def __init__(self, key, flags = 0, mode = 0o600, max_messages = 1, max_message_size = 2048): + sysv_ipc.MessageQueue.__init__(self, key, flags, mode, max_messages * max_message_size) self.send_ = sysv_ipc.MessageQueue.send self.recv_ = sysv_ipc.MessageQueue.receive def send(self, message, timeout = None, type = 1): self.send_(self, message, (timeout is None) or (timeout != 0), type) def receive(self, timeout = None, type = 1): - self.recv_(self, (timeout is None) or (timeout != 0), type) + return self.recv_(self, (timeout is None) or (timeout != 0), type) def close(self): pass -- cgit v1.2.3-70-g09d2