mirrors/cosmopolitan
1
0
Fork 0
mirror of https://github.com/jart/cosmopolitan.git synced 2025-08-06 01:40:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fgets_interrupt_test needs single core affinity

Browse source
This commit is contained in:
Cadence Ember 2024-04-28 02:44:54 +12:00
parent e2bebc73e3
commit 7500b02db5
1 changed files with 20 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

21
test/libc/stdio/fgets_interrupt_test.c
View file

@ -17,6 +17,7 @@
│ PERFORMANCE OF THIS SOFTWARE. │ │ PERFORMANCE OF THIS SOFTWARE. │
╚─────────────────────────────────────────────────────────────────────────────*/ ╚─────────────────────────────────────────────────────────────────────────────*/
#include "libc/isystem/errno.h" #include "libc/isystem/errno.h"
#include "libc/isystem/sched.h"
#include "libc/isystem/signal.h" #include "libc/isystem/signal.h"
#include "libc/isystem/stddef.h" #include "libc/isystem/stddef.h"
#include "libc/isystem/unistd.h" #include "libc/isystem/unistd.h"
@ -31,6 +32,8 @@ int pipes[2];
int pid; int pid;
int got_sigusr1 = 0; int got_sigusr1 = 0;
// -=- these get called for each test ------------------------------------------
void sigusr1_handler(int) { void sigusr1_handler(int) {
got_sigusr1 = 1; got_sigusr1 = 1;
} }
@ -50,7 +53,6 @@ void write_pipe(int send_signal_before_end) {
// Send rest of stream // Send rest of stream
fputs(MY_TEST_STRING_2, stream); fputs(MY_TEST_STRING_2, stream);
// Close stream - this will cause the parent's fgets to end // Close stream - this will cause the parent's fgets to end
fclose(stream); fclose(stream);
} }
@ -67,6 +69,19 @@ void read_pipe() {
fclose(stream); fclose(stream);
} }
// -=- these set up the tests --------------------------------------------------
void SetUpOnce(void) {
cpu_set_t set;
CPU_ZERO(&set);
CPU_SET(1, &set);
if (sched_setaffinity(0, sizeof set, &set) == -1) {
perror("sched_setaffinity");
fprintf(stderr, "single core affinity is needed for test reliability\n");
_exit(1);
}
}
void setup_signal_and_pipe(uint64_t sa_flags) { void setup_signal_and_pipe(uint64_t sa_flags) {
// Set up SIGUSR1 handler // Set up SIGUSR1 handler
struct sigaction sa = {.sa_handler = sigusr1_handler, .sa_flags = sa_flags}; struct sigaction sa = {.sa_handler = sigusr1_handler, .sa_flags = sa_flags};
@ -74,6 +89,7 @@ void setup_signal_and_pipe(uint64_t sa_flags) {
perror("sigaction"); perror("sigaction");
_exit(1); _exit(1);
} }
got_sigusr1 = 0;
// Set up pipe between parent and child // Set up pipe between parent and child
if (pipe(pipes) == -1) { if (pipe(pipes) == -1) {
@ -82,6 +98,8 @@ void setup_signal_and_pipe(uint64_t sa_flags) {
} }
} }
// -=- these are the tests -----------------------------------------------------
TEST(fgets_eintr, testThatFgetsReadsFromPipeNormally) { TEST(fgets_eintr, testThatFgetsReadsFromPipeNormally) {
setup_signal_and_pipe(0); // 0 = no SA_RESTART setup_signal_and_pipe(0); // 0 = no SA_RESTART
ASSERT_NE(-1, (pid = fork())); ASSERT_NE(-1, (pid = fork()));
@ -103,6 +121,7 @@ TEST(fgets_eintr, testThatTheSignalInterruptsFgets) {
read_pipe(); read_pipe();
EXPECT_STRNE(MY_TEST_STRING_1 MY_TEST_STRING_2, buf); EXPECT_STRNE(MY_TEST_STRING_1 MY_TEST_STRING_2, buf);
EXPECT_EQ(EINTR, errno); EXPECT_EQ(EINTR, errno);
EXPECT_EQ(1, got_sigusr1);
} }
TEST(fgets_eintr, testThatFgetsRestartsWhenSaRestartIsSet) { TEST(fgets_eintr, testThatFgetsRestartsWhenSaRestartIsSet) {