24 	uint32_t write;  member
95 	uint32_t write;  in spdk_pipe_writer_get_buffer()  local
98 	write = pipe->write;  in spdk_pipe_writer_get_buffer()
110 	if (read <= write) {  in spdk_pipe_writer_get_buffer()
111 		sz = spdk_min(requested_sz, pipe->sz - write);  in spdk_pipe_writer_get_buffer()
113 		iovs[0].iov_base = pipe->buf + write;  in spdk_pipe_writer_get_buffer()
128 		sz = spdk_min(requested_sz, read - write);  in spdk_pipe_writer_get_buffer()
130 		iovs[0].iov_base = pipe->buf + write;  in spdk_pipe_writer_get_buffer()
144 	uint32_t write;  in spdk_pipe_writer_advance()  local
147 	write = pipe->write;  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()
158 		sz = spdk_min(requested_sz, pipe->sz - write);  in spdk_pipe_writer_advance()
160 		write += sz;  in spdk_pipe_writer_advance()
161 		if (write == pipe->sz) {  in spdk_pipe_writer_advance()
162 			write = 0;  in spdk_pipe_writer_advance()
167 			write = requested_sz;  in spdk_pipe_writer_advance()
170 		if (requested_sz > (read - write)) {  in spdk_pipe_writer_advance()
174 		write += requested_sz;  in spdk_pipe_writer_advance()
177 	if (read == write) {  in spdk_pipe_writer_advance()
180 	pipe->write = write;  in spdk_pipe_writer_advance()
189 	uint32_t write;  in spdk_pipe_reader_bytes_available()  local
192 	write = pipe->write;  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()
208 	uint32_t write;  in spdk_pipe_reader_get_buffer()  local
211 	write = pipe->write;  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()
234 			sz = spdk_min(requested_sz, write);  in spdk_pipe_reader_get_buffer()
251 	uint32_t write;  in spdk_pipe_reader_advance()  local
254 	write = pipe->write;  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()
276 			if (requested_sz > write) {  in spdk_pipe_reader_advance()
287 	if (read == write) {  in spdk_pipe_reader_advance()
291 		pipe->write = 0;  in spdk_pipe_reader_advance()
341 	if (pipe->read != pipe->write || pipe->full) {  in spdk_pipe_group_add()