21 	uint8_t	*buf;  member
32 spdk_pipe_create(void *buf, uint32_t sz)  in spdk_pipe_create()  argument
41 	pipe->buf = buf;  in spdk_pipe_create()
50 	void *buf;  in spdk_pipe_destroy()  local
60 	buf = pipe->buf;  in spdk_pipe_destroy()
62 	return buf;  in spdk_pipe_destroy()
68 	struct spdk_pipe_buf *buf;  in pipe_alloc_buf_from_group()  local
76 	buf = SLIST_FIRST(&group->bufs);  in pipe_alloc_buf_from_group()
77 	while (buf != NULL) {  in pipe_alloc_buf_from_group()
78 		if (buf->sz == pipe->sz) {  in pipe_alloc_buf_from_group()
80 			SLIST_REMOVE(&pipe->group->bufs, buf, spdk_pipe_buf, link);  in pipe_alloc_buf_from_group()
81 			pipe->buf = (void *)buf;  in pipe_alloc_buf_from_group()
84 		buf = SLIST_NEXT(buf, link);  in pipe_alloc_buf_from_group()
106 	if (pipe->buf == NULL) {  in spdk_pipe_writer_get_buffer()
113 		iovs[0].iov_base = pipe->buf + write;  in spdk_pipe_writer_get_buffer()
121 			iovs[1].iov_base = (sz == 0) ? NULL : pipe->buf;  in spdk_pipe_writer_get_buffer()
130 		iovs[0].iov_base = pipe->buf + write;  in spdk_pipe_writer_get_buffer()
221 		iovs[0].iov_base = pipe->buf + read;  in spdk_pipe_reader_get_buffer()
228 		iovs[0].iov_base = pipe->buf + read;  in spdk_pipe_reader_get_buffer()
235 			iovs[1].iov_base = (sz == 0) ? NULL : pipe->buf;  in spdk_pipe_reader_get_buffer()
295 			struct spdk_pipe_buf *buf = (struct spdk_pipe_buf *)pipe->buf;  in spdk_pipe_reader_advance()  local
296 			buf->sz = pipe->sz;  in spdk_pipe_reader_advance()
297 			SLIST_INSERT_HEAD(&pipe->group->bufs, buf, link);  in spdk_pipe_reader_advance()
298 			pipe->buf = NULL;  in spdk_pipe_reader_advance()
336 	struct spdk_pipe_buf *buf;  in spdk_pipe_group_add()  local
349 	buf = (struct spdk_pipe_buf *)pipe->buf;  in spdk_pipe_group_add()
350 	buf->sz = pipe->sz;  in spdk_pipe_group_add()
351 	SLIST_INSERT_HEAD(&group->bufs, buf, link);  in spdk_pipe_group_add()
352 	pipe->buf = NULL;  in spdk_pipe_group_add()
361 	if (pipe->buf == NULL) {  in spdk_pipe_group_remove()
364 		assert(pipe->buf != NULL);  in spdk_pipe_group_remove()