diogo/symfony
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix lock failling test

Browse Source
This commit is contained in:
Jérémy Derussé 2017-08-09 22:57:38 +02:00
parent 01d1563df4
commit ff951697b6
No known key found for this signature in database
GPG Key ID: 2083FA5758C473D2
1 changed files with 23 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/Symfony/Component/Lock/Tests/Store/BlockingStoreTestTrait.php
View File

@ -35,7 +35,7 @@ trait BlockingStoreTestTrait
public function testBlockingLocks()
{
// Amount a microsecond used to order async actions
$clockDelay = 200000;
$clockDelay = 50000;
if (\PHP_VERSION_ID < 50600 || defined('HHVM_VERSION_ID')) {
$this->markTestSkipped('The PHP engine does not keep resource in child forks');
@ -46,31 +46,46 @@ trait BlockingStoreTestTrait
/** @var StoreInterface $store */
$store = $this->getStore();
$key = new Key(uniqid(__METHOD__, true));
$parentPID = posix_getpid();
if ($childPID1 = pcntl_fork()) {
// give time to fork to start
usleep(1 * $clockDelay);
// Block SIGHUP signal
pcntl_sigprocmask(SIG_BLOCK, array(SIGHUP));
if ($childPID = pcntl_fork()) {
// Wait the start of the child
pcntl_sigwaitinfo(array(SIGHUP), $info);
try {
// This call should failed given the lock should already by acquired by the child #1
// This call should failed given the lock should already by acquired by the child
$store->save($key);
$this->fail('The store saves a locked key.');
} catch (LockConflictedException $e) {
}
// send the ready signal to the child
posix_kill($childPID, SIGHUP);
// This call should be blocked by the child #1
$store->waitAndSave($key);
$this->assertTrue($store->exists($key));
$store->delete($key);
// Now, assert the child process worked well
pcntl_waitpid($childPID1, $status1);
pcntl_waitpid($childPID, $status1);
$this->assertSame(0, pcntl_wexitstatus($status1), 'The child process couldn\'t lock the resource');
} else {
// Block SIGHUP signal
pcntl_sigprocmask(SIG_BLOCK, array(SIGHUP));
try {
$store->save($key);
// Wait 2 ClockDelay to let parent process to finish
usleep(2 * $clockDelay);
// send the ready signal to the parent
posix_kill($parentPID, SIGHUP);
// Wait for the parent to be ready
pcntl_sigwaitinfo(array(SIGHUP), $info);
// Wait ClockDelay to let parent assert to finish
usleep($clockDelay);
$store->delete($key);
exit(0);
} catch (\Exception $e) {