Searched refs:msub (Results 1 – 2 of 2) sorted by relevance
39 struct zbus_observer *msub = msub_ref; in msg_sub_thread() local42 if (zbus_sub_wait_msg(msub, &chan, &msg_received, K_FOREVER) == 0) { in msg_sub_thread()
71 const struct zbus_observer *msub = ptr1; in consumer_msg_sub_thread() local76 if (zbus_sub_wait_msg(msub, &chan, &msg, K_FOREVER) != 0) { in consumer_msg_sub_thread()82 zbus_obs_detach_from_thread(msub); in consumer_msg_sub_thread()
