Lines Matching refs:candidate_step
551 uint32_t candidate_step = get_step_size(r, v, bytes); in ring_buffer_write_fully_with_abort() local
557 if (bytes - processed < candidate_step) { in ring_buffer_write_fully_with_abort()
558 candidate_step = bytes - processed; in ring_buffer_write_fully_with_abort()
562 ring_buffer_wait_write(r, v, candidate_step, (uint64_t)(-1)); in ring_buffer_write_fully_with_abort()
565 processed_here = ring_buffer_view_write(r, v, dst + processed, candidate_step, 1); in ring_buffer_write_fully_with_abort()
567 processed_here = ring_buffer_write(r, dst + processed, candidate_step, 1); in ring_buffer_write_fully_with_abort()
570 processed += processed_here ? candidate_step : 0; in ring_buffer_write_fully_with_abort()
588 uint32_t candidate_step = get_step_size(r, v, bytes); in ring_buffer_read_fully_with_abort() local
597 if (bytes - processed < candidate_step) { in ring_buffer_read_fully_with_abort()
598 candidate_step = bytes - processed; in ring_buffer_read_fully_with_abort()
602 ring_buffer_wait_read(r, v, candidate_step, (uint64_t)(-1)); in ring_buffer_read_fully_with_abort()
605 processed_here = ring_buffer_view_read(r, v, dst + processed, candidate_step, 1); in ring_buffer_read_fully_with_abort()
607 processed_here = ring_buffer_read(r, dst + processed, candidate_step, 1); in ring_buffer_read_fully_with_abort()
610 processed += processed_here ? candidate_step : 0; in ring_buffer_read_fully_with_abort()