Lines Matching refs:lqe_state

80 	_Atomic log_queue_entry_state_t lqe_state;  member
194 log_queue_entry_state_t state = read_dependency(&lqe->lqe_state); in log_queue_entry_state()
250 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_STORED); in log_queue_add_entry()
267 log_queue_entry_state_t lqe_state = log_queue_entry_state(lqe); in dispatch_list_cleanup() local
268 assert(lqe_state != LOG_QUEUE_ENTRY_STATE_STORED); in dispatch_list_cleanup()
270 if (lqe_state == LOG_QUEUE_ENTRY_STATE_SENT) { in dispatch_list_cleanup()
272 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_INVALID); in dispatch_list_cleanup()
294 log_queue_entry_state_t lqe_state = log_queue_entry_state(lqe); in log_dispatch_prepare() local
295 assert(lqe_state != LOG_QUEUE_ENTRY_STATE_STORED); in log_dispatch_prepare()
297 if (lqe_state == LOG_QUEUE_ENTRY_STATE_FAILED) { in log_dispatch_prepare()
298 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_DISPATCHED); in log_dispatch_prepare()
313 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_DISPATCHED); in log_dispatch_prepare()
334 log_queue_entry_state_t lqe_state = log_queue_entry_state(lqe); in log_queue_dispatch_logs() local
336 if (lqe_state == LOG_QUEUE_ENTRY_STATE_DISPATCHED) { in log_queue_dispatch_logs()
340 .lp_ftid = read_dependent_w(&lqe_lp->lp_ftid, lqe_state), in log_queue_dispatch_logs()
341 .lp_timestamp = read_dependent_w(&lqe_lp->lp_timestamp, lqe_state), in log_queue_dispatch_logs()
342 .lp_stream = read_dependent(&lqe_lp->lp_stream, lqe_state), in log_queue_dispatch_logs()
343 .lp_pub_data_size = read_dependent(&lqe_lp->lp_pub_data_size, lqe_state), in log_queue_dispatch_logs()
344 .lp_data_size = read_dependent(&lqe_lp->lp_data_size, lqe_state) in log_queue_dispatch_logs()
355 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_SENT); in log_queue_dispatch_logs()
358 publish(&lqe->lqe_state, LOG_QUEUE_ENTRY_STATE_FAILED); in log_queue_dispatch_logs()