Skip to content

Commit 6f083a5

Browse files
committed
atomics cd
1 parent b6e07d6 commit 6f083a5

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

src/pool/pool_disjoint.c

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -529,12 +529,14 @@ bool bucket_can_pool(bucket_t *bucket, bool *to_pool) {
529529
break;
530530
}
531531

532-
// TODO!!!
533-
//if (utils_compare_exchange(&bucket->shared_limits->total_size,
534-
// pool_size, new_pool_size)) {
532+
// TODO!!!
533+
#ifdef _WIN32
535534
if (bucket->shared_limits->total_size != new_pool_size) {
536535
bucket->shared_limits->total_size = new_pool_size;
537-
536+
#else
537+
if (utils_compare_exchange(&bucket->shared_limits->total_size,
538+
&pool_size, &new_pool_size)) {
539+
#endif
538540
if (chunkedBucket) {
539541
++bucket->chunkedSlabsInPool;
540542
}
@@ -693,7 +695,7 @@ utils_mutex_t *AllocImpl_getKnownSlabsMapLock(AllocImpl *ai) {
693695

694696
critnib *AllocImpl_getKnownSlabs(AllocImpl *ai) { return ai->known_slabs; }
695697

696-
size_t AllocImpl_SlabMinSize(AllocImpl *ai) { return ai->params.SlabMinSize; };
698+
size_t AllocImpl_SlabMinSize(AllocImpl *ai) { return ai->params.SlabMinSize; }
697699

698700
umf_disjoint_pool_params_t *AllocImpl_getParams(AllocImpl *ai) {
699701
return &ai->params;

0 commit comments

Comments
 (0)