samples/subsys/zbus/uart_bridge/src/peripheral.c

/*
 * Copyright (c) 2022 Rodrigo Peixoto <rodrigopex@gmail.com>
 * SPDX-License-Identifier: Apache-2.0
 */
#include "messages.h"

#include <zephyr/logging/log.h>
#include <zephyr/zbus/zbus.h>
LOG_MODULE_DECLARE(zbus, CONFIG_ZBUS_LOG_LEVEL);

ZBUS_SUBSCRIBER_DEFINE(peripheral_sub, 8);

ZBUS_CHAN_DECLARE(sensor_data_chan);

static bool sensor_data_from_bridge;
ZBUS_CHAN_DEFINE(sensor_data_chan,	 /* Name */
		 struct sensor_data_msg, /* Message type */

		 NULL,			     /* Validator */
		 &sensor_data_from_bridge,   /* User data */
		 ZBUS_OBSERVERS(bridge_sub), /* observers */
		 ZBUS_MSG_INIT(0)	     /* Initial value {0} */
);

static bool start_measurement_from_bridge;
ZBUS_CHAN_DEFINE(start_measurement_chan, /* Name */
		 struct action_msg,	 /* Message type */

		 NULL,					     /* Validator */
		 &start_measurement_from_bridge,	     /* User data */
		 ZBUS_OBSERVERS(bridge_sub, peripheral_sub), /* observers */
		 ZBUS_MSG_INIT(false)			     /* Initial value */
);

static void peripheral_thread(void)
{
	const struct zbus_channel *chan;
	struct sensor_data_msg sd = {0, 0};

	while (!zbus_sub_wait(&peripheral_sub, &chan, K_FOREVER)) {
		LOG_DBG("Peripheral sending sensor data");

		sd.a += 1;
		sd.b += 10;

		zbus_chan_pub(&sensor_data_chan, &sd, K_MSEC(250));
	}
}

K_THREAD_DEFINE(peripheral_thread_id, 1024, peripheral_thread, NULL, NULL, NULL, 3, 0, 0);