Lines Matching refs:log
220 struct read_log *log = &mi->mi_log; in log_block_read() local
230 if (log->rl_size == 0) in log_block_read()
233 spin_lock(&log->rl_writer_lock); in log_block_read()
234 state = READ_ONCE(log->rl_state); in log_block_read()
235 log->rl_ring_buf[state.next_index] = record; in log_block_read()
236 if (++state.next_index == log->rl_size) { in log_block_read()
240 WRITE_ONCE(log->rl_state, state); in log_block_read()
241 spin_unlock(&log->rl_writer_lock); in log_block_read()
243 wake_up_all(&log->ml_notif_wq); in log_block_read()
1036 struct read_log *log = &mi->mi_log; in incfs_get_log_state() local
1039 spin_lock(&log->rl_writer_lock); in incfs_get_log_state()
1040 result = READ_ONCE(log->rl_state); in incfs_get_log_state()
1041 spin_unlock(&log->rl_writer_lock); in incfs_get_log_state()
1053 struct read_log *log = &mi->mi_log; in incfs_get_uncollected_logs_count() local
1055 u64 count = calc_record_count(&log->rl_state, log->rl_size) - in incfs_get_uncollected_logs_count()
1056 calc_record_count(&state, log->rl_size); in incfs_get_uncollected_logs_count()
1057 return min_t(int, count, log->rl_size); in incfs_get_uncollected_logs_count()
1076 struct read_log *log = &mi->mi_log; in incfs_collect_logged_reads() local
1078 u64 read_count = calc_record_count(reader_state, log->rl_size); in incfs_collect_logged_reads()
1079 u64 written_count = calc_record_count(&live_state, log->rl_size); in incfs_collect_logged_reads()
1082 if (reader_state->next_index >= log->rl_size || in incfs_collect_logged_reads()
1095 if (written_count - read_count > log->rl_size) { in incfs_collect_logged_reads()
1104 (u32)live_state.current_pass_no - 1, (u32)log->rl_size); in incfs_collect_logged_reads()
1119 &log->rl_ring_buf[reader_state->next_index], in incfs_collect_logged_reads()
1120 reader_state, log->rl_size); in incfs_collect_logged_reads()
1123 if (reader_state->next_index == log->rl_size) { in incfs_collect_logged_reads()