EXPECT = `if [ "$${READ1}" != "" ] ; then \
echo $${rootme}/expect-read1; \
+ elif [ "$${READMORE}" != "" ] ; then \
+ echo $${rootme}/expect-readmore; \
elif [ -f $${rootme}/../../expect/expect ] ; then \
echo $${rootme}/../../expect/expect ; \
else \
check-read1: read1.so expect-read1
$(MAKE) READ1="1" check
+check-readmore: readmore.so expect-readmore
+ $(MAKE) READMORE="1" check
+
# Check whether we need to print the timestamp for each line of
# status.
TIMESTAMP = $(if $(TS),| $(srcdir)/print-ts.py $(if $(TS_FORMAT),$(TS_FORMAT),),)
-rm -f *.dwo *.dwp
-rm -rf outputs temp cache
-rm -rf gdb.perf/workers gdb.perf/outputs gdb.perf/temp gdb.perf/cache
- -rm -f read1.so expect-read1
+ -rm -f read1.so expect-read1 readmore.so expect-readmore
distclean maintainer-clean realclean: clean
-rm -f *~ core
-
# Build the expect wrapper script that preloads the read1.so library.
-expect-read1:
+expect-read1 expect-readmore:
$(ECHO_GEN) \
- rm -f expect-read1-tmp; \
- touch expect-read1-tmp; \
- echo "# THIS FILE IS GENERATED -*- buffer-read-only: t -*- \n" >>expect-read1-tmp; \
- echo "# vi:set ro: */\n\n" >>expect-read1-tmp; \
- echo "# To regenerate this file, run:\n" >>expect-read1-tmp; \
- echo "# make clean; make/\n" >>expect-read1-tmp; \
- echo "export LD_PRELOAD=`pwd`/read1.so" >>expect-read1-tmp; \
- echo 'exec expect "$$@"' >>expect-read1-tmp; \
- chmod +x expect-read1-tmp; \
- mv expect-read1-tmp expect-read1
+ rm -f $@-tmp; \
+ touch $@-tmp; \
+ echo "# THIS FILE IS GENERATED -*- buffer-read-only: t -*- \n" >>$@-tmp; \
+ echo "# vi:set ro: */\n\n" >>$@-tmp; \
+ echo "# To regenerate this file, run:\n" >>$@-tmp; \
+ echo "# make clean; make/\n" >>$@-tmp; \
+ if [ $@ = expect-read1 ]; then \
+ echo "export LD_PRELOAD=`pwd`/read1.so" >>$@-tmp; \
+ else \
+ echo "export LD_PRELOAD=`pwd`/readmore.so" >>$@-tmp; \
+ fi; \
+ echo 'exec expect "$$@"' >>$@-tmp; \
+ chmod +x $@-tmp; \
+ mv $@-tmp $@
# Build the read1.so preload library. This overrides the `read'
# function, making it read one byte at a time. Running the testsuite
read1.so: lib/read1.c
$(ECHO_CC) $(CC) -o $@ ${srcdir}/lib/read1.c -Wall -g -shared -fPIC $(CFLAGS)
+# Build the readmore.so preload library. This overrides the `read'
+# function, making it try harder to read more at a time. Running the
+# testsuite with this catches racy tests.
+readmore.so: lib/read1.c
+ $(ECHO_CC) $(CC) -o $@ ${srcdir}/lib/read1.c -Wall -g -shared -fPIC \
+ $(CFLAGS) -DREADMORE
+
# Build the read1 machinery.
-.PHONY: read1
+.PHONY: read1 readmore
read1: read1.so expect-read1
+readmore: readmore.so expect-readmore
# Disable implicit make rules.
include $(srcdir)/../disable-implicit-rules.mk
#include <unistd.h>
#include <fcntl.h>
#include <stdlib.h>
+#include <string.h>
+#include <errno.h>
+#include <stdio.h>
-/* Wrap 'read', forcing it to return only one byte at a time, if
- reading from the terminal. */
+/* Default READMORE method. */
+#define READMORE_METHOD_DEFAULT 2
+
+/* Default READMORE sleep time in miliseconds. */
+#define READMORE_SLEEP_DEFAULT 10
+
+/* Helper function. Intialize *METHOD according to environment variable
+ READMORE_METHOD, and *SLEEP according to environment variable
+ READMORE_SLEEP. */
+
+static void
+init_readmore (int *method, unsigned int *sleep, FILE **log)
+{
+ char *env = getenv ("READMORE_METHOD");
+ if (env == NULL)
+ *method = READMORE_METHOD_DEFAULT;
+ else if (strcmp (env, "1") == 0)
+ *method = 1;
+ else if (strcmp (env, "2") == 0)
+ *method = 2;
+ else
+ /* Default. */
+ *method = READMORE_METHOD_DEFAULT;
+
+ env = getenv ("READMORE_SLEEP");
+ if (env == NULL)
+ *sleep = READMORE_SLEEP_DEFAULT;
+ else
+ *sleep = atoi (env);
+
+ env = getenv ("READMORE_LOG");
+ if (env == NULL)
+ *log = NULL;
+ else
+ *log = fopen (env, "w");
+}
+
+/* Wrap 'read', and modify it's behaviour using READ1 or READMORE style. */
ssize_t
read (int fd, void *buf, size_t count)
{
static ssize_t (*read2) (int fd, void *buf, size_t count) = NULL;
+ static FILE *log;
+ int readmore;
+#ifdef READMORE
+ readmore = 1;
+#else
+ readmore = 0;
+#endif
+ static int readmore_method;
+ static unsigned int readmore_sleep;
if (read2 == NULL)
{
/* Use setenv (v, "", 1) rather than unsetenv (v) to work around
for existence from another interp". */
setenv ("LD_PRELOAD", "", 1);
read2 = dlsym (RTLD_NEXT, "read");
+ if (readmore)
+ init_readmore (&readmore_method, &readmore_sleep, &log);
}
- if (count > 1 && isatty (fd) >= 1)
- count = 1;
+
+ /* Only modify 'read' behaviour when reading from the terminal. */
+ if (isatty (fd) == 0)
+ goto fallback;
+
+ if (!readmore)
+ {
+ /* READ1. Force read to return only one byte at a time. */
+ return read2 (fd, buf, 1);
+ }
+
+ if (readmore_method == 1)
+ {
+ /* READMORE, method 1. Wait a little before doing a read. */
+ usleep (readmore_sleep * 1000);
+ return read2 (fd, buf, count);
+ }
+
+ if (readmore_method == 2)
+ {
+ /* READMORE, method 2. After doing a read, either return or wait
+ a little and do another read, and so on. */
+ ssize_t res, total;
+ int iteration;
+ int max_iterations = -1;
+
+ total = 0;
+ for (iteration = 1; ; iteration++)
+ {
+ res = read2 (fd, (char *)buf + total, count - total);
+ if (log != NULL)
+ fprintf (log,
+ "READ (%d): fd: %d, COUNT: %zd, RES: %zd, ERRNO: %s\n",
+ iteration, fd, count - total, res,
+ res == -1 ? strerror (errno) : "none");
+ if (res == -1)
+ {
+ if (iteration == 1)
+ {
+ /* Error on first read, report. */
+ total = -1;
+ break;
+ }
+
+ if (total > 0
+ && (errno == EAGAIN || errno == EWOULDBLOCK || errno == EIO))
+ {
+ /* Ignore error, but don't try anymore reading. */
+ errno = 0;
+ break;
+ }
+
+ /* Other error, report back. */
+ total = -1;
+ break;
+ }
+
+ total += res;
+ if (total == count)
+ /* Buf full, no need to do any more reading. */
+ break;
+
+ /* Handle end-of-file. */
+ if (res == 0)
+ break;
+
+ if (iteration == max_iterations)
+ break;
+
+ usleep (readmore_sleep * 1000);
+ }
+
+ if (log)
+ fprintf (log, "READ returning: RES: %zd, ERRNO: %s\n",
+ total, total == -1 ? strerror (errno) : "none");
+ return total;
+ }
+
+ fallback:
+ /* Fallback, regular read. */
return read2 (fd, buf, count);
}