POSIX Message Queues library for PicoLisp
16 Sep 2020You can get it on GitHub.
POSIX Message Queues provide a dependency-free mechanism for processes to exchange data in the form of messages.
This library makes it simple to embed support for POSIX Message Queues in PicoLisp applications running on Linux.
Requirements
- PicoLisp 64-bit
v17.12
tov20.7.16
, orpil21
- Linux with kernel
v3.5+
- Kernel POSIX Message Queues support
- POSIX Realtime Extensions library (librt.so)
Getting Started
The first step is to run the unit tests: make check
If those fail, jump to the TUTORIALS section to perform the initial setup and and system check.
If all works well, then your system is ready to use this library.
Quick Start
The code below illustrates how to use the queue for sending and receiving a message.
Example Code
(load "mqueue.l") # load the library
(let Fd (pmq-open "/myQ" (list O_RDWR O_CREAT)) # create a read/write queue named "/myQ"
(pmq-send Fd "Hello World") # send the message "Hello World"
(pmq-receive Fd) # receive the message
(pmq-close Fd) # close the queue
(pmq-unlink "/myQ") ) # remove the queue
Example Output
Note: Verbose output is enabled by default and can be disabled with (off *PMQ_verbose)
.
[2020-09-17T03:37:15] Opened queue: Name='/myqueue', FD=3
[2020-09-17T03:37:15] Send: String='Hello World', Priority=0, FD=3
[2020-09-17T03:37:15] Get attributes: Flags=0, Maxmsg=10, Msgsize=8192, Curmsgs=1, FD=3
[2020-09-17T03:37:15] Receive: String='Hello World' (12 Bytes), FD=3
[2020-09-17T03:37:15] Closed queue: FD=3
[2020-09-17T03:37:15] Unlinked queue: Name='/myqueue'
-> 0
Documentation
Additional usage and reference documentation can be found in docs/