blob: 8557ce33ee3a614c7bdd03749d1e9639391bf21d (
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
|
--TEST--
Test sem_acquire with nowait option
--SKIPIF--
<?php // vim600: ts=4 sw=4 syn=php fdm=marker
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 $p_sem_id.\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 $p_sem_id.\n";
sem_remove($p_sem_id);
exit;
}
echo "P: acquired semaphore $p_sem_id.\n";
// Acquire semaphore for child
if (!sem_acquire($c_sem_id)) {
echo "P: fail to acquire semaphore $c_sem_id.\n";
sem_remove($c_sem_id);
exit;
}
echo "P: acquired semaphore $c_sem_id\n";
// Fork process
$pid = pcntl_fork();
if ($pid) {
register_shutdown_function(function () use ($p_sem_id) {
echo "P: removing semaphore $p_sem_id.\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 $c_sem_id.\n";
exit;
}
echo "P: releasing semaphore $p_sem_id.\n";
if (!sem_release($p_sem_id)) {
echo "P: failed to release semaphore\n";
}
sem_release($c_sem_id);
$status = null;
pcntl_waitpid($pid, $status);
} else {
register_shutdown_function(function () use ($c_sem_id) {
echo "C: removing semaphore $c_sem_id.\n";
sem_remove($c_sem_id);
});
echo "C: child process running.\n";
// Have the semaphore after process forked
echo "C: got semaphore $p_sem_id and $c_sem_id.\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 $p_sem_id.\n";
exit;
}
// The child process did not wait to acquire the semaphore
echo "C: failed to acquire semaphore $p_sem_id.\n";
echo "C: releasing semaphore $c_sem_id\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 $p_sem_id.\n";
exit;
}
echo "C: success acquired semaphore $p_sem_id.\n";
echo "C: releasing semaphore $p_sem_id.\n";
sem_release($p_sem_id);
}
?>
--EXPECTF--
P: parent process running.
P: got semaphore Resource id #%i.
P: acquired semaphore Resource id #%i.
P: acquired semaphore Resource id #%i
C: child process running.
C: got semaphore Resource id #%i and Resource id #%i.
C: failed to acquire semaphore Resource id #%i.
C: releasing semaphore Resource id #%i
P: releasing semaphore Resource id #%i.
C: success acquired semaphore Resource id #%i.
C: releasing semaphore Resource id #%i.
C: removing semaphore Resource id #%i.
P: removing semaphore Resource id #%i.
|
