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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
/*
* fork.c
*
* Description:
* Implementation of fork() for POSIX threads.
*/
/* FIXME! */
#define ENOMEM 0
#include "pthread.h"
#include "implement.h"
int
pthread_atfork(void (*prepare)(void),
void (*parent)(void),
void (*child)(void))
{
/* Push handlers (unless NULL) onto their respective stacks.
Local implementation semantics:
If we get an ENOMEM at any time in here then ALL handlers
(including those from previous pthread_atfork() calls) will be
popped off each of the three atfork stacks before we return. */
int ret = 0;
if (prepare != NULL)
{
/* Push prepare. */
if (_pthread_handler_push(_PTHREAD_FORKPREPARE_STACK,
_PTHREAD_HANDLER_POP_FIFO,
(void (*)(void *)) prepare,
NULL) == ENOMEM)
{
ret = ENOMEM;
}
}
if (parent != NULL &&
ret != ENOMEM)
{
/* Push parent. */
if (_pthread_handler_push(_PTHREAD_FORKPARENT_STACK,
_PTHREAD_HANDLER_POP_LIFO,
(void (*)(void *)) parent,
NULL) == ENOMEM)
{
ret = ENOMEM;
}
}
if (child != NULL &&
ret != ENOMEM)
{
/* Push child. */
if (_pthread_handler_push(_PTHREAD_FORKCHILD_STACK,
_PTHREAD_HANDLER_POP_LIFO,
(void (*)(void *)) child,
NULL) == ENOMEM)
{
ret = ENOMEM;
}
}
if (ret == ENOMEM)
{
/* Pop all handlers without executing them before we return
the error. */
_pthread_handler_pop_all(_PTHREAD_FORKPREPARE_STACK,
_PTHREAD_HANDLER_NOEXECUTE);
_pthread_handler_pop_all(_PTHREAD_FORKPARENT_STACK,
_PTHREAD_HANDLER_NOEXECUTE);
_pthread_handler_pop_all(_PTHREAD_FORKCHILD_STACK,
_PTHREAD_HANDLER_NOEXECUTE);
}
return ret;
}
/* It looks like the GNU linker is capable of selecting this version of
fork() over a version provided in more primitive libraries further down
the linker command line. */
#if HAVE_PID_T && HAVE_FORK
pid_t
fork()
{
pid_t pid;
/* Pop prepare handlers here. */
_pthread_handler_pop_all(_PTHREAD_FORKPREPARE_STACK,
_PTHREAD_HANDLER_EXECUTE);
/* Now call the real fork(). */
if ((pid = _fork()) > 0)
{
/* PARENT */
/* Clear the child handler stack. */
_pthread_handler_pop_all(_PTHREAD_FORKCHILD_STACK,
_PTHREAD_HANDLER_NOEXECUTE);
/* Pop parent handlers and execute them. */
_pthread_handler_pop_all(_PTHREAD_FORKPARENT_STACK,
_PTHREAD_HANDLER_EXECUTE);
/* At this point all three atfork stacks are empty. */
return pid;
}
else
{
/* CHILD */
/* Clear the parent handler stack. */
_pthread_handler_pop_all(_PTHREAD_FORKPARENT_STACK,
_PTHREAD_HANDLER_NOEXECUTE);
/* Pop child handlers and execute them. */
_pthread_handler_pop_all(_PTHREAD_FORKCHILD_STACK,
_PTHREAD_HANDLER_EXECUTE);
/* At this point all three atfork stacks are empty. */
/* Terminate all threads except pthread_self() using
pthread_cancel(). */
_pthread_cancel_all_not_self();
/* Wait for them to finish before we continue. */
_pthread_join_all_not_self();
return 0;
}
/* Not reached. */
return 0;
}
#endif /* HAVE_PID_T && HAVE_FORK */
|
