From ec688b4723a041044226358bcd4dd6e2da39da49 Mon Sep 17 00:00:00 2001 From: Luca Muscariello Date: Thu, 23 Feb 2017 17:01:02 +0100 Subject: Initial commit: cframework. Longbow and Libparc Change-Id: I90378dbd30da6033b20fb1f829b3b822cf366c59 Signed-off-by: Luca Muscariello --- libparc/parc/algol/parc_AtomicInteger.c | 94 +++++++++++++++++++++++++++++++++ 1 file changed, 94 insertions(+) create mode 100755 libparc/parc/algol/parc_AtomicInteger.c (limited to 'libparc/parc/algol/parc_AtomicInteger.c') diff --git a/libparc/parc/algol/parc_AtomicInteger.c b/libparc/parc/algol/parc_AtomicInteger.c new file mode 100755 index 00000000..b32a698f --- /dev/null +++ b/libparc/parc/algol/parc_AtomicInteger.c @@ -0,0 +1,94 @@ +/* + * Copyright (c) 2017 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/** + */ +#include +#include + +#include + +#ifdef USE_GCC_EXTENSIONS +uint32_t +parcAtomicInteger_Uint32IncrementGCC(uint32_t *value) +{ + return __sync_add_and_fetch(value, 1); +} + +uint32_t +parcAtomicInteger_Uint32DecrementGCC(uint32_t *value) +{ + return __sync_sub_and_fetch(value, 1); +} + +uint64_t +parcAtomicInteger_Uint64IncrementGCC(uint64_t *value) +{ + return __sync_add_and_fetch(value, 1); +} + +uint64_t +parcAtomicInteger_Uint64DecrementGCC(uint64_t *value) +{ + return __sync_sub_and_fetch(value, 1); +} +#endif + + +// Since there is no per integer mutex, we must use something to protect an integer from multiple, +// simultaneous competitors. +// Unfortunately, this is an indiscrimiate mutex causing all atomic integer updates to be +// serialized rather than each individually protected. +static pthread_mutex_t _parcAtomicInteger_PthreadMutex = PTHREAD_MUTEX_INITIALIZER; + +uint32_t +parcAtomicInteger_Uint32IncrementPthread(uint32_t *value) +{ + pthread_mutex_lock(&_parcAtomicInteger_PthreadMutex); + *value = *value + 1; + uint32_t result = *value; + pthread_mutex_unlock(&_parcAtomicInteger_PthreadMutex); + return result; +} + +uint32_t +parcAtomicInteger_Uint32DecrementPthread(uint32_t *value) +{ + pthread_mutex_lock(&_parcAtomicInteger_PthreadMutex); + *value = *value - 1; + uint32_t result = *value; + pthread_mutex_unlock(&_parcAtomicInteger_PthreadMutex); + return result; +} + +uint64_t +parcAtomicInteger_Uint64IncrementPthread(uint64_t *value) +{ + pthread_mutex_lock(&_parcAtomicInteger_PthreadMutex); + *value = *value + 1; + uint64_t result = *value; + pthread_mutex_unlock(&_parcAtomicInteger_PthreadMutex); + return result; +} + +uint64_t +parcAtomicInteger_Uint64DecrementPthread(uint64_t *value) +{ + pthread_mutex_lock(&_parcAtomicInteger_PthreadMutex); + *value = *value - 1; + uint64_t result = *value; + pthread_mutex_unlock(&_parcAtomicInteger_PthreadMutex); + return result; +} -- cgit 1.2.3-korg