diff options
| author | Mattias Andrée <maandree@operamail.com> | 2014-06-14 19:43:37 +0200 |
|---|---|---|
| committer | Mattias Andrée <maandree@operamail.com> | 2014-06-14 19:43:37 +0200 |
| commit | 078303e4e488c1fdb431815f2fff85b7f0597397 (patch) | |
| tree | 4712bcd34e9921e601ae69e7102082ef8cdfe3a1 /src/unified_sysv_ipc.py | |
| parent | fix small errors (diff) | |
| download | cmdipc-078303e4e488c1fdb431815f2fff85b7f0597397.tar.gz cmdipc-078303e4e488c1fdb431815f2fff85b7f0597397.tar.bz2 cmdipc-078303e4e488c1fdb431815f2fff85b7f0597397.tar.xz | |
finish common api for mqueue
Signed-off-by: Mattias Andrée <maandree@operamail.com>
Diffstat (limited to 'src/unified_sysv_ipc.py')
| -rw-r--r-- | src/unified_sysv_ipc.py | 6 |
1 files changed, 3 insertions, 3 deletions
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 |