Lines Matching refs:channel

87 static void notify_subscribers(enum Channels channel)  in notify_subscribers()  argument
90 struct subs *subs = &channel_subscribers[channel]; in notify_subscribers()
93 k_event_post(subs->subscribers[i].evt, channel); in notify_subscribers()
124 int z_impl_publish(enum Channels channel, void *data, size_t data_len) in z_impl_publish() argument
126 const struct zbus_channel *chan = channel_subscribers[channel].chan; in z_impl_publish()
128 if (channel == CHAN_LAST) { in z_impl_publish()
137 static inline int z_vrfy_publish(enum Channels channel, void *data, in z_vrfy_publish() argument
148 ret = z_impl_publish(channel, copy_data, data_len); in z_vrfy_publish()
157 int z_impl_receive(enum Channels channel, void *data, size_t data_len) in z_impl_receive() argument
161 if (channel == CHAN_LAST || data == NULL) { in z_impl_receive()
165 msg_size = channel_subscribers[channel].chan->message_size; in z_impl_receive()
170 return zbus_chan_read(channel_subscribers[channel].chan, data, in z_impl_receive()
176 static inline int z_vrfy_receive(enum Channels channel, void *data, in z_vrfy_receive() argument
183 return z_impl_receive(channel, data, data_len); in z_vrfy_receive()
188 int z_impl_register_subscriber(enum Channels channel, struct k_event *evt) in z_impl_register_subscriber() argument
190 struct subs *subs = &channel_subscribers[channel]; in z_impl_register_subscriber()
193 if (channel == CHAN_LAST) { in z_impl_register_subscriber()
212 static inline int z_vrfy_register_subscriber(enum Channels channel, in z_vrfy_register_subscriber() argument
219 return z_impl_register_subscriber(channel, evt); in z_vrfy_register_subscriber()