diff options
| author | Amar Tumballi <amarts@redhat.com> | 2012-07-11 22:25:30 +0530 | 
|---|---|---|
| committer | Anand Avati <avati@redhat.com> | 2012-07-11 16:29:58 -0700 | 
| commit | ea08bf886732d9680f2d6de19f3d68908a55143b (patch) | |
| tree | e7531a52b1ece148ad049e3d150e1dbe3c00a41f /mod_glusterfs/lighttpd/1.5/mod_glusterfs.c | |
| parent | cb60a046bbb24cc864aa007707c75bdadf2157e3 (diff) | |
core: remove unused code
BUG: 764890
Change-Id: Ia8bcaa7a4daeb706bcb0bba24b2e634e9ca20d49
Signed-off-by: Amar Tumballi <amarts@redhat.com>
Reviewed-on: http://review.gluster.com/3657
Tested-by: Gluster Build System <jenkins@build.gluster.com>
Reviewed-by: Anand Avati <avati@redhat.com>
Diffstat (limited to 'mod_glusterfs/lighttpd/1.5/mod_glusterfs.c')
| -rw-r--r-- | mod_glusterfs/lighttpd/1.5/mod_glusterfs.c | 1476 | 
1 files changed, 0 insertions, 1476 deletions
diff --git a/mod_glusterfs/lighttpd/1.5/mod_glusterfs.c b/mod_glusterfs/lighttpd/1.5/mod_glusterfs.c deleted file mode 100644 index 67f7a7eacf5..00000000000 --- a/mod_glusterfs/lighttpd/1.5/mod_glusterfs.c +++ /dev/null @@ -1,1476 +0,0 @@ -/* -  Copyright (c) 2008-2011 Gluster, Inc. <http://www.gluster.com> -  This file is part of GlusterFS. - -  GlusterFS is free software; you can redistribute it and/or modify -  it under the terms of the GNU General Public License as published -  by the Free Software Foundation; either version 3 of the License, -  or (at your option) any later version. - -  GlusterFS is distributed in the hope that it will be useful, but -  WITHOUT ANY WARRANTY; without even the implied warranty of -  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU -  General Public License for more details. - -  You should have received a copy of the GNU General Public License -  along with this program.  If not, see -  <http://www.gnu.org/licenses/>. -*/ - -#include <ctype.h> -#include <stdlib.h> -#include <stdio.h> -#include <string.h> -#include <pthread.h> -#include <sys/types.h> -#include <fcntl.h> - -#include <sys/types.h> -#include <sys/stat.h> - -#include <errno.h> -#include <unistd.h> -#include <assert.h> - -#include "base.h" -#include "log.h" -#include "buffer.h" - -#include "plugin.h" - -#include "stat_cache.h" -#include "mod_glusterfs.h" -#include "etag.h" -#include "response.h" - -#include "fdevent.h" -#include "joblist.h" -#include "http_req_range.h" -#include "connections.h" -#include "configfile.h" - -#include <libglusterfsclient.h> - -#ifdef HAVE_ATTR_ATTRIBUTES_H -#include <attr/attributes.h> -#endif - -#ifdef HAVE_FAM_H -# include <fam.h> -#endif - -#include "sys-mmap.h" - -/* NetBSD 1.3.x needs it */ -#ifndef MAP_FAILED -# define MAP_FAILED -1 -#endif - -#ifndef O_LARGEFILE -# define O_LARGEFILE 0 -#endif - -#ifndef HAVE_LSTAT -#define lstat stat -#endif - -#if 0 -/* enables debug code for testing if all nodes in the stat-cache as accessable */ -#define DEBUG_STAT_CACHE -#endif - -#ifdef HAVE_LSTAT -#undef HAVE_LSTAT -#endif - -#define GLUSTERFS_FILE_CHUNK (FILE_CHUNK + 1) - -/* Keep this value large. Each glusterfs_async_read of GLUSTERFS_CHUNK_SIZE results in a network_backend_write of the read data*/ - -#define GLUSTERFS_CHUNK_SIZE 8192 - -/** - * this is a staticfile for a lighttpd plugin - * - */ - - -/* plugin config for all request/connections */ - -typedef struct { -        buffer *logfile; -        buffer *loglevel; -        buffer *specfile; -        buffer *prefix; -        buffer *xattr_file_size; -        buffer *document_root; -        array *exclude_exts; -        unsigned short cache_timeout; - -        /* FIXME: its a pointer, hence cant be short */ -        unsigned long handle; -} plugin_config; - -static network_status_t (*network_backend_write)(struct server *srv, connection *con, iosocket *sock, chunkqueue *cq); - -typedef struct { -        PLUGIN_DATA; -        buffer *range_buf; -        plugin_config **config_storage; -        http_req_range *ranges; -        plugin_config conf; -} plugin_data; - -typedef struct glusterfs_async_local { -        int op_ret; -        int op_errno; -        pthread_mutex_t lock; -        pthread_cond_t cond; -        connection *con; -        server *srv; -        plugin_data *p; - -        union { -                struct { -                        char async_read_complete; -                        off_t length; -                        size_t read_bytes; -                        glusterfs_read_buf_t *buf; -                }readv; - -                struct { -                        buffer *name; -                        buffer *hash_key; -                        size_t size; -                }lookup; -        }fop; -} glusterfs_async_local_t; - -typedef struct { -        unsigned long fd; -        buffer *glusterfs_path; -        void *buf; -        off_t response_content_length; -        int prefix; -}mod_glusterfs_ctx_t; - -typedef struct { -        chunkqueue *cq; -        glusterfs_read_buf_t *buf; -        size_t length; -}mod_glusterfs_chunkqueue; - -#ifdef HAVE_FAM_H -typedef struct { -        FAMRequest *req; -        FAMConnection *fc; - -        buffer *name; - -        int version; -} fam_dir_entry; -#endif - -/* the directory name is too long to always compare on it - * - we need a hash - * - the hash-key is used as sorting criteria for a tree - * - a splay-tree is used as we can use the caching effect of it - */ - -/* we want to cleanup the stat-cache every few seconds, let's say 10 - * - * - remove entries which are outdated since 30s - * - remove entries which are fresh but havn't been used since 60s - * - if we don't have a stat-cache entry for a directory, release it from the monitor - */ - -#ifdef DEBUG_STAT_CACHE -typedef struct { -        int *ptr; - -        size_t used; -        size_t size; -} fake_keys; - -static fake_keys ctrl; -#endif - -static stat_cache_entry *  -stat_cache_entry_init(void)  -{ -        stat_cache_entry *sce = NULL; - -        sce = calloc(1, sizeof(*sce)); -        /* ERR_ABORT (sce); */ - -        sce->name = buffer_init(); -        sce->etag = buffer_init(); -        sce->content_type = buffer_init(); - -        return sce; -} - -int chunkqueue_append_glusterfs_mem (chunkqueue *cq, const char * mem, size_t len) { -        buffer *buf = NULL; -  -        buf = chunkqueue_get_append_buffer (cq); - -        if (buf->ptr) -                free (buf->ptr); - -        buf->used = len + 1; -        buf->ptr = (char *)mem; -        buf->size = len; - -        return 0; -} - -static int -glusterfs_lookup_async_cbk (int op_ret,  -                            int op_errno, -                            void *buf, -                            struct stat *st, -                            void *cbk_data) -{ -        glusterfs_async_local_t *local = cbk_data; - -        mod_glusterfs_ctx_t *ctx = NULL; -        ctx = local->con->plugin_ctx[local->p->id]; - -        assert (ctx->buf== buf); - -        if (op_ret || !(S_ISREG (st->st_mode) && (size_t)st->st_size <= local->fop.lookup.size)) { - -                free (ctx->buf); -                ctx->buf = NULL; - -                if (op_ret) { -                        buffer_free (ctx->glusterfs_path); -                        ctx->glusterfs_path = NULL; -                        free (ctx); -                        local->con->plugin_ctx[local->p->id] = NULL; - -                        if (op_errno == ENOENT) -                                local->con->http_status = 404; -                        else  -                                local->con->http_status = 403; -                } -        } - -        if (!op_ret) { -                stat_cache_entry *sce = NULL; -                stat_cache *sc = local->srv->stat_cache; - -                sce = (stat_cache_entry *)g_hash_table_lookup(sc->files, local->fop.lookup.hash_key); - -                if (!sce) { -                        sce = stat_cache_entry_init(); - -                        buffer_copy_string_buffer(sce->name, local->fop.lookup.name); -                        g_hash_table_insert(sc->files, buffer_init_string(BUF_STR(local->fop.lookup.hash_key)), sce); -                } - -                sce->state = STAT_CACHE_ENTRY_STAT_FINISHED; -                sce->stat_ts = time (NULL); -                memcpy (&sce->st, st, sizeof (*st)); -        } - -        g_async_queue_push (local->srv->joblist_queue, local->con); -        /* -          joblist_append (local->srv, local->con); -          kill (getpid(), SIGUSR1); -        */ -        free (local); -        return 0; -} - -static handler_t -glusterfs_stat_cache_get_entry_async (server *srv,  -                                      connection *con,  -                                      plugin_data *p, -                                      buffer *glusterfs_path, -                                      buffer *name, -                                      void *buf, -                                      size_t size, -                                      stat_cache_entry **ret_sce) -{ -        stat_cache_entry *sce = NULL; -        stat_cache *sc; -        glusterfs_async_local_t *local = NULL; - -        *ret_sce = NULL; - -        /* -         * check if the directory for this file has changed -         */ - -        sc = srv->stat_cache; - -        buffer_copy_string_buffer(sc->hash_key, name); -        buffer_append_long(sc->hash_key, con->conf.follow_symlink); - -        if ((sce = (stat_cache_entry *)g_hash_table_lookup(sc->files, sc->hash_key))) { -                /* know this entry already */ - -                if (sce->state == STAT_CACHE_ENTRY_STAT_FINISHED &&  -                    !buf) { -                        /* verify that this entry is still fresh */ - -                        *ret_sce = sce; - -                        return HANDLER_GO_ON; -                } -        } - - -        /* -         * *lol* -         * - open() + fstat() on a named-pipe results in a (intended) hang. -         * - stat() if regular file + open() to see if we can read from it is better -         * -         * */ - -        /* pass a job to the stat-queue */ - -        local = calloc (1, sizeof (*local)); -        /* ERR_ABORT (local); */ -        local->con = con; -        local->srv = srv; -        local->p = p; -        local->fop.lookup.name = buffer_init_buffer (name); -        local->fop.lookup.hash_key = buffer_init_buffer (sc->hash_key); -        local->fop.lookup.size = size; - -        if (glusterfs_lookup_async ((libglusterfs_handle_t )p->conf.handle, glusterfs_path->ptr, buf, size, glusterfs_lookup_async_cbk, (void *) local)) { -                free (local); -                return HANDLER_ERROR; -        } - -        return HANDLER_WAIT_FOR_EVENT; -} - -int  -mod_glusterfs_readv_async_cbk (glusterfs_read_buf_t *buf, -                               void *cbk_data) -{ -        glusterfs_async_local_t *local = cbk_data; -        pthread_mutex_lock (&local->lock); -        { -                local->fop.readv.async_read_complete = 1; -                local->fop.readv.buf = buf; - -                pthread_cond_signal (&local->cond); -        } -        pthread_mutex_unlock (&local->lock); - -        return 0; -} - -network_status_t  -mod_glusterfs_read_async (server *srv, connection *con, chunk *glusterfs_chunk) -{ -        glusterfs_async_local_t local; -        off_t end = 0; -        int nbytes; -        int complete; -        chunkqueue *cq = NULL; -        chunk *c = NULL; -        off_t offset = glusterfs_chunk->file.start; -        size_t length = glusterfs_chunk->file.length; -        unsigned long fd = (unsigned long)glusterfs_chunk->file.name; -        network_status_t ret; - -        pthread_cond_init (&local.cond, NULL); -        pthread_mutex_init (&local.lock, NULL); -   -        //local.fd = fd; -        memset (&local, 0, sizeof (local)); - -        if (length > 0) -                end = offset + length; - -        cq = chunkqueue_init (); -        if (!cq) { -                con->http_status = 500; -                return NETWORK_STATUS_FATAL_ERROR; -        } - -        do { -                glusterfs_read_buf_t *buf; -                int i; -                if (length > 0) { -                        nbytes = end - offset; -                        if (nbytes > GLUSTERFS_CHUNK_SIZE) -                                nbytes = GLUSTERFS_CHUNK_SIZE; -                } else -                        nbytes = GLUSTERFS_CHUNK_SIZE; - -                glusterfs_read_async(fd,  -                                     nbytes, -                                     offset, -                                     mod_glusterfs_readv_async_cbk, -                                     (void *)&local); - -                pthread_mutex_lock (&local.lock); -                { -                        while (!local.fop.readv.async_read_complete) { -                                pthread_cond_wait (&local.cond, &local.lock); -                        } - -                        local.op_ret = local.fop.readv.buf->op_ret; -                        local.op_errno = local.fop.readv.buf->op_errno; - -                        local.fop.readv.async_read_complete = 0; -                        buf = local.fop.readv.buf; - -                        if ((int)length < 0) -                                complete = (local.fop.readv.buf->op_ret <= 0); -                        else { -                                local.fop.readv.read_bytes += local.fop.readv.buf->op_ret; -                                complete = ((local.fop.readv.read_bytes == length) || (local.fop.readv.buf->op_ret <= 0)); -                        } -                } -                pthread_mutex_unlock (&local.lock); - -                if (local.op_ret > 0) { -                        for (i = 0; i < buf->count; i++) { -                                buffer *nw_write_buf = chunkqueue_get_append_buffer (cq); - -                                nw_write_buf->used = nw_write_buf->size = buf->vector[i].iov_len + 1; -                                nw_write_buf->ptr = buf->vector[i].iov_base; - -                                //      buffer_copy_memory (nw_write_buf, buf->vector[i].iov_base, buf->vector[i].iov_len + 1); -                                offset += local.op_ret; -                        } -   -                        ret = network_backend_write (srv, con, con->sock, cq); -   -                        if (chunkqueue_written (cq) != local.op_ret) { -                                mod_glusterfs_chunkqueue *gf_cq; -                                glusterfs_chunk->file.start = offset; -                                if ((int)glusterfs_chunk->file.length > 0) -                                        glusterfs_chunk->file.length -= local.fop.readv.read_bytes; - -                                gf_cq = calloc (1, sizeof (*gf_cq)); -                                /* ERR_ABORT (qf_cq); */ -                                gf_cq->cq = cq; -                                gf_cq->buf = buf; -                                gf_cq->length = local.op_ret; -                                glusterfs_chunk->file.mmap.start = (char *)gf_cq; -                                return ret; -                        } -       -                        for (c = cq->first ; c; c = c->next)  -                                c->mem->ptr = NULL; - -                        chunkqueue_reset (cq); -                } - -                glusterfs_free (buf); -        } while (!complete); - -        chunkqueue_free (cq); -        glusterfs_close (fd); - -        if (local.op_ret < 0) -                con->http_status = 500; - -        return (local.op_ret < 0 ? NETWORK_STATUS_FATAL_ERROR : NETWORK_STATUS_SUCCESS); -} - -network_status_t mod_glusterfs_network_backend_write(struct server *srv, connection *con, iosocket *sock, chunkqueue *cq) -{ -        chunk *c, *prev, *first; -        int chunks_written = 0; -        int error = 0; -        network_status_t ret; - -        for (first = prev = c = cq->first; c; c = c->next, chunks_written++) { - -                if (c->type == MEM_CHUNK && c->mem->used && !c->mem->ptr) { -                        if (cq->first != c) { -                                prev->next = NULL; - -                                /* call stored network_backend_write */ -                                ret = network_backend_write (srv, con, sock, cq); - -                                prev->next = c; -                                if (ret != NETWORK_STATUS_SUCCESS) { -                                        cq->first = first; -                                        return ret; -                                } -                        }  -                        cq->first = c->next; - -                        if (c->file.fd < 0) { -                                error = HANDLER_ERROR; -                                break; -                        } - -                        if (c->file.mmap.start) { -                                chunk *tmp; -                                size_t len; -                                mod_glusterfs_chunkqueue *gf_cq = (mod_glusterfs_chunkqueue *)c->file.mmap.start; - -                                ret = network_backend_write (srv, con, sock, gf_cq->cq); - -                                if ((len = (size_t)chunkqueue_written (gf_cq->cq)) != gf_cq->length) { -                                        gf_cq->length -= len; -                                        cq->first = first; -                                        chunkqueue_remove_finished_chunks (gf_cq->cq); -                                        return ret; -                                } - -                                for (tmp = gf_cq->cq->first ; tmp; tmp = tmp->next) -                                        tmp->mem->ptr = NULL; - -                                chunkqueue_free (gf_cq->cq); -                                glusterfs_free (gf_cq->buf); -                                free (gf_cq); -                                c->file.mmap.start = NULL; -                        } -       -                        ret = mod_glusterfs_read_async (srv, con, c); //c->file.fd, c->file.start, -1);//c->file.length); -                        if (c->file.mmap.start) { -                                /* pending chunkqueue from mod_glusterfs_read_async to be written to network */ -                                cq->first = first; -                                return ret; -                        } - -                        buffer_free (c->mem); -                        c->mem = NULL; - -                        c->type = FILE_CHUNK; -                        c->offset = c->file.length = 0; -                        c->file.name = NULL; - -                        if (first == c) -                                first = c->next; - -                        if (cq->last == c) -                                cq->last = NULL; - -                        prev->next = c->next; - -                        free(c); -                }      -                prev = c; -        } - -        ret = network_backend_write (srv, con, sock, cq); - -        cq->first = first; - -        return ret; -} - -#if 0 -int chunkqueue_append_glusterfs_file (chunkqueue *cq, unsigned long fd, off_t offset, off_t len) -{ -        chunk *c = NULL; -        c = chunkqueue_get_append_tempfile (cq); -   -        if (c->file.is_temp) { -                close (c->file.fd); -                unlink (c->file.name->ptr); -        } - -        c->type = MEM_CHUNK; - -        c->mem = buffer_init (); -        c->mem->used = len + 1; -        c->mem->ptr = NULL; -        c->offset = 0; - -        /*  buffer_copy_string_buffer (c->file.name, fn); */ -        c->file.start = offset; -        c->file.length = len; -        /*  buffer_free (c->file.name); */ - -        /* identify chunk as glusterfs related */ -        c->file.mmap.start = MAP_FAILED; -        /*  c->file.mmap.length = c->file.mmap.offset = len;*/ - -        return 0; -} -#endif - -int chunkqueue_append_dummy_mem_chunk (chunkqueue *cq, off_t len) -{ -        chunk *c = NULL; -        c = chunkqueue_get_append_tempfile (cq); -   -        if (c->file.is_temp) { -                close (c->file.fd); -                unlink (c->file.name->ptr); -                c->file.is_temp = 0; -        } - -        c->type = MEM_CHUNK; - -        c->mem->used = len + 1; -        c->offset = len; -        c->mem->ptr = NULL; - -        return 0; -} - -int chunkqueue_append_glusterfs_file (chunkqueue *cq, unsigned long fd, off_t offset, off_t len) -{ -        chunk *c = NULL; -        c = chunkqueue_get_append_tempfile (cq); -   -        if (c->file.is_temp) { -                close (c->file.fd); -                unlink (c->file.name->ptr); -                c->file.is_temp = 0; -        } - -        c->type = MEM_CHUNK; - -        c->mem = buffer_init (); -        c->mem->used = len + 1; -        c->mem->ptr = NULL; -        c->offset = 0; - -        /*  buffer_copy_string_buffer (c->file.name, fn); */ -        buffer_free (c->file.name); - -        /* fd returned by libglusterfsclient is a pointer */ -        c->file.name = (buffer *)fd; -        c->file.start = offset; -        c->file.length = len; - -        //c->file.fd = fd; -        c->file.mmap.start = NULL; -        return 0; -} - -/* init the plugin data */ -INIT_FUNC(mod_glusterfs_init) { -        plugin_data *p; - -        UNUSED (srv); -        p = calloc(1, sizeof(*p)); -        /* ERR_ABORT (p); */ -        network_backend_write = NULL; -        p->ranges = http_request_range_init(); -        return p; -} - -/* detroy the plugin data */ -FREE_FUNC(mod_glusterfs_free) { -        plugin_data *p = p_d; - -        UNUSED (srv); - -        if (!p) return HANDLER_GO_ON; -   -        if (p->config_storage) { -                size_t i; -                for (i = 0; i < srv->config_context->used; i++) { -                        plugin_config *s = p->config_storage[i]; -       -                        buffer_free (s->logfile); -                        buffer_free (s->loglevel); -                        buffer_free (s->specfile); -                        buffer_free (s->prefix); -                        buffer_free (s->xattr_file_size); -                        buffer_free (s->document_root); -                        array_free (s->exclude_exts); -   -                        free (s); -                } -                free (p->config_storage); -        } -        buffer_free (p->range_buf); -        http_request_range_free (p->ranges); - -        free (p); -   -        return HANDLER_GO_ON; -} - -SETDEFAULTS_FUNC(mod_glusterfs_set_defaults) { -        plugin_data *p = p_d; -        size_t i = 0; -   -        config_values_t cv[] = { -                { "glusterfs.logfile",              NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION }, -     -                { "glusterfs.loglevel",             NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION },          -                { "glusterfs.volume-specfile",             NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION },           -                { "glusterfs.cache-timeout",              NULL, T_CONFIG_SHORT, T_CONFIG_SCOPE_CONNECTION }, -     -                { "glusterfs.exclude-extensions",   NULL, T_CONFIG_ARRAY, T_CONFIG_SCOPE_CONNECTION }, -     -                /*TODO: get the prefix from config_conext and remove glusterfs.prefix from conf file */ -                { "glusterfs.prefix", NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION }, -     -                { "glusterfs.xattr-interface-size-limit", NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION }, - -                { "glusterfs.document-root", NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION }, -     -                { NULL,                          NULL, T_CONFIG_UNSET, T_CONFIG_SCOPE_UNSET } -        }; -   -        p->config_storage = calloc(1, srv->config_context->used * sizeof(specific_config *)); -        /* ERR_ABORT (p->config_storage); */ -        p->range_buf = buffer_init (); -   -        for (i = 0; i < srv->config_context->used; i++) { -                plugin_config *s; - -                s = calloc(1, sizeof(plugin_config)); -                /* ERR_ABORT (s); */ -                s->logfile = buffer_init (); -                s->loglevel = buffer_init (); -                s->specfile = buffer_init (); -                s->exclude_exts = array_init (); -                s->prefix = buffer_init (); -                s->xattr_file_size = buffer_init (); -                s->document_root = buffer_init (); -     -                cv[0].destination = s->logfile; -                cv[1].destination = s->loglevel; -                cv[2].destination = s->specfile; -                cv[3].destination = &s->cache_timeout; -                cv[4].destination = s->exclude_exts; -                cv[5].destination = s->prefix; -                cv[6].destination = s->xattr_file_size; -                cv[7].destination = s->document_root; - -                p->config_storage[i] = s; -     -                if (0 != config_insert_values_global(srv, ((data_config *)srv->config_context->data[i])->value, cv)) { -                        return HANDLER_FINISHED; -                } -        } -   -        return HANDLER_GO_ON; -} - -#define PATCH(x)                                \ -        p->conf.x = s->x; - -static int mod_glusterfs_patch_connection(server *srv, connection *con, plugin_data *p) { -        size_t i, j; -        plugin_config *s; - -        p->conf.logfile = NULL; -        p->conf.loglevel = NULL; -        p->conf.specfile = NULL; -        p->conf.cache_timeout = 0; -        p->conf.exclude_exts = NULL; -        p->conf.prefix = NULL; -        p->conf.xattr_file_size = NULL; -        p->conf.exclude_exts = NULL; - -        /* skip the first, the global context */ -        /* glusterfs related config can only occur inside $HTTP["url"] == "<glusterfs-prefix>" */ -        for (i = 1; i < srv->config_context->used; i++) { -                data_config *dc = (data_config *)srv->config_context->data[i]; -                s = p->config_storage[i]; - -                /* condition didn't match */ -                if (!config_check_cond(srv, con, dc)) continue; -     -                /* merge config */ -                for (j = 0; j < dc->value->used; j++) { -                        data_unset *du = dc->value->data[j]; -       -                        if (buffer_is_equal_string (du->key, CONST_STR_LEN("glusterfs.logfile"))) { -                                PATCH (logfile); -                        } else if (buffer_is_equal_string (du->key, CONST_STR_LEN("glusterfs.loglevel"))) { -                                PATCH (loglevel); -                        } else if (buffer_is_equal_string (du->key, CONST_STR_LEN ("glusterfs.volume-specfile"))) { -                                PATCH (specfile); -                        } else if (buffer_is_equal_string (du->key, CONST_STR_LEN("glusterfs.cache-timeout"))) { -                                PATCH (cache_timeout); -                        } else if (buffer_is_equal_string (du->key, CONST_STR_LEN ("glusterfs.exclude-extensions"))) { -                                PATCH (exclude_exts); -                        } else if (buffer_is_equal_string (du->key, CONST_STR_LEN ("glusterfs.prefix"))) { -                                PATCH (prefix); -                        } else if (buffer_is_equal_string (du->key, CONST_STR_LEN ("glusterfs.xattr-interface-size-limit"))) { -                                PATCH (xattr_file_size); -                        } else if (buffer_is_equal_string (du->key, CONST_STR_LEN ("glusterfs.document-root"))) { -                                PATCH (document_root); -                        } -                } -        } -        return 0; -} - -#undef PATCH - -static int http_response_parse_range(server *srv, connection *con, plugin_data *p) { -        int multipart = 0; -        char *boundary = "fkj49sn38dcn3"; -        data_string *ds; -        stat_cache_entry *sce = NULL; -        buffer *content_type = NULL; -        buffer *range = NULL; -        http_req_range *ranges, *r; -        mod_glusterfs_ctx_t *ctx = con->plugin_ctx[p->id]; -        size_t size = 0; - -        if (!ctx) { -                return -1; -        } - -        if (NULL != (ds = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("Range")))) { -                range = ds->value; -        } else { -                /* we don't have a Range header */ - -                return -1; -        } - -        if (HANDLER_ERROR == stat_cache_get_entry(srv, con, con->physical.path, &sce)) { -                SEGFAULT(); -        } - -        ctx->response_content_length = con->response.content_length = 0; - -        if (NULL != (ds = (data_string *)array_get_element(con->response.headers, CONST_STR_LEN("Content-Type")))) { -                content_type = ds->value; -        } - -        /* start the range-header parser -         * bytes=<num>  */ - -        ranges = p->ranges; -        http_request_range_reset(ranges); -        switch (http_request_range_parse(range, ranges)) { -        case PARSE_ERROR: -                return -1; /* no range valid Range Header */ -        case PARSE_SUCCESS: -                break; -        default: -                TRACE("%s", "foobar"); -                return -1; -        } - -        if (ranges->next) { -                multipart = 1; -        } - -        if (p->conf.xattr_file_size && p->conf.xattr_file_size->ptr) { -                size = atoi (p->conf.xattr_file_size->ptr); -        } - -        /* patch the '-1' */ -        for (r = ranges; r; r = r->next) { -                if (r->start == -1) { -                        /* -<end> -                         * -                         * the last <end> bytes  */ -                        r->start = sce->st.st_size - r->end; -                        r->end = sce->st.st_size - 1; -                } -                if (r->end == -1) { -                        /* <start>- -                         * all but the first <start> bytes */ - -                        r->end = sce->st.st_size - 1; -                } - -                if (r->end > sce->st.st_size - 1) { -                        /* RFC 2616 - 14.35.1 -                         * -                         * if last-byte-pos not present or > size-of-file -                         * take the size-of-file -                         * -                         *  */ -                        r->end = sce->st.st_size - 1; -                } - -                if (r->start > sce->st.st_size - 1) { -                        /* RFC 2616 - 14.35.1 -                         * -                         * if first-byte-pos > file-size, 416 -                         */ - -                        con->http_status = 416; -                        return -1; -                } - -                if (r->start > r->end) { -                        /* RFC 2616 - 14.35.1 -                         * -                         * if last-byte-pos is present, it has to be >= first-byte-pos -                         * -                         * invalid ranges have to be handle as no Range specified -                         *  */ - -                        return -1; -                } -        } - -        if (r) { -                /* we ran into an range violation */ -                return -1; -        } - -        if (multipart) { -                buffer *b; -                for (r = ranges; r; r = r->next) { -                        /* write boundary-header */ - -                        b = chunkqueue_get_append_buffer(con->send); - -                        buffer_copy_string(b, "\r\n--"); -                        buffer_append_string(b, boundary); - -                        /* write Content-Range */ -                        buffer_append_string(b, "\r\nContent-Range: bytes "); -                        buffer_append_off_t(b, r->start); -                        buffer_append_string(b, "-"); -                        buffer_append_off_t(b, r->end); -                        buffer_append_string(b, "/"); -                        buffer_append_off_t(b, sce->st.st_size); - -                        buffer_append_string(b, "\r\nContent-Type: "); -                        buffer_append_string_buffer(b, content_type); - -                        /* write END-OF-HEADER */ -                        buffer_append_string(b, "\r\n\r\n"); - -                        con->response.content_length += b->used - 1; -                        ctx->response_content_length += b->used - 1; -                        con->send->bytes_in += b->used - 1; - -                        if ((size_t)sce->st.st_size > size) { -                                chunkqueue_append_glusterfs_file(con->send_raw, ctx->fd, r->start, r->end - r->start + 1); -                                con->send_raw->bytes_in += (r->end - r->start + 1); -                                chunkqueue_append_dummy_mem_chunk (con->send, r->end - r->start + 1); -                        } else { -                                chunkqueue_append_mem (con->send, ((char *)ctx->buf) + r->start, r->end - r->start + 1);  -                                free (ctx->buf); -                                ctx->buf = NULL; -                        } -                 -                        con->response.content_length += r->end - r->start + 1; -                        ctx->response_content_length += r->end - r->start + 1; -                        con->send->bytes_in += r->end - r->start + 1; -                } - -                /* add boundary end */ -                b = chunkqueue_get_append_buffer(con->send); - -                buffer_copy_string_len(b, "\r\n--", 4); -                buffer_append_string(b, boundary); -                buffer_append_string_len(b, "--\r\n", 4); - -                con->response.content_length += b->used - 1; -                ctx->response_content_length += b->used - 1; -                con->send->bytes_in += b->used - 1; - -                /* set header-fields */ - -                buffer_copy_string(p->range_buf, "multipart/byteranges; boundary="); -                buffer_append_string(p->range_buf, boundary); - -                /* overwrite content-type */ -                response_header_overwrite(srv, con, CONST_STR_LEN("Content-Type"), CONST_BUF_LEN(p->range_buf)); - -        } else { -                r = ranges; - -                chunkqueue_append_glusterfs_file(con->send_raw, ctx->fd, r->start, r->end - r->start + 1); -                con->send_raw->bytes_in += (r->end - r->start + 1); -                chunkqueue_append_dummy_mem_chunk (con->send, r->end - r->start + 1); -                con->response.content_length += r->end - r->start + 1; -                ctx->response_content_length += r->end - r->start + 1; -                con->send->bytes_in += r->end - r->start + 1; - -                buffer_copy_string(p->range_buf, "bytes "); -                buffer_append_off_t(p->range_buf, r->start); -                buffer_append_string(p->range_buf, "-"); -                buffer_append_off_t(p->range_buf, r->end); -                buffer_append_string(p->range_buf, "/"); -                buffer_append_off_t(p->range_buf, sce->st.st_size); - -                response_header_insert(srv, con, CONST_STR_LEN("Content-Range"), CONST_BUF_LEN(p->range_buf)); -        } - -        /* ok, the file is set-up */ -        return 0; -} - -PHYSICALPATH_FUNC(mod_glusterfs_handle_physical) { -        plugin_data *p = p_d; -        stat_cache_entry *sce; -        size_t size = 0; -        handler_t ret = 0; -        mod_glusterfs_ctx_t *plugin_ctx = NULL; - -        if (con->http_status != 0) return HANDLER_GO_ON; -        if (con->uri.path->used == 0) return HANDLER_GO_ON; -        if (con->physical.path->used == 0) return HANDLER_GO_ON; - -        if (con->mode != DIRECT) return HANDLER_GO_ON; - -        /* -          network_backend_write = srv->network_backend_write; -          srv->network_backend_write = mod_glusterfs_network_backend_write; -        */ - -        switch (con->request.http_method) { -        case HTTP_METHOD_GET: -        case HTTP_METHOD_POST: -        case HTTP_METHOD_HEAD: -                break; - -        default: -                return HANDLER_GO_ON; -        } - -        mod_glusterfs_patch_connection(srv, con, p); - -        if (!p->conf.prefix || !p->conf.prefix->ptr) { -                return HANDLER_GO_ON; -        } - -        if (!p->conf.document_root || p->conf.document_root->used == 0) { -                log_error_write(srv, __FILE__, __LINE__, "s", "glusterfs.document-root is not specified"); -                con->http_status = 500; -                return HANDLER_FINISHED; -        } - -        if (p->conf.handle <= 0) { -                glusterfs_init_ctx_t ctx; - -                if (!p->conf.specfile || p->conf.specfile->used == 0) { -                        return HANDLER_GO_ON; -                } -                memset (&ctx, 0, sizeof (ctx)); - -                ctx.specfile = p->conf.specfile->ptr; -                ctx.logfile = p->conf.logfile->ptr; -                ctx.loglevel = p->conf.loglevel->ptr; -                ctx.lookup_timeout = ctx.stat_timeout = p->conf.cache_timeout; - -                p->conf.handle = (unsigned long)glusterfs_init (&ctx); - -                if (p->conf.handle <= 0) { -                        con->http_status = 500; -                        log_error_write(srv, __FILE__, __LINE__,  "sbs",  "glusterfs initialization failed, please check your configuration. Glusterfs logfile ", p->conf.logfile, "might contain details"); -                        return HANDLER_FINISHED; -                } -        } - -        size = 0; -        if (p->conf.xattr_file_size && p->conf.xattr_file_size->ptr)  -                size = atoi (p->conf.xattr_file_size->ptr); - -        if (!con->plugin_ctx[p->id]) { -                buffer *tmp_buf = buffer_init_buffer (con->physical.basedir); - -                plugin_ctx = calloc (1, sizeof (*plugin_ctx)); -                /* ERR_ABORT (plugin_ctx); */ -                con->plugin_ctx[p->id] = plugin_ctx; -     -                buffer_append_string_buffer (tmp_buf, p->conf.prefix); -                buffer_path_simplify (tmp_buf, tmp_buf); - -                plugin_ctx->prefix = tmp_buf->used - 1; -                if (tmp_buf->ptr[plugin_ctx->prefix - 1] == '/') -                        plugin_ctx->prefix--; - -                buffer_free (tmp_buf); -        } else  -                /*FIXME: error!! error!! */ -                plugin_ctx = con->plugin_ctx[p->id]; - - -        if (size)  -        { -                plugin_ctx->buf = malloc (size); -                /* ERR_ABORT (plugin_ctx->buf); */ -        } - -        plugin_ctx->glusterfs_path = buffer_init (); -        buffer_copy_string_buffer (plugin_ctx->glusterfs_path, p->conf.document_root); -        buffer_append_string (plugin_ctx->glusterfs_path, "/"); -        buffer_append_string (plugin_ctx->glusterfs_path, con->physical.path->ptr + plugin_ctx->prefix); -        buffer_path_simplify (plugin_ctx->glusterfs_path, plugin_ctx->glusterfs_path); - -        ret = glusterfs_stat_cache_get_entry_async (srv, con, p, plugin_ctx->glusterfs_path, con->physical.path, plugin_ctx->buf, size, &sce); - -        if (ret == HANDLER_ERROR) { -                free (plugin_ctx->buf); -                plugin_ctx->buf = NULL; - -                buffer_free (plugin_ctx->glusterfs_path); -                plugin_ctx->glusterfs_path = NULL; - -                free (plugin_ctx); -                con->plugin_ctx[p->id] = NULL; - -                con->http_status = 500; -                ret = HANDLER_FINISHED; -        } - -        return ret; -} - -URIHANDLER_FUNC(mod_glusterfs_subrequest) { -        plugin_data *p = p_d; -        stat_cache_entry *sce = NULL; -        int s_len; -        unsigned long fd; -        char allow_caching = 1; -        size_t size = 0; -        mod_glusterfs_ctx_t *ctx = con->plugin_ctx[p->id]; - -        /* someone else has done a decision for us */ -        if (con->http_status != 0) return HANDLER_GO_ON; -        if (con->uri.path->used == 0) return HANDLER_GO_ON; -        if (con->physical.path->used == 0) return HANDLER_GO_ON; -   -        /* someone else has handled this request */ -        if (con->mode != DIRECT) return HANDLER_GO_ON; -   -        /* we only handle GET, POST and HEAD */ -        switch(con->request.http_method) { -        case HTTP_METHOD_GET: -        case HTTP_METHOD_POST: -        case HTTP_METHOD_HEAD: -                break; -        default: -                return HANDLER_GO_ON; -        } -   -        mod_glusterfs_patch_connection(srv, con, p); -   -        if (!p->conf.prefix || !p->conf.prefix->ptr) -                return HANDLER_GO_ON; - -        if (!ctx) { -                con->http_status = 500; -                return HANDLER_FINISHED; -        } - -        s_len = con->uri.path->used - 1; -        /* ignore certain extensions */ -        /* -          for (k = 0; k < p->conf.exclude_exts->used; k++) { -          data_string *ds; -          ds = (data_string *)p->conf.exclude_exts->data[k]; -           -          if (ds->value->used == 0) continue; -     -          if (!strncmp (ds->value->ptr, con->uri.path->ptr, strlen (ds->value->ptr))) -          break; -          } -   -          if (k == p->conf.exclude_exts->used) { -          return HANDLER_GO_ON; -          } -        */ - -        if (con->conf.log_request_handling) { -                log_error_write(srv, __FILE__, __LINE__,  "s",  "-- serving file from glusterfs"); -        } - -        if (HANDLER_ERROR == stat_cache_get_entry(srv, con, con->physical.path, &sce)) { -                con->http_status = 403; - -                /* this might happen if the sce is removed from stat-cache after a successful glusterfs_lookup */ -                if (ctx) { -                        if (ctx->buf) { -                                free (ctx->buf); -                                ctx->buf = NULL; -                        } - -                        if (ctx->glusterfs_path) { -                                buffer_free (ctx->glusterfs_path); -                                ctx->glusterfs_path = NULL; -                        }                -                        free (ctx); -                        con->plugin_ctx[p->id] = NULL; -                } - -                log_error_write(srv, __FILE__, __LINE__, "sbsb", -                                "not a regular file:", con->uri.path, -                                "->", con->physical.path); -     -                return HANDLER_FINISHED; -        } - -        if (con->uri.path->ptr[s_len] == '/' || !S_ISREG(sce->st.st_mode)) { -                if (ctx) { -                        if (ctx->glusterfs_path) { -                                buffer_free (ctx->glusterfs_path); -                                ctx->glusterfs_path = NULL; -                        } - -                        free (ctx); -                        con->plugin_ctx[p->id] = NULL; -                } - -                return HANDLER_FINISHED; -        } - -        if (p->conf.xattr_file_size && p->conf.xattr_file_size->ptr) -                size = atoi (p->conf.xattr_file_size->ptr); - -        if ((size_t)sce->st.st_size > size) { -     -                fd = glusterfs_open ((libglusterfs_handle_t ) ((unsigned long)p->conf.handle), ctx->glusterfs_path->ptr, O_RDONLY, 0); -     -                if (!fd) { -                        if (ctx) { -                                if (ctx->glusterfs_path) { -                                        buffer_free (ctx->glusterfs_path); -                                        ctx->glusterfs_path = NULL; -                                } - -                                free (ctx); -                                con->plugin_ctx[p->id] = NULL; -                        } - -                        con->http_status = 403; -                        return HANDLER_FINISHED; -                } -                ctx->fd = fd; -        } - -        /* we only handline regular files */ -#ifdef HAVE_LSTAT -        if ((sce->is_symlink == 1) && !con->conf.follow_symlink) { -                con->http_status = 403; -           -                if (con->conf.log_request_handling) { -                        log_error_write(srv, __FILE__, __LINE__,  "s",  "-- access denied due symlink restriction"); -                        log_error_write(srv, __FILE__, __LINE__,  "sb", "Path         :", con->physical.path); -                } -     -                buffer_reset(con->physical.path); -                if (ctx) { -                        if (ctx->glusterfs_path) { -                                buffer_free (ctx->glusterfs_path); -                                ctx->glusterfs_path = NULL; -                        } - -                        free (ctx); -                        con->plugin_ctx[p->id] = NULL; -                } - -                return HANDLER_FINISHED; -        } -#endif -        if (!S_ISREG(sce->st.st_mode)) { -                con->http_status = 404; -     -                if (con->conf.log_file_not_found) { -                        log_error_write(srv, __FILE__, __LINE__, "sbsb", -                                        "not a regular file:", con->uri.path, -                                        "->", sce->name); -                } -     -                if (ctx) { -                        if (ctx->glusterfs_path) { -                                buffer_free (ctx->glusterfs_path); -                                ctx->glusterfs_path = NULL; -                        } - -                        free (ctx); -                        con->plugin_ctx[p->id] = NULL; -                } - -                return HANDLER_FINISHED; -        } - -        /* mod_compress might set several data directly, don't overwrite them */ - -        /* set response content-type, if not set already */ -   -        if (NULL == array_get_element(con->response.headers, CONST_STR_LEN("Content-Type"))) { -                if (buffer_is_empty(sce->content_type)) { -                        /* we are setting application/octet-stream, but also announce that -                         * this header field might change in the seconds few requests  -                         * -                         * This should fix the aggressive caching of FF and the script download -                         * seen by the first installations -                         */ -                        response_header_overwrite(srv, con, CONST_STR_LEN("Content-Type"), CONST_STR_LEN("application/octet-stream")); -       -                        allow_caching = 0; -                } else { -                        response_header_overwrite(srv, con, CONST_STR_LEN("Content-Type"), CONST_BUF_LEN(sce->content_type)); -                } -        } -   -        if (con->conf.range_requests) { -                response_header_overwrite(srv, con, CONST_STR_LEN("Accept-Ranges"), CONST_STR_LEN("bytes")); -        } - -        /* TODO: Allow Cachable requests */      -#if 0 -        if (allow_caching) { -                if (p->conf.etags_used && con->etag_flags != 0 && !buffer_is_empty(sce->etag)) { -                        if (NULL == array_get_element(con->response.headers, "ETag")) { -                                /* generate e-tag */ -                                etag_mutate(con->physical.etag, sce->etag); -         -                                response_header_overwrite(srv, con, CONST_STR_LEN("ETag"), CONST_BUF_LEN(con->physical.etag)); -                        } -                } -     -                /* prepare header */ -                if (NULL == (ds = (data_string *)array_get_element(con->response.headers, "Last-Modified"))) { -                        mtime = strftime_cache_get(srv, sce->st.st_mtime); -                        response_header_overwrite(srv, con, CONST_STR_LEN("Last-Modified"), CONST_BUF_LEN(mtime)); -                } else { -                        mtime = ds->value; -                } -     -                if (HANDLER_FINISHED == http_response_handle_cachable(srv, con, mtime)) { -                        if (ctx) { -                                if (ctx->glusterfs_path) { -                                        buffer_free (ctx->glusterfs_path); -                                        ctx->glusterfs_path = NULL; -                                } - -                                free (ctx); -                                con->plugin_ctx[p->id] = NULL; -                        } - -                        return HANDLER_FINISHED; -                } -        } -#endif  -   -        /*TODO: Read about etags */ -        if (NULL != array_get_element(con->request.headers, CONST_STR_LEN("Range")) && con->conf.range_requests) { -                int do_range_request = 1; -                data_string *ds = NULL; -                buffer *mtime = NULL; -                /* check if we have a conditional GET */ -     -                /* prepare header */ -                if (NULL == (ds = (data_string *)array_get_element(con->response.headers, CONST_STR_LEN("Last-Modified")))) { -                        mtime = strftime_cache_get(srv, sce->st.st_mtime); -                        response_header_overwrite(srv, con, CONST_STR_LEN("Last-Modified"), CONST_BUF_LEN(mtime)); -                } else { -                        mtime = ds->value; -                } - -                if (NULL != (ds = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("If-Range")))) { -                        /* if the value is the same as our ETag, we do a Range-request, -                         * otherwise a full 200 */ -             -                        if (ds->value->ptr[0] == '"') { -                                /** -                                 * client wants a ETag -                                 */ -                                if (!con->physical.etag) { -                                        do_range_request = 0; -                                } else if (!buffer_is_equal(ds->value, con->physical.etag)) { -                                        do_range_request = 0; -                                } -                        } else if (!mtime) { -                                /** -                                 * we don't have a Last-Modified and can match the If-Range:  -                                 * -                                 * sending all -                                 */ -                                do_range_request = 0; -                        } else if (!buffer_is_equal(ds->value, mtime)) { -                                do_range_request = 0; -                        } -                } -     -                if (do_range_request) { -                        /* content prepared, I'm done */ -                        con->send->is_closed = 1;  -             -                        if (0 == http_response_parse_range(srv, con, p)) { -                                con->http_status = 206; -                        } -                        if (ctx) { -                                if (ctx->glusterfs_path) { -                                        buffer_free (ctx->glusterfs_path); -                                        ctx->glusterfs_path = NULL; -                                } -                                free (ctx); -                                con->plugin_ctx[p->id] = NULL; -                        } - -                        return HANDLER_FINISHED; -                } -        } -   -        /* if we are still here, prepare body */ - -        /* we add it here for all requests -         * the HEAD request will drop it afterwards again -         */ - -        if (p->conf.xattr_file_size && p->conf.xattr_file_size->ptr) -                size = atoi (p->conf.xattr_file_size->ptr); - -        if (size < (size_t)sce->st.st_size) { -                chunkqueue_append_glusterfs_file (con->send_raw, fd, 0, sce->st.st_size); -                con->send_raw->bytes_in += sce->st.st_size; -                chunkqueue_append_dummy_mem_chunk (con->send, sce->st.st_size); -        } else { -                if (!ctx->buf) { -                        con->http_status = 404; -                        return HANDLER_ERROR; -                } -                chunkqueue_append_glusterfs_mem (con->send, ctx->buf, sce->st.st_size); -                ctx->buf = NULL; -        } -        ctx->response_content_length = con->response.content_length = sce->st.st_size; -   -        con->send->is_closed = 1; -        con->send->bytes_in = sce->st.st_size; - -        return HANDLER_FINISHED; -} - -/* this function is called at dlopen() time and inits the callbacks */ -CONNECTION_FUNC(mod_glusterfs_connection_reset)  -{ -        (void) p_d; -        (void) con; -        if (!network_backend_write) -                network_backend_write = srv->network_backend_write; - -        srv->network_backend_write = mod_glusterfs_network_backend_write; - -        return HANDLER_GO_ON; -} - -URIHANDLER_FUNC(mod_glusterfs_response_done) { -        plugin_data *p = p_d; -        UNUSED (srv); -        mod_glusterfs_ctx_t *ctx = con->plugin_ctx[p->id]; -         -        con->plugin_ctx[p->id] = NULL; -        if (ctx->glusterfs_path) { -                free (ctx->glusterfs_path); -        } - -        free (ctx); -        return HANDLER_GO_ON; -} - -int mod_glusterfs_plugin_init(plugin *p) { -        p->version     = LIGHTTPD_VERSION_ID; -        p->name        = buffer_init_string("glusterfs"); -        p->init        = mod_glusterfs_init; -        p->handle_physical = mod_glusterfs_handle_physical; -        p->handle_start_backend = mod_glusterfs_subrequest; -        p->handle_response_done = mod_glusterfs_response_done; -        p->set_defaults  = mod_glusterfs_set_defaults; -        p->connection_reset = mod_glusterfs_connection_reset; -        p->cleanup     = mod_glusterfs_free; -   -        p->data        = NULL; -   -        return 0; -}  | 
