shared-block-ring
A single-consumer single-producer queue on a block device
README
A simple on-disk fixed length queue in the style of the
Xen shared-memory-ring.
In particular the producer and consumer APIs allow clients to control
exactly when data is exposed to the consumer and removed from the queue.
Example usage
First create a "block device"-- any file will do:
dd if=/dev/zero of=test.raw bs=10240 count=1
Then initialise the ring in the file:
./main.native create
Then start two shells, in one run:
./main.native produce
and in the other
./main.native consume
The producer takes input from stdin and puts it onto the ring, and the consumer takes entries from the ring and prints them to stdout.
Install
- Published
-
16 Apr 2022
- Maintainers
-
Sources
shared-block-ring-3.0.1.tbz
sha256=cf2ad61fbbf598f2aa6cb85fbea2e554a0a1fdaaadb0c8161eccbaa1910f3b83
sha512=274c9edaf7cc9bec72afd50f366bdc7287e354485649b5c29a9c4441356e222592573b31e2b5e3e28d98253d6303a77b8c353a3345d2664e5795ae35075f9b9c
Dependencies
ppx_sexp_conv
>= "v0.10.0"
ounit2
with-test
mirage-time
>= "2.0.1"
mirage-clock-unix
with-test
mirage-clock
>= "3.0.0"
mirage-block-unix
>= "2.13.0"
mirage-block
>= "3.0.0"
io-page
>= "2.4.0"
dune
>= "2.7.0"
cstruct
>= "6.0.0"
cmdliner
>= "1.1.0"
bisect_ppx
dev & >= "2.5.0"
ocaml
>= "4.06.0"
Reverse Dependencies
message-switch
>= "1.4.0"