Skip to content

Fix nowait.phpt to no longer depend on sleeping #2266

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 1 commit into from
Closed

Fix nowait.phpt to no longer depend on sleeping #2266

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
157 changes: 92 additions & 65 deletions ext/sysvsem/tests/nowait.phpt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
--TEST--
sem_acquire with nowait
Test sem_acquire with nowait option
--SKIPIF--
<?php // vim600: ts=4 sw=4 syn=php fdm=marker
if(!extension_loaded('sysvsem') || !extension_loaded('pcntl')) {
Expand All @@ -8,96 +8,123 @@ if(!extension_loaded('sysvsem') || !extension_loaded('pcntl')) {
?>
--FILE--
<?php
$SEMKEY = ftok(__FILE__, 'P'); // Semaphore key
$P_SEMKEY = ftok(__FILE__, 'P'); // Parent Semaphore key
$C_SEMKEY = ftok(__FILE__, 'C'); // Child Semaphore key

$pid = pcntl_fork();
echo "P: parent process running.\n";

if ($pid) {
echo "Parent.\n";
pcntl_signal(SIGCHLD, SIG_IGN);

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;
}

// Get semaphore
$sem_id = sem_get($SEMKEY, 1);
if ($sem_id === FALSE) {
echo "P: fail to get semaphore";
exit;
}
echo "P: got semaphore $sem_id.\n";
echo "P: got semaphore $p_sem_id.\n";

register_shutdown_function(function () use ($sem_id) {
echo "P: cleanup.\n";
sem_remove($sem_id);
});

// Acquire semaphore
if (! sem_acquire($sem_id)) {
echo "P: fail to acquire semaphore $sem_id.\n";
sem_remove($sem_id);
exit;
}
echo "P: success acquire semaphore $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;
}

usleep(20000);

echo "P: releases.\n";
sem_release($sem_id);
// 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";

usleep(5000);
// 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) {

// Acquire semaphore
if (! sem_acquire($sem_id)) {
echo "P: fail to acquire semaphore $sem_id.\n";
sem_remove($sem_id);
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: success acquire semaphore $sem_id.\n";

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 {
usleep(10000);
echo "Child.\n";

// Get semaphore
$sem_id = sem_get($SEMKEY, 1);
if ($sem_id === FALSE) {
echo "C: fail to get semaphore";
exit;
}
echo "C: got semaphore $sem_id.\n";

// Acquire semaphore
if (! sem_acquire($sem_id)) {
echo "C: fail to acquire semaphore $sem_id.\n";
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;
}
echo "C: success acquire semaphore $sem_id.\n";

echo "C: releases.\n";
sem_release($sem_id);
// The child process did not wait to acquire the semaphore
echo "C: failed to acquire semaphore $p_sem_id.\n";

usleep(10000);
echo "C: releasing semaphore $c_sem_id\n";
if (!sem_release($c_sem_id)) {
echo "C: Failed to release semaphore\n";
}

// Acquire semaphore
if (! sem_acquire($sem_id, true)) {
echo "C: fail to acquire semaphore $sem_id.\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 acquire semaphore $sem_id.\n";
echo "C: success acquired semaphore $p_sem_id.\n";

echo "C: releasing semaphore $p_sem_id.\n";
sem_release($p_sem_id);
}

?>
--EXPECTF--
Parent.
P: parent process running.
P: got semaphore Resource id #%i.
P: success acquire semaphore Resource id #%i.
Child.
C: got semaphore Resource id #%i.
P: releases.
C: success acquire semaphore Resource id #%i.
C: releases.
P: success acquire semaphore Resource id #%i.
C: fail to acquire semaphore Resource id #%i.
P: cleanup.
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.