summaryrefslogtreecommitdiff
path: root/src/network_freebsd_sendfile.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/network_freebsd_sendfile.c')
-rw-r--r--src/network_freebsd_sendfile.c157
1 files changed, 0 insertions, 157 deletions
diff --git a/src/network_freebsd_sendfile.c b/src/network_freebsd_sendfile.c
deleted file mode 100644
index 446e1fe7..00000000
--- a/src/network_freebsd_sendfile.c
+++ /dev/null
@@ -1,157 +0,0 @@
-#include "network_backends.h"
-
-#ifdef USE_FREEBSD_SENDFILE
-
-#include <sys/types.h>
-#include <sys/socket.h>
-#include <sys/stat.h>
-#include <sys/time.h>
-#include <sys/resource.h>
-
-#include <netinet/in.h>
-#include <netinet/tcp.h>
-
-#include <errno.h>
-#include <fcntl.h>
-#include <unistd.h>
-#include <netdb.h>
-#include <string.h>
-#include <stdlib.h>
-
-#include "network.h"
-#include "fdevent.h"
-#include "log.h"
-#include "stat_cache.h"
-
-
-#ifndef UIO_MAXIOV
-# if defined(__FreeBSD__) || defined(__DragonFly__)
-/* FreeBSD 4.7, 4.9 defined it in sys/uio.h only if _KERNEL is specified */
-# define UIO_MAXIOV 1024
-# endif
-#endif
-
-NETWORK_BACKEND_WRITE(freebsdsendfile) {
- chunk *c;
- size_t chunks_written = 0;
-
- for(c = cq->first; c; c = c->next, chunks_written++) {
- chunk *tc;
- int chunk_finished = 0;
- network_status_t ret;
-
- switch(c->type) {
- case MEM_CHUNK:
- ret = network_write_chunkqueue_writev_mem(srv, con, sock, cq, c);
-
- /* check which chunks are finished now */
- for (tc = c; tc; tc = tc->next) {
- /* finished the chunk */
- if (tc->offset == tc->mem->used - 1) {
- /* skip the first c->next as that will be done by the c = c->next in the other for()-loop */
- if (chunk_finished) {
- c = c->next;
- } else {
- chunk_finished = 1;
- }
- } else {
- break;
- }
- }
-
- if (ret != NETWORK_STATUS_SUCCESS) {
- return ret;
- }
-
- break;
- case FILE_CHUNK: {
- off_t offset, r;
- size_t toSend;
- stat_cache_entry *sce = NULL;
-
- if (HANDLER_ERROR == stat_cache_get_entry(srv, con, c->file.name, &sce)) {
- log_error_write(srv, __FILE__, __LINE__, "sb",
- strerror(errno), c->file.name);
- return NETWORK_STATUS_FATAL_ERROR;
- }
-
- offset = c->file.start + c->offset;
- /* limit the toSend to 2^31-1 bytes in a chunk */
- toSend = c->file.length - c->offset > ((1 << 30) - 1) ?
- ((1 << 30) - 1) : c->file.length - c->offset;
-
- if (-1 == c->file.fd) {
- if (-1 == (c->file.fd = open(c->file.name->ptr, O_RDONLY))) {
- switch (errno) {
- case EMFILE:
- return NETWORK_STATUS_WAIT_FOR_FD;
- default:
- ERROR("opening '%s' failed: %s", SAFE_BUF_STR(c->file.name), strerror(errno));
-
- return NETWORK_STATUS_FATAL_ERROR;
- }
-
- return NETWORK_STATUS_FATAL_ERROR;
- }
- }
-
- r = 0;
-
- /* FreeBSD sendfile() */
- if (-1 == sendfile(c->file.fd, sock->fd, offset, toSend, NULL, &r, 0)) {
- switch(errno) {
- case EAGAIN:
- break;
- case ENOTCONN:
- return NETWORK_STATUS_CONNECTION_CLOSE;
- default:
- log_error_write(srv, __FILE__, __LINE__, "ssd", "sendfile: ", strerror(errno), errno);
- return NETWORK_STATUS_FATAL_ERROR;
- }
- }
-
- if (r == 0) {
- /* We got an event to write but we wrote nothing
- *
- * - the file shrinked -> error
- * - the remote side closed inbetween -> remote-close */
-
- if (HANDLER_ERROR == stat_cache_get_entry(srv, con, c->file.name, &sce)) {
- /* file is gone ? */
- return NETWORK_STATUS_FATAL_ERROR;
- }
-
- if (offset > sce->st.st_size) {
- /* file shrinked, close the connection */
- return NETWORK_STATUS_FATAL_ERROR;
- }
-
- return NETWORK_STATUS_CONNECTION_CLOSE;
- }
-
- c->offset += r;
- cq->bytes_out += r;
-
- if (c->offset == c->file.length) {
- chunk_finished = 1;
- }
-
- break;
- }
- default:
- ERROR("chunk-type '%d' not known", c->type);
-
- return NETWORK_STATUS_FATAL_ERROR;
- }
-
- if (!chunk_finished) {
- /* not finished yet */
-
- return NETWORK_STATUS_WAIT_FOR_EVENT;
- }
- }
-
- return NETWORK_STATUS_SUCCESS;
-}
-
-#endif