Lines Matching refs:lqe_state

75 	_Atomic log_queue_entry_state_t lqe_state;  member
176 log_queue_entry_state_t state = read_dependency(&lqe->lqe_state); in log_queue_entry_state()
226 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_STORED); in log_queue_add_entry()
243 log_queue_entry_state_t lqe_state = log_queue_entry_state(lqe); in dispatch_list_cleanup() local
244 assert(lqe_state != LOG_QUEUE_ENTRY_STATE_STORED); in dispatch_list_cleanup()
246 if (lqe_state == LOG_QUEUE_ENTRY_STATE_SENT) { in dispatch_list_cleanup()
248 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_INVALID); in dispatch_list_cleanup()
270 log_queue_entry_state_t lqe_state = log_queue_entry_state(lqe); in log_dispatch_prepare() local
271 assert(lqe_state != LOG_QUEUE_ENTRY_STATE_STORED); in log_dispatch_prepare()
273 if (lqe_state == LOG_QUEUE_ENTRY_STATE_FAILED) { in log_dispatch_prepare()
274 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_DISPATCHED); in log_dispatch_prepare()
289 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_DISPATCHED); in log_dispatch_prepare()
310 log_queue_entry_state_t lqe_state = log_queue_entry_state(lqe); in log_queue_dispatch_logs() local
312 if (lqe_state == LOG_QUEUE_ENTRY_STATE_DISPATCHED) { in log_queue_dispatch_logs()
316 .lp_ftid = read_dependent_w(&lqe_lp->lp_ftid, lqe_state), in log_queue_dispatch_logs()
317 .lp_timestamp = read_dependent_w(&lqe_lp->lp_timestamp, lqe_state), in log_queue_dispatch_logs()
318 .lp_stream = read_dependent(&lqe_lp->lp_stream, lqe_state), in log_queue_dispatch_logs()
319 .lp_data_size = read_dependent(&lqe_lp->lp_data_size, lqe_state) in log_queue_dispatch_logs()
330 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_SENT); in log_queue_dispatch_logs()
333 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_FAILED); in log_queue_dispatch_logs()