mirror of
https://git.rwth-aachen.de/acs/public/villas/node/
synced 2025-03-30 00:00:11 +01:00
Revert "use proper enum type for atomic state"
This reverts commit 44669a748d
.
This commit is contained in:
parent
867fb90f7f
commit
292e846bf8
2 changed files with 3 additions and 3 deletions
|
@ -56,7 +56,7 @@ struct queue_cell {
|
||||||
struct queue {
|
struct queue {
|
||||||
cacheline_pad_t _pad0; /**< Shared area: all threads read */
|
cacheline_pad_t _pad0; /**< Shared area: all threads read */
|
||||||
|
|
||||||
_Atomic enum state state;
|
atomic_size_t state;
|
||||||
|
|
||||||
struct memtype *mem;
|
struct memtype *mem;
|
||||||
size_t buffer_mask;
|
size_t buffer_mask;
|
||||||
|
|
|
@ -188,8 +188,8 @@ int queue_pull_many(struct queue *q, void *ptr[], size_t cnt)
|
||||||
|
|
||||||
int queue_close(struct queue *q)
|
int queue_close(struct queue *q)
|
||||||
{
|
{
|
||||||
enum state expected = STATE_INITIALIZED;
|
size_t expected = STATE_INITIALIZED;
|
||||||
if (atomic_compare_exchange_weak_explicit(&q->state, &expected, STATE_STOPPED, memory_order_relaxed, memory_order_relaxed))
|
if (atomic_compare_exchange_weak_explicit(&q->state, &expected, STATE_STOPPED, memory_order_relaxed, memory_order_relaxed)) {
|
||||||
return 0;
|
return 0;
|
||||||
|
|
||||||
return -1;
|
return -1;
|
||||||
|
|
Loading…
Add table
Reference in a new issue