1362181Sdim/* ==================================================================== 2362181Sdim * Licensed to the Apache Software Foundation (ASF) under one 3362181Sdim * or more contributor license agreements. See the NOTICE file 4362181Sdim * distributed with this work for additional information 5362181Sdim * regarding copyright ownership. The ASF licenses this file 6362181Sdim * to you under the Apache License, Version 2.0 (the 7362181Sdim * "License"); you may not use this file except in compliance 8362181Sdim * with the License. You may obtain a copy of the License at 9251877Speter * 10362181Sdim * http://www.apache.org/licenses/LICENSE-2.0 11251877Speter * 12362181Sdim * Unless required by applicable law or agreed to in writing, 13362181Sdim * software distributed under the License is distributed on an 14362181Sdim * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 15362181Sdim * KIND, either express or implied. See the License for the 16362181Sdim * specific language governing permissions and limitations 17362181Sdim * under the License. 18362181Sdim * ==================================================================== 19251877Speter */ 20251877Speter 21251877Speter#include <apr_pools.h> 22251877Speter 23251877Speter#include "serf.h" 24251877Speter#include "serf_bucket_util.h" 25251877Speter 26251877Spetertypedef struct { 27251877Speter apr_file_t *file; 28251877Speter 29251877Speter serf_databuf_t databuf; 30251877Speter 31251877Speter} file_context_t; 32251877Speter 33251877Speter 34251877Speterstatic apr_status_t file_reader(void *baton, apr_size_t bufsize, 35251877Speter char *buf, apr_size_t *len) 36251877Speter{ 37251877Speter file_context_t *ctx = baton; 38251877Speter 39251877Speter *len = bufsize; 40251877Speter return apr_file_read(ctx->file, buf, len); 41251877Speter} 42251877Speter 43251877Speterserf_bucket_t *serf_bucket_file_create( 44251877Speter apr_file_t *file, 45251877Speter serf_bucket_alloc_t *allocator) 46251877Speter{ 47251877Speter file_context_t *ctx; 48251877Speter#if APR_HAS_MMAP 49251877Speter apr_finfo_t finfo; 50251877Speter const char *file_path; 51251877Speter 52251877Speter /* See if we'd be better off mmap'ing this file instead. 53251877Speter * 54251877Speter * Note that there is a failure case here that we purposely fall through: 55251877Speter * if a file is buffered, apr_mmap will reject it. However, on older 56251877Speter * versions of APR, we have no way of knowing this - but apr_mmap_create 57251877Speter * will check for this and return APR_EBADF. 58251877Speter */ 59251877Speter apr_file_name_get(&file_path, file); 60251877Speter apr_stat(&finfo, file_path, APR_FINFO_SIZE, 61251877Speter serf_bucket_allocator_get_pool(allocator)); 62251877Speter if (APR_MMAP_CANDIDATE(finfo.size)) { 63251877Speter apr_status_t status; 64251877Speter apr_mmap_t *file_mmap; 65251877Speter status = apr_mmap_create(&file_mmap, file, 0, finfo.size, 66251877Speter APR_MMAP_READ, 67251877Speter serf_bucket_allocator_get_pool(allocator)); 68251877Speter 69251877Speter if (status == APR_SUCCESS) { 70251877Speter return serf_bucket_mmap_create(file_mmap, allocator); 71251877Speter } 72251877Speter } 73251877Speter#endif 74251877Speter 75251877Speter /* Oh, well. */ 76251877Speter ctx = serf_bucket_mem_alloc(allocator, sizeof(*ctx)); 77251877Speter ctx->file = file; 78251877Speter 79251877Speter serf_databuf_init(&ctx->databuf); 80251877Speter ctx->databuf.read = file_reader; 81251877Speter ctx->databuf.read_baton = ctx; 82251877Speter 83251877Speter return serf_bucket_create(&serf_bucket_type_file, allocator, ctx); 84251877Speter} 85251877Speter 86251877Speterstatic apr_status_t serf_file_read(serf_bucket_t *bucket, 87251877Speter apr_size_t requested, 88251877Speter const char **data, apr_size_t *len) 89251877Speter{ 90251877Speter file_context_t *ctx = bucket->data; 91251877Speter 92251877Speter return serf_databuf_read(&ctx->databuf, requested, data, len); 93251877Speter} 94251877Speter 95251877Speterstatic apr_status_t serf_file_readline(serf_bucket_t *bucket, 96251877Speter int acceptable, int *found, 97251877Speter const char **data, apr_size_t *len) 98251877Speter{ 99251877Speter file_context_t *ctx = bucket->data; 100251877Speter 101251877Speter return serf_databuf_readline(&ctx->databuf, acceptable, found, data, len); 102251877Speter} 103251877Speter 104251877Speterstatic apr_status_t serf_file_peek(serf_bucket_t *bucket, 105251877Speter const char **data, 106251877Speter apr_size_t *len) 107251877Speter{ 108251877Speter file_context_t *ctx = bucket->data; 109251877Speter 110251877Speter return serf_databuf_peek(&ctx->databuf, data, len); 111251877Speter} 112251877Speter 113251877Speterconst serf_bucket_type_t serf_bucket_type_file = { 114251877Speter "FILE", 115251877Speter serf_file_read, 116251877Speter serf_file_readline, 117251877Speter serf_default_read_iovec, 118251877Speter serf_default_read_for_sendfile, 119251877Speter serf_default_read_bucket, 120251877Speter serf_file_peek, 121251877Speter serf_default_destroy_and_data, 122251877Speter}; 123