public function LockFunctionalTest::testLockAcquire in Drupal 9

Same name and namespace in other branches

1. 8 core/modules/system/tests/src/Functional/Lock/LockFunctionalTest.php \Drupal\Tests\system\Functional\Lock\LockFunctionalTest::testLockAcquire()

Confirms that we can acquire and release locks in two parallel requests.

File

core/modules/system/tests/src/Functional/Lock/LockFunctionalTest.php, line 29

Class

LockFunctionalTest

Confirm locking works between two separate requests.

Namespace

Drupal\Tests\system\Functional\Lock

Code

public function testLockAcquire() {
  $lock = $this->container
    ->get('lock');
  $lock_acquired = 'TRUE: Lock successfully acquired in \\Drupal\\system_test\\Controller\\SystemTestController::lockAcquire()';
  $lock_not_acquired = 'FALSE: Lock not acquired in \\Drupal\\system_test\\Controller\\SystemTestController::lockAcquire()';
  $this
    ->assertTrue($lock
    ->acquire('system_test_lock_acquire'), 'Lock acquired by this request.', 'Lock');
  $this
    ->assertTrue($lock
    ->acquire('system_test_lock_acquire'), 'Lock extended by this request.', 'Lock');
  $lock
    ->release('system_test_lock_acquire');

  // Cause another request to acquire the lock.
  $this
    ->drupalGet('system-test/lock-acquire');
  $this
    ->assertSession()
    ->pageTextContains($lock_acquired);

  // The other request has finished, thus it should have released its lock.
  $this
    ->assertTrue($lock
    ->acquire('system_test_lock_acquire'), 'Lock acquired by this request.', 'Lock');

  // This request holds the lock, so the other request cannot acquire it.
  $this
    ->drupalGet('system-test/lock-acquire');
  $this
    ->assertSession()
    ->pageTextContains($lock_not_acquired);
  $lock
    ->release('system_test_lock_acquire');

  // Try a very short timeout and lock breaking.
  $this
    ->assertTrue($lock
    ->acquire('system_test_lock_acquire', 0.5), 'Lock acquired by this request.', 'Lock');
  sleep(1);

  // The other request should break our lock.
  $this
    ->drupalGet('system-test/lock-acquire');
  $this
    ->assertSession()
    ->pageTextContains($lock_acquired);

  // We cannot renew it, since the other thread took it.
  $this
    ->assertFalse($lock
    ->acquire('system_test_lock_acquire'), 'Lock cannot be extended by this request.', 'Lock');

  // Check the shut-down function.
  $lock_acquired_exit = 'TRUE: Lock successfully acquired in \\Drupal\\system_test\\Controller\\SystemTestController::lockExit()';
  $this
    ->drupalGet('system-test/lock-exit');
  $this
    ->assertSession()
    ->pageTextContains($lock_acquired_exit);
  $this
    ->assertTrue($lock
    ->acquire('system_test_lock_exit'), 'Lock acquired by this request after the other request exits.', 'Lock');
}