Mercurial > gnulib
view tests/test-nonblocking-writer.h @ 40224:5d9b82ca550a
tests: Free allocated memory.
Reported by <deltatau@protonmail.com> via Assaf Gordon.
* tests/test-astrxfrm.c (main): Free allocated memory.
* tests/test-bitset.c (compare, check_attributes): Free allocated
bitsets.
* tests/test-filenamecat.c (main): Free allocated memory.
* tests/test-freadahead.c (main): Free allocated memory and close stdin.
* tests/test-freadptr.c (main): Likewise.
* tests/test-freadptr2.c (main): Free allocated memory.
* tests/test-freadseek.c (main): Likewise.
* tests/test-gc-arcfour.c (main): Close allocated context.
* tests/test-gc-arctwo.c (main): Likewise.
* tests/test-gc-des.c (main): Close all allocated contexts.
* tests/test-pipe-filter-gi1.c (main): Free allocated memory.
* tests/test-pipe-filter-ii1.c (main): Likewise.
* tests/test-posix_spawn_file_actions_addchdir.c (main): Destroy the
allocated file actions.
* tests/test-posix_spawn_file_actions_addclose.c (main): Likewise.
* tests/test-posix_spawn_file_actions_adddup2.c (main): Likewise.
* tests/test-posix_spawn_file_actions_addopen.c (main): Likewise.
* tests/test-sameacls.c (main): Free allocated memory and ACLs.
* tests/test-strfmon_l.c (main): Free allocated locales.
* tests/test-striconveh.c (main): Free allocated iconv_t objects.
* tests/uniconv/test-u8-conv-to-enc.c (main): Free allocated memory.
* tests/uniconv/test-u16-conv-to-enc.c (main): Likewise.
* tests/uniconv/test-u32-conv-to-enc.c (main): Likewise.
* tests/unistr/test-chr.h (main): Free input32.
* tests/unistr/test-strchr.h (test_strchr): Likewise.
author | Bruno Haible <bruno@clisp.org> |
---|---|
date | Sun, 10 Mar 2019 14:05:09 +0100 |
parents | b06060465f09 |
children |
line wrap: on
line source
/* The writer part of a test program for non-blocking communication. Copyright (C) 2011-2019 Free Software Foundation, Inc. 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 3 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, see <https://www.gnu.org/licenses/>. */ /* This program implements 4 tests: test == 0: Test blocking write() with blocking read(). Timeline Main process Child process 0 s Start Start, read(10000) 1 s write(20000) Return from read(10000) 2 s Next read(10000) 2 s Return from write(20000) Return from read(10000) test == 1: Test non-blocking write() with blocking read(). Timeline Main process Child process 0 s Start Start, read(10000) 1 s write(20000) Return from read(10000) Return with at least 10000, Repeatedly continue write() of the rest 2 s Next read(10000) 2 s Return from write(10000) Return from read(10000) test == 2: Test blocking write() with non-blocking read(). Timeline Main process Child process 0 s Start Start, read(10000) repeatedly polling 1 s write(20000) Return from read(10000) 2 s Next read(10000) 2 s Return from write(20000) Return from read(10000) test == 3: Test non-blocking write() with non-blocking read(). */ #include "test-nonblocking-misc.h" /* Execute the writer loop. Returns 0 if successful, 1 if data_block_size is too small. */ static int main_writer_loop (int test, size_t data_block_size, int fd, bool has_large_buffer) { int too_small = 0; unsigned char *data; /* Set up the data to transfer. */ data = init_data (data_block_size); switch (test) { TIMING_DECLS ssize_t ret; case 0: /* Test blocking write() with blocking read(). */ case 2: /* Test blocking write() with non-blocking read(). */ { int saved_errno; usleep (1000000); dbgfprintf (stderr, "%s:1: >> write (%lu)\n", PROG_ROLE, (unsigned long) 2 * data_block_size); START_TIMING ret = write (fd, data, 2 * data_block_size); saved_errno = errno; END_TIMING dbgfprintf (stderr, "%s:1: << write -> %ld%s\n", PROG_ROLE, (long) ret, dbgstrerror (ret < 0, saved_errno)); ASSERT (ret == 2 * data_block_size); if (!has_large_buffer) { /* This assertion fails if data_block_size is too small. */ if (!(spent_time > 0.5)) { fprintf (stderr, "%s:1: spent_time = %g, data_block_size too small\n", PROG_ROLE, spent_time); too_small = 1; } } ASSERT (spent_time < 1.5); } break; case 1: /* Test non-blocking write() with blocking read(). */ case 3: /* Test non-blocking write() with non-blocking read(). */ { size_t bytes_written; int saved_errno; usleep (1000000); bytes_written = 0; while (bytes_written < 2 * data_block_size) { dbgfprintf (stderr, "%s:2: >> write (%lu)\n", PROG_ROLE, (unsigned long) (2 * data_block_size - bytes_written)); START_TIMING ret = write (fd, data + bytes_written, 2 * data_block_size - bytes_written); saved_errno = errno; END_TIMING dbgfprintf (stderr, "%s:2: << write -> %ld%s\n", PROG_ROLE, (long) ret, dbgstrerror (ret < 0, saved_errno)); if (ret < 0 && bytes_written >= data_block_size) { ASSERT (saved_errno == EAGAIN || saved_errno == EWOULDBLOCK); ASSERT (spent_time < 0.5); break; } /* This assertion fails if the non-blocking flag is effectively not set on fd. */ ASSERT (spent_time < 0.5); if (ret < 0) { ASSERT (saved_errno == EAGAIN || saved_errno == EWOULDBLOCK); usleep (SMALL_DELAY); } else { /* This assertion fails if data_block_size is too small. */ if (!(ret > 0)) { fprintf (stderr, "%s:1: spent_time = %g, data_block_size too small\n", PROG_ROLE, spent_time); too_small = 1; } bytes_written += ret; } } ASSERT (bytes_written >= data_block_size); while (bytes_written < 2 * data_block_size) { dbgfprintf (stderr, "%s:3: >> write (%lu)\n", PROG_ROLE, (unsigned long) (2 * data_block_size - bytes_written)); START_TIMING ret = write (fd, data + bytes_written, 2 * data_block_size - bytes_written); saved_errno = errno; END_TIMING dbgfprintf (stderr, "%s:3: << write -> %ld%s\n", PROG_ROLE, (long) ret, dbgstrerror (ret < 0, saved_errno)); ASSERT (spent_time < 0.5); if (ret < 0) { ASSERT (saved_errno == EAGAIN || saved_errno == EWOULDBLOCK); usleep (SMALL_DELAY); } else { ASSERT (ret > 0); bytes_written += ret; } } } break; default: abort (); } free (data); return too_small; }