1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
| | /*
* Copyright (C) 2012-2020 all contributors <cmogstored-public@yhbt.net>
* License: GPL-3.0+ <https://www.gnu.org/licenses/gpl-3.0.txt>
*/
/*
* fault injection wrapper for epoll
*/
#include "cmogstored.h"
#if defined(HAVE_EPOLL_WAIT) && ! MOG_LIBKQUEUE
static sig_atomic_t epoll_ctl_fail;
#define EMIT(s) write(STDERR_FILENO, (s), sizeof(s)-1)
/* test/epoll_enospc depends on the following line */
static const char msg[] = "epoll_ctl failure injection\n";
int __real_epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);
int __real_epoll_create(int flags);
int __wrap_epoll_ctl(int epfd, int op, int fd, struct epoll_event *event)
{
if (epoll_ctl_fail) {
EMIT(msg);
errno = epoll_ctl_fail;
return -1;
}
return __real_epoll_ctl(epfd, op, fd, event);
}
static void set_wrap_epoll_ctl(int signum)
{
if (signum == SIGTTIN) {
epoll_ctl_fail = ENOSPC;
EMIT("epoll_ctl ENOSPC on\n");
} else {
epoll_ctl_fail = 0;
EMIT("epoll_ctl ENOSPC off\n");
}
}
int __wrap_epoll_create(int flags)
{
struct sigaction sa;
memset(&sa, 0, sizeof(struct sigaction));
CHECK(int, 0, sigemptyset(&sa.sa_mask) );
sa.sa_handler = set_wrap_epoll_ctl;
CHECK(int, 0, sigaction(SIGTTIN, &sa, NULL));
CHECK(int, 0, sigaction(SIGTTOU, &sa, NULL));
return __real_epoll_create(flags);
}
#endif /* defined(HAVE_EPOLL_WAIT) && ! MOG_LIBKQUEUE */
|