Merge pull request #462 from MathieuBordere/init-barrier

uv_append: Initialize barrier upon creation.
canonical · Jul 27, 2023 · 8ba37b3 · 8ba37b3
2 parents 64d3503 + 36c2388
commit 8ba37b3
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/uv_append.c b/src/uv_append.c
@@ -790,13 +790,14 @@ static void uvBarrierTriggerAll(struct UvBarrier *barrier)
     }
 }
 
-struct UvBarrier *uvBarrierAlloc(void)
+static struct UvBarrier *uvBarrierCreate(void)
 {
     struct UvBarrier *barrier;
-    barrier = RaftHeapMalloc(sizeof(*barrier));
+    barrier = RaftHeapCalloc(1, sizeof(*barrier));
     if (!barrier) {
         return NULL;
     }
+    barrier->blocking = false;
     QUEUE_INIT(&barrier->reqs);
     return barrier;
 }
@@ -829,7 +830,7 @@ int UvBarrier(struct uv *uv, raft_index next_index, struct UvBarrierReq *req)
         }
 
         if (!barrier) {
-            barrier = uvBarrierAlloc();
+            barrier = uvBarrierCreate();
             if (!barrier) {
                 return RAFT_NOMEM;
             }
@@ -856,7 +857,7 @@ int UvBarrier(struct uv *uv, raft_index next_index, struct UvBarrierReq *req)
             barrier = uv->barrier;
             /* There is no uv->barrier, make new one. */
         } else {
-            barrier = uvBarrierAlloc();
+            barrier = uvBarrierCreate();
             if (!barrier) {
                 return RAFT_NOMEM;
             }