About

mruby-chan is an easy to use library for InterProcess Communication (IPC).

The library provides a channel that can help facilitate communication between mruby processes who have a parent <=> child relationship. A channel lock is provided by lockf(3) and a file in Chan.tmpdir to protect against race conditions that can happen when multiple processes access the same channel at the same time.

Examples

Introduction

chan

The chan method creates a channel with a given serializer.
The two default serializers are pure, and json:

ch = chan(:pure)
ch = chan(:json)

Serialization

A channel that will communicate purely in strings (in other words: without serialization) is available as chan(:pure). Otherwise json or a custom serializer that implements dumpand load methods can be given instead:

ch = chan(:pure)

Nonblocking

By default a channel is blocking, but it can also be non-blocking and work well with mruby-task:

ch = chan(:pure).tap(&:nonblock!)

The following exceptions can be raised:

• Chan::WaitReadable when a read would block.
• Chan::WaitWritable when a write would block.

Read operations

#read

The ch.read method performs a blocking read by default. The example performs a read that blocks until the parent process writes to the channel. In nonblocking mode, ch.read raises Chan::WaitReadable when no complete message is ready:

ch = chan(:pure)
fork do
  print "Received: ", ch.read, "\n"
end
sleep(1)
puts "Sending..."
ch.write("hello")
ch.close
Process.wait
## Received: hello

Write operations

#write

The ch.write method performs a blocking write by default. A write can block when a lock is held by another process. In nonblocking mode, ch.write raises Chan::WaitWritable when the pipe cannot accept data immediately:

ch = chan(:pure)
fork do
  puts ch.read
end
ch.write("hello from parent")
ch.close
Process.wait
## hello from parent

Lock

File

The default lock for a channel is a file lock. The locking mechanism is implemented with the lockf function from the C standard library:

ch = chan(:pure, lock: :file)
5.times.map do
  fork do
    ch.write("data")
  end
end.each { Process.wait(_1) }

Null

The null lock is the same as using no lock at all. The null lock is implemented as a collection of no-op operations:

ch = chan(:pure, lock: :null)
fork do
  ch.write("data")
end
Process.wait

Install

Add to your mruby build config:

conf.gem github: "0x1eef/mruby-chan", branch: "main"

Sources

• github.com/0x1eef

License

BSD Zero Clause
See LICENSE