32 static struct subs {  struct
47 static int remove_subscriber(k_tid_t thread, struct subs *sus)  in remove_subscriber()  argument
72 static int add_subscriber(k_tid_t thread, struct subs *sus,  in add_subscriber()
90 	struct subs *subs = &channel_subscribers[channel];  in notify_subscribers()  local
92 	for (i = 0; i < subs->subscribers_count; i++) {  in notify_subscribers()
93 		k_event_post(subs->subscribers[i].evt, channel);  in notify_subscribers()
190 	struct subs *subs = &channel_subscribers[channel];  in z_impl_register_subscriber()  local
197 	k_mutex_lock(&subs->subscribers_mtx, K_FOREVER);  in z_impl_register_subscriber()
200 		ret = remove_subscriber(k_current_get(), subs);  in z_impl_register_subscriber()
202 		ret = add_subscriber(k_current_get(), subs, evt);  in z_impl_register_subscriber()
205 	k_mutex_unlock(&subs->subscribers_mtx);  in z_impl_register_subscriber()