Lines Matching refs:end_time
126 const struct zbus_observer *obs, k_timepoint_t end_time, in _zbus_notify_observer() argument
135 return k_msgq_put(obs->queue, &chan, sys_timepoint_timeout(end_time)); in _zbus_notify_observer()
139 struct net_buf *cloned_buf = net_buf_clone(buf, sys_timepoint_timeout(end_time)); in _zbus_notify_observer()
157 static inline int _zbus_vded_exec(const struct zbus_channel *chan, k_timepoint_t end_time) in _zbus_vded_exec() argument
172 buf = _zbus_create_net_buf(pool, zbus_chan_msg_size(chan), sys_timepoint_timeout(end_time)); in _zbus_vded_exec()
199 err = _zbus_notify_observer(chan, obs, end_time, buf); in _zbus_vded_exec()
227 err = _zbus_notify_observer(chan, obs, end_time, buf); in _zbus_vded_exec()
388 k_timepoint_t end_time = sys_timepoint_calc(timeout); in zbus_chan_pub() local
408 err = _zbus_vded_exec(chan, end_time); in zbus_chan_pub()
446 k_timepoint_t end_time = sys_timepoint_calc(timeout); in zbus_chan_notify() local
455 err = _zbus_vded_exec(chan, end_time); in zbus_chan_notify()