summaryrefslogtreecommitdiffstats
path: root/lib/libc_r
diff options
context:
space:
mode:
authorjasone <jasone@FreeBSD.org>2000-04-27 00:59:44 +0000
committerjasone <jasone@FreeBSD.org>2000-04-27 00:59:44 +0000
commitf89de11e935baf078cf587d2294188f9e5c65349 (patch)
treea74583e073a27a7c43636acd6034c5fc78910c8e /lib/libc_r
parenta5a543c27bf6808ea0d0a258890809714d4a7445 (diff)
downloadFreeBSD-src-f89de11e935baf078cf587d2294188f9e5c65349.zip
FreeBSD-src-f89de11e935baf078cf587d2294188f9e5c65349.tar.gz
Add a wrapper for the sendfile() system call.
PR: bin/17366
Diffstat (limited to 'lib/libc_r')
-rw-r--r--lib/libc_r/Makefile4
-rw-r--r--lib/libc_r/uthread/Makefile.inc1
-rw-r--r--lib/libc_r/uthread/uthread_sendfile.c154
3 files changed, 158 insertions, 1 deletions
diff --git a/lib/libc_r/Makefile b/lib/libc_r/Makefile
index 1b0afbb..0092a44 100644
--- a/lib/libc_r/Makefile
+++ b/lib/libc_r/Makefile
@@ -16,6 +16,8 @@ CFLAGS+=-I${.CURDIR}/../../include
# thread locking.
CFLAGS+=-D_LOCK_DEBUG
+DEBUG_FLAGS=-g3
+
# enable extra internal consistancy checks
# CFLAGS+=-D_PTHREADS_INVARIANTS
@@ -31,7 +33,7 @@ HIDDEN_SYSCALLS= aio_suspend.o accept.o bind.o close.o connect.o dup.o dup2.o \
flock.o fpathconf.o fstat.o fstatfs.o fsync.o getdirentries.o \
getlogin.o getpeername.o getsockname.o getsockopt.o ioctl.o listen.o \
msync.o nanosleep.o nfssvc.o open.o poll.o read.o readv.o recvfrom.o \
- recvmsg.o sched_yield.o select.o sendmsg.o sendto.o \
+ recvmsg.o sched_yield.o select.o sendfile.o sendmsg.o sendto.o \
setsockopt.o shutdown.o sigaction.o sigaltstack.o \
signanosleep.o sigpending.o sigprocmask.o sigreturn.o sigsetmask.o \
sigsuspend.o socket.o \
diff --git a/lib/libc_r/uthread/Makefile.inc b/lib/libc_r/uthread/Makefile.inc
index a88f955..68c3ae4 100644
--- a/lib/libc_r/uthread/Makefile.inc
+++ b/lib/libc_r/uthread/Makefile.inc
@@ -92,6 +92,7 @@ SRCS+= \
uthread_select.c \
uthread_self.c \
uthread_sem.c \
+ uthread_sendfile.c \
uthread_sendmsg.c \
uthread_sendto.c \
uthread_seterrno.c \
diff --git a/lib/libc_r/uthread/uthread_sendfile.c b/lib/libc_r/uthread/uthread_sendfile.c
new file mode 100644
index 0000000..694f1ff
--- /dev/null
+++ b/lib/libc_r/uthread/uthread_sendfile.c
@@ -0,0 +1,154 @@
+/*
+ * Copyright (C) 2000 Jason Evans <jasone@canonware.com>.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ * notice(s), this list of conditions and the following disclaimer as
+ * the first lines of this file unmodified other than the possible
+ * addition of one or more copyright notices.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice(s), this list of conditions and the following disclaimer in
+ * the documentation and/or other materials provided with the
+ * distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDER(S) ``AS IS'' AND ANY
+ * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+ * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER(S) BE
+ * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+ * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+ * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
+ * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
+ * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
+ * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,
+ * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ *
+ * $FreeBSD$
+ */
+
+#include <sys/fcntl.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/uio.h>
+#include <errno.h>
+#ifdef _THREAD_SAFE
+#include <pthread.h>
+#include "pthread_private.h"
+
+int
+sendfile(int fd, int s, off_t offset, size_t nbytes, struct sf_hdtr *hdtr,
+ off_t *sbytes, int flags)
+{
+ int ret, type, blocking;
+ ssize_t wvret, num = 0;
+ off_t n, nwritten = 0;
+
+ /* Write the headers if any. */
+ if ((hdtr != NULL) && (hdtr->headers != NULL)) {
+ if (wvret = writev(s, hdtr->headers, hdtr->hdr_cnt) == -1) {
+ ret = -1;
+ goto ERROR;
+ } else
+ nwritten += wvret;
+ }
+
+ /* Lock the descriptors. */
+ if ((ret = _FD_LOCK(fd, FD_READ, NULL)) != 0) {
+ ret = -1;
+ errno = EBADF;
+ goto ERROR;
+ }
+ if ((ret = _FD_LOCK(s, FD_WRITE, NULL)) != 0) {
+ ret = -1;
+ errno = EBADF;
+ goto ERROR_1;
+ }
+
+ /* Check the descriptor access modes. */
+ type = _thread_fd_table[fd]->flags & O_ACCMODE;
+ if (type != O_RDONLY && type != O_RDWR) {
+ /* File is not open for read. */
+ ret = -1;
+ errno = EBADF;
+ goto ERROR_2;
+ }
+ type = _thread_fd_table[s]->flags & O_ACCMODE;
+ if (type != O_WRONLY && type != O_RDWR) {
+ /* File is not open for write. */
+ ret = -1;
+ errno = EBADF;
+ goto ERROR_2;
+ }
+
+ /* Check if file operations are to block */
+ blocking = ((_thread_fd_table[s]->flags & O_NONBLOCK) == 0);
+
+ /*
+ * Loop while no error occurs and until the expected number of bytes are
+ * written.
+ */
+ for (;;) {
+ /* Perform a non-blocking sendfile syscall. */
+ ret = _thread_sys_sendfile(fd, s, offset + num, nbytes - num,
+ NULL, &n, flags);
+
+ if (ret == 0) {
+ /* Writing completed. */
+ num += n;
+ break;
+ } else if ((blocking) && (ret == -1) && (errno == EAGAIN)) {
+ /*
+ * Some bytes were written but there are still more to
+ * write.
+ */
+
+ /* Update the count of bytes written. */
+ num += n;
+
+ _thread_run->data.fd.fd = fd;
+ _thread_kern_set_timeout(NULL);
+
+ /* Reset the interrupted operation flag. */
+ _thread_run->interrupted = 0;
+
+ _thread_kern_sched_state(PS_FDW_WAIT, __FILE__,
+ __LINE__);
+
+ if (_thread_run->interrupted) {
+ /* Interrupted by a signal. Return an error. */
+ break;
+ }
+ } else {
+ /* Incomplete non-blocking syscall, or error. */
+ break;
+ }
+ }
+
+ ERROR_2:
+ _FD_UNLOCK(s, FD_WRITE);
+ ERROR_1:
+ _FD_UNLOCK(fd, FD_READ);
+ ERROR:
+ if (ret == 0) {
+ /* Write the trailers, if any. */
+ if ((hdtr != NULL) && (hdtr->trailers != NULL)) {
+ if (wvret = writev(s, hdtr->trailers, hdtr->trl_cnt)
+ == -1)
+ ret = -1;
+ else
+ nwritten += wvret;
+ }
+ }
+ if (sbytes != NULL) {
+ /*
+ * Number of bytes written in headers/trailers, plus in the main
+ * sendfile() loop.
+ */
+ *sbytes = nwritten + num;
+ }
+ return ret;
+}
+#endif
OpenPOWER on IntegriCloud