LockReleaser.php

<?php declare(strict_types=1);

namespace MyApp\Adapter\Couchbase;

use CouchbaseException;

/** Releases all couchbase locks that are tracked. */
class LockReleaser
{
    // ...

    /** @throws \InvalidArgumentException Can only release tracked locks */
    public function releaseLocksFromCurrentProcess(): void
    {
        foreach ($this->lockTracker->getAllTrackingData() as $key => $lockData) {
            if ($lockData['type'] !== 'couchbase') {
                continue;
            }
            $this->release($key, $lockData);
            $this->lockTracker->stopTracking($key);
        }
    }

    protected function release(string $key, array $lockData): void
    {
        try {
            $this->couchbaseCluster->
                openBucket($lockData['bucket_name'])->
                unlock($key, ['cas' => $lockData['lock_id']]);
        } catch (CouchbaseException $exception) {
            if ($exception->getCode() === COUCHBASE_ETMPFAIL) {
                // this may just mean the lock is expired
                return;
            }
            throw $exception;
        }
    }
}