Zephyr message bus (zbus)

The Zephyr message bus - Zbus is a lightweight and flexible message bus enabling a simple way for threads to talk to one another.

Concepts
- Limitations
Implementation
Samples
Suggested Uses
Configuration Options
API Reference

Concepts 

Threads can broadcast messages to all interested observers using zbus. Many-to-many communication is possible. The bus implements message-passing and publish/subscribe communication paradigms that enable threads to communicate synchronously or asynchronously through shared memory. The communication through zbus is channel-based, where threads publish and read to and from using messages. Additionally, threads can observe channels and receive notifications from the bus when the channels are modified. Fig. 24 shows an example of a typical application using zbus in which the application logic (hardware independent) talks to other threads via message bus. Note that the threads are decoupled from each other because they only use zbus’ channels and do not need to know each other to talk.

zbus usage overview — Fig. 24 A typical zbus application architecture.

Fig. 25 illustrates zbus’ anatomy. The bus comprises:

Set of channels that consists of a unique identifier, its control metadata information, and the message itself;
Virtual distributed event dispatcher (VDED), the bus logic responsible for sending notifications to the observers. The VDED logic runs inside the publishing action in the same thread context, giving the bus an idea of a distributed execution. When a thread publishes to a channel, it also propagates the notifications to the observers;
Threads (subscribers) and callbacks (listeners) publishing, reading, and receiving notifications from the bus.

The bus makes the publish, read, and subscribe actions available over channels. Publishing and reading are available in all RTOS contexts except inside an Interrupt Service Routine (ISR). The publish and read operations were designed to be simple and fast; the procedure is a mutex locking followed by a memory copy to and from a shared memory region. Zbus observers’ registration can be:

Static, defined in compile time. It is not possible to remove at runtime, but it is possible to suppress it by calling the zbus_obs_set_enable();
Dynamic, it can be added and removed to and from a channel at runtime.

For illustration purposes, suppose a usual sensor-based solution in Fig. 26. When the timer is triggered, it pushes an action to a workqueue that publishes to the Start trigger channel. As the sensor thread subscribed to the Start trigger channel, it starts to fetch the sensor data. Notice the event dispatcher executes the blink callback because it also listens to the Start trigger channel. When the sensor data is ready, the sensor thread publishes it to the Sensor data channel. The core thread as a Sensor data channel subscriber process the sensor data and stores it in a internal sample buffer. It repeats until the sample buffer is full; when it happens, the core thread aggregates the sample buffer information, prepares a package, and publishes that to the Payload channel. The Lora thread receives that because it is a Payload channel subscriber and sends the payload to the cloud. When the transmission is completed, the Lora thread publishes to the Transmission done channel. The blink callback will be executed again since it listens to the Transmission done channel.

This way of implementing the solution gives us certain flexibility enabling us to change things independently. For example, suppose we would like to change the trigger from a timer to a button press. We can do that, and the change does not affect other parts of the system. Suppose, again, we would like to change the communication interface from LoRa to Bluetooth; for that, we only need to change the LoRa thread. No other change is needed to make that work. Thus, the developer would do that for every block of the image. Based on that, there is a sign zbus promotes decoupling in the system architecture.

Another important aspect of using zbus is the reuse of system modules. If a module, code portion with a set of well-defined behaviors, only uses zbus channels and not hardware interfaces, it can easily be reused in other solutions. For that, the new solution must implement the interfaces (set of channels) the module needs to work. That indicates zbus could improve the module reuse.

The last important note is the zbus solution reach. We can count on many different ways of using zbus to enable the developer to be as free as possible to create what they need with it. Messages can be dynamic or static allocated, notifications can be synchronous or asynchronous, the developer can control the channel in so many different ways claiming the channel, developers can add their metadata information to a channel by using the user-data field, the discretionary use of a validator enables the systems to be accurate over message format, and so on. Those characteristics increase the solutions that can be done with zbus and make it a good fit as an open-source community tool.

Limitations 

Based on the fact that developers can use zbus to solve many different problems, some challenges arise. Zbus will not solve every problem, so it is necessary to analyze the situation to be sure zbus is applicable. For instance, based on the zbus benchmark, it would not be well suited to a high-speed stream of bytes between threads. The Pipe kernel object solves this kind of need.

Delivery guarantees

Zbus always delivers the messages to the listeners. However, there are no message delivery guarantees for subscribers because zbus only sends the notification, but the message reading depends on the subscriber’s implementation. It is possible to increase the delivery rate by following design tips:

Keep the listeners quick-as-possible (deal with them as ISRs). If some processing is needed, consider submitting a work to a work-queue;
Try to give producers a high priority to avoid losses;
Leave spare CPU for observers to consume data produced;
Consider using message queues or pipes for intensive byte transfers.

Message delivery sequence

The listeners (synchronous observers) will follow the channel definition sequence as the notification and message consumption sequence. However, the subscribers, as they have an asynchronous nature, all will receive the notification as the channel definition sequence but only will consume the data when they execute again, so the delivery respects the order, but the priority assigned to the subscribers will define the reaction sequence. All the listeners (static o dynamic) will receive the message before subscribers receive the notification. The sequence of delivery is: (i) static listeners; (ii) runtime listeners; (iii) static subscribers; at last (iv) runtime subscribers.

Implementation 

Zbus operation depends on channels and observers. Therefore, it is necessary to determine its message and observers list during the channel definition. A message is a regular C struct; the observer can be a subscriber (asynchronous) or a listener (synchronous). Channels can have a validator function that enables a channel to accept only valid messages.

The following code defines and initializes a regular channel and its dependencies. This channel exchanges accelerometer data, for example.

struct acc_msg {
        int x;
        int y;
        int z;
};

ZBUS_CHAN_DEFINE(acc_chan,                               /* Name */
         struct acc_msg,                         /* Message type */

         NULL,                                           /* Validator */
         NULL,                                           /* User Data */
         ZBUS_OBSERVERS(my_listener, my_subscriber), /* observers */
         ZBUS_MSG_INIT(.x = 0, .y = 0, .z = 0)           /* Initial value {0} */
);

void listener_callback_example(const struct zbus_channel *chan)
{
        const struct acc_msg *acc;
        if (&acc_chan == chan) {
                acc = zbus_chan_const_msg(chan); // Direct message access
                LOG_DBG("From listener -> Acc x=%d, y=%d, z=%d", acc->x, acc->y, acc->z);
        }
}

ZBUS_LISTENER_DEFINE(my_listener, listener_callback_example);

ZBUS_SUBSCRIBER_DEFINE(my_subscriber, 4);
void subscriber_task(void)
{
        const struct zbus_channel *chan;

        while (!zbus_sub_wait(&my_subscriber, &chan, K_FOREVER)) {
                struct acc_msg acc = {0};

                if (&acc_chan == chan) {
                        // Indirect message access
                        zbus_chan_read(&acc_chan, &acc, K_NO_WAIT);
                        LOG_DBG("From subscriber -> Acc x=%d, y=%d, z=%d", acc.x, acc.y, acc.z);
                }
        }
}
K_THREAD_DEFINE(subscriber_task_id, 512, subscriber_task, NULL, NULL, NULL, 3, 0, 0);

Note

It is unnecessary to claim/lock a channel before accessing the message inside the listener since the event dispatcher calls listeners with the notifying channel already locked. Subscribers, however, must claim/lock that or use regular read operations to access the message after being notified.

The following code defines and initializes a hard channel and its dependencies. Only valid messages can be published to a hard channel. It is possible because a Validator function passed to the channel’s definition. In this example, only messages with move equal to 0, -1, and 1 are valid. Publish function will discard all other values to move.

struct control_msg {
        int move;
};

bool control_validator(const void* msg, size_t msg_size) {
        const struct control_msg* cm = msg;
        bool is_valid = (cm->move == -1) || (cm->move == 0) || (cm->move == 1);
        return is_valid;
}

static int message_count = 0;

ZBUS_CHAN_DEFINE(control_chan,     /* Name */
         struct control_msg,      /* Message type */

         control_validator,       /* Validator */
         &message_count,          /* User data */
         ZBUS_OBSERVERS_EMPTY,    /* observers */
         ZBUS_MSG_INIT(.move = 0) /* Initial value {.move=0} */
);

The following sections describe in detail how to use zbus features.

Publishing to a channel 

Messages are published to a channel in zbus by calling zbus_chan_pub(). For example, the following code builds on the examples above and publishes to channel acc_chan. The code is trying to publish the message acc1 to channel acc_chan, and it will wait up to one second for the message to be published. Otherwise, the operation fails.

struct acc_msg acc1 = {.x = 1, .y = 1, .z = 1};
zbus_chan_pub(&acc_chan, &acc1, K_SECONDS(1));

Warning

Do not use this function inside an ISR.

Reading from a channel 

Messages are read from a channel in zbus by calling zbus_chan_read(). So, for example, the following code tries to read the channel acc_chan, which will wait up to 500 milliseconds to read the message. Otherwise, the operation fails.

struct acc_msg acc = {0};
zbus_chan_read(&acc_chan, &acc, K_MSEC(500));

Warning

Do not use this function inside an ISR.

Forcing channel notification 

It is possible to force zbus to notify a channel’s observers by calling zbus_chan_notify(). For example, the following code builds on the examples above and forces a notification for the channel acc_chan. Note this can send events with no message, which does not require any data exchange.

zbus_chan_notify(&acc_chan, K_NO_WAIT);

Warning

Do not use this function inside an ISR.

Declaring channels and observers 

For accessing channels or observers from files other than its defining files, it is necessary to declare them by calling ZBUS_CHAN_DECLARE and ZBUS_OBS_DECLARE. It is possible to declare more than one channel or observer at the same call. The following code builds on the examples above and displays the defined channels and observers.

ZBUS_OBS_DECLARE(my_listener, my_subscriber);
ZBUS_CHAN_DECLARE(acc_chan, version_chan);

Iterating over channels and observers 

There is an iterator mechanism in zbus that enables the developer to execute some procedure per channel and observer. The sequence executed is sorted by channel or observer name.

int count;

bool print_channel_data_iterator(const struct zbus_channel *chan)
{
        LOG_DBG("%d - Channel %s:", count, zbus_chan_name(chan));
        LOG_DBG("      Message size: %d", zbus_chan_msg_size(chan));
        ++count;
        LOG_DBG("      Observers:");
        for (struct zbus_observer **obs = chan->observers; *obs != NULL; ++obs) {
            LOG_DBG("      - %s", zbus_obs_name(*obs));
        }
        return true;
}

bool print_observer_data_iterator(const struct zbus_observer *obs)
{
        LOG_DBG("%d - %s %s", count, ((obs->queue != NULL) ? "Subscriber" : "Listener"), zbus_obs_name(obs));
        ++count;
        return true;
}
void main(void)
{
        LOG_DBG("Channel list:");
        count = 0;
        zbus_iterate_over_channels(print_channel_data_iterator);

        LOG_DBG("Observers list:");
        count = 0;
        zbus_iterate_over_observers(print_observer_data_iterator);
}

The code will log the following output:

D: Channel list:
D: 0 - Channel acc_chan:
D:       Message size: 12
D:       Observers:
D:       - my_listener
D:       - my_subscriber
D: 1 - Channel version_chan:
D:       Message size: 4
D:       Observers:
D: Observers list:
D: 0 - Listener my_listener
D: 1 - Subscriber my_subscriber

Advanced channel control 

Zbus was designed to be as flexible and extensible as possible. Thus there are some features designed to provide some control and extensibility to the bus.

Listeners message access

For performance purposes, listeners can access the receiving channel message directly since they already have the mutex lock for it. To access the channel’s message, the listener should use the zbus_chan_const_msg because the channel passed as an argument to the listener function is a constant pointer to the channel. The const pointer ensures that the message will be kept unchanged during the notification process.

void listener_callback_example(const struct zbus_channel *chan)
{
        const struct acc_msg *acc;
        if (&acc_chan == chan) {
                acc = zbus_chan_const_msg(chan); // Use this
                // instead of zbus_chan_read(chan, &acc, K_MSEC(200))
                // or zbus_chan_msg(chan)

                LOG_DBG("From listener -> Acc x=%d, y=%d, z=%d", acc->x, acc->y, acc->z);
        }
}

User Data

There is a possibility of injecting data into the channel’s metadata by passing the user_data pointer to the channel’s definition macro. The user_data field enables others to access the data. Note that it needs to be set individually for each channel.

Claim and finish a channel

To take more control over channels, two function were added zbus_chan_claim() and zbus_chan_finish(). With these functions, it is possible to access the channel’s metadata safely. When a channel is claimed, no actions are available to that channel. After finishing the channel, all the actions are available again.

Warning

Never change the fields of the channel struct directly. It may cause zbus behavior inconsistencies and concurrency issues.

The following code builds on the examples above and claims the acc_chan to set the user_data to the channel. Suppose we would like to count how many times the channels exchange messages. We defined the user_data to have the 32 bits integer. This code could be added to the listener code described above.

if (!zbus_chan_claim(&acc_chan, K_MSEC(200))) {
        int *message_counting = (int *) zbus_chan_user_data(acc_chan);
        *message_counting += 1;
        zbus_chan_finish(&acc_chan);
}

Warning

Do not use these functions inside an ISR.

Runtime observer registration

It is possible to add observers to channels in runtime. This feature uses the object pool pattern technique in which the dynamic nodes are pre-allocated and can be used and recycled. Therefore, it is necessary to set the pool size by changing the feature CONFIG_ZBUS_RUNTIME_OBSERVERS_POOL_SIZE to enable this feature. Furthermore, it uses memory slabs. When necessary, turn on the CONFIG_MEM_SLAB_TRACE_MAX_UTILIZATION configuration to track the maximum usage of the pool. The following example illustrates the runtime registration usage.

ZBUS_LISTENER_DEFINE(my_listener, callback);
// ...
void thread_entry(void) {
        // ...
        /* Adding the observer to channel chan1 */
        zbus_chan_add_obs(&chan1, &my_listener);
        /* Removing the observer from channel chan1 */
        zbus_chan_rm_obs(&chan1, &my_listener);

Zbus can only use a limited number of dynamic observers. The configuration option CONFIG_ZBUS_RUNTIME_OBSERVERS_POOL_SIZE represents the size of the runtime observers pool (memory slab). Change that to fit the solution needs. Use the k_mem_slab_num_used_get() to verify how many runtime observers slots are available. The function k_mem_slab_max_used_get() will provide information regarding the maximum number of used slots count reached during the execution. Use that to set the appropriate pool size avoiding waste. The following code illustrates how to use that.

extern struct k_mem_slab _zbus_runtime_obs_pool;
uint32_t slots_available = k_mem_slab_num_free_get(&_zbus_runtime_obs_pool);
uint32_t max_usage = k_mem_slab_max_used_get(&_zbus_runtime_obs_pool);

Warning

Do not use _zbus_runtime_obs_pool memory slab directly. It may lead to inconsistencies.

Samples 

For a complete overview of zbus usage, take a look at the samples. There are the following samples available:

Hello world sample illustrates the code used above in action;
Workqueue sample shows how to define and use different kinds of observers. Note there is an example of using a work queue instead of executing the listener as an execution option;
Dynamic channel sample demonstrates how to use dynamically allocated exchanging data in zbus;
UART bridge sample shows an example of sending the operation of the channel to a host via serial;
Remote mock sample illustrates how to implement an external mock (on the host) to send and receive messages to and from the bus.
Runtime observer registration sample illustrates a way of using the runtime observer registration feature;
Benchmark sample implements a benchmark with different combinations of inputs.

Suggested Uses 

Use zbus to transfer data (messages) between threads in one-to-one, one-to-many, and many-to-many synchronously or asynchronously.

Note

Zbus can be used to transfer streams from the producer to the consumer. However, this can increase zbus’ communication latency. So maybe consider a Pipe a good alternative for this communication topology.

Configuration Options 

For enabling zbus, it is necessary to enable the CONFIG_ZBUS option.

Related configuration options:

API Reference 

group zbus_apis

Zbus API.

Defines

ZBUS_OBS_DECLARE(...): This macro list the observers to be used in a file. Internally, it declares the observers with the extern statement. Note it is only necessary when the observers are declared outside the file.

ZBUS_CHAN_DECLARE(...): This macro list the channels to be used in a file. Internally, it declares the channels with the extern statement. Note it is only necessary when the channels are declared outside the file.

ZBUS_OBSERVERS_EMPTY: This macro indicates the channel has no observers.

ZBUS_OBSERVERS(...): This macro indicates the channel has listed observers. Note the sequence of observer notification will follow the same as listed.

ZBUS_CHAN_DEFINE(_name, _type, _validator, _user_data, _observers, _init_val)

Zbus channel definition.

This macro defines a channel.

See also

struct zbus_channel

Parameters

_name – The channel’s name.
_type – The Message type. It must be a struct or union.
_validator – The validator function.
_user_data – A pointer to the user data.
_observers – The observers list. The sequence indicates the priority of the observer. The first the highest priority.
_init_val – The message initialization.

ZBUS_MSG_INIT(_val, ...)

Initialize a message.

This macro initializes a message by passing the values to initialize the message struct or union.

Parameters

_val – [in] Variadic with the initial values. ZBUS_INIT(0) means {0}, as ZBUS_INIT(.a=10, .b=30) means {.a=10, .b=30}.

ZBUS_SUBSCRIBER_DEFINE(_name, _queue_size)

Define and initialize a subscriber.

This macro defines an observer of subscriber type. It defines a message queue where the subscriber will receive the notification asynchronously, and initialize the struct zbus_observer defining the subscriber.

Parameters

_name – [in] The subscriber’s name.
_queue_size – [in] The notification queue’s size.

ZBUS_LISTENER_DEFINE(_name, _cb)

Define and initialize a listener.

This macro defines an observer of listener type. This macro establishes the callback where the listener will be notified synchronously, and initialize the struct zbus_observer defining the listener.

Parameters

_name – [in] The listener’s name.
_cb – [in] The callback function.

Functions

int zbus_chan_pub(const struct zbus_channel *chan, const void *msg, k_timeout_t timeout)

Publish to a channel.

This routine publishes a message to a channel.

Parameters

chan – The channel’s reference.
msg – Reference to the message where the publish function copies the channel’s message data from.
timeout – Waiting period to publish the channel, or one of the special values K_NO_WAIT and K_FOREVER.

Return values

0 – Channel published.
-ENOMSG – The message is invalid based on the validator function or some of the observers could not receive the notification.
-EBUSY – The channel is busy.
-EAGAIN – Waiting period timed out.
-EFAULT – A parameter is incorrect, the notification could not be sent to one or more observer, or the function context is invalid (inside an ISR). The function only returns this value when the CONFIG_ZBUS_ASSERT_MOCK is enabled.

int zbus_chan_read(const struct zbus_channel *chan, void *msg, k_timeout_t timeout)

Read a channel.

This routine reads a message from a channel.

Parameters

chan – [in] The channel’s reference.
msg – [out] Reference to the message where the read function copies the channel’s message data to.
timeout – [in] Waiting period to read the channel, or one of the special values K_NO_WAIT and K_FOREVER.

Return values

0 – Channel read.
-EBUSY – The channel is busy.
-EAGAIN – Waiting period timed out.
-EFAULT – A parameter is incorrect, or the function context is invalid (inside an ISR). The function only returns this value when the CONFIG_ZBUS_ASSERT_MOCK is enabled.

int zbus_chan_claim(const struct zbus_channel *chan, k_timeout_t timeout)

Claim a channel.

This routine claims a channel. During the claiming period the channel is blocked for publishing, reading, notifying or claiming again. Finishing is the only available action.

Warning

After calling this routine, the channel cannot be used by other thread until the zbus_chan_finish routine is performed.

Warning

This routine should only be called once before a zbus_chan_finish.

Parameters

chan – [in] The channel’s reference.
timeout – [in] Waiting period to claim the channel, or one of the special values K_NO_WAIT and K_FOREVER.

Return values

0 – Channel claimed.
-EBUSY – The channel is busy.
-EAGAIN – Waiting period timed out.
-EFAULT – A parameter is incorrect, or the function context is invalid (inside an ISR). The function only returns this value when the CONFIG_ZBUS_ASSERT_MOCK is enabled.

int zbus_chan_finish(const struct zbus_channel *chan)

Finish a channel claim.

This routine finishes a channel claim. After calling this routine with success, the channel will be able to be used by other thread.

Warning

This routine must only be used after a zbus_chan_claim.

Parameters

chan – The channel’s reference.

Return values

0 – Channel finished.
-EPERM – The channel was claimed by other thread.
-EINVAL – The channel’s mutex is not locked.
-EFAULT – A parameter is incorrect, or the function context is invalid (inside an ISR). The function only returns this value when the CONFIG_ZBUS_ASSERT_MOCK is enabled.

int zbus_chan_notify(const struct zbus_channel *chan, k_timeout_t timeout)

Force a channel notification.

This routine forces the event dispatcher to notify the channel’s observers even if the message has no changes. Note this function could be useful after claiming/finishing actions.

Parameters

chan – The channel’s reference.
timeout – Waiting period to notify the channel, or one of the special values K_NO_WAIT and K_FOREVER.

Return values

0 – Channel notified.
-EPERM – The current thread does not own the channel.
-EBUSY – The channel’s mutex returned without waiting.
-EAGAIN – Timeout to acquiring the channel’s mutex.
-EFAULT – A parameter is incorrect, the notification could not be sent to one or more observer, or the function context is invalid (inside an ISR). The function only returns this value when the CONFIG_ZBUS_ASSERT_MOCK is enabled.

static inline const char *zbus_chan_name(const struct zbus_channel *chan)

Get the channel’s name.

This routine returns the channel’s name reference.

Parameters

chan – The channel’s reference.

Returns

Channel’s name reference.

static inline void *zbus_chan_msg(const struct zbus_channel *chan)

Get the reference for a channel message directly.

This routine returns the reference of a channel message.

Warning

This function must only be used directly for acquired (locked by mutex) channels. This can be done inside a listener for the receiving channel or after claim a channel.

Parameters

chan – The channel’s reference.

Returns

Channel’s message reference.

static inline const void *zbus_chan_const_msg(const struct zbus_channel *chan)

Get a constant reference for a channel message directly.

This routine returns a constant reference of a channel message. This should be used inside listeners to access the message directly. In this way zbus prevents the listener of changing the notifying channel’s message during the notification process.

Warning

This function must only be used directly for acquired (locked by mutex) channels. This can be done inside a listener for the receiving channel or after claim a channel.

Parameters

chan – The channel’s constant reference.

Returns

A constant channel’s message reference.

static inline uint16_t zbus_chan_msg_size(const struct zbus_channel *chan)

Get the channel’s message size.

This routine returns the channel’s message size.

Parameters

chan – The channel’s reference.

Returns

Channel’s message size.

static inline void *zbus_chan_user_data(const struct zbus_channel *chan)

Get the channel’s user data.

This routine returns the channel’s user data.

Parameters

chan – The channel’s reference.

Returns

Channel’s user data.

int zbus_chan_add_obs(const struct zbus_channel *chan, const struct zbus_observer *obs, k_timeout_t timeout)

Add an observer to a channel.

This routine adds an observer to the channel.

Parameters

chan – The channel’s reference.
obs – The observer’s reference to be added.
timeout – Waiting period to add an observer, or one of the special values K_NO_WAIT and K_FOREVER.

Return values

0 – Observer added to the channel.
-EALREADY – The observer is already present in the channel’s runtime observers list.
-ENOMEM – Returned without waiting.
-EAGAIN – Waiting period timed out.
-EINVAL – Some parameter is invalid.

int zbus_chan_rm_obs(const struct zbus_channel *chan, const struct zbus_observer *obs, k_timeout_t timeout)

Remove an observer from a channel.

This routine removes an observer to the channel.

Parameters

chan – The channel’s reference.
obs – The observer’s reference to be removed.
timeout – Waiting period to remove an observer, or one of the special values K_NO_WAIT and K_FOREVER.

Return values

0 – Observer removed to the channel.
-EINVAL – Invalid data supplied.
-EBUSY – Returned without waiting.
-EAGAIN – Waiting period timed out.
-ENODATA – no observer found in channel’s runtime observer list.
-ENOMEM – Returned without waiting.

struct k_mem_slab *zbus_runtime_obs_pool(void)

Get zbus runtime observers pool.

This routine returns a reference of the runtime observers pool.

Returns: Reference of runtime observers pool.

static inline int zbus_obs_set_enable(struct zbus_observer *obs, bool enabled)

Change the observer state.

This routine changes the observer state. A channel when disabled will not receive notifications from the event dispatcher.

Parameters

obs – [in] The observer’s reference.
enabled – [in] State to be. When false the observer stops to receive notifications.

Return values

0 – Observer set enable.
-EFAULT – A parameter is incorrect, or the function context is invalid (inside an ISR). The function only returns this value when the CONFIG_ZBUS_ASSERT_MOCK is enabled.

static inline const char *zbus_obs_name(const struct zbus_observer *obs)

Get the observer’s name.

This routine returns the observer’s name reference.

Parameters

obs – The observer’s reference.

Returns

The observer’s name reference.

int zbus_sub_wait(const struct zbus_observer *sub, const struct zbus_channel **chan, k_timeout_t timeout)

Wait for a channel notification.

This routine makes the subscriber to wait a notification. The notification comes as a channel reference.

Parameters

sub – [in] The subscriber’s reference.
chan – [out] The notification channel’s reference.
timeout – [in] Waiting period for a notification arrival, or one of the special values K_NO_WAIT and K_FOREVER.

Return values

0 – Notification received.
-ENOMSG – Returned without waiting.
-EAGAIN – Waiting period timed out.
-EINVAL – The observer is not a subscriber.
-EFAULT – A parameter is incorrect, or the function context is invalid (inside an ISR). The function only returns this value when the CONFIG_ZBUS_ASSERT_MOCK is enabled.

bool zbus_iterate_over_channels(bool (*iterator_func)(const struct zbus_channel *chan))

Iterate over channels.

Enables the developer to iterate over the channels giving to this function an iterator_func which is called for each channel. If the iterator_func returns false all the iteration stops.

Return values

true – Iterator executed for all channels.
false – Iterator could not be executed. Some iterate returned false.

bool zbus_iterate_over_observers(bool (*iterator_func)(const struct zbus_observer *obs))

Iterate over observers.

Enables the developer to iterate over the observers giving to this function an iterator_func which is called for each observer. If the iterator_func returns false all the iteration stops.

Return values

true – Iterator executed for all channels.
false – Iterator could not be executed. Some iterate returned false.

struct zbus_channel

#include <zbus.h>

Type used to represent a channel.

Every channel has a zbus_channel structure associated used to control the channel access and usage.

Public Members

const char *const name: Channel name.

const uint16_t message_size: Message size. Represents the channel’s message size.

void *const user_data: User data available to extend zbus features. The channel must be claimed before using this field.

void *const message: Message reference. Represents the message’s reference that points to the actual shared memory region.

bool (*const validator)(const void *msg, size_t msg_size): Message validator. Stores the reference to the function to check the message validity before actually performing the publishing. No invalid messages can be published. Every message is valid when this field is empty.

struct k_mutex *mutex: Access control mutex. Points to the mutex used to avoid race conditions for accessing the channel.

sys_slist_t *runtime_observers: Dynamic channel observer list. Represents the channel’s observers list, it can be empty or have listeners and subscribers mixed in any sequence. It can be changed in runtime.

const struct zbus_observer *const *observers: Channel observer list. Represents the channel’s observers list, it can be empty or have listeners and subscribers mixed in any sequence.

struct zbus_observer

#include <zbus.h>

Type used to represent an observer.

Every observer has an representation structure containing the relevant information. An observer is a code portion interested in some channel. The observer can be notified synchronously or asynchronously and it is called listener and subscriber respectively. The observer can be enabled or disabled during runtime by change the enabled boolean field of the structure. The listeners have a callback function that is executed by the bus with the index of the changed channel as argument when the notification is sent. The subscribers have a message queue where the bus enqueues the index of the changed channel when a notification is sent.