chickadee » dbus

dbus

Overview

This is a binding for libdbus 1.x. D-Bus is a popular IPC (inter-process communication) protocol which is often used between system components (for example hald informs applications when new hardware becomes available, gpsd informs apps when the location has changed, or an application requests gsmd to place a phone call).

Goals & status

GoalAchieved?
send signalsyes
call methods in other processes, and get the return valuesyes
call methods in other processes asynchronously, and the return values come back to a callback later
register a procedure as a handler which will be called when a signal is receivedyes
register a procedure as a method which can be called from another processyes
assign a path to a TinyClos object and map applicable generic functions as D-Bus methods
create proxy methods matching remote methodsyes
create proxy objects matching remote objects (so that all the remote object's applicable methods are made into local proxy methods)
discover services locallyyes
discover services on nearby machinesimpossible with dbus-daemon as-is
discover methods and signals provided by servicesXML only so far
registered methods and signal-handlers are automatically included in the Introspectable interface implementation
user code to do any of the above should be minimal: abstract away the orthogonal extra steps (open a connection, start a polling thread, etc.)yes
support all D-Bus data types for method parameters and return values

Author

Shawn Rutledge

Repository

https://github.com/ec1oud/dbus-egg

Requirements

libdbus and its headers

License

libdbus has historically had a GPL license. Later they switched to AFL / GPL dual license. This egg is released under the MIT license, which is compatible with AFL.

Version

As of version 0.96, it seems to be more or less working, but the interface should not be considered "frozen" yet.

Terminology

bus
The aggregator and dispatcher of messages between processes. The usual choices are system bus, session bus or an app-specific bus. This egg uses the session bus by default. It is the same bus used by desktop session services, like KDE components for example. Accessing the system bus requires special permission. An app-specific bus does not promote application interoperability. So that leaves the session bus as generally being the most appropriate.
bus name
A unique identifier for a D-Bus client. Every D-Bus client is automatically assigned a bus name. These consist of a colon character ':' followed by some numbers. You can see these in the D-Bus traffic in the output of dbus-monitor. D-Bus clients that want to listen for method calls can request a second bus name, a so-called well-known bus name, which is a name by which other D-Bus clients can refer to them. Well-known bus names are what you use in the 'service' field of a method call.
service
A well-known bus name giving the destination of a method call. Conventionally, these look like reversed domain names. Signals do not use services.
path
A D-Bus-exposed API can be conceptually organized into a hierarchy. Paths index into this hierarchy with notation familiarly derived from file and URL paths, where path components are separated by slashes '/'. The program might map path components to actual objects in memory, but this is not required. The default path, when not given, is "/".
interface
a partitioned set of methods which is being offered, like a Java interface or an abstract class. An interface is technically optional when registering a method or signal handler, but this egg currently requires it.
member name
also called method name, or the name of the signal or message.
signal
a one-to-many notification from one process to any others which happen to be listening for that particular notification. A signal message does not include a service because it does not have a specific destination. Signals are one way; there is no explicit reply from the receivers.
method call
a one-to-one message between D-Bus clients. The caller can pass arguments, and the handler sends a method return message back with the result.
method return
the message type of the response to a method call.
method
a scheme function to be invoked when a particular method call message is received. Its result will be sent back to the calling client as a method return.
message
the D-Bus-protocol representation of a signal or a method call passing across the D-Bus connection between two processes.

And this egg introduces one more:

context
a combination of bus, service, interface and path. That and a method name will get you a unique identifier for a callback (AKA method or message handler).

This egg does not yet fully support making methods, signal handlers, and interfaces discoverable by other clients.

D-Bus in general

Use dbus-monitor to see all the D-Bus traffic (on the session bus by default).

A many-to-many "bus" exists as a running dbus-daemon process. Each application which is interested in using that bus connects to the daemon via Unix-domain sockets. The daemon collects incoming messages and dispatches them to the connected processes which have expressed interest in receiving particular categories of messages. Usually there is one running instance of dbus-daemon for the system bus, and one running instance for each session bus: each user who is logged in and running a desktop session is typically running one instance of the daemon.

A one-to-one application-specific bus can bypass the daemon: one app connects directly to the other. But this is not a flexible service-oriented approach to IPC, so it is not usually done, and this egg does not support it.

Data types

D-Bus protocol (unlike XML, for example) allows sending real native datatypes across the connection. In fact it provides more data types than does Chicken. So when you pass some parameters along with a method call, these are the default conversions:

Chicken data typeD-Bus data type
fixnumDBUS_TYPE_INT32
flonumDBUS_TYPE_DOUBLE
booleanDBUS_TYPE_BOOLEAN
vectorDBUS_TYPE_ARRAY
anything elseDBUS_TYPE_STRING

TODO that table needs updating: 64-bit ints are there, signed and unsigned, variants, dictionaries, structs etc. Also need to explain about unboxing.

When a D-Bus message is received, the parameters are converted similarly, but unsupported D-Bus types will be converted to #f.

Watch out for cases when Chicken converts an integer to a flonum, because it was too large to fit in a fixnum. It will go across the D-Bus connection as a double, which might not be what you wanted.

Exported functions

make-context #!key (bus session-bus) service interface (path /)procedure

Glom together a bus, service, interface and path into an object that you can conveniently hold for later use. The choices for bus are session-bus (which is the default if you don't specify it), system-bus and starter-bus. The service, interface and path can be given as strings or symbols. Symbols would be preferred; if you provide strings, make-context will convert them to symbols. The default for path is "/" so if you don't need a hierarchical organization of "objects", you don't need to specify it.

send context name #!rest paramsprocedure

Send a signal.

call context name #!rest paramsprocedure

Call a remote method, wait for the reply, and receive the return values from the remote method, as a list. Note that since this is a blocking call (it waits for the reply), it's not suitable for implementing the actor model or anything similarly lightweight/low-latency.

make-method-proxy context nameprocedure

Wrap call in a lambda, which you can then use like any local function. The return value from the function thus created will be the list of return values from the remote method.

register-signal-handler context name msg-cbprocedure

Provide a handler to be called when the current process receives a D-Bus signal which matches the given context and the given signal name. Start a SRFI-18 thread to poll for incoming signals (unless polling has been disabled on this bus).

register-method context name msg-cbprocedure

Provide a handler (a method body) to be called when the current process receives a D-Bus message which matches the given context and the given method name. Start a SRFI-18 thread to poll for incoming messages (unless polling has been disabled on this bus).

enable-polling-thread! #!key (bus session-bus) (enable #t) (interval default-polling-interval)procedure

Enable or disable the polling thread for a particular bus, and set the polling interval in seconds.

poll-for-message #!key (bus session-bus) (timeout 0)procedure

Check once whether any incoming D-Bus message is waiting on a particular bus, and if so, dispatch it to the appropriate callback (which you have previously registered using register-method or register-signal-handler). Returns #t if it received a message, #f if not. The optional timeout parameter is an integer that indicates the maximum time in milliseconds to block waiting for messages.

discover-services #!key (bus session-bus)procedure

Get a list of service names available on a bus.

discover-api-xml contextprocedure

Get the XML API "documentation" provided by the Introspectable interface of a service, if that interface is implemented.

Exported constants

session-busconstant

Session bus.

system-busconstant

System bus.

starter-busconstant

Starter bus.

Examples

These are in the examples subdirectory, and included with the egg too.

Examples you can test with Qt

Qt includes a D-Bus remote-controlled car example. E.g. it might be located in /usr/share/doc/qt6/examples/dbus/remotecontrolledcar depending on your distro. If you run the car, you can cause the wheels of the car to turn to the right by doing this:

(import (prefix dbus dbus:))

(define rc-car-context (dbus:make-context
        service: 'org.example.CarExample
        interface: 'org.example.Examples.CarInterface
        path: '/Car))

(dbus:call rc-car-context "turnRight")

That example called a method but it did not expect any return values. But if you are watching with dbus-monitor, you can see that a response was returned:

method call time=1625916883.288564 sender=:1.1458 -> destination=org.example.CarExample serial=2 path=/Car; interface=org.example.Examples.CarInterface; member=turnRight
method return time=1625916883.289087 sender=:1.1455 -> destination=:1.1458 serial=9 reply_serial=2

Now suppose you want to simulate the car, so you can use the above example to control your own car rather than the Qt one. And suppose you want to poll for messages manually rather than via the default SRFI-18 polling thread:

(import (prefix dbus dbus:) (chicken format))

(dbus:default-signal-handler (lambda (ctx mber args)
        ((dbus:printing-signal-handler) ctx mber args)
        (dbus:dump-callback-table)))

(define (turn-right) (printf "car is turning to the right~%"))
(define (turn-left) (printf "car is turning to the left~%"))

(define rc-car-context (dbus:make-context
        service: 'org.example.CarExample
        path: '/Car
        interface: 'org.example.Examples.CarInterface ))

(dbus:enable-polling-thread!
        enable: #f)

(dbus:register-method rc-car-context "turnRight" turn-right)
(dbus:register-method rc-car-context "turnLeft" turn-left)

(let loop ()
        (dbus:poll-for-message)
        (loop))

register-method starts a polling loop the first time that it is called with a context specifying a particular bus. (And if you register methods on multiple buses, there must be a polling thread for each.) So you can then run the program above which does send, and you will see the appropriate printf statement execute asynchronously when the message is received. However the polling thread is subject to the usual limitations of Chicken threads: if there is any blocking I/O, which is waiting for something, then all threads are blocked. That means you should not use the readline egg for example, because the polling thread will be blocked between each time that you type something and hit Enter.

If the polling thread doesn't work, and you would prefer to poll manually, you can call (enable-polling-thread! enable: #f) to stop the thread (or to prevent it from being started when you register a new method), and then call poll-for-message periodically. Both of those functions can take an optional bus: parameter (which defaults to session-bus, naturally). poll-for-message can also take an optional timeout: parameter (which is 0 by default, so that it is a non-blocking call).

Examples based on the D-Bus Tutorial

The next example, taken from the D-Bus tutorial, shows how to deal with return values. First the "listener" program which will answer the query:

(import (prefix dbus dbus:) (chicken format))

(define (query . params)
        (printf "got a query; params: ~s~%" params)
        ;; the response to the query:
        `(#t 42))

(define ctxt (dbus:make-context
        service: 'test.method.server
        interface: 'test.method.Type
        path: '/test/method/Object))

(dbus:register-method ctxt "Method" query)

And now the program which sends a query and prints out the response:

(import (prefix dbus dbus:) (chicken format))

(define ctxt (dbus:make-context
        service: 'test.method.server
        interface: 'test.method.Type
        path: '/test/method/Object))

(define remote-method (dbus:make-method-proxy ctxt "Method"))

(let ([response (remote-method "query"
                "What is the meaning of life, the universe and everything?") ])

        (printf "sent a very important query with a known answer; got flippant response ~s~%" response)
        (if (and (list? response) (eq? 42 (cadr response)))
                (printf "bingo!~%")
                (printf "and the answer is wrong too!  Bad supercomputer, bad!~%")))

What do you get if you combine a remote-controlled mobile thingy with a supercomputer capable of deep thought? A paranoid android of course! This example in the examples directory handles both kinds of messages from the two examples above (the query and the turnLeft/turnRight commands) and proves that one polling thread is enough to handle multiple, completely different contexts, on a single bus. So registering more than one method is low-cost compared to registering the first one.

Version History

Contents »