diff options
| author | Quentin Young <qlyoung@nvidia.com> | 2021-04-26 18:42:19 -0400 |
|---|---|---|
| committer | Quentin Young <qlyoung@nvidia.com> | 2021-04-29 12:12:32 -0400 |
| commit | 6c55ee964e600cba385afabb8438b9d09eb509f2 (patch) | |
| tree | 00d2573aeaee899b63d64d84118254a64327a742 /lib/ringbuf.c | |
| parent | fe2e3bae6a2207f97437c84f8a7525a7b31f38d6 (diff) | |
Revert "lib: add ringbuf socket read function"
This reverts commit d9d7af1a52d77ed0074ebb72f87678308296e74e.
Diffstat (limited to 'lib/ringbuf.c')
| -rw-r--r-- | lib/ringbuf.c | 35 |
1 files changed, 0 insertions, 35 deletions
diff --git a/lib/ringbuf.c b/lib/ringbuf.c index 49221e7cb3..6efa8077c2 100644 --- a/lib/ringbuf.c +++ b/lib/ringbuf.c @@ -131,38 +131,3 @@ void ringbuf_wipe(struct ringbuf *buf) memset(buf->data, 0x00, buf->size); ringbuf_reset(buf); } - -ssize_t ringbuf_read(struct ringbuf *buf, int sock) -{ - size_t to_read = ringbuf_space(buf); - size_t bytes_to_end = buf->size - buf->end; - ssize_t bytes_read; - struct iovec iov[2] = {}; - - /* Calculate amount of read blocks. */ - if (to_read > bytes_to_end) { - iov[0].iov_base = buf->data + buf->end; - iov[0].iov_len = bytes_to_end; - iov[1].iov_base = buf->data; - iov[1].iov_len = to_read - bytes_to_end; - } else { - iov[0].iov_base = buf->data + buf->end; - iov[0].iov_len = to_read; - } - - /* Do the system call. */ - bytes_read = readv(sock, iov, 2); - if (bytes_read <= 0) - return bytes_read; - - /* Calculate the new end. */ - if ((size_t)bytes_read > bytes_to_end) - buf->end = bytes_read - bytes_to_end; - else - buf->end += bytes_read; - - /* Set emptiness state. */ - buf->empty = (buf->start == buf->end) && (buf->empty && !bytes_read); - - return bytes_read; -} |
