Lines Matching refs:reader
3065 struct buffer_page *reader) in rb_update_meta_reader() argument
3069 void *new_reader = reader->page; in rb_update_meta_reader()
3072 id = reader->id; in rb_update_meta_reader()
3074 reader->id = 0; in rb_update_meta_reader()
3080 rb_update_meta_head(cpu_buffer, reader); in rb_update_meta_reader()
4640 struct buffer_page *reader = cpu_buffer->reader_page; in rb_per_cpu_empty() local
4649 if (reader->read != rb_page_size(reader)) in rb_per_cpu_empty()
4656 if (commit == reader) in rb_per_cpu_empty()
5083 struct buffer_page *reader; in ring_buffer_iter_empty() local
5092 reader = cpu_buffer->reader_page; in ring_buffer_iter_empty()
5118 (iter->head_page == reader && commit_page == head_page && in ring_buffer_iter_empty()
5187 struct buffer_page *reader = NULL; in rb_get_reader_page() local
5205 reader = NULL; in rb_get_reader_page()
5209 reader = cpu_buffer->reader_page; in rb_get_reader_page()
5212 if (cpu_buffer->reader_page->read < rb_page_size(reader)) in rb_get_reader_page()
5217 cpu_buffer->reader_page->read > rb_page_size(reader))) in rb_get_reader_page()
5221 reader = NULL; in rb_get_reader_page()
5241 reader = rb_set_head_page(cpu_buffer); in rb_get_reader_page()
5242 if (!reader) in rb_get_reader_page()
5244 cpu_buffer->reader_page->list.next = rb_list_head(reader->list.next); in rb_get_reader_page()
5245 cpu_buffer->reader_page->list.prev = reader->list.prev; in rb_get_reader_page()
5252 cpu_buffer->pages = reader->list.prev; in rb_get_reader_page()
5280 ret = rb_head_page_replace(reader, cpu_buffer->reader_page); in rb_get_reader_page()
5289 rb_update_meta_reader(cpu_buffer, reader); in rb_get_reader_page()
5296 rb_list_head(reader->list.next)->prev = &cpu_buffer->reader_page->list; in rb_get_reader_page()
5302 cpu_buffer->reader_page = reader; in rb_get_reader_page()
5314 if (reader && reader->read == 0) in rb_get_reader_page()
5315 cpu_buffer->read_stamp = reader->page->time_stamp; in rb_get_reader_page()
5327 if (likely(!reader || rb_page_write(reader) <= bsize)) in rb_get_reader_page()
5338 reader = NULL; in rb_get_reader_page()
5352 return reader; in rb_get_reader_page()
5358 struct buffer_page *reader; in rb_advance_reader() local
5361 reader = rb_get_reader_page(cpu_buffer); in rb_advance_reader()
5364 if (RB_WARN_ON(cpu_buffer, !reader)) in rb_advance_reader()
5418 struct buffer_page *reader; in rb_buffer_peek() local
5433 reader = rb_get_reader_page(cpu_buffer); in rb_buffer_peek()
5434 if (!reader) in rb_buffer_peek()
5461 *ts = rb_fix_abs_ts(*ts, reader->page->time_stamp); in rb_buffer_peek()
5915 meta->reader.read = cpu_buffer->reader_page->read; in rb_update_meta_page()
5916 meta->reader.id = cpu_buffer->reader_page->id; in rb_update_meta_page()
5917 meta->reader.lost_events = cpu_buffer->lost_events; in rb_update_meta_page()
6424 struct buffer_page *reader; in ring_buffer_read_page() local
6455 reader = rb_get_reader_page(cpu_buffer); in ring_buffer_read_page()
6456 if (!reader) in ring_buffer_read_page()
6461 read = reader->read; in ring_buffer_read_page()
6462 commit = rb_page_size(reader); in ring_buffer_read_page()
6519 rpos = reader->read; in ring_buffer_read_page()
6538 cpu_buffer->read += rb_page_entries(reader); in ring_buffer_read_page()
6539 cpu_buffer->read_bytes += rb_page_size(reader); in ring_buffer_read_page()
6543 bpage = reader->page; in ring_buffer_read_page()
6544 reader->page = data_page->data; in ring_buffer_read_page()
6545 local_set(&reader->write, 0); in ring_buffer_read_page()
6546 local_set(&reader->entries, 0); in ring_buffer_read_page()
6547 reader->read = 0; in ring_buffer_read_page()
6555 if (reader->real_end) in ring_buffer_read_page()
6556 local_set(&bpage->commit, reader->real_end); in ring_buffer_read_page()
7159 struct buffer_page *reader; in ring_buffer_map_get_reader() local
7187 reader = rb_get_reader_page(cpu_buffer); in ring_buffer_map_get_reader()
7188 if (WARN_ON(!reader)) in ring_buffer_map_get_reader()
7196 struct buffer_data_page *bpage = reader->page; in ring_buffer_map_get_reader()
7203 if (reader->real_end) in ring_buffer_map_get_reader()
7204 local_set(&bpage->commit, reader->real_end); in ring_buffer_map_get_reader()
7209 commit = rb_page_size(reader); in ring_buffer_map_get_reader()