1999-12-19 03:45:25 +08:00
|
|
|
/* Tests for 64bit AIO in librt.
|
2019-01-01 08:11:28 +08:00
|
|
|
Copyright (C) 1998-2019 Free Software Foundation, Inc.
|
2001-07-06 12:58:11 +08:00
|
|
|
This file is part of the GNU C Library.
|
1999-12-19 03:45:25 +08:00
|
|
|
Contributed by Ulrich Drepper <drepper@cygnus.com>, 1998.
|
|
|
|
|
|
|
|
The GNU C Library is free software; you can redistribute it and/or
|
2001-07-06 12:58:11 +08:00
|
|
|
modify it under the terms of the GNU Lesser General Public
|
|
|
|
License as published by the Free Software Foundation; either
|
|
|
|
version 2.1 of the License, or (at your option) any later version.
|
1999-12-19 03:45:25 +08:00
|
|
|
|
|
|
|
The GNU C Library 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
|
2001-07-06 12:58:11 +08:00
|
|
|
Lesser General Public License for more details.
|
1999-12-19 03:45:25 +08:00
|
|
|
|
2001-07-06 12:58:11 +08:00
|
|
|
You should have received a copy of the GNU Lesser General Public
|
2012-02-10 07:18:22 +08:00
|
|
|
License along with the GNU C Library; if not, see
|
Prefer https to http for gnu.org and fsf.org URLs
Also, change sources.redhat.com to sourceware.org.
This patch was automatically generated by running the following shell
script, which uses GNU sed, and which avoids modifying files imported
from upstream:
sed -ri '
s,(http|ftp)(://(.*\.)?(gnu|fsf|sourceware)\.org($|[^.]|\.[^a-z])),https\2,g
s,(http|ftp)(://(.*\.)?)sources\.redhat\.com($|[^.]|\.[^a-z]),https\2sourceware.org\4,g
' \
$(find $(git ls-files) -prune -type f \
! -name '*.po' \
! -name 'ChangeLog*' \
! -path COPYING ! -path COPYING.LIB \
! -path manual/fdl-1.3.texi ! -path manual/lgpl-2.1.texi \
! -path manual/texinfo.tex ! -path scripts/config.guess \
! -path scripts/config.sub ! -path scripts/install-sh \
! -path scripts/mkinstalldirs ! -path scripts/move-if-change \
! -path INSTALL ! -path locale/programs/charmap-kw.h \
! -path po/libc.pot ! -path sysdeps/gnu/errlist.c \
! '(' -name configure \
-execdir test -f configure.ac -o -f configure.in ';' ')' \
! '(' -name preconfigure \
-execdir test -f preconfigure.ac ';' ')' \
-print)
and then by running 'make dist-prepare' to regenerate files built
from the altered files, and then executing the following to cleanup:
chmod a+x sysdeps/unix/sysv/linux/riscv/configure
# Omit irrelevant whitespace and comment-only changes,
# perhaps from a slightly-different Autoconf version.
git checkout -f \
sysdeps/csky/configure \
sysdeps/hppa/configure \
sysdeps/riscv/configure \
sysdeps/unix/sysv/linux/csky/configure
# Omit changes that caused a pre-commit check to fail like this:
# remote: *** error: sysdeps/powerpc/powerpc64/ppc-mcount.S: trailing lines
git checkout -f \
sysdeps/powerpc/powerpc64/ppc-mcount.S \
sysdeps/unix/sysv/linux/s390/s390-64/syscall.S
# Omit change that caused a pre-commit check to fail like this:
# remote: *** error: sysdeps/sparc/sparc64/multiarch/memcpy-ultra3.S: last line does not end in newline
git checkout -f sysdeps/sparc/sparc64/multiarch/memcpy-ultra3.S
2019-09-07 13:40:42 +08:00
|
|
|
<https://www.gnu.org/licenses/>. */
|
1999-12-19 03:45:25 +08:00
|
|
|
|
|
|
|
#define _LARGEFILE_SOURCE 1
|
|
|
|
#include <aio.h>
|
|
|
|
#include <errno.h>
|
|
|
|
#include <error.h>
|
2012-02-28 05:58:42 +08:00
|
|
|
#include <fcntl.h>
|
1999-12-19 03:45:25 +08:00
|
|
|
#include <stdlib.h>
|
|
|
|
#include <string.h>
|
|
|
|
#include <unistd.h>
|
|
|
|
#include <sys/stat.h>
|
|
|
|
|
|
|
|
|
|
|
|
/* Prototype for our test function. */
|
|
|
|
extern void do_prepare (int argc, char *argv[]);
|
|
|
|
extern int do_test (int argc, char *argv[]);
|
|
|
|
|
|
|
|
/* We have a preparation function. */
|
|
|
|
#define PREPARE do_prepare
|
|
|
|
|
|
|
|
/* This defines the `main' function and some more. */
|
|
|
|
#include <test-skeleton.c>
|
|
|
|
|
|
|
|
|
|
|
|
/* These are for the temporary file we generate. */
|
|
|
|
char *name;
|
|
|
|
int fd;
|
|
|
|
|
|
|
|
void
|
|
|
|
do_prepare (int argc, char *argv[])
|
|
|
|
{
|
2006-09-12 19:44:01 +08:00
|
|
|
size_t name_len;
|
1999-12-19 03:45:25 +08:00
|
|
|
|
|
|
|
name_len = strlen (test_dir);
|
2016-06-12 05:59:27 +08:00
|
|
|
name = xmalloc (name_len + sizeof ("/aioXXXXXX"));
|
1999-12-19 03:45:25 +08:00
|
|
|
mempcpy (mempcpy (name, test_dir, name_len),
|
|
|
|
"/aioXXXXXX", sizeof ("/aioXXXXXX"));
|
|
|
|
|
|
|
|
/* Open our test file. */
|
|
|
|
fd = mkstemp (name);
|
|
|
|
if (fd == -1)
|
|
|
|
error (EXIT_FAILURE, errno, "cannot open test file `%s'", name);
|
2015-10-16 06:29:06 +08:00
|
|
|
add_temp_file (name);
|
1999-12-19 03:45:25 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
|
2000-11-27 22:36:57 +08:00
|
|
|
static int
|
1999-12-19 03:45:25 +08:00
|
|
|
test_file (const void *buf, size_t size, int fd, const char *msg)
|
|
|
|
{
|
|
|
|
struct stat st;
|
|
|
|
char tmp[size];
|
|
|
|
|
|
|
|
errno = 0;
|
|
|
|
if (fstat (fd, &st) < 0)
|
|
|
|
{
|
|
|
|
error (0, errno, "%s: failed stat", msg);
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
2002-09-24 12:24:25 +08:00
|
|
|
if (st.st_size != (off_t) size)
|
1999-12-19 03:45:25 +08:00
|
|
|
{
|
|
|
|
error (0, errno, "%s: wrong size: %lu, should be %lu",
|
|
|
|
msg, (unsigned long int) st.st_size, (unsigned long int) size);
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
2002-09-24 12:24:25 +08:00
|
|
|
if (pread (fd, tmp, size, 0) != (ssize_t) size)
|
1999-12-19 03:45:25 +08:00
|
|
|
{
|
2000-07-26 21:49:15 +08:00
|
|
|
error (0, errno, "%s: failed pread", msg);
|
1999-12-19 03:45:25 +08:00
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (memcmp (buf, tmp, size) != 0)
|
|
|
|
{
|
|
|
|
error (0, errno, "%s: failed comparison", msg);
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
printf ("%s test ok\n", msg);
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2000-11-27 22:36:57 +08:00
|
|
|
static int
|
2000-07-27 21:03:23 +08:00
|
|
|
do_wait (struct aiocb64 **cbp, size_t nent, int allowed_err)
|
1999-12-19 03:45:25 +08:00
|
|
|
{
|
|
|
|
int go_on;
|
2000-07-27 21:03:23 +08:00
|
|
|
size_t cnt;
|
|
|
|
int result = 0;
|
|
|
|
|
1999-12-19 03:45:25 +08:00
|
|
|
do
|
|
|
|
{
|
|
|
|
aio_suspend64 ((const struct aiocb64 *const *) cbp, nent, NULL);
|
|
|
|
go_on = 0;
|
|
|
|
for (cnt = 0; cnt < nent; ++cnt)
|
2000-07-27 21:03:23 +08:00
|
|
|
if (cbp[cnt] != NULL)
|
|
|
|
{
|
|
|
|
if (aio_error64 (cbp[cnt]) == EINPROGRESS)
|
|
|
|
go_on = 1;
|
|
|
|
else
|
|
|
|
{
|
|
|
|
if (aio_return64 (cbp[cnt]) == -1
|
|
|
|
&& (allowed_err == 0
|
|
|
|
|| aio_error64 (cbp[cnt]) != allowed_err))
|
|
|
|
{
|
|
|
|
error (0, aio_error64 (cbp[cnt]), "Operation failed\n");
|
|
|
|
result = 1;
|
|
|
|
}
|
|
|
|
cbp[cnt] = NULL;
|
|
|
|
}
|
|
|
|
}
|
1999-12-19 03:45:25 +08:00
|
|
|
}
|
|
|
|
while (go_on);
|
2000-07-27 21:03:23 +08:00
|
|
|
|
|
|
|
return result;
|
1999-12-19 03:45:25 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
int
|
|
|
|
do_test (int argc, char *argv[])
|
|
|
|
{
|
|
|
|
struct aiocb64 cbs[10];
|
2000-07-27 21:03:23 +08:00
|
|
|
struct aiocb64 cbs_fsync;
|
1999-12-19 03:45:25 +08:00
|
|
|
struct aiocb64 *cbp[10];
|
2000-07-27 21:03:23 +08:00
|
|
|
struct aiocb64 *cbp_fsync[1];
|
1999-12-19 03:45:25 +08:00
|
|
|
char buf[1000];
|
|
|
|
size_t cnt;
|
|
|
|
int result = 0;
|
|
|
|
|
|
|
|
/* Preparation. */
|
|
|
|
for (cnt = 0; cnt < 10; ++cnt)
|
|
|
|
{
|
|
|
|
cbs[cnt].aio_fildes = fd;
|
|
|
|
cbs[cnt].aio_reqprio = 0;
|
|
|
|
cbs[cnt].aio_buf = memset (&buf[cnt * 100], '0' + cnt, 100);
|
|
|
|
cbs[cnt].aio_nbytes = 100;
|
|
|
|
cbs[cnt].aio_offset = cnt * 100;
|
|
|
|
cbs[cnt].aio_sigevent.sigev_notify = SIGEV_NONE;
|
|
|
|
|
|
|
|
cbp[cnt] = &cbs[cnt];
|
|
|
|
}
|
|
|
|
|
|
|
|
/* First a simple test. */
|
|
|
|
for (cnt = 10; cnt > 0; )
|
* locale/programs/ld-ctype.c (ctype_read): When given a repertoire
name of "", store a null pointer instead.
* configure.in (elf): Set to yes for freebsd*, netbsd*.
* configure: Regenerated.
* locale/xlocale.c [! (USE_TLS && HAVE___THREAD)] (__libc_tsd_LOCALE):
Initialize this instead of __libc_tsd_LOCALE_data.
* sysdeps/unix/grantpt.c (pts_name): Convert ENOTTY return from
ptsname_r to EINVAL.
* sysdeps/generic/ptsname.c (__ptsname_r): Return ENOSYS instead of 0.
* rt/Makefile: Revert last change, it was inappropriate to presume aio
implementations depend on pthreads.
* rt/tst-aio.c (do_test): Exit happy if first failure is ENOSYS.
* rt/tst-aio64.c (do_test): Likewise.
* rt/tst-aio2.c (do_test): Likewise.
* rt/tst-aio3.c (do_test): Likewise.
* rt/tst-aio4.c (do_test): Likewise.
* rt/tst-aio5.c (do_test): Likewise.
* rt/tst-aio6.c (do_test): Likewise.
* rt/tst-aio7.c (do_test): Likewise.
* sysdeps/generic/bits/libc-lock.h (__libc_setspecific): Use a cast to
void so as to avoid compiler warnings.
* libio/oldstdfiles.c [! _IO_MTSAFE_IO] (DEF_STDFILE): Don't define
_IO_wide_data_FD, which is never used here.
* libio/iofread.c
[! _IO_MTSAFE_IO] (fread_unlocked): Add libc_hidden_ver defn.
* libio/iofputs.c [! _IO_MTSAFE_IO] (fputs_unlocked): Likewise.
* libio/iofgets.c [! _IO_MTSAFE_IO] (fgets_unlocked): Likewise.
* include/resolv.h [! _LIBC_REENTRANT] (_res): #undef it before decl.
* include/netdb.h [! _LIBC_REENTRANT] (h_errno): Declare normal extern.
* misc/syslog.c (openlog): Conditionalize locking on [_LIBC_REENTRANT].
(closelog): Likewise.
2002-07-06 Bruno Haible <bruno@clisp.org>
* sysdeps/alpha/fpu/fpu_control.h: Comment fix.
* sysdeps/unix/sysv/linux/alpha/pipe.S: Moved to ...
* sysdeps/unix/alpha/pipe.S: ... here.
* sysdeps/unix/bsd/osf/alpha/pipe.S: File removed.
* sysdeps/unix/i386/brk.S: Rename local label to '.Lhere' in ELF.
* sysdeps/unix/i386/brk.S: Add PSEUDO_END invocation.
* sysdeps/unix/i386/fork.S: Likewise.
* sysdeps/unix/i386/pipe.S: Likewise.
* sysdeps/unix/i386/wait.S: Likewise.
* sysdeps/unix/fork.S: Fix PSEUDO_END argument.
* sysdeps/unix/arm/fork.S: Likewise.
* sysdeps/unix/sysv/linux/arm/sysdep.h (PSEUDO): Swap DO_CALL
arguments.
(DO_CALL): Swap argument order.
* sysdeps/unix/sysv/linux/hppa/sysdep.h (PSEUDO): Swap DO_CALL
arguments.
(DO_CALL): Swap argument order.
* sysdeps/unix/sysv/linux/i386/sysdep.h (PSEUDO): Swap DO_CALL
arguments.
(DO_CALL): Swap argument order.
* sysdeps/unix/sysv/linux/s390/s390-32/sysdep.h (PSEUDO): Swap DO_CALL
arguments.
(DO_CALL): Swap argument order.
* sysdeps/unix/sysv/linux/s390/s390-64/sysdep.h (PSEUDO): Swap DO_CALL
arguments.
(DO_CALL): Swap argument order.
* sysdeps/unix/sysv/linux/sh/sysdep.h (PSEUDO): Swap DO_CALL
arguments.
(DO_CALL): Swap argument order.
* sysdeps/unix/sysv/linux/x86_64/sysdep.h (PSEUDO): Swap DO_CALL
arguments.
(DO_CALL): Swap argument order.
* sysdeps/i386/sysdep.h (PSEUDO): Fix syntax error.
(L): Define right for ELF.
* sysdeps/unix/sysv/linux/i386/sysdep.h (L): Remove definition.
Now defined in sysdeps/i386/sysdep.h.
* sysdeps/posix/readv.c: Ansify function definition.
* sysdeps/posix/writev.c: Likewise.
* stdio-common/tst-fseek.c (main): Don't assume that off_t and size_t
have the same size. Avoid direct cast from size_t to off_t.
* login/tst-utmp.c (simulate_login): Don't leave garbage after the
nul byte in entry[n].ut_user.
(simulate_logout): Likewise.
* login/programs/utmpdump.c (print_entry): Test _HAVE_UT_TYPE,
_HAVE_UT_PID, _HAVE_UT_ID, _HAVE_UT_HOST, instead of assuming the
existence of corresponding members of 'struct utmp'.
* login/tst-utmp.c: Trivialize the test if testing 'struct utmp' and
!_HAVE_UT_TYPE.
* sysdeps/unix/opendir.c (__opendir): If st_blksize is 0 or too small,
allocate a buffer of at least BUFSIZ bytes, not just of
sizeof (struct dirent).
* sysdeps/generic/glob.c: Include <limits.h>.
(NAME_MAX): Define a fallback.
(glob_in_dir): Allocate enough room for a 'struct dirent64' on the
stack.
* posix/tst-dir.c: Include <stddef.h>, for offsetof.
(main): Allocate enough room for a 'struct dirent64' on the stack.
* posix/tst-gnuglob.c (my_DIR): Allocate enough room for a
'struct dirent'.
* sysdeps/unix/sysv/linux/init-first.c: Don't include
kernel-features.h.
* inet/htontest.c: Include <sys/types.h>.
* sysdeps/generic/sys/sysinfo.h: Surround with __{BEGIN,END}_DECLS.
* include/sys/sysctl.h: Comment fix.
* elf/rtld.c (_rtld_global) [! _LIBC_REENTRANT]: Don't initialize
_dl_load_lock.
* libio/fileno.c (fileno_unlocked): Define regardless of _IO_MTSAFE_IO.
* sysdeps/unix/bsd/bsd4.4/syscalls.list (__sigaltstack): New alias.
* sysdeps/unix/inet/syscalls.list (__connect_internal): New alias.
(__getpeername): New alias.
(__getsockname): New alias.
(__socket): New alias.
* sysdeps/unix/common/syscalls.list (getpgid): Remove.
* sysdeps/unix/syscalls.list (__chown_internal): New alias.
(__fcntl_internal): New alias.
(__profil): New alias.
2002-08-26 19:39:12 +08:00
|
|
|
if (aio_write64 (cbp[--cnt]) < 0 && errno == ENOSYS)
|
|
|
|
{
|
|
|
|
error (0, 0, "no aio support in this configuration");
|
|
|
|
return 0;
|
|
|
|
}
|
1999-12-19 03:45:25 +08:00
|
|
|
/* Wait 'til the results are there. */
|
2000-07-27 21:03:23 +08:00
|
|
|
result |= do_wait (cbp, 10, 0);
|
1999-12-19 03:45:25 +08:00
|
|
|
/* Test this. */
|
|
|
|
result |= test_file (buf, sizeof (buf), fd, "aio_write");
|
|
|
|
|
|
|
|
/* Read now as we've written it. */
|
|
|
|
memset (buf, '\0', sizeof (buf));
|
|
|
|
/* Issue the commands. */
|
|
|
|
for (cnt = 10; cnt > 0; )
|
|
|
|
{
|
|
|
|
--cnt;
|
|
|
|
cbp[cnt] = &cbs[cnt];
|
|
|
|
aio_read64 (cbp[cnt]);
|
|
|
|
}
|
|
|
|
/* Wait 'til the results are there. */
|
2000-07-27 21:03:23 +08:00
|
|
|
result |= do_wait (cbp, 10, 0);
|
1999-12-19 03:45:25 +08:00
|
|
|
/* Test this. */
|
|
|
|
for (cnt = 0; cnt < 1000; ++cnt)
|
|
|
|
if (buf[cnt] != '0' + (cnt / 100))
|
|
|
|
{
|
|
|
|
result = 1;
|
|
|
|
error (0, 0, "comparison failed for aio_read test");
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (cnt == 1000)
|
|
|
|
puts ("aio_read test ok");
|
|
|
|
|
|
|
|
/* Remove the test file contents. */
|
|
|
|
if (ftruncate64 (fd, 0) < 0)
|
|
|
|
{
|
|
|
|
error (0, errno, "ftruncate failed\n");
|
|
|
|
result = 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Test lio_listio. */
|
|
|
|
for (cnt = 0; cnt < 10; ++cnt)
|
|
|
|
{
|
|
|
|
cbs[cnt].aio_lio_opcode = LIO_WRITE;
|
|
|
|
cbp[cnt] = &cbs[cnt];
|
|
|
|
}
|
|
|
|
/* Issue the command. */
|
|
|
|
lio_listio64 (LIO_WAIT, cbp, 10, NULL);
|
|
|
|
/* ...and immediately test it since we started it in wait mode. */
|
|
|
|
result |= test_file (buf, sizeof (buf), fd, "lio_listio (write)");
|
|
|
|
|
2000-07-27 21:03:23 +08:00
|
|
|
/* Test aio_fsync. */
|
|
|
|
cbs_fsync.aio_fildes = fd;
|
|
|
|
cbs_fsync.aio_sigevent.sigev_notify = SIGEV_NONE;
|
|
|
|
cbp_fsync[0] = &cbs_fsync;
|
|
|
|
|
|
|
|
/* Remove the test file contents first. */
|
|
|
|
if (ftruncate64 (fd, 0) < 0)
|
|
|
|
{
|
|
|
|
error (0, errno, "ftruncate failed\n");
|
|
|
|
result = 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Write again. */
|
|
|
|
for (cnt = 10; cnt > 0; )
|
|
|
|
aio_write64 (cbp[--cnt]);
|
|
|
|
|
|
|
|
if (aio_fsync64 (O_SYNC, &cbs_fsync) < 0)
|
|
|
|
{
|
|
|
|
error (0, errno, "aio_fsync failed\n");
|
|
|
|
result = 1;
|
|
|
|
}
|
|
|
|
result |= do_wait (cbp_fsync, 1, 0);
|
|
|
|
|
|
|
|
/* ...and test since all data should be on disk now. */
|
|
|
|
result |= test_file (buf, sizeof (buf), fd, "aio_fsync (aio_write)");
|
|
|
|
|
|
|
|
/* Test aio_cancel. */
|
|
|
|
/* Remove the test file contents first. */
|
|
|
|
if (ftruncate64 (fd, 0) < 0)
|
|
|
|
{
|
|
|
|
error (0, errno, "ftruncate failed\n");
|
|
|
|
result = 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Write again. */
|
|
|
|
for (cnt = 10; cnt > 0; )
|
|
|
|
aio_write64 (cbp[--cnt]);
|
|
|
|
|
|
|
|
/* Cancel all requests. */
|
|
|
|
if (aio_cancel64 (fd, NULL) == -1)
|
|
|
|
printf ("aio_cancel64 (fd, NULL) cannot cancel anything\n");
|
|
|
|
|
|
|
|
result |= do_wait (cbp, 10, ECANCELED);
|
|
|
|
|
|
|
|
/* Another test for aio_cancel. */
|
|
|
|
/* Remove the test file contents first. */
|
|
|
|
if (ftruncate64 (fd, 0) < 0)
|
|
|
|
{
|
|
|
|
error (0, errno, "ftruncate failed\n");
|
|
|
|
result = 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Write again. */
|
|
|
|
for (cnt = 10; cnt > 0; )
|
|
|
|
{
|
|
|
|
--cnt;
|
|
|
|
cbp[cnt] = &cbs[cnt];
|
|
|
|
aio_write64 (cbp[cnt]);
|
|
|
|
}
|
|
|
|
puts ("finished3");
|
|
|
|
|
|
|
|
/* Cancel all requests. */
|
|
|
|
for (cnt = 10; cnt > 0; )
|
|
|
|
if (aio_cancel64 (fd, cbp[--cnt]) == -1)
|
|
|
|
/* This is not an error. The request can simply be finished. */
|
|
|
|
printf ("aio_cancel64 (fd, cbp[%Zd]) cannot be canceled\n", cnt);
|
|
|
|
puts ("finished2");
|
|
|
|
|
|
|
|
result |= do_wait (cbp, 10, ECANCELED);
|
|
|
|
|
|
|
|
puts ("finished");
|
|
|
|
|
1999-12-19 03:45:25 +08:00
|
|
|
return result;
|
|
|
|
}
|