storages::postgres::DistLockStrategy Class Reference

#include <userver/storages/postgres/dist_lock_strategy.hpp>

Detailed Description

Postgres distributed locking strategy.

Definition at line 20 of file dist_lock_strategy.hpp.

Inheritance diagram for storages::postgres::DistLockStrategy:

Public Member Functions
	DistLockStrategy (ClusterPtr cluster, std::string_view table, std::string_view lock_name, const dist_lock::DistLockSettings &settings)
void	Acquire (std::chrono::milliseconds lock_ttl, const std::string &locker_id) override
void	Release (const std::string &locker_id) override
void	UpdateCommandControl (CommandControl cc)
virtual void	Prolong (std::chrono::milliseconds lock_ttl, const std::string &locker_id)

Member Function Documentation

Acquire()

void storages::postgres::DistLockStrategy::Acquire ( std::chrono::milliseconds lock_ttl, const std::string & locker_id )

overridevirtual

Acquires the distributed lock.

Parameters

lock_ttl	The duration for which the lock must be held.
locker_id	Globally unique ID of the locking entity.

Exceptions

LockIsAcquiredByAnotherHostError	when the lock is busy
anything	else when the locking fails, strategy is responsible for cleanup, Release won't be invoked.

Implements dist_lock::DistLockStrategyBase.

Prolong()

virtual void dist_lock::DistLockStrategyBase::Prolong ( std::chrono::milliseconds lock_ttl, const std::string & locker_id )

inlinevirtualinherited

Prolongs (refreshes the TTL of) a lock already held by locker_id.

Called instead of Acquire() on every refresh while the lock is held, so backends may implement a cheaper query than the full Acquire().

Parameters

lock_ttl	The new duration for which the lock must be held.
locker_id	Globally unique ID of the locking entity, must be the same as in Acquire().

Exceptions

LockIsAcquiredByAnotherHostException	when the lock is no longer held by locker_id (ownership was lost)
anything	else when the prolongation fails, strategy is responsible for cleanup, Release won't be invoked.

Note

The default implementation simply calls Acquire(), preserving the legacy behaviour for strategies that do not override it.

Reimplemented in storages::mongo::DistLockStrategy.

Definition at line 51 of file dist_lock_strategy.hpp.

Release()

void storages::postgres::DistLockStrategy::Release ( const std::string & locker_id )

overridevirtual

Releases the lock.

Parameters

locker_id

Globally unique ID of the locking entity, must be the same as in Acquire().

Note

Exceptions are ignored.

Implements dist_lock::DistLockStrategyBase.

---

The documentation for this class was generated from the following file:

• userver/storages/postgres/dist_lock_strategy.hpp