Lines Matching refs:lqe_state
76 _Atomic log_queue_entry_state_t lqe_state; member
165 log_queue_entry_state_t state = read_dependency(&lqe->lqe_state); in log_queue_entry_state()
215 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_STORED); in log_queue_add_entry()
232 log_queue_entry_state_t lqe_state = log_queue_entry_state(lqe); in dispatch_list_cleanup() local
233 assert(lqe_state != LOG_QUEUE_ENTRY_STATE_STORED); in dispatch_list_cleanup()
235 if (lqe_state == LOG_QUEUE_ENTRY_STATE_SENT) { in dispatch_list_cleanup()
237 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_INVALID); in dispatch_list_cleanup()
259 log_queue_entry_state_t lqe_state = log_queue_entry_state(lqe); in log_dispatch_prepare() local
260 assert(lqe_state != LOG_QUEUE_ENTRY_STATE_STORED); in log_dispatch_prepare()
262 if (lqe_state == LOG_QUEUE_ENTRY_STATE_FAILED) { in log_dispatch_prepare()
263 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_DISPATCHED); in log_dispatch_prepare()
278 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_DISPATCHED); in log_dispatch_prepare()
299 log_queue_entry_state_t lqe_state = log_queue_entry_state(lqe); in log_queue_dispatch_logs() local
301 if (lqe_state == LOG_QUEUE_ENTRY_STATE_DISPATCHED) { in log_queue_dispatch_logs()
305 .lp_ftid = read_dependent_w(&lqe_lp->lp_ftid, lqe_state), in log_queue_dispatch_logs()
306 .lp_timestamp = read_dependent_w(&lqe_lp->lp_timestamp, lqe_state), in log_queue_dispatch_logs()
307 .lp_stream = read_dependent(&lqe_lp->lp_stream, lqe_state), in log_queue_dispatch_logs()
308 .lp_pub_data_size = read_dependent(&lqe_lp->lp_pub_data_size, lqe_state), in log_queue_dispatch_logs()
309 .lp_data_size = read_dependent(&lqe_lp->lp_data_size, lqe_state) in log_queue_dispatch_logs()
320 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_SENT); in log_queue_dispatch_logs()
323 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_FAILED); in log_queue_dispatch_logs()