From mboxrd@z Thu Jan 1 00:00:00 1970 From: Konstantin Ananyev Subject: [PATCH v2 1/2] rwlock: introduce 'try' semantics for RD and WR locking Date: Wed, 19 Dec 2018 18:07:16 +0000 Message-ID: <1545242837-28585-2-git-send-email-konstantin.ananyev@intel.com> References: <1542130061-3702-1-git-send-email-konstantin.ananyev@intel.com> Cc: Konstantin Ananyev To: dev@dpdk.org Return-path: Received: from mga09.intel.com (mga09.intel.com [134.134.136.24]) by dpdk.org (Postfix) with ESMTP id C4AAF1B586 for ; Wed, 19 Dec 2018 19:07:29 +0100 (CET) In-Reply-To: <1542130061-3702-1-git-send-email-konstantin.ananyev@intel.com> List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org Sender: "dev" Introduce rte_rwlock_read_trylock() and rte_rwlock_write_trylock(). Signed-off-by: Konstantin Ananyev Reviewed-by: Honnappa Nagarahalli Reviewed-by: Gavin Hu --- .../common/include/generic/rte_rwlock.h | 56 +++++++++++++++++++ 1 file changed, 56 insertions(+) diff --git a/lib/librte_eal/common/include/generic/rte_rwlock.h b/lib/librte_eal/common/include/generic/rte_rwlock.h index 5751a0e6d..b05d85aee 100644 --- a/lib/librte_eal/common/include/generic/rte_rwlock.h +++ b/lib/librte_eal/common/include/generic/rte_rwlock.h @@ -75,6 +75,36 @@ rte_rwlock_read_lock(rte_rwlock_t *rwl) } } +/** + * @warning + * @b EXPERIMENTAL: this API may change without prior notice. + * + * try to take a read lock. + * + * @param rwl + * A pointer to a rwlock structure. + * @return + * - zero if the lock is successfully taken + * - -EBUSY if lock could not be acquired for reading because a + * writer holds the lock + */ +static inline __rte_experimental int +rte_rwlock_read_trylock(rte_rwlock_t *rwl) +{ + int32_t x; + int success = 0; + + while (success == 0) { + x = rwl->cnt; + /* write lock is held */ + if (x < 0) + return -EBUSY; + success = rte_atomic32_cmpset((volatile uint32_t *)&rwl->cnt, + (uint32_t)x, (uint32_t)(x + 1)); + } + return 0; +} + /** * Release a read lock. * @@ -87,6 +117,32 @@ rte_rwlock_read_unlock(rte_rwlock_t *rwl) rte_atomic32_dec((rte_atomic32_t *)(intptr_t)&rwl->cnt); } +/** + * @warning + * @b EXPERIMENTAL: this API may change without prior notice. + * + * try to take a write lock. + * + * @param rwl + * A pointer to a rwlock structure. + * @return + * - zero if the lock is successfully taken + * - -EBUSY if lock could not be acquired for writing because + * it was already locked for reading or writing + */ +static inline __rte_experimental int +rte_rwlock_write_trylock(rte_rwlock_t *rwl) +{ + int32_t x; + + x = rwl->cnt; + if (x != 0 || rte_atomic32_cmpset((volatile uint32_t *)&rwl->cnt, + 0, (uint32_t)-1) == 0) + return -EBUSY; + + return 0; +} + /** * Take a write lock. Loop until the lock is held. * -- 2.17.1