path: root/test/testfile.c

/* Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "apr_file_io.h"
#include "apr_file_info.h"
#include "apr_network_io.h"
#include "apr_errno.h"
#include "apr_general.h"
#include "apr_poll.h"
#include "apr_lib.h"
#include "apr_strings.h"
#include "apr_thread_proc.h"
#include "testutil.h"

#define DIRNAME "data"
#define FILENAME DIRNAME "/file_datafile.txt"
#define TESTSTR  "This is the file data file."

#define TESTREAD_BLKSIZE 1024
#define APR_BUFFERSIZE   4096 /* This should match APR's buffer size. */



static void test_open_noreadwrite(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *thefile = NULL;

    rv = apr_file_open(&thefile, FILENAME,
                       APR_FOPEN_CREATE | APR_FOPEN_EXCL,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_TRUE(tc, rv != APR_SUCCESS);
    ABTS_INT_EQUAL(tc, 1, APR_STATUS_IS_EACCES(rv));
    ABTS_PTR_EQUAL(tc, NULL, thefile); 
}

static void test_open_excl(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *thefile = NULL;

    rv = apr_file_open(&thefile, FILENAME,
                       APR_FOPEN_CREATE | APR_FOPEN_EXCL | APR_FOPEN_WRITE,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_TRUE(tc, rv != APR_SUCCESS);
    ABTS_INT_EQUAL(tc, 1, APR_STATUS_IS_EEXIST(rv));
    ABTS_PTR_EQUAL(tc, NULL, thefile); 
}

static void test_open_read(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *filetest = NULL;

    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_READ,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_PTR_NOTNULL(tc, filetest);
    apr_file_close(filetest);
}

static void link_existing(abts_case *tc, void *data)
{
    apr_status_t rv;
    
    rv = apr_file_link("data/file_datafile.txt", "data/file_datafile2.txt");
    apr_file_remove("data/file_datafile2.txt", p);
    ABTS_ASSERT(tc, "Couldn't create hardlink to file", rv == APR_SUCCESS);
}

static void link_nonexisting(abts_case *tc, void *data)
{
    apr_status_t rv;
    
    rv = apr_file_link("data/does_not_exist.txt", "data/fake.txt");
    ABTS_ASSERT(tc, "", rv != APR_SUCCESS);
}

static void test_read(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_size_t nbytes = 256;
    char *str = apr_pcalloc(p, nbytes + 1);
    apr_file_t *filetest = NULL;
    
    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_READ,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);

    APR_ASSERT_SUCCESS(tc, "Opening test file " FILENAME, rv);
    rv = apr_file_read(filetest, str, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(TESTSTR), nbytes);
    ABTS_STR_EQUAL(tc, TESTSTR, str);

    apr_file_close(filetest);
}

static void test_readzero(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_size_t nbytes = 0;
    char *str = NULL;
    apr_file_t *filetest;
    
    rv = apr_file_open(&filetest, FILENAME, APR_FOPEN_READ, APR_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "Opening test file " FILENAME, rv);

    rv = apr_file_read(filetest, str, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, 0, nbytes);

    apr_file_close(filetest);
}

static void test_filename(abts_case *tc, void *data)
{
    const char *str;
    apr_status_t rv;
    apr_file_t *filetest = NULL;
    
    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_READ,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    APR_ASSERT_SUCCESS(tc, "Opening test file " FILENAME, rv);

    rv = apr_file_name_get(&str, filetest);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_STR_EQUAL(tc, FILENAME, str);

    apr_file_close(filetest);
}
    
static void test_fileclose(abts_case *tc, void *data)
{
    char str;
    apr_status_t rv;
    apr_size_t one = 1;
    apr_file_t *filetest = NULL;
    
    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_READ,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    APR_ASSERT_SUCCESS(tc, "Opening test file " FILENAME, rv);

    rv = apr_file_close(filetest);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    /* We just closed the file, so this should fail */
    rv = apr_file_read(filetest, &str, &one);
    ABTS_INT_EQUAL(tc, 1, APR_STATUS_IS_EBADF(rv));
}

static void test_file_remove(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *filetest = NULL;

    rv = apr_file_remove(FILENAME, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_open(&filetest, FILENAME, APR_FOPEN_READ,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_INT_EQUAL(tc, 1, APR_STATUS_IS_ENOENT(rv));
}

static void test_open_write(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *filetest = NULL;

    filetest = NULL;
    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_WRITE,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_INT_EQUAL(tc, 1, APR_STATUS_IS_ENOENT(rv));
    ABTS_PTR_EQUAL(tc, NULL, filetest);
}

static void test_open_writecreate(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *filetest = NULL;

    filetest = NULL;
    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_WRITE | APR_FOPEN_CREATE,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    apr_file_close(filetest);
}

static void test_write(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_size_t bytes = strlen(TESTSTR);
    apr_file_t *filetest = NULL;

    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_WRITE | APR_FOPEN_CREATE,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_write(filetest, TESTSTR, &bytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    apr_file_close(filetest);
}

static void test_open_readwrite(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *filetest = NULL;

    filetest = NULL;
    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_READ | APR_FOPEN_WRITE,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_PTR_NOTNULL(tc, filetest);

    apr_file_close(filetest);
}

static void test_seek(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_off_t offset = 5;
    apr_size_t nbytes = 256;
    char *str = apr_pcalloc(p, nbytes + 1);
    apr_file_t *filetest = NULL;

    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_READ,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    APR_ASSERT_SUCCESS(tc, "Open test file " FILENAME, rv);

    rv = apr_file_read(filetest, str, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(TESTSTR), nbytes);
    ABTS_STR_EQUAL(tc, TESTSTR, str);

    memset(str, 0, nbytes + 1);

    rv = apr_file_seek(filetest, SEEK_SET, &offset);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    
    rv = apr_file_read(filetest, str, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(TESTSTR) - 5, nbytes);
    ABTS_STR_EQUAL(tc, TESTSTR + 5, str);

    apr_file_close(filetest);

    /* Test for regression of sign error bug with SEEK_END and
       buffered files. */
    rv = apr_file_open(&filetest, FILENAME,
                       APR_FOPEN_READ | APR_FOPEN_BUFFERED,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    APR_ASSERT_SUCCESS(tc, "Open test file " FILENAME, rv);

    offset = -5;
    rv = apr_file_seek(filetest, SEEK_END, &offset);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(TESTSTR) - 5, nbytes);

    memset(str, 0, nbytes + 1);
    nbytes = 256;
    rv = apr_file_read(filetest, str, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, 5, nbytes);
    ABTS_STR_EQUAL(tc, TESTSTR + strlen(TESTSTR) - 5, str);

    apr_file_close(filetest);
}                

static void test_userdata_set(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *filetest = NULL;

    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_WRITE,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_data_set(filetest, "This is a test",
                           "test", apr_pool_cleanup_null);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    apr_file_close(filetest);
}

static void test_userdata_get(abts_case *tc, void *data)
{
    apr_status_t rv;
    void *udata;
    char *teststr;
    apr_file_t *filetest = NULL;

    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_WRITE,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_data_set(filetest, "This is a test",
                           "test", apr_pool_cleanup_null);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_data_get(&udata, "test", filetest);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    teststr = udata;
    ABTS_STR_EQUAL(tc, "This is a test", teststr);

    apr_file_close(filetest);
}

static void test_userdata_getnokey(abts_case *tc, void *data)
{
    apr_status_t rv;
    void *teststr;
    apr_file_t *filetest = NULL;

    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_WRITE,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_data_get(&teststr, "nokey", filetest);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_PTR_EQUAL(tc, NULL, teststr);
    apr_file_close(filetest);
}

static void test_buffer_set_get(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_size_t bufsize;
    apr_file_t *filetest = NULL;
    char   * buffer;

    rv = apr_file_open(&filetest, FILENAME, 
                       APR_FOPEN_WRITE | APR_FOPEN_BUFFERED,
                       APR_UREAD | APR_UWRITE | APR_GREAD, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    bufsize = apr_file_buffer_size_get(filetest);
    ABTS_SIZE_EQUAL(tc, APR_BUFFERSIZE, bufsize);
 
    buffer = apr_pcalloc(p, 10240);
    rv = apr_file_buffer_set(filetest, buffer, 10240);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    
    bufsize = apr_file_buffer_size_get(filetest);
    ABTS_SIZE_EQUAL(tc, 10240, bufsize);
    
    rv = apr_file_buffer_set(filetest, buffer, 12);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    
    bufsize = apr_file_buffer_size_get(filetest);
    ABTS_SIZE_EQUAL(tc, 12, bufsize);
    
    apr_file_close(filetest);
}
static void test_getc(abts_case *tc, void *data)
{
    apr_file_t *f = NULL;
    apr_status_t rv;
    char ch;

    rv = apr_file_open(&f, FILENAME, APR_FOPEN_READ, 0, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    apr_file_getc(&ch, f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_INT_EQUAL(tc, (int)TESTSTR[0], (int)ch);
    apr_file_close(f);
}

static void test_ungetc(abts_case *tc, void *data)
{
    apr_file_t *f = NULL;
    apr_status_t rv;
    char ch;

    rv = apr_file_open(&f, FILENAME, APR_FOPEN_READ, 0, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    apr_file_getc(&ch, f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_INT_EQUAL(tc, (int)TESTSTR[0], (int)ch);

    apr_file_ungetc('X', f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    apr_file_getc(&ch, f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_INT_EQUAL(tc, 'X', (int)ch);

    apr_file_close(f);
}

static void test_gets(abts_case *tc, void *data)
{
    apr_file_t *f = NULL;
    apr_status_t rv;
    char *str = apr_palloc(p, 256);

    rv = apr_file_open(&f, FILENAME, APR_FOPEN_READ, 0, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_gets(str, 256, f);
    /* Only one line in the test file, so APR will encounter EOF on the first
     * call to gets, but we should get APR_SUCCESS on this call and
     * APR_EOF on the next.
     */
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_STR_EQUAL(tc, TESTSTR, str);
    rv = apr_file_gets(str, 256, f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", str);
    /* Calling gets after EOF should return EOF. */
    rv = apr_file_gets(str, 256, f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", str);
    apr_file_close(f);
}

static void test_gets_buffered(abts_case *tc, void *data)
{
    apr_file_t *f = NULL;
    apr_status_t rv;
    char *str = apr_palloc(p, 256);

    /* This will deadlock gets before the r524355 fix. */
    rv = apr_file_open(&f, FILENAME, APR_FOPEN_READ|APR_FOPEN_BUFFERED|APR_FOPEN_XTHREAD, 0, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_gets(str, 256, f);
    /* Only one line in the test file, so APR will encounter EOF on the first
     * call to gets, but we should get APR_SUCCESS on this call and
     * APR_EOF on the next.
     */
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_STR_EQUAL(tc, TESTSTR, str);
    rv = apr_file_gets(str, 256, f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", str);
    /* Calling gets after EOF should return EOF. */
    rv = apr_file_gets(str, 256, f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", str);
    apr_file_close(f);
}

static void test_gets_empty(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testgets_empty.dat";
    char buf[256];

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ, APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "re-open test file", rv);

    rv = apr_file_gets(buf, sizeof(buf), f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", buf);
    /* Calling gets after EOF should return EOF. */
    rv = apr_file_gets(buf, sizeof(buf), f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", buf);
    apr_file_close(f);
}

static void test_gets_multiline(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testgets_multiline.dat";
    char buf[256];

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file", rv);
    rv = apr_file_puts("a\nb\n", f);
    APR_ASSERT_SUCCESS(tc, "write test data", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ, APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "re-open test file", rv);

    memset(buf, 0, sizeof(buf));
    rv = apr_file_gets(buf, sizeof(buf), f);
    APR_ASSERT_SUCCESS(tc, "read first line", rv);
    ABTS_STR_EQUAL(tc, "a\n", buf);

    memset(buf, 0, sizeof(buf));
    rv = apr_file_gets(buf, sizeof(buf), f);
    APR_ASSERT_SUCCESS(tc, "read second line", rv);
    ABTS_STR_EQUAL(tc, "b\n", buf);

    rv = apr_file_gets(buf, sizeof(buf), f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", buf);
    /* Calling gets after EOF should return EOF. */
    rv = apr_file_gets(buf, sizeof(buf), f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", buf);
    apr_file_close(f);
}

static void test_gets_small_buf(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testgets_small_buf.dat";
    char buf[2];

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file", rv);
    rv = apr_file_puts("ab\n", f);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ, APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "re-open test file", rv);
    /* Buffer is too small to hold the full line, test that gets properly
     * returns the line content character by character.
     */
    memset(buf, 0, sizeof(buf));
    rv = apr_file_gets(buf, sizeof(buf), f);
    APR_ASSERT_SUCCESS(tc, "read first chunk", rv);
    ABTS_STR_EQUAL(tc, "a", buf);

    memset(buf, 0, sizeof(buf));
    rv = apr_file_gets(buf, sizeof(buf), f);
    APR_ASSERT_SUCCESS(tc, "read second chunk", rv);
    ABTS_STR_EQUAL(tc, "b", buf);

    memset(buf, 0, sizeof(buf));
    rv = apr_file_gets(buf, sizeof(buf), f);
    APR_ASSERT_SUCCESS(tc, "read third chunk", rv);
    ABTS_STR_EQUAL(tc, "\n", buf);

    rv = apr_file_gets(buf, sizeof(buf), f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", buf);
    /* Calling gets after EOF should return EOF. */
    rv = apr_file_gets(buf, sizeof(buf), f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", buf);
    apr_file_close(f);
}

static void test_gets_ungetc(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testgets_ungetc.dat";
    char buf[256];

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file", rv);
    rv = apr_file_puts("a\n", f);
    APR_ASSERT_SUCCESS(tc, "write test data", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ, APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "re-open test file", rv);

    rv = apr_file_ungetc('b', f);
    APR_ASSERT_SUCCESS(tc, "call ungetc", rv);
    memset(buf, 0, sizeof(buf));
    rv = apr_file_gets(buf, sizeof(buf), f);
    APR_ASSERT_SUCCESS(tc, "read line", rv);
    ABTS_STR_EQUAL(tc, "ba\n", buf);

    rv = apr_file_ungetc('\n', f);
    APR_ASSERT_SUCCESS(tc, "call ungetc with EOL", rv);
    memset(buf, 0, sizeof(buf));
    rv = apr_file_gets(buf, sizeof(buf), f);
    APR_ASSERT_SUCCESS(tc, "read line", rv);
    ABTS_STR_EQUAL(tc, "\n", buf);

    rv = apr_file_gets(buf, sizeof(buf), f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", buf);
    /* Calling gets after EOF should return EOF. */
    rv = apr_file_gets(buf, sizeof(buf), f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", buf);
    apr_file_close(f);
}

static void test_gets_buffered_big(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testgets_buffered_big.dat";
    char hugestr[APR_BUFFERSIZE + 2];
    char buf[APR_BUFFERSIZE + 2];

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file", rv);
    /* Test an edge case with a buffered file and the line that exceeds
     * the default buffer size by 1 (the line itself fits into the buffer,
     * but the line + EOL does not).
     */
    memset(hugestr, 'a', sizeof(hugestr));
    hugestr[sizeof(hugestr) - 2] = '\n';
    hugestr[sizeof(hugestr) - 1] = '\0';
    rv = apr_file_puts(hugestr, f);
    APR_ASSERT_SUCCESS(tc, "write first line", rv);
    rv = apr_file_puts("b\n", f);
    APR_ASSERT_SUCCESS(tc, "write second line", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "re-open test file", rv);

    memset(buf, 0, sizeof(buf));
    rv = apr_file_gets(buf, sizeof(buf), f);
    APR_ASSERT_SUCCESS(tc, "read first line", rv);
    ABTS_STR_EQUAL(tc, hugestr, buf);

    memset(buf, 0, sizeof(buf));
    rv = apr_file_gets(buf, sizeof(buf), f);
    APR_ASSERT_SUCCESS(tc, "read second line", rv);
    ABTS_STR_EQUAL(tc, "b\n", buf);

    rv = apr_file_gets(buf, sizeof(buf), f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", buf);
    /* Calling gets after EOF should return EOF. */
    rv = apr_file_gets(buf, sizeof(buf), f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_STR_EQUAL(tc, "", buf);
    apr_file_close(f);
}

static void test_bigread(abts_case *tc, void *data)
{
    apr_file_t *f = NULL;
    apr_status_t rv;
    char buf[APR_BUFFERSIZE * 2];
    apr_size_t nbytes;

    /* Create a test file with known content.
     */
    rv = apr_file_open(&f, "data/created_file", 
                       APR_FOPEN_CREATE | APR_FOPEN_WRITE | APR_FOPEN_TRUNCATE,
                       APR_UREAD | APR_UWRITE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    nbytes = APR_BUFFERSIZE;
    memset(buf, 0xFE, nbytes);

    rv = apr_file_write(f, buf, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, APR_BUFFERSIZE, nbytes);

    rv = apr_file_close(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    f = NULL;
    rv = apr_file_open(&f, "data/created_file", APR_FOPEN_READ, 0, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    nbytes = sizeof buf;
    rv = apr_file_read(f, buf, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, APR_BUFFERSIZE, nbytes);

    rv = apr_file_close(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_remove("data/created_file", p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
}

/* This is a horrible name for this function.  We are testing APR, not how
 * Apache uses APR.  And, this function tests _way_ too much stuff.
 */
static void test_mod_neg(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *s;
    int i;
    apr_size_t nbytes;
    char buf[8192];
    apr_off_t cur;
    const char *fname = "data/modneg.dat";

    rv = apr_file_open(&f, fname, 
                       APR_FOPEN_CREATE | APR_FOPEN_WRITE, APR_UREAD | APR_UWRITE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    s = "body56789\n";
    nbytes = strlen(s);
    rv = apr_file_write(f, s, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(s), nbytes);
    
    for (i = 0; i < 7980; i++) {
        s = "0";
        nbytes = strlen(s);
        rv = apr_file_write(f, s, &nbytes);
        ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
        ABTS_SIZE_EQUAL(tc, strlen(s), nbytes);
    }
    
    s = "end456789\n";
    nbytes = strlen(s);
    rv = apr_file_write(f, s, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(s), nbytes);

    for (i = 0; i < 10000; i++) {
        s = "1";
        nbytes = strlen(s);
        rv = apr_file_write(f, s, &nbytes);
        ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
        ABTS_SIZE_EQUAL(tc, strlen(s), nbytes);
    }
    
    rv = apr_file_close(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ, 0, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_gets(buf, 11, f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_STR_EQUAL(tc, "body56789\n", buf);

    cur = 0;
    rv = apr_file_seek(f, APR_CUR, &cur);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_ASSERT(tc, "File Pointer Mismatch, expected 10", cur == 10);

    nbytes = sizeof(buf);
    rv = apr_file_read(f, buf, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, nbytes, sizeof(buf));

    cur = -((apr_off_t)nbytes - 7980);
    rv = apr_file_seek(f, APR_CUR, &cur);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_ASSERT(tc, "File Pointer Mismatch, expected 7990", cur == 7990);

    rv = apr_file_gets(buf, 11, f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_STR_EQUAL(tc, "end456789\n", buf);

    rv = apr_file_close(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_remove(fname, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
}

/* Test that the contents of file FNAME are equal to data EXPECT of
 * length EXPECTLEN. */
static void file_contents_equal(abts_case *tc,
                                const char *fname,
                                const void *expect,
                                apr_size_t expectlen)
{
    void *actual = apr_palloc(p, expectlen);
    apr_file_t *f;

    APR_ASSERT_SUCCESS(tc, "open file",
                       apr_file_open(&f, fname, APR_FOPEN_READ|APR_FOPEN_BUFFERED,
                                     0, p));
    APR_ASSERT_SUCCESS(tc, "read from file",
                       apr_file_read_full(f, actual, expectlen, NULL));
    
    ABTS_ASSERT(tc, "matched expected file contents",
                memcmp(expect, actual, expectlen) == 0);

    APR_ASSERT_SUCCESS(tc, "close file", apr_file_close(f));
}

#define LINE1 "this is a line of text\n"
#define LINE2 "this is a second line of text\n"

static void test_puts(abts_case *tc, void *data)
{
    apr_file_t *f;
    const char *fname = "data/testputs.dat";

    APR_ASSERT_SUCCESS(tc, "open file for writing",
                       apr_file_open(&f, fname, 
                                     APR_FOPEN_WRITE|APR_FOPEN_CREATE|APR_FOPEN_TRUNCATE,
                                     APR_OS_DEFAULT, p));
    
    APR_ASSERT_SUCCESS(tc, "write line to file", 
                       apr_file_puts(LINE1, f));
    APR_ASSERT_SUCCESS(tc, "write second line to file", 
                       apr_file_puts(LINE2, f));
    
    APR_ASSERT_SUCCESS(tc, "close for writing",
                       apr_file_close(f));

    file_contents_equal(tc, fname, LINE1 LINE2, strlen(LINE1 LINE2));
}

static void test_writev(abts_case *tc, void *data)
{
    apr_file_t *f;
    apr_size_t nbytes;
    struct iovec vec[5];
    const char *fname = "data/testwritev.dat";

    APR_ASSERT_SUCCESS(tc, "open file for writing",
                       apr_file_open(&f, fname, 
                                     APR_FOPEN_WRITE|APR_FOPEN_CREATE|APR_FOPEN_TRUNCATE,
                                     APR_OS_DEFAULT, p));
    
    vec[0].iov_base = LINE1;
    vec[0].iov_len = strlen(LINE1);

    APR_ASSERT_SUCCESS(tc, "writev of size 1 to file",
                       apr_file_writev(f, vec, 1, &nbytes));

    file_contents_equal(tc, fname, LINE1, strlen(LINE1));
    
    vec[0].iov_base = LINE1;
    vec[0].iov_len = strlen(LINE1);
    vec[1].iov_base = LINE2;
    vec[1].iov_len = strlen(LINE2);
    vec[2].iov_base = LINE1;
    vec[2].iov_len = strlen(LINE1);
    vec[3].iov_base = LINE1;
    vec[3].iov_len = strlen(LINE1);
    vec[4].iov_base = LINE2;
    vec[4].iov_len = strlen(LINE2);

    APR_ASSERT_SUCCESS(tc, "writev of size 5 to file",
                       apr_file_writev(f, vec, 5, &nbytes));

    APR_ASSERT_SUCCESS(tc, "close for writing",
                       apr_file_close(f));

    file_contents_equal(tc, fname, LINE1 LINE1 LINE2 LINE1 LINE1 LINE2, 
                        strlen(LINE1)*4 + strlen(LINE2)*2);

}

static void test_writev_full(abts_case *tc, void *data)
{
    apr_file_t *f;
    apr_size_t nbytes;
    struct iovec vec[5];
    const char *fname = "data/testwritev_full.dat";

    APR_ASSERT_SUCCESS(tc, "open file for writing",
                       apr_file_open(&f, fname, 
                                     APR_FOPEN_WRITE|APR_FOPEN_CREATE|APR_FOPEN_TRUNCATE,
                                     APR_OS_DEFAULT, p));
    
    vec[0].iov_base = LINE1;
    vec[0].iov_len = strlen(LINE1);
    vec[1].iov_base = LINE2;
    vec[1].iov_len = strlen(LINE2);
    vec[2].iov_base = LINE1;
    vec[2].iov_len = strlen(LINE1);
    vec[3].iov_base = LINE1;
    vec[3].iov_len = strlen(LINE1);
    vec[4].iov_base = LINE2;
    vec[4].iov_len = strlen(LINE2);

    APR_ASSERT_SUCCESS(tc, "writev_full of size 5 to file",
                       apr_file_writev_full(f, vec, 5, &nbytes));

    ABTS_SIZE_EQUAL(tc, strlen(LINE1)*3 + strlen(LINE2)*2, nbytes);

    APR_ASSERT_SUCCESS(tc, "close for writing",
                       apr_file_close(f));

    file_contents_equal(tc, fname, LINE1 LINE2 LINE1 LINE1 LINE2, 
                        strlen(LINE1)*3 + strlen(LINE2)*2);

}

static void test_writev_buffered(abts_case *tc, void *data)
{
    apr_file_t *f;
    apr_size_t nbytes;
    struct iovec vec[2];
    const char *fname = "data/testwritev_buffered.dat";

    APR_ASSERT_SUCCESS(tc, "open file for writing",
                       apr_file_open(&f, fname,
                                     APR_FOPEN_WRITE | APR_FOPEN_CREATE | APR_FOPEN_TRUNCATE |
                                     APR_FOPEN_BUFFERED, APR_OS_DEFAULT, p));

    nbytes = strlen(TESTSTR);
    APR_ASSERT_SUCCESS(tc, "buffered write",
                       apr_file_write(f, TESTSTR, &nbytes));

    vec[0].iov_base = LINE1;
    vec[0].iov_len = strlen(LINE1);
    vec[1].iov_base = LINE2;
    vec[1].iov_len = strlen(LINE2);

    APR_ASSERT_SUCCESS(tc, "writev of size 2 to file",
                       apr_file_writev(f, vec, 2, &nbytes));

    APR_ASSERT_SUCCESS(tc, "close for writing",
                       apr_file_close(f));

    file_contents_equal(tc, fname, TESTSTR LINE1 LINE2,
                        strlen(TESTSTR) + strlen(LINE1) + strlen(LINE2));
}

static void test_writev_buffered_seek(abts_case *tc, void *data)
{
    apr_file_t *f;
    apr_status_t rv;
    apr_off_t off = 0;
    struct iovec vec[3];
    apr_size_t nbytes = strlen(TESTSTR);
    char *str = apr_pcalloc(p, nbytes+1);
    const char *fname = "data/testwritev_buffered.dat";

    APR_ASSERT_SUCCESS(tc, "open file for writing",
                       apr_file_open(&f, fname,
                                     APR_FOPEN_WRITE | APR_FOPEN_READ | APR_FOPEN_BUFFERED,
                                     APR_OS_DEFAULT, p));

    rv = apr_file_read(f, str, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_STR_EQUAL(tc, TESTSTR, str);
    APR_ASSERT_SUCCESS(tc, "buffered seek", apr_file_seek(f, APR_SET, &off));

    vec[0].iov_base = LINE1;
    vec[0].iov_len = strlen(LINE1);
    vec[1].iov_base = LINE2;
    vec[1].iov_len = strlen(LINE2);
    vec[2].iov_base = TESTSTR;
    vec[2].iov_len = strlen(TESTSTR);

    APR_ASSERT_SUCCESS(tc, "writev of size 2 to file",
                       apr_file_writev(f, vec, 3, &nbytes));

    APR_ASSERT_SUCCESS(tc, "close for writing",
                       apr_file_close(f));

    file_contents_equal(tc, fname, LINE1 LINE2 TESTSTR,
                        strlen(LINE1) + strlen(LINE2) + strlen(TESTSTR));

    APR_ASSERT_SUCCESS(tc, "remove file", apr_file_remove(fname, p));
}

static void test_truncate(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtruncate.dat";
    const char *s;
    apr_size_t nbytes;
    apr_finfo_t finfo;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname,
                       APR_FOPEN_CREATE | APR_FOPEN_WRITE, APR_UREAD | APR_UWRITE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    
    s = "some data";
    nbytes = strlen(s);
    rv = apr_file_write(f, s, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(s), nbytes);

    rv = apr_file_close(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_open(&f, fname,
                       APR_FOPEN_TRUNCATE | APR_FOPEN_WRITE, APR_UREAD | APR_UWRITE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_file_close(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    rv = apr_stat(&finfo, fname, APR_FINFO_SIZE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_ASSERT(tc, "File size mismatch, expected 0 (empty)", finfo.size == 0);

    rv = apr_file_remove(fname, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
}

static void test_file_trunc(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtruncate.dat";
    const char *s;
    apr_size_t nbytes;
    apr_finfo_t finfo;

    apr_file_remove(fname, p);

    /* Test unbuffered */
    rv = apr_file_open(&f, fname,
                        APR_FOPEN_CREATE | APR_FOPEN_READ |
                        APR_FOPEN_WRITE,
                        APR_FPROT_UREAD | APR_FPROT_UWRITE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    s = "some data";
    nbytes = strlen(s);
    rv = apr_file_write(f, s, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(s), nbytes);
    rv = apr_file_trunc(f, 4);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    rv = apr_file_close(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    rv = apr_stat(&finfo, fname, APR_FINFO_SIZE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_ASSERT(tc, "File size mismatch, expected 4", finfo.size == 4);

    rv = apr_file_remove(fname, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    /* Test buffered */
    rv = apr_file_open(&f, fname,
                        APR_FOPEN_CREATE | APR_FOPEN_READ |
                        APR_FOPEN_WRITE | APR_FOPEN_BUFFERED,
                        APR_FPROT_UREAD | APR_FPROT_UWRITE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    nbytes = strlen(s);
    rv = apr_file_write(f, s, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(s), nbytes);
    rv = apr_file_trunc(f, 4);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    rv = apr_file_close(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    rv = apr_stat(&finfo, fname, APR_FINFO_SIZE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_ASSERT(tc, "File size mismatch, expected 4", finfo.size == 4);

    rv = apr_file_remove(fname, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
}

static void test_file_trunc2(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtruncate.dat";
    const char *s;
    apr_size_t nbytes;
    apr_finfo_t finfo;
    char c;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname,
                        APR_FOPEN_CREATE | APR_FOPEN_READ |
                        APR_FOPEN_WRITE,
                        APR_FPROT_UREAD | APR_FPROT_UWRITE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    s = "some data";
    nbytes = strlen(s);
    rv = apr_file_write(f, s, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(s), nbytes);
    rv = apr_file_trunc(f, 4);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    /* Test apr_file_info_get(). */
    rv = apr_file_info_get(&finfo, APR_FINFO_SIZE, f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_INT_EQUAL(tc, 4, (int)finfo.size);
    /* EOF is not reported until the next read. */
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    rv = apr_file_getc(&c, f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);

    rv = apr_file_close(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    rv = apr_stat(&finfo, fname, APR_FINFO_SIZE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_INT_EQUAL(tc, 4, (int)finfo.size);

    rv = apr_file_remove(fname, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
}

static void test_file_trunc_buffered_write(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtruncate_buffered_write.dat";
    const char *s;
    apr_size_t nbytes;
    apr_finfo_t finfo;
    char c;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname,
                        APR_FOPEN_CREATE | APR_FOPEN_READ |
                        APR_FOPEN_WRITE | APR_FOPEN_BUFFERED,
                        APR_FPROT_UREAD | APR_FPROT_UWRITE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    s = "some data";
    nbytes = strlen(s);
    rv = apr_file_write(f, s, &nbytes);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_SIZE_EQUAL(tc, strlen(s), nbytes);
    rv = apr_file_trunc(f, 4);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    /* Test apr_file_info_get(). */
    rv = apr_file_info_get(&finfo, APR_FINFO_SIZE, f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_INT_EQUAL(tc, 4, (int)finfo.size);
    /* EOF is not reported until the next read. */
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    rv = apr_file_getc(&c, f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);

    rv = apr_file_close(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    rv = apr_stat(&finfo, fname, APR_FINFO_SIZE, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    ABTS_INT_EQUAL(tc, 4, (int)finfo.size);

    rv = apr_file_remove(fname, p);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
}

static void test_file_trunc_buffered_write2(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtruncate_buffered_write2.dat";
    apr_finfo_t finfo;
    char c;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname,
                       APR_FOPEN_CREATE | APR_FOPEN_READ |
                       APR_FOPEN_WRITE | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file", rv);

    rv = apr_file_puts("abc", f);
    APR_ASSERT_SUCCESS(tc, "write first string", rv);
    rv = apr_file_flush(f);
    APR_ASSERT_SUCCESS(tc, "flush", rv);
    rv = apr_file_puts("def", f);
    APR_ASSERT_SUCCESS(tc, "write second string", rv);
    /* Truncate behind the write buffer. */
    rv = apr_file_trunc(f, 2);
    APR_ASSERT_SUCCESS(tc, "truncate the file", rv);
    /* Test apr_file_info_get(). */
    rv = apr_file_info_get(&finfo, APR_FINFO_SIZE, f);
    APR_ASSERT_SUCCESS(tc, "get file info", rv);
    ABTS_INT_EQUAL(tc, 2, (int)finfo.size);
    /* EOF is not reported until the next read. */
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    rv = apr_file_getc(&c, f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);

    apr_file_close(f);

    rv = apr_stat(&finfo, fname, APR_FINFO_SIZE, p);
    APR_ASSERT_SUCCESS(tc, "stat file", rv);
    ABTS_INT_EQUAL(tc, 2, (int)finfo.size);

    apr_file_remove(fname, p);
}

static void test_file_trunc_buffered_read(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtruncate_buffered_read.dat";
    apr_finfo_t finfo;
    char c;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname,
                       APR_FOPEN_CREATE | APR_FOPEN_READ |
                       APR_FOPEN_WRITE, APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file", rv);

    rv = apr_file_puts("abc", f);
    APR_ASSERT_SUCCESS(tc, "write test data", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname,
                       APR_FOPEN_READ | APR_FOPEN_WRITE |
                       APR_FOPEN_BUFFERED, APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "re-open test file", rv);

    /* Read to fill in the buffer. */
    rv = apr_file_getc(&c, f);
    APR_ASSERT_SUCCESS(tc, "read char", rv);
    /* Truncate the file. */
    rv = apr_file_trunc(f, 1);
    APR_ASSERT_SUCCESS(tc, "truncate the file", rv);
    /* Test apr_file_info_get(). */
    rv = apr_file_info_get(&finfo, APR_FINFO_SIZE, f);
    APR_ASSERT_SUCCESS(tc, "get file info", rv);
    ABTS_INT_EQUAL(tc, 1, (int)finfo.size);
    /* EOF is not reported until the next read. */
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    rv = apr_file_getc(&c, f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);

    apr_file_close(f);

    rv = apr_stat(&finfo, fname, APR_FINFO_SIZE, p);
    APR_ASSERT_SUCCESS(tc, "stat file", rv);
    ABTS_INT_EQUAL(tc, 1, (int)finfo.size);

    apr_file_remove(fname, p);
}

static void test_bigfprintf(abts_case *tc, void *data)
{
    apr_file_t *f;
    const char *fname = "data/testbigfprintf.dat";
    char *to_write;
    int i;

    apr_file_remove(fname, p);

    APR_ASSERT_SUCCESS(tc, "open test file",
                       apr_file_open(&f, fname,
                                     APR_FOPEN_CREATE|APR_FOPEN_WRITE,
                                     APR_UREAD|APR_UWRITE, p));
    

    to_write = malloc(HUGE_STRING_LEN + 3);

    for (i = 0; i < HUGE_STRING_LEN + 1; ++i)
        to_write[i] = 'A' + i%26;

    strcpy(to_write + HUGE_STRING_LEN, "42");

    i = apr_file_printf(f, "%s", to_write);
    ABTS_INT_EQUAL(tc, HUGE_STRING_LEN + 2, i);

    apr_file_close(f);

    file_contents_equal(tc, fname, to_write, HUGE_STRING_LEN + 2);

    free(to_write);
}

static void test_fail_write_flush(abts_case *tc, void *data)
{
    apr_file_t *f;
    const char *fname = "data/testflush.dat";
    apr_status_t rv;
    char buf[APR_BUFFERSIZE];
    int n;

    apr_file_remove(fname, p);

    APR_ASSERT_SUCCESS(tc, "open test file",
                       apr_file_open(&f, fname,
                                     APR_FOPEN_CREATE|APR_FOPEN_READ|APR_FOPEN_BUFFERED,
                                     APR_UREAD|APR_UWRITE, p));

    memset(buf, 'A', sizeof buf);

    /* Try three writes.  One of these should fail when it exceeds the
     * internal buffer and actually tries to write to the file, which
     * was opened read-only and hence should be unwritable. */
    for (n = 0, rv = APR_SUCCESS; n < 4 && rv == APR_SUCCESS; n++) {
        apr_size_t bytes = sizeof buf;
        rv = apr_file_write(f, buf, &bytes);
    }

    ABTS_ASSERT(tc, "failed to write to read-only buffered fd",
                rv != APR_SUCCESS);

    apr_file_close(f);
}

static void test_fail_read_flush(abts_case *tc, void *data)
{
    apr_file_t *f;
    const char *fname = "data/testflush.dat";
    apr_status_t rv;
    char buf[2];

    apr_file_remove(fname, p);

    APR_ASSERT_SUCCESS(tc, "open test file",
                       apr_file_open(&f, fname,
                                     APR_FOPEN_CREATE|APR_FOPEN_READ|APR_FOPEN_BUFFERED,
                                     APR_UREAD|APR_UWRITE, p));

    /* this write should be buffered. */
    APR_ASSERT_SUCCESS(tc, "buffered write should succeed",
                       apr_file_puts("hello", f));

    /* Now, trying a read should fail since the write must be flushed,
     * and should fail with something other than EOF since the file is
     * opened read-only. */
    rv = apr_file_read_full(f, buf, 2, NULL);

    ABTS_ASSERT(tc, "read should flush buffered write and fail",
                rv != APR_SUCCESS && rv != APR_EOF);

    /* Likewise for gets */
    rv = apr_file_gets(buf, 2, f);

    ABTS_ASSERT(tc, "gets should flush buffered write and fail",
                rv != APR_SUCCESS && rv != APR_EOF);

    /* Likewise for seek. */
    {
        apr_off_t offset = 0;

        rv = apr_file_seek(f, APR_SET, &offset);
    }

    ABTS_ASSERT(tc, "seek should flush buffered write and fail",
                rv != APR_SUCCESS && rv != APR_EOF);

    apr_file_close(f);
}

static void test_xthread(abts_case *tc, void *data)
{
    apr_file_t *f;
    const char *fname = "data/testxthread.dat";
    apr_status_t rv;
    apr_int32_t flags = APR_FOPEN_CREATE|APR_FOPEN_READ|APR_FOPEN_WRITE|APR_FOPEN_APPEND|APR_FOPEN_XTHREAD;
    char buf[128] = { 0 };

    /* Test for bug 38438, opening file with append + xthread and seeking to 
       the end of the file resulted in writes going to the beginning not the
       end. */

    apr_file_remove(fname, p);

    APR_ASSERT_SUCCESS(tc, "open test file",
                       apr_file_open(&f, fname, flags,
                                     APR_UREAD|APR_UWRITE, p));

    APR_ASSERT_SUCCESS(tc, "write should succeed",
                       apr_file_puts("hello", f));

    apr_file_close(f);
    
    APR_ASSERT_SUCCESS(tc, "open test file",
                       apr_file_open(&f, fname, flags,
                                     APR_UREAD|APR_UWRITE, p));

    /* Seek to the end. */
    {
        apr_off_t offset = 0;

        rv = apr_file_seek(f, APR_END, &offset);
        ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    }

    APR_ASSERT_SUCCESS(tc, "more writes should succeed",
                       apr_file_puts("world", f));

    /* Back to the beginning. */
    {
        apr_off_t offset = 0;
        
        rv = apr_file_seek(f, APR_SET, &offset);
        ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);
    }
    
    apr_file_read_full(f, buf, sizeof(buf), NULL);

    ABTS_STR_EQUAL(tc, "helloworld", buf);

    apr_file_close(f);
}

static void test_datasync_on_file(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = DIRNAME "/testtest_datasync.dat";
    apr_size_t bytes_written;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);
    rv = apr_file_write_full(f, "abcdef", 6, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    rv = apr_file_datasync(f);
    APR_ASSERT_SUCCESS(tc, "sync file contents", rv);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_datasync_on_stream(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    apr_size_t bytes_written;

    rv = apr_file_open_stdout(&f, p);
    APR_ASSERT_SUCCESS(tc, "open stdout", rv);
    rv = apr_file_write_full(f, "abcdef\b\b\b\b\b\b\b", 12, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to stdout", rv);
    rv = apr_file_datasync(f);
    if (rv != APR_SUCCESS) {
#if defined(__APPLE__)
        ABTS_INT_EQUAL(tc, ENOTSUP, rv);
#else
        ABTS_INT_EQUAL(tc, APR_EINVAL, rv);
#endif
    }
}

#if APR_HAS_THREADS
typedef struct thread_file_append_ctx_t {
    apr_pool_t *pool;
    const char *fname;
    apr_size_t chunksize;
    char val;
    int num_writes;
    char *errmsg;
} thread_file_append_ctx_t;

static void * APR_THREAD_FUNC thread_file_append_func(apr_thread_t *thd, void *data)
{
    thread_file_append_ctx_t *ctx = data;
    apr_status_t rv;
    apr_file_t *f;
    int i;
    char *writebuf;
    char *readbuf;

    rv = apr_file_open(&f, ctx->fname,
                       APR_FOPEN_READ | APR_FOPEN_WRITE | APR_FOPEN_APPEND,
                       APR_FPROT_OS_DEFAULT, ctx->pool);
    if (rv) {
        apr_thread_exit(thd, rv);
        return NULL;
    }

    writebuf = apr_palloc(ctx->pool, ctx->chunksize);
    memset(writebuf, ctx->val, ctx->chunksize);
    readbuf = apr_palloc(ctx->pool, ctx->chunksize);

    for (i = 0; i < ctx->num_writes; i++) {
        apr_size_t bytes_written;
        apr_size_t bytes_read;
        apr_off_t offset;

        rv = apr_file_write_full(f, writebuf, ctx->chunksize, &bytes_written);
        if (rv) {
            apr_thread_exit(thd, rv);
            return NULL;
        }
        /* After writing the data, seek back from the current offset and
         * verify what we just wrote. */
        offset = -((apr_off_t)ctx->chunksize);
        rv = apr_file_seek(f, APR_CUR, &offset);
        if (rv) {
            apr_thread_exit(thd, rv);
            return NULL;
        }
        rv = apr_file_read_full(f, readbuf, ctx->chunksize, &bytes_read);
        if (rv) {
            apr_thread_exit(thd, rv);
            return NULL;
        }
        if (memcmp(readbuf, writebuf, ctx->chunksize) != 0) {
            ctx->errmsg = apr_psprintf(
                ctx->pool,
                "Unexpected data at file offset %" APR_OFF_T_FMT,
                offset);
            apr_thread_exit(thd, APR_SUCCESS);
            return NULL;
        }
    }

    apr_file_close(f);
    apr_thread_exit(thd, APR_SUCCESS);

    return NULL;
}
#endif  /* APR_HAS_THREADS */

static void test_atomic_append(abts_case *tc, void *data)
{
#if APR_HAS_THREADS
    apr_status_t rv;
    apr_status_t thread_rv;
    apr_file_t *f;
    const char *fname = "data/testatomic_append.dat";
    unsigned int seed;
    thread_file_append_ctx_t ctx1 = {0};
    thread_file_append_ctx_t ctx2 = {0};
    apr_thread_t *t1;
    apr_thread_t *t2;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_WRITE | APR_FOPEN_CREATE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "create file", rv);
    apr_file_close(f);

    seed = (unsigned int)apr_time_now();
    abts_log_message("Random seed for test_atomic_append() is %u", seed);
    srand(seed);

    /* Create two threads appending data to the same file. */
    apr_pool_create(&ctx1.pool, p);
    ctx1.fname = fname;
    ctx1.chunksize = 1 + rand() % 8192;
    ctx1.val = 'A';
    ctx1.num_writes = 1000;
    rv = apr_thread_create(&t1, NULL, thread_file_append_func, &ctx1, p);
    APR_ASSERT_SUCCESS(tc, "create thread", rv);

    apr_pool_create(&ctx2.pool, p);
    ctx2.fname = fname;
    ctx2.chunksize = 1 + rand() % 8192;
    ctx2.val = 'B';
    ctx2.num_writes = 1000;
    rv = apr_thread_create(&t2, NULL, thread_file_append_func, &ctx2, p);
    APR_ASSERT_SUCCESS(tc, "create thread", rv);

    rv = apr_thread_join(&thread_rv, t1);
    APR_ASSERT_SUCCESS(tc, "join thread", rv);
    APR_ASSERT_SUCCESS(tc, "no thread errors", thread_rv);
    if (ctx1.errmsg) {
        ABTS_FAIL(tc, ctx1.errmsg);
    }
    rv = apr_thread_join(&thread_rv, t2);
    APR_ASSERT_SUCCESS(tc, "join thread", rv);
    APR_ASSERT_SUCCESS(tc, "no thread errors", thread_rv);
    if (ctx2.errmsg) {
        ABTS_FAIL(tc, ctx2.errmsg);
    }

    apr_file_remove(fname, p);
#else
    ABTS_SKIP(tc, data, "This test requires APR thread support.");
#endif /* APR_HAS_THREADS */
}

static void test_append_locked(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testappend_locked.dat";
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char buf[64] = {0};

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname,
                       APR_FOPEN_WRITE | APR_FOPEN_CREATE | APR_FOPEN_APPEND,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "create file", rv);

    rv = apr_file_lock(f, APR_FLOCK_EXCLUSIVE);
    APR_ASSERT_SUCCESS(tc, "lock file", rv);

    /* PR50058: Appending to a locked file should not deadlock. */
    rv = apr_file_write_full(f, "abc", 3, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);

    apr_file_unlock(f);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ, APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open file", rv);

    rv = apr_file_read_full(f, buf, sizeof(buf), &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, 3, (int)bytes_read);
    ABTS_STR_EQUAL(tc, "abc", buf);

    apr_file_close(f);
    apr_file_remove(fname, p);
}

static void test_large_write_buffered(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testlarge_write_buffered.dat";
    apr_size_t len;
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char *buf;
    char *buf2;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname,
                       APR_FOPEN_CREATE | APR_FOPEN_WRITE | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);

    /* Test a single large write. */
    len = 80000;
    buf = apr_palloc(p, len);
    memset(buf, 'a', len);
    rv = apr_file_write_full(f, buf, len, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    ABTS_INT_EQUAL(tc, (int)len, (int)bytes_written);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    buf2 = apr_palloc(p, len + 1);
    rv = apr_file_read_full(f, buf2, len + 1, &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, (int)len, (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf, buf2, len) == 0);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_two_large_writes_buffered(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtwo_large_writes_buffered.dat";
    apr_size_t len;
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char *buf;
    char *buf2;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname,
                       APR_FOPEN_CREATE | APR_FOPEN_WRITE | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);

    /* Test two consecutive large writes. */
    len = 80000;
    buf = apr_palloc(p, len);
    memset(buf, 'a', len);

    rv = apr_file_write_full(f, buf, len / 2, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    ABTS_INT_EQUAL(tc, (int)(len / 2), (int)bytes_written);

    rv = apr_file_write_full(f, buf, len / 2, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    ABTS_INT_EQUAL(tc, (int)(len / 2), (int)bytes_written);

    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    buf2 = apr_palloc(p, len + 1);
    rv = apr_file_read_full(f, buf2, len + 1, &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, (int) len, (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf, buf2, len) == 0);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_small_and_large_writes_buffered(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtwo_large_writes_buffered.dat";
    apr_size_t len;
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char *buf;
    char *buf2;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname,
                       APR_FOPEN_CREATE | APR_FOPEN_WRITE | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);

    /* Test small write followed by a large write. */
    len = 80000;
    buf = apr_palloc(p, len);
    memset(buf, 'a', len);

    rv = apr_file_write_full(f, buf, 5, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    ABTS_INT_EQUAL(tc, 5, (int)bytes_written);

    rv = apr_file_write_full(f, buf, len - 5, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    ABTS_INT_EQUAL(tc, (int)(len - 5), (int)bytes_written);

    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    buf2 = apr_palloc(p, len + 1);
    rv = apr_file_read_full(f, buf2, len + 1, &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, (int) len, (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf, buf2, len) == 0);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_write_buffered_spanning_over_bufsize(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testwrite_buffered_spanning_over_bufsize.dat";
    apr_size_t len;
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char *buf;
    char *buf2;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname,
                       APR_FOPEN_CREATE | APR_FOPEN_WRITE | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);

    /* Test three writes than span over the default buffer size. */
    len = APR_BUFFERSIZE + 1;
    buf = apr_palloc(p, len);
    memset(buf, 'a', len);

    rv = apr_file_write_full(f, buf, APR_BUFFERSIZE - 1, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    ABTS_INT_EQUAL(tc, APR_BUFFERSIZE - 1, (int)bytes_written);

    rv = apr_file_write_full(f, buf, 2, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    ABTS_INT_EQUAL(tc, 2, (int)bytes_written);

    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    buf2 = apr_palloc(p, len + 1);
    rv = apr_file_read_full(f, buf2, len + 1, &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, (int)len, (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf, buf2, len) == 0);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_empty_read_buffered(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testempty_read_buffered.dat";
    apr_size_t len;
    apr_size_t bytes_read;
    char buf[64];

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "create empty test file", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    /* Test an empty read. */
    len = 1;
    rv = apr_file_read_full(f, buf, len, &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, 0, (int)bytes_read);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_large_read_buffered(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testlarge_read_buffered.dat";
    apr_size_t len;
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char *buf;
    char *buf2;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);
    len = 80000;
    buf = apr_palloc(p, len);
    memset(buf, 'a', len);
    rv = apr_file_write_full(f, buf, len, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    /* Test a single large read. */
    buf2 = apr_palloc(p, len);
    rv = apr_file_read_full(f, buf2, len, &bytes_read);
    APR_ASSERT_SUCCESS(tc, "read from file", rv);
    ABTS_INT_EQUAL(tc, (int)len, (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf, buf2, bytes_read) == 0);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    /* Test that we receive an EOF. */
    len = 1;
    rv = apr_file_read_full(f, buf2, len, &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, 0, (int)bytes_read);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_two_large_reads_buffered(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtwo_large_reads_buffered.dat";
    apr_size_t len;
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char *buf;
    char *buf2;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);
    len = 80000;
    buf = apr_palloc(p, len);
    memset(buf, 'a', len);
    rv = apr_file_write_full(f, buf, len, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    /* Test two consecutive large reads. */
    buf2 = apr_palloc(p, len);
    memset(buf2, 0, len);
    rv = apr_file_read_full(f, buf2, len / 2, &bytes_read);
    APR_ASSERT_SUCCESS(tc, "read from file", rv);
    ABTS_INT_EQUAL(tc, (int)(len / 2), (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf, buf2, bytes_read) == 0);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    memset(buf2, 0, len);
    rv = apr_file_read_full(f, buf2, len / 2, &bytes_read);
    APR_ASSERT_SUCCESS(tc, "read from file", rv);
    ABTS_INT_EQUAL(tc, (int)(len / 2), (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf + len / 2, buf2, bytes_read) == 0);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    /* Test that we receive an EOF. */
    len = 1;
    rv = apr_file_read_full(f, buf2, len, &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, 0, (int)bytes_read);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_small_and_large_reads_buffered(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtwo_large_reads_buffered.dat";
    apr_size_t len;
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char *buf;
    char *buf2;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);
    len = 80000;
    buf = apr_palloc(p, len);
    memset(buf, 'a', len);
    rv = apr_file_write_full(f, buf, len, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    /* Test small read followed by a large read. */
    buf2 = apr_palloc(p, len);
    memset(buf2, 0, len);
    rv = apr_file_read_full(f, buf2, 5, &bytes_read);
    APR_ASSERT_SUCCESS(tc, "read from file", rv);
    ABTS_INT_EQUAL(tc, 5, (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf, buf2, bytes_read) == 0);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    memset(buf2, 0, len);
    rv = apr_file_read_full(f, buf2, len - 5, &bytes_read);
    APR_ASSERT_SUCCESS(tc, "read from file", rv);
    ABTS_INT_EQUAL(tc, (int)(len - 5), (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf + 5, buf2, bytes_read) == 0);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    /* Test that we receive an EOF. */
    len = 1;
    rv = apr_file_read_full(f, buf2, len, &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, 0, (int)bytes_read);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_read_buffered_spanning_over_bufsize(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testread_buffered_spanning_over_bufsize.dat";
    apr_size_t len;
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char *buf;
    char *buf2;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);
    len = APR_BUFFERSIZE + 1;
    buf = apr_palloc(p, len);
    memset(buf, 'a', len);
    rv = apr_file_write_full(f, buf, len, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    /* Test reads than span over the default buffer size. */
    buf2 = apr_palloc(p, len);
    memset(buf2, 0, len);
    rv = apr_file_read_full(f, buf2, APR_BUFFERSIZE - 1, &bytes_read);
    APR_ASSERT_SUCCESS(tc, "read from file", rv);
    ABTS_INT_EQUAL(tc, APR_BUFFERSIZE - 1, (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf, buf2, bytes_read) == 0);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    memset(buf2, 0, len);
    rv = apr_file_read_full(f, buf2, 2, &bytes_read);
    APR_ASSERT_SUCCESS(tc, "read from file", rv);
    ABTS_INT_EQUAL(tc, 2, (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf, buf2, bytes_read) == 0);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    /* Test that we receive an EOF. */
    len = 1;
    rv = apr_file_read_full(f, buf2, len, &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, 0, (int)bytes_read);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_single_byte_reads_buffered(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testsingle_byte_reads_buffered.dat";
    apr_size_t len;
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char *buf;
    apr_size_t total;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);
    len = 40000;
    buf = apr_palloc(p, len);
    memset(buf, 'a', len);
    rv = apr_file_write_full(f, buf, len, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    total = 0;
    while (1) {
        memset(buf, 0, len);
        rv = apr_file_read_full(f, buf, 1, &bytes_read);
        if (rv == APR_EOF) {
            break;
        }
        APR_ASSERT_SUCCESS(tc, "read from file", rv);
        ABTS_INT_EQUAL(tc, 1, (int)bytes_read);
        ABTS_INT_EQUAL(tc, 'a', buf[0]);
        total += bytes_read;
    }
    ABTS_INT_EQUAL(tc, (int)len, (int)total);

    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_read_buffered_seek(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testtest_read_buffered_seek.dat";
    apr_size_t len;
    apr_size_t bytes_written;
    apr_size_t bytes_read;
    char buf[64];
    apr_off_t off;

    apr_file_remove(fname, p);

    rv = apr_file_open(&f, fname, APR_FOPEN_CREATE | APR_FOPEN_WRITE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for writing", rv);
    rv = apr_file_write_full(f, "abcdef", 6, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open test file for reading", rv);

    /* Read one byte. */
    memset(buf, 0, sizeof(buf));
    rv = apr_file_read_full(f, buf, 1, &bytes_read);
    APR_ASSERT_SUCCESS(tc, "read from file", rv);
    ABTS_INT_EQUAL(tc, 1, (int)bytes_read);
    ABTS_INT_EQUAL(tc, 'a', buf[0]);

    /* Seek into the middle of the file. */
    off = 3;
    rv = apr_file_seek(f, APR_SET, &off);
    APR_ASSERT_SUCCESS(tc, "change file read offset", rv);
    ABTS_INT_EQUAL(tc, 3, (int)off);

    /* Read three bytes. */
    memset(buf, 0, sizeof(buf));
    rv = apr_file_read_full(f, buf, 3, &bytes_read);
    APR_ASSERT_SUCCESS(tc, "read from file", rv);
    ABTS_INT_EQUAL(tc, 3, (int)bytes_read);
    ABTS_TRUE(tc, memcmp(buf, "def", bytes_read) == 0);

    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_SUCCESS, rv);

    /* Test that we receive an EOF. */
    len = 1;
    rv = apr_file_read_full(f, buf, len, &bytes_read);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    ABTS_INT_EQUAL(tc, 0, (int)bytes_read);
    rv = apr_file_eof(f);
    ABTS_INT_EQUAL(tc, APR_EOF, rv);
    apr_file_close(f);

    apr_file_remove(fname, p);
}

static void test_append_buffered(abts_case *tc, void *data)
{
    apr_status_t rv;
    apr_file_t *f;
    const char *fname = "data/testappend_buffered.dat";
    apr_size_t bytes_written;
    char buf[64];

    apr_file_remove(fname, p);

    /* Create file with contents. */
    rv = apr_file_open(&f, fname, APR_FOPEN_WRITE | APR_FOPEN_CREATE,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "create file", rv);

    rv = apr_file_write_full(f, "abc", 3, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    apr_file_close(f);

    /* Re-open it with APR_FOPEN_APPEND and APR_FOPEN_BUFFERED. */
    rv = apr_file_open(&f, fname,
                       APR_FOPEN_READ | APR_FOPEN_WRITE |
                       APR_FOPEN_APPEND | APR_FOPEN_BUFFERED,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open file", rv);

    /* Append to the file. */
    rv = apr_file_write_full(f, "def", 3, &bytes_written);
    APR_ASSERT_SUCCESS(tc, "write to file", rv);
    apr_file_close(f);

    rv = apr_file_open(&f, fname, APR_FOPEN_READ,
                       APR_FPROT_OS_DEFAULT, p);
    APR_ASSERT_SUCCESS(tc, "open file", rv);

    /* Test the file contents. */
    rv = apr_file_gets(buf, sizeof(buf), f);
    APR_ASSERT_SUCCESS(tc, "read from file", rv);
    ABTS_STR_EQUAL(tc, "abcdef", buf);

    apr_file_close(f);
    apr_file_remove(fname, p);
}

abts_suite *testfile(abts_suite *suite)
{
    suite = ADD_SUITE(suite)

    abts_run_test(suite, test_open_noreadwrite, NULL);
    abts_run_test(suite, test_open_excl, NULL);
    abts_run_test(suite, test_open_read, NULL);
    abts_run_test(suite, test_open_readwrite, NULL);
    abts_run_test(suite, link_existing, NULL);
    abts_run_test(suite, link_nonexisting, NULL);
    abts_run_test(suite, test_read, NULL); 
    abts_run_test(suite, test_readzero, NULL); 
    abts_run_test(suite, test_seek, NULL);
    abts_run_test(suite, test_filename, NULL);
    abts_run_test(suite, test_fileclose, NULL);
    abts_run_test(suite, test_file_remove, NULL);
    abts_run_test(suite, test_open_write, NULL);
    abts_run_test(suite, test_open_writecreate, NULL);
    abts_run_test(suite, test_write, NULL);
    abts_run_test(suite, test_userdata_set, NULL);
    abts_run_test(suite, test_userdata_get, NULL);
    abts_run_test(suite, test_userdata_getnokey, NULL);
    abts_run_test(suite, test_getc, NULL);
    abts_run_test(suite, test_ungetc, NULL);
    abts_run_test(suite, test_gets, NULL);
    abts_run_test(suite, test_gets_buffered, NULL);
    abts_run_test(suite, test_gets_empty, NULL);
    abts_run_test(suite, test_gets_multiline, NULL);
    abts_run_test(suite, test_gets_small_buf, NULL);
    abts_run_test(suite, test_gets_ungetc, NULL);
    abts_run_test(suite, test_gets_buffered_big, NULL);
    abts_run_test(suite, test_puts, NULL);
    abts_run_test(suite, test_writev, NULL);
    abts_run_test(suite, test_writev_full, NULL);
    abts_run_test(suite, test_writev_buffered, NULL);
    abts_run_test(suite, test_writev_buffered_seek, NULL);
    abts_run_test(suite, test_bigread, NULL);
    abts_run_test(suite, test_mod_neg, NULL);
    abts_run_test(suite, test_truncate, NULL);
    abts_run_test(suite, test_file_trunc, NULL);
    abts_run_test(suite, test_file_trunc2, NULL);
    abts_run_test(suite, test_file_trunc_buffered_write, NULL);
    abts_run_test(suite, test_file_trunc_buffered_write2, NULL);
    abts_run_test(suite, test_file_trunc_buffered_read, NULL);
    abts_run_test(suite, test_bigfprintf, NULL);
    abts_run_test(suite, test_fail_write_flush, NULL);
    abts_run_test(suite, test_fail_read_flush, NULL);
    abts_run_test(suite, test_buffer_set_get, NULL);
    abts_run_test(suite, test_xthread, NULL);
    abts_run_test(suite, test_datasync_on_file, NULL);
    abts_run_test(suite, test_datasync_on_stream, NULL);
    abts_run_test(suite, test_atomic_append, NULL);
    abts_run_test(suite, test_append_locked, NULL);
    abts_run_test(suite, test_large_write_buffered, NULL);
    abts_run_test(suite, test_two_large_writes_buffered, NULL);
    abts_run_test(suite, test_small_and_large_writes_buffered, NULL);
    abts_run_test(suite, test_write_buffered_spanning_over_bufsize, NULL);
    abts_run_test(suite, test_empty_read_buffered, NULL);
    abts_run_test(suite, test_large_read_buffered, NULL);
    abts_run_test(suite, test_two_large_reads_buffered, NULL);
    abts_run_test(suite, test_small_and_large_reads_buffered, NULL);
    abts_run_test(suite, test_read_buffered_spanning_over_bufsize, NULL);
    abts_run_test(suite, test_single_byte_reads_buffered, NULL);
    abts_run_test(suite, test_read_buffered_seek, NULL);
    abts_run_test(suite, test_append_buffered, NULL);

    return suite;
}