blob: b52d2d7e20f4fb5df278f598b0c93fc97459991f (
plain)
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
|
--TEST--
Test sem_acquire with nowait option
--SKIPIF--
<?php
if(!extension_loaded('sysvsem') || !extension_loaded('pcntl')) {
die("skip sysvsem and pcntl required");
}
?>
--FILE--
<?php
$P_SEMKEY = ftok(__FILE__, 'P'); // Parent Semaphore key
$C_SEMKEY = ftok(__FILE__, 'C'); // Child Semaphore key
echo "P: parent process running.\n";
pcntl_signal(SIGCHLD, SIG_IGN);
// Get semaphore for parent
$p_sem_id = sem_get($P_SEMKEY, 1);
if ($p_sem_id === FALSE) {
echo "P: failed to parent get semaphore.\n";
exit;
}
echo "P: got semaphore.\n";
// Get semaphore for child
$c_sem_id = sem_get($C_SEMKEY, 1);
if ($c_sem_id === FALSE) {
echo "P: failed to child get semaphore.\n";
exit;
}
// Acquire semaphore for parent
if (!sem_acquire($p_sem_id)) {
echo "P: fail to acquire semaphore.\n";
sem_remove($p_sem_id);
exit;
}
echo "P: acquired semaphore.\n";
// Acquire semaphore for child
if (!sem_acquire($c_sem_id)) {
echo "P: failed to acquire semaphore.\n";
sem_remove($c_sem_id);
exit;
}
echo "P: acquired semaphore.\n";
// Fork process
$pid = pcntl_fork();
if ($pid) {
register_shutdown_function(function () use ($p_sem_id) {
echo "P: removing semaphore.\n";
sem_remove($p_sem_id);
});
// Release semaphore after 50ms
usleep(50000);
/* Wait for the child semaphore to be released to
to release the parent semaphore */
if (!sem_acquire($c_sem_id)) {
echo "P: failed to acquire semaphore.\n";
exit;
}
/* Release the child semahpore before releasing
the releasing the parent semaphore and letting
the child continue execution */
sem_release($c_sem_id);
echo "P: releasing semaphore.\n";
if (!sem_release($p_sem_id)) {
echo "P: failed to release semaphore.\n";
}
$status = null;
pcntl_waitpid($pid, $status);
} else {
register_shutdown_function(function () use ($c_sem_id) {
echo "C: removing semaphore.\n";
sem_remove($c_sem_id);
});
echo "C: child process running.\n";
// Have the semaphore after process forked
echo "C: got semaphores.\n";
// This should fail to get to the semaphore and not wait
if (sem_acquire($p_sem_id, true)) {
echo "C: test failed, Child was able to acquire semaphore.\n";
exit;
}
// The child process did not wait to acquire the semaphore
echo "C: failed to acquire semaphore.\n";
echo "C: releasing semaphore.\n";
if (!sem_release($c_sem_id)) {
echo "C: failed to release semaphore.\n";
}
// Acquire semaphore with waiting
if (!sem_acquire($p_sem_id)) {
echo "C: fail to acquire semaphore.\n";
exit;
}
echo "C: success acquired semaphore.\n";
echo "C: releasing semaphore.\n";
sem_release($p_sem_id);
}
?>
--EXPECT--
P: parent process running.
P: got semaphore.
P: acquired semaphore.
P: acquired semaphore.
C: child process running.
C: got semaphores.
C: failed to acquire semaphore.
C: releasing semaphore.
P: releasing semaphore.
C: success acquired semaphore.
C: releasing semaphore.
C: removing semaphore.
P: removing semaphore.
|
