apfs/apfstests
0
0
Fork 0
mirror of https://github.com/linux-apfs/apfstests.git synced 2026-05-01 15:01:44 -07:00
Code Issues Packages Projects Releases Wiki Activity

Add aio-dio-regress tests

Browse Source 
Pull in the aio-dio-regress test suite from
http://git.kernel.org/?p=linux/kernel/git/zab/aio-dio-regress.git

Signed-off-by: Eric Sandeen <sandeen@sandeen.net>
Reviewed-by: Christoph Hellwig <hch@lst.de>
This commit is contained in:
Eric Sandeen
2009-06-03 15:07:02 -05:00
parent e17b2a1acb
commit c639e76bdb
23 changed files with 1178 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.gitignore
+6
View File
@@ -88,3 +88,9 @@ src/unwritten_sync
src/usemem
src/writemod
src/xfsctl
src/aio-dio-regress/aio-dio-extend-stat
src/aio-dio-regress/aio-dio-invalidate-failure
src/aio-dio-regress/aio-dio-invalidate-readahead
src/aio-dio-regress/aio-dio-subblock-eof-read
src/aio-dio-regress/aio-free-ring-with-bogus-nr-pages
src/aio-dio-regress/aio-io-setup-with-nonwritable-context-pointer
207
Executable
+54
View File
@@ -0,0 +1,54 @@
#! /bin/sh
# FS QA Test No. 207
#
# Run aio-dio-extend-stat - test race in dio aio completion
#
#-----------------------------------------------------------------------
# Copyright (c) 2009 Eric Sandeen. All Rights Reserved.
#
# This program 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.
#
# This program is distributed in the hope that it would 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, write the Free Software Foundation,
# Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
#-----------------------------------------------------------------------
#
# creator
owner=sandeen@sandeen.net
seq=`basename $0`
echo "QA output created by $seq"
here=`pwd`
tmp=/tmp/$$
status=1 # failure is the default!
trap "_cleanup; exit \$status" 0 1 2 3 15
_cleanup()
{
cd /
rm -f $tmp.*
}
# get standard environment, filters and checks
. ./common.rc
. ./common.filter
# real QA test starts here
_supported_fs generic
_supported_os Linux
rm -f $TEST_DIR/aio-testfile
src/aio-dio-regress/aio-dio-extend-stat $TEST_DIR/aio-testfile 2>&1
status=$?
rm -f $TEST_DIR/aio-testfile
exit $status
207.out
+2
View File
@@ -0,0 +1,2 @@
QA output created by 207
4000 iterations of racing extensions and collection passed
208
Executable
+54
View File
@@ -0,0 +1,54 @@
#! /bin/sh
# FS QA Test No. 208
#
# Run aio-dio-invalidate-failure - test race in read cache invalidation
#
#-----------------------------------------------------------------------
# Copyright (c) 2009 Eric Sandeen. All Rights Reserved.
#
# This program 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.
#
# This program is distributed in the hope that it would 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, write the Free Software Foundation,
# Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
#-----------------------------------------------------------------------
#
# creator
owner=sandeen@sandeen.net
seq=`basename $0`
echo "QA output created by $seq"
here=`pwd`
tmp=/tmp/$$
status=1 # failure is the default!
trap "_cleanup; exit \$status" 0 1 2 3 15
_cleanup()
{
cd /
rm -f $tmp.*
}
# get standard environment, filters and checks
. ./common.rc
. ./common.filter
# real QA test starts here
_supported_fs generic
_supported_os Linux
rm -f $TEST_DIR/aio-testfile
src/aio-dio-regress/aio-dio-invalidate-failure $TEST_DIR/aio-testfile 2>&1
status=$?
rm -f $TEST_DIR/aio-testfile
exit $status
208.out
+2
View File
@@ -0,0 +1,2 @@
QA output created by 208
ran for 200 seconds without error, passing
209
Executable
+54
View File
@@ -0,0 +1,54 @@
#! /bin/sh
# FS QA Test No. 209
#
# Run aio-dio-invalidate-readahead - test sync DIO invalidation of readahead
#
#-----------------------------------------------------------------------
# Copyright (c) 2009 Eric Sandeen. All Rights Reserved.
#
# This program 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.
#
# This program is distributed in the hope that it would 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, write the Free Software Foundation,
# Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
#-----------------------------------------------------------------------
#
# creator
owner=sandeen@sandeen.net
seq=`basename $0`
echo "QA output created by $seq"
here=`pwd`
tmp=/tmp/$$
status=1 # failure is the default!
trap "_cleanup; exit \$status" 0 1 2 3 15
_cleanup()
{
cd /
rm -f $tmp.*
}
# get standard environment, filters and checks
. ./common.rc
. ./common.filter
# real QA test starts here
_supported_fs generic
_supported_os Linux
rm -f $TEST_DIR/aio-testfile
src/aio-dio-regress/aio-dio-invalidate-readahead $TEST_DIR/aio-testfile 2>&1
status=$?
rm -f $TEST_DIR/aio-testfile
exit $status
209.out
+2
View File
@@ -0,0 +1,2 @@
QA output created by 209
test ran for 30 seconds without error
210
Executable
+54
View File
@@ -0,0 +1,54 @@
#! /bin/sh
# FS QA Test No. 210
#
# Run aio-dio-subblock-eof-read - test AIO read of last block of DIO file
#
#-----------------------------------------------------------------------
# Copyright (c) 2009 Eric Sandeen. All Rights Reserved.
#
# This program 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.
#
# This program is distributed in the hope that it would 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, write the Free Software Foundation,
# Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
#-----------------------------------------------------------------------
#
# creator
owner=sandeen@sandeen.net
seq=`basename $0`
echo "QA output created by $seq"
here=`pwd`
tmp=/tmp/$$
status=1 # failure is the default!
trap "_cleanup; exit \$status" 0 1 2 3 15
_cleanup()
{
cd /
rm -f $tmp.*
}
# get standard environment, filters and checks
. ./common.rc
. ./common.filter
# real QA test starts here
_supported_fs generic
_supported_os Linux
rm -f $TEST_DIR/aio-testfile
src/aio-dio-regress/aio-dio-subblock-eof-read $TEST_DIR/aio-testfile 2>&1
status=$?
rm -f $TEST_DIR/aio-testfile
exit $status
210.out
+2
View File
@@ -0,0 +1,2 @@
QA output created by 210
AIO read of last block in file succeeded.
211
Executable
+54
View File
@@ -0,0 +1,54 @@
#! /bin/sh
# FS QA Test No. 211
#
# Run aio-free-ring-with-bogus-nr-pages - test aio_setup_ring with bad nr_pages
#
#-----------------------------------------------------------------------
# Copyright (c) 2009 Eric Sandeen. All Rights Reserved.
#
# This program 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.
#
# This program is distributed in the hope that it would 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, write the Free Software Foundation,
# Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
#-----------------------------------------------------------------------
#
# creator
owner=sandeen@sandeen.net
seq=`basename $0`
echo "QA output created by $seq"
here=`pwd`
tmp=/tmp/$$
status=1 # failure is the default!
trap "_cleanup; exit \$status" 0 1 2 3 15
_cleanup()
{
cd /
rm -f $tmp.*
}
# get standard environment, filters and checks
. ./common.rc
. ./common.filter
# real QA test starts here
_supported_fs generic
_supported_os Linux
rm -f $TEST_DIR/aio-testfile
src/aio-dio-regress/aio-free-ring-with-bogus-nr-pages $TEST_DIR/aio-testfile 2>&1
status=$?
rm -f $TEST_DIR/aio-testfile
exit $status
211.out
+2
View File
@@ -0,0 +1,2 @@
QA output created by 211
aio-free-ring-with-bogus-nr-pages: Success!
212
Executable
+55
View File
@@ -0,0 +1,55 @@
#! /bin/sh
# FS QA Test No. 212
#
# Run aio-io-setup-with-nonwritable-context-pointer -
# Test what happens when a non-writable context pointer is passed to io_setup
#
#-----------------------------------------------------------------------
# Copyright (c) 2009 Eric Sandeen. All Rights Reserved.
#
# This program 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.
#
# This program is distributed in the hope that it would 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, write the Free Software Foundation,
# Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
#-----------------------------------------------------------------------
#
# creator
owner=sandeen@sandeen.net
seq=`basename $0`
echo "QA output created by $seq"
here=`pwd`
tmp=/tmp/$$
status=1 # failure is the default!
trap "_cleanup; exit \$status" 0 1 2 3 15
_cleanup()
{
cd /
rm -f $tmp.*
}
# get standard environment, filters and checks
. ./common.rc
. ./common.filter
# real QA test starts here
_supported_fs generic
_supported_os Linux
rm -f $TEST_DIR/aio-testfile
src/aio-dio-regress/aio-io-setup-with-nonwritable-context-pointer $TEST_DIR/aio-testfile 2>&1
status=$?
rm -f $TEST_DIR/aio-testfile
exit $status
212.out
+2
View File
@@ -0,0 +1,2 @@
QA output created by 212
aio-io-setup-with-nonwritable-context-pointer: Success!
group
+6
View File
@@ -311,3 +311,9 @@ atime
204 metadata rw auto
205 metadata rw auto
206 growfs auto quick
207 generic auto aio quick
208 generic auto aio
209 generic auto aio
210 generic auto aio quick
211 generic auto aio quick
212 generic auto aio quick
src/Makefile
+5 -1
View File
@@ -39,10 +39,14 @@ ifeq ($(PKG_PLATFORM),linux)
TARGETS += t_immutable
endif
ifeq ($(HAVE_AIO), true)
SUBDIRS += aio-dio-regress
endif
CFILES = $(TARGETS:=.c)
LDIRT = $(TARGETS)
default: $(TARGETS)
default: $(TARGETS) $(SUBDIRS)
include $(BUILDRULES)
LINKTEST = $(LTLINK) $@.c -o $@ $(CFLAGS) $(LDFLAGS)
src/aio-dio-regress/Makefile
+20
View File
@@ -0,0 +1,20 @@
TOPDIR = ../..
include $(TOPDIR)/include/builddefs
TARGETS = $(basename $(wildcard *.c))
CFILES = $(TARGETS:=.c)
LDIRT = $(TARGETS)
LIBAIO = -laio -lpthread
default: $(TARGETS)
include $(BUILDRULES)
$(TARGETS): %: %.c
$(CC) -g -Wall $(LIBAIO) -o $@ $*.c
install:
$(INSTALL) -m 755 -d $(PKG_LIB_DIR)/src/aio-dio-regress
$(INSTALL) -m 755 $(TARGETS) $(PKG_LIB_DIR)/src/aio-dio-regress
src/aio-dio-regress/SOURCE
+7
View File
@@ -0,0 +1,7 @@
From:
http://www.kernel.org/pub/scm/linux/kernel/git/zab/aio-dio-regress.git
description AIO and DIO regression tests
owner Zach Brown
URL git://git.kernel.org/pub/scm/linux/kernel/git/zab/aio-dio-regress.git
http://www.kernel.org/pub/scm/linux/kernel/git/zab/aio-dio-regress.git
src/aio-dio-regress/aio-dio-extend-stat.c
+181
View File
@@ -0,0 +1,181 @@
/*
* aio-dio-extend-stat - test race in dio aio completion
* Copyright (C) 2006 Rafal Wijata
*
* This program 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 2 of the License, or
* (at your option) any later version.
*
* This program 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, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
#define __USE_GNU
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <libaio.h>
#include <malloc.h>
#include <fcntl.h>
#include <pthread.h>
#include <errno.h>
#ifndef O_DIRECT
#define O_DIRECT 040000 /* direct disk access hint */
#endif
/*
* This was originally submitted to
* http://bugzilla.kernel.org/show_bug.cgi?id=6831 by
* Rafal Wijata <wijata@nec-labs.com>. It caught a race in dio aio completion
* that would call aio_complete() before the dio callers would update i_size.
* A stat after io_getevents() would not see the new file size.
*
* The bug was fixed in the fs/direct-io.c completion reworking that appeared
* in 2.6.20. This test should fail on 2.6.19.
*/
#define BUFSIZE 1024
static unsigned char buf[BUFSIZE] __attribute((aligned (512)));
/*
* this was arbitrarily chosen to take about two seconds on a dual athlon in a
* debugging kernel.. it trips up long before that.
*/
#define MAX_AIO_EVENTS 4000
#define fail(fmt , args...) do {\
printf(fmt , ##args); \
exit(1); \
} while (0)
void fun_write1(void* ptr);
void fun_writeN(void* ptr);
void fun_read(void* ptr);
int handle = 0;
io_context_t ctxp;
struct iocb *iocbs[MAX_AIO_EVENTS];
struct io_event ioevents[MAX_AIO_EVENTS];
volatile int submittedSize = 0; //synchronization
int main(int argc, char **argv)
{
pthread_t thread_read;
pthread_t thread_write;
int i;
int ret;
if (argc != 2)
fail("only arg should be file name\n");
for (i = 0; i < BUFSIZE; ++i)
buf[i] = 'A' + (char)(i % ('Z'-'A'+1));
buf[BUFSIZE-1] = '\n';
handle = open(argv[1], O_CREAT | O_TRUNC | O_DIRECT | O_RDWR, 0600);
if (handle == -1)
fail("failed to open test file %s, errno: %d\n",
argv[1], errno);
memset(&ctxp, 0, sizeof(ctxp));
ret = io_setup(MAX_AIO_EVENTS, &ctxp);
if (ret)
fail("io_setup returned %d\n", ret);
for (i = 0; i < MAX_AIO_EVENTS; ++i) {
iocbs[i] = calloc(1, sizeof(struct iocb));
if (iocbs[i] == NULL)
fail("failed to allocate an iocb\n");
/* iocbs[i]->data = i; */
iocbs[i]->aio_fildes = handle;
iocbs[i]->aio_lio_opcode = IO_CMD_PWRITE;
iocbs[i]->aio_reqprio = 0;
iocbs[i]->u.c.buf = buf;
iocbs[i]->u.c.nbytes = BUFSIZE;
iocbs[i]->u.c.offset = BUFSIZE*i;
}
pthread_create(&thread_read, NULL, (void*)&fun_read, NULL);
pthread_create(&thread_write, NULL, (void*)&fun_writeN, NULL);
pthread_join(thread_read, NULL);
pthread_join(thread_write, NULL);
io_destroy(ctxp);
close(handle);
printf("%u iterations of racing extensions and collection passed\n",
MAX_AIO_EVENTS);
return 0;
}
void fun_read(void *ptr)
{
long n = MAX_AIO_EVENTS;
struct stat filestat;
long long exSize;
long i;
long r;
while (n > 0) {
r = io_getevents(ctxp, 1, MAX_AIO_EVENTS, ioevents, NULL);
if (r < 0)
fail("io_getevents returned %ld\n", r);
n -= r;
for (i = 0; i < r; ++i) {
if (ioevents[i].obj->u.c.nbytes != BUFSIZE)
fail("error in block: expacted %d bytes, "
"receiced %ld\n", BUFSIZE,
ioevents[i].obj->u.c.nbytes);
exSize = ioevents[i].obj->u.c.offset +
ioevents[i].obj->u.c.nbytes;
fstat(handle, &filestat);
if (filestat.st_size < exSize)
fail("write of %lu bytes @%llu finished, "
"expected filesize at least %llu, but "
"got %ld\n", ioevents[i].obj->u.c.nbytes,
ioevents[i].obj->u.c.offset, exSize,
filestat.st_size);
}
}
}
void fun_writeN(void *ptr)
{
int i;
int ret;
for(i = 0; i < MAX_AIO_EVENTS; ++i) {
ret = io_submit(ctxp, 1, &(iocbs[i]));
if (ret != 1)
fail("io_subit returned %d instead of 1\n", ret);
}
}
void fun_write1(void *ptr)
{
int ret;
ret = io_submit(ctxp, MAX_AIO_EVENTS, iocbs);
if (ret != MAX_AIO_EVENTS)
fail("io_subit returned %d instead of %u\n", ret,
MAX_AIO_EVENTS);
}
src/aio-dio-regress/aio-dio-invalidate-failure.c
+174
View File
@@ -0,0 +1,174 @@
/*
* aio-dio-invalidate-failure - test race in read cache invalidation
* Copyright (C) 2007 Zach Brown
*
* This program 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 2 of the License, or
* (at your option) any later version.
*
* This program 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, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
#define _XOPEN_SOURCE 500 /* pwrite */
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <libaio.h>
#include <errno.h>
#include <time.h>
#include <sys/types.h>
#include <sys/wait.h>
/*
* DIO invalidates the read cache after it writes. At one point it tried to
* return EIO if this failed. When called from AIO, though, this EIO return
* would clobber EIOCBQUEUED and cause fs/aio.c and fs/direct-io.c to complete
* an iocb twice. This typically references freed memory from an interrupt
* handler and oopses.
*
* This test hits the race after at most two minutes on a single spindle. It
* spins performing large dio writes. It also spins racing buffered writes.
* It assumes it's on ext3 using ordered writes. The ordered write bhs can be
* pinned by jbd as a transaction commits. If invalidate_inode_pages2_range()
* hits pages backed by those buffers ->releasepage will fail and it'll try to
* return -EIO.
*/
#ifndef O_DIRECT
#define O_DIRECT 040000 /* direct disk access hint */
#endif
#define GINORMOUS (32 * 1024 * 1024)
/* This test never survived to 180 seconds on a single spindle */
#define SECONDS 200
static unsigned char buf[GINORMOUS] __attribute((aligned (512)));
#define fail(fmt , args...) do {\
printf(fmt , ##args); \
exit(1); \
} while (0)
void spin_dio(int fd)
{
io_context_t ctx;
struct iocb iocb;
struct iocb *iocbs[1] = { &iocb };
struct io_event event;
int ret;
io_prep_pwrite(&iocb, fd, buf, GINORMOUS, 0);
ret = io_queue_init(1, &ctx);
if (ret)
fail("io_queue_init returned %d", ret);
while (1) {
ret = io_submit(ctx, 1, iocbs);
if (ret != 1)
fail("io_submit returned %d instead of 1", ret);
ret = io_getevents(ctx, 1, 1, &event, NULL);
if (ret != 1)
fail("io_getevents returned %d instead of 1", ret);
if (event.res == -EIO) {
printf("invalidation returned -EIO, OK\n");
exit(0);
}
if (event.res != GINORMOUS)
fail("event res %ld\n", event.res);
}
}
void spin_buffered(int fd)
{
int ret;
while (1) {
ret = pwrite(fd, buf, GINORMOUS, 0);
if (ret != GINORMOUS)
fail("buffered write returned %d", ret);
}
}
static void alarm_handler(int signum)
{
}
int main(int argc, char **argv)
{
pid_t buffered_pid;
pid_t dio_pid;
pid_t pid;
int fd;
int fd2;
int status;
if (argc != 2)
fail("only arg should be file name");
fd = open(argv[1], O_DIRECT|O_CREAT|O_RDWR, 0644);
if (fd < 0)
fail("open dio failed: %d\n", errno);
fd2 = open(argv[1], O_RDWR, 0644);
if (fd < 0)
fail("open failed: %d\n", errno);
buffered_pid = fork();
if (buffered_pid < 0)
fail("fork failed: %d\n", errno);
if (buffered_pid == 0) {
spin_buffered(fd2);
exit(0);
}
dio_pid = fork();
if (dio_pid < 0) {
kill(buffered_pid, SIGKILL);
fail("fork failed: %d\n", errno);
}
if (dio_pid == 0) {
spin_dio(fd);
exit(0);
}
signal(SIGALRM, alarm_handler);
alarm(SECONDS);
pid = wait(&status);
if (pid < 0 && errno == EINTR) {
/* if we timed out then we're done */
kill(buffered_pid, SIGKILL);
kill(dio_pid, SIGKILL);
printf("ran for %d seconds without error, passing\n", SECONDS);
exit(0);
}
if (pid == dio_pid)
kill(buffered_pid, SIGKILL);
else
kill(dio_pid, SIGKILL);
/*
* pass on the child's pass/fail return code or fail if the child
* didn't exit cleanly.
*/
exit(WIFEXITED(status) ? WEXITSTATUS(status) : 1);
}
src/aio-dio-regress/aio-dio-invalidate-readahead.c
+191
View File
@@ -0,0 +1,191 @@
/*
* aio-dio-invalidate-readahead - test sync DIO invalidation of readahead
* Copyright (C) 2007 Zach Brown
*
* This program 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 2 of the License, or
* (at your option) any later version.
*
* This program 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, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
#define _XOPEN_SOURCE 500 /* pwrite */
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <libaio.h>
#include <errno.h>
#include <time.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <pthread.h>
#include <malloc.h>
/*
* sync DIO invalidates the read cache after it finishes the write. This
* is to invalidate cached pages which might have been brought in during
* the write.
*
* In http://lkml.org/lkml/2007/10/26/478 a user reported this failing
* for his case of readers and writers racing. It turned out that his
* reader wasn't actually racing with the writer, but read-ahead from
* the reader pushed reads up into the region that the writer was working
* on.
*
* This test reproduces his case. We have a writing thread tell
* a reading thread how far into the file it will find new data.
* The reader reads behind the writer, checking for stale data.
* If the kernel fails to invalidate the read-ahead after the
* write then the reader will see stale data.
*/
#ifndef O_DIRECT
#define O_DIRECT 040000 /* direct disk access hint */
#endif
#define FILE_SIZE (8 * 1024 * 1024)
/* this test always failed before 10 seconds on a single spindle */
#define SECONDS 30
#define fail(fmt , args...) do {\
printf(fmt , ##args); \
exit(1); \
} while (0)
int page_size;
pthread_mutex_t mut = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
loff_t write_pos = 0;
loff_t read_pos = 0;
unsigned char byte = 0;
static void *writer(void *arg)
{
char *path = arg;
loff_t off;
void *buf;
int ret;
int fd;
time_t start = time(NULL);
buf = memalign(page_size, page_size);
if (buf == NULL)
fail("failed to allocate an aligned page");
fd = open(path, O_DIRECT|O_CREAT|O_RDWR|O_TRUNC, 0644);
if (fd < 0)
fail("dio open failed: %d\n", errno);
while (1) {
if ((time(NULL) - start) > SECONDS) {
printf("test ran for %u seconds without error\n",
SECONDS);
exit(0);
}
pthread_mutex_lock(&mut);
while (read_pos != write_pos)
pthread_cond_wait(&cond, &mut);
byte++;
write_pos = 0;
pthread_mutex_unlock(&mut);
memset(buf, byte, page_size);
for (off = 0; off < FILE_SIZE; off += page_size) {
ret = pwrite(fd, buf, page_size, off);
if (ret != page_size)
fail("write returned %d", ret);
if ((rand() % 4) == 0) {
pthread_mutex_lock(&mut);
write_pos = off;
pthread_cond_signal(&cond);
pthread_mutex_unlock(&mut);
};
}
}
}
static void *reader(void *arg)
{
char *path = arg;
unsigned char old;
loff_t read_to = 0;
void *found;
int fd;
int ret;
void *buf;
loff_t off;
setvbuf(stdout, NULL, _IONBF, 0);
buf = memalign(page_size, page_size);
if (buf == NULL)
fail("failed to allocate an aligned page");
fd = open(path, O_CREAT|O_RDONLY, 0644);
if (fd < 0)
fail("buffered open failed: %d\n", errno);
while (1) {
pthread_mutex_lock(&mut);
read_pos = read_to;
pthread_cond_signal(&cond);
while (read_pos == write_pos)
pthread_cond_wait(&cond, &mut);
read_to = write_pos;
off = read_pos;
old = byte - 1;
pthread_mutex_unlock(&mut);
for (; off < read_to; off += page_size) {
ret = pread(fd, buf, page_size, off);
if (ret != page_size)
fail("write returned %d", ret);
found = memchr(buf, old, page_size);
if (found)
fail("reader found old byte at pos %lu",
(unsigned long)off +
(unsigned long)found -
(unsigned long)buf);
}
}
}
int main(int argc, char **argv)
{
pthread_t reader_thread;
pthread_t writer_thread;
int ret;
page_size = getpagesize();
if (argc != 2)
fail("only arg should be file name");
ret = pthread_create(&writer_thread, NULL, writer, argv[1]);
if (ret == 0)
ret = pthread_create(&reader_thread, NULL, reader, argv[1]);
if (ret)
fail("failed to start reader and writer threads: %d", ret);
pthread_join(writer_thread, NULL);
pthread_join(reader_thread, NULL);
exit(0);
}

Some files were not shown because too many files have changed in this diff Show More