1 /* The reader part of a test program for non-blocking communication.
3 Copyright (C) 2011 Free Software Foundation, Inc.
5 This program is free software: you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation; either version 3 of the License, or
8 (at your option) any later version.
10 This program is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 GNU General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with this program. If not, see <http://www.gnu.org/licenses/>. */
18 /* This program implements 4 tests:
21 Test blocking write() with blocking read().
23 Timeline Main process Child process
24 0 s Start Start, read(10000)
25 1 s write(20000) Return from read(10000)
27 2 s Return from write(20000) Return from read(10000)
30 Test non-blocking write() with blocking read().
32 Timeline Main process Child process
33 0 s Start Start, read(10000)
34 1 s write(20000) Return from read(10000)
35 Return with at least 10000,
39 2 s Return from write(10000) Return from read(10000)
42 Test blocking write() with non-blocking read().
44 Timeline Main process Child process
45 0 s Start Start, read(10000)
47 1 s write(20000) Return from read(10000)
49 2 s Return from write(20000) Return from read(10000)
52 Test non-blocking write() with non-blocking read().
55 #include "test-nonblocking-misc.h"
58 full_read (size_t fd, void *buf, size_t count)
63 while (bytes_read < count)
69 dbgfprintf (stderr, "%s: >> read (%lu)\n", PROG_ROLE,
70 (unsigned long) (count - bytes_read));
72 ret = read (fd, (char *) buf + bytes_read, count - bytes_read);
75 dbgfprintf (stderr, "%s: << read -> %ld%s\n", PROG_ROLE,
76 (long) ret, dbgstrerror (ret < 0, saved_errno));
89 full_read_from_nonblocking_fd (size_t fd, void *buf, size_t count)
94 while (bytes_read < count)
100 dbgfprintf (stderr, "%s: >> read (%lu)\n", PROG_ROLE,
101 (unsigned long) (count - bytes_read));
103 ret = read (fd, (char *) buf + bytes_read, count - bytes_read);
106 dbgfprintf (stderr, "%s: << read -> %ld%s\n", PROG_ROLE,
107 (long) ret, dbgstrerror (ret < 0, saved_errno));
108 /* This assertion fails if the non-blocking flag is effectively not set
110 ASSERT (spent_time < 0.5);
113 ASSERT (saved_errno == EAGAIN);
114 usleep (SMALL_DELAY);
125 /* Execute the reader loop. */
127 main_reader_loop (int test, size_t data_block_size, int fd)
129 unsigned char *expected;
132 /* Set up the expected data. */
133 expected = init_data (data_block_size);
135 data = (unsigned char *) malloc (2 * data_block_size);
136 ASSERT (data != NULL);
143 case 0: /* Test blocking write() with blocking read(). */
144 case 1: /* Test non-blocking write() with blocking read(). */
146 ret = full_read (fd, data, data_block_size);
148 ASSERT (ret == data_block_size);
149 ASSERT (memcmp (data, expected, data_block_size) == 0);
150 ASSERT (spent_time > 0.5);
151 /* This assertion fails if data_block_size is very large and
152 ENABLE_DEBUGGING is 1. */
153 ASSERT (spent_time < 1.5);
158 ret = full_read (fd, data, data_block_size);
160 ASSERT (ret == data_block_size);
161 ASSERT (memcmp (data, expected + data_block_size, data_block_size) == 0);
162 /* This assertion fails if data_block_size is much larger than needed
163 and SMALL_DELAY is too large. */
164 ASSERT (spent_time < 0.5);
168 case 2: /* Test blocking write() with non-blocking read(). */
169 case 3: /* Test non-blocking write() with non-blocking read(). */
171 ret = full_read_from_nonblocking_fd (fd, data, data_block_size);
173 ASSERT (ret == data_block_size);
174 ASSERT (memcmp (data, expected, data_block_size) == 0);
175 ASSERT (spent_time > 0.5);
176 /* This assertion fails if data_block_size is much larger than needed
177 and SMALL_DELAY is too large, or if data_block_size is very large and
178 ENABLE_DEBUGGING is 1. */
179 ASSERT (spent_time < 1.5);
184 ret = full_read_from_nonblocking_fd (fd, data, data_block_size);
186 ASSERT (ret == data_block_size);
187 ASSERT (memcmp (data, expected + data_block_size, data_block_size) == 0);
188 /* This assertion fails if data_block_size is much larger than needed
189 and SMALL_DELAY is too large. */
190 ASSERT (spent_time < 0.5);