A pipe that is intended for buffering data between a source, such as a socket, and a sink, such as a parser, or vice versa. More...
Functions | |
| struct spdk_pipe * | spdk_pipe_create (void *buf, uint32_t sz) |
| Construct a pipe around the given memory buffer. More... | |
| void * | spdk_pipe_destroy (struct spdk_pipe *pipe) |
| Destroys the pipe. More... | |
| int | spdk_pipe_writer_get_buffer (struct spdk_pipe *pipe, uint32_t sz, struct iovec *iovs) |
| Acquire memory from the pipe for writing. More... | |
| int | spdk_pipe_writer_advance (struct spdk_pipe *pipe, uint32_t count) |
| Advance the write pointer by the given number of bytes. More... | |
| uint32_t | spdk_pipe_reader_bytes_available (struct spdk_pipe *pipe) |
| Get the number of bytes available to read from the pipe. More... | |
| int | spdk_pipe_reader_get_buffer (struct spdk_pipe *pipe, uint32_t sz, struct iovec *iovs) |
| Obtain previously written memory from the pipe for reading. More... | |
| int | spdk_pipe_reader_advance (struct spdk_pipe *pipe, uint32_t count) |
| Mark memory as read, making it available for writing. More... | |
| struct spdk_pipe_group * | spdk_pipe_group_create (void) |
| Constructs a pipe group. More... | |
| void | spdk_pipe_group_destroy (struct spdk_pipe_group *group) |
| Destroys the pipe group. More... | |
| int | spdk_pipe_group_add (struct spdk_pipe_group *group, struct spdk_pipe *pipe) |
| Adds the pipe to the group. More... | |
| int | spdk_pipe_group_remove (struct spdk_pipe_group *group, struct spdk_pipe *pipe) |
| Removes the pipe to the group. More... | |
A pipe that is intended for buffering data between a source, such as a socket, and a sink, such as a parser, or vice versa.
Any time data is received in units that differ from the the units it is consumed in may benefit from using a pipe.
The pipe is not thread safe. Only a single thread can act as both the producer (called the writer) and the consumer (called the reader).
| struct spdk_pipe* spdk_pipe_create | ( | void * | buf, |
| uint32_t | sz | ||
| ) |
Construct a pipe around the given memory buffer.
The pipe treats the memory buffer as a circular ring of bytes.
| buf | The data buffer that backs this pipe. |
| sz | The size of the data buffer. |
| void* spdk_pipe_destroy | ( | struct spdk_pipe * | pipe | ) |
Destroys the pipe.
This does not release the buffer, but does make it safe for the user to release the buffer.
| pipe | The pipe to operate on. |
| int spdk_pipe_group_add | ( | struct spdk_pipe_group * | group, |
| struct spdk_pipe * | pipe | ||
| ) |
Adds the pipe to the group.
When a pipe reaches empty state, it puts the data buffer into the group's pool. If a pipe needs a data buffer, it takes one from the pool. Since the pool is a stack, a small number of data buffers tend to be re-used very frequently.
| group | The pipe group to operate on. |
| pipe | The pipe to be added. |
| struct spdk_pipe_group* spdk_pipe_group_create | ( | void | ) |
Constructs a pipe group.
| void spdk_pipe_group_destroy | ( | struct spdk_pipe_group * | group | ) |
Destroys the pipe group.
| group | The pipe group to operate on. |
| int spdk_pipe_group_remove | ( | struct spdk_pipe_group * | group, |
| struct spdk_pipe * | pipe | ||
| ) |
Removes the pipe to the group.
| group | The pipe group to operate on. |
| pipe | The pipe to be removed. |
| int spdk_pipe_reader_advance | ( | struct spdk_pipe * | pipe, |
| uint32_t | count | ||
| ) |
Mark memory as read, making it available for writing.
The user is not required to advance the same number of byte as was obtained by a previous call to spdk_pipe_reader_get_buffer().
| pipe | The pipe to operate on. |
| count | The number of bytes to advance. |
| uint32_t spdk_pipe_reader_bytes_available | ( | struct spdk_pipe * | pipe | ) |
Get the number of bytes available to read from the pipe.
| pipe | The pipe to operate on. |
| int spdk_pipe_reader_get_buffer | ( | struct spdk_pipe * | pipe, |
| uint32_t | sz, | ||
| struct iovec * | iovs | ||
| ) |
Obtain previously written memory from the pipe for reading.
This call populates the two element iovec provided with a region of memory containing the next available data in the pipe. The size will be up to sz bytes, but may be less.
Calling this function does not mark the memory as consumed. Calling this function twice without a call to spdk_pipe_reader_advance in between will return the same region of memory.
| pipe | The pipe to operate on. |
| sz | The size requested. |
| iovs | A two element iovec array that will be populated with the requested memory. |
| int spdk_pipe_writer_advance | ( | struct spdk_pipe * | pipe, |
| uint32_t | count | ||
| ) |
Advance the write pointer by the given number of bytes.
The user can obtain memory from the pipe using spdk_pipe_writer_get_buffer(), but only calling this function marks it as consumed. The user is not required to advance the same number of bytes as was obtained from spdk_pipe_writer_get_buffer(). However, upon calling this function, the previous memory region is considered invalid and the user must call spdk_pipe_writer_get_buffer() again to obtain additional memory.
The user cannot advance past the current read location.
| pipe | The pipe to operate on. |
| count | The number of bytes to advance. |
| int spdk_pipe_writer_get_buffer | ( | struct spdk_pipe * | pipe, |
| uint32_t | sz, | ||
| struct iovec * | iovs | ||
| ) |
Acquire memory from the pipe for writing.
This function will acquire up to sz bytes from the pipe to be used for writing. It may return fewer total bytes.
The memory is only marked as consumed upon a call to spdk_pipe_writer_advance(). Multiple calls to this function without calling advance return the same region of memory.
| pipe | The pipe to operate on. |
| sz | The size requested. |
| iovs | A two element iovec array that will be populated with the requested memory. |