25 	uint32_t read;  member
94 	uint32_t read;  in spdk_pipe_writer_get_buffer()  local
97 	read = pipe->read;  in spdk_pipe_writer_get_buffer()
110 	if (read <= write) {  in spdk_pipe_writer_get_buffer()
119 			sz = spdk_min(requested_sz, read);  in spdk_pipe_writer_get_buffer()
128 		sz = spdk_min(requested_sz, read - write);  in spdk_pipe_writer_get_buffer()
143 	uint32_t read;  in spdk_pipe_writer_advance()  local
146 	read = pipe->read;  in spdk_pipe_writer_advance()
153 	if (read <= write) {  in spdk_pipe_writer_advance()
154 		if (requested_sz > (pipe->sz - write) + read) {  in spdk_pipe_writer_advance()
170 		if (requested_sz > (read - write)) {  in spdk_pipe_writer_advance()
177 	if (read == write) {  in spdk_pipe_writer_advance()
188 	uint32_t read;  in spdk_pipe_reader_bytes_available()  local
191 	read = pipe->read;  in spdk_pipe_reader_bytes_available()
194 	if (read == write && !pipe->full) {  in spdk_pipe_reader_bytes_available()
196 	} else if (read < write) {  in spdk_pipe_reader_bytes_available()
197 		return write - read;  in spdk_pipe_reader_bytes_available()
199 		return (pipe->sz - read) + write;  in spdk_pipe_reader_bytes_available()
207 	uint32_t read;  in spdk_pipe_reader_get_buffer()  local
210 	read = pipe->read;  in spdk_pipe_reader_get_buffer()
213 	if ((read == write && !pipe->full) || requested_sz == 0) {  in spdk_pipe_reader_get_buffer()
218 	} else if (read < write) {  in spdk_pipe_reader_get_buffer()
219 		sz = spdk_min(requested_sz, write - read);  in spdk_pipe_reader_get_buffer()
221 		iovs[0].iov_base = pipe->buf + read;  in spdk_pipe_reader_get_buffer()
226 		sz = spdk_min(requested_sz, pipe->sz - read);  in spdk_pipe_reader_get_buffer()
228 		iovs[0].iov_base = pipe->buf + read;  in spdk_pipe_reader_get_buffer()
250 	uint32_t read;  in spdk_pipe_reader_advance()  local
253 	read = pipe->read;  in spdk_pipe_reader_advance()
260 	if (read < write) {  in spdk_pipe_reader_advance()
261 		if (requested_sz > (write - read)) {  in spdk_pipe_reader_advance()
265 		read += requested_sz;  in spdk_pipe_reader_advance()
267 		sz = spdk_min(requested_sz, pipe->sz - read);  in spdk_pipe_reader_advance()
269 		read += sz;  in spdk_pipe_reader_advance()
270 		if (read == pipe->sz) {  in spdk_pipe_reader_advance()
271 			read = 0;  in spdk_pipe_reader_advance()
280 			read = requested_sz;  in spdk_pipe_reader_advance()
287 	if (read == write) {  in spdk_pipe_reader_advance()
290 		read = 0;  in spdk_pipe_reader_advance()
302 	pipe->read = read;  in spdk_pipe_reader_advance()
341 	if (pipe->read != pipe->write || pipe->full) {  in spdk_pipe_group_add()