paraslash 0.7.3

[paraslash.git] / chunk_queue.c

diff --git a/chunk_queue.c b/chunk_queue.c
index cf74cc336de25caa593b198bcfd79a3166996381..1f11359fcb16e4e55073a5fd36d5d5cff7f5504c 100644 (file)
--- a/chunk_queue.c
+++ b/chunk_queue.c
@@ -52,7 +52,7 @@ int cq_enqueue(struct chunk_queue *cq, const char *buf, size_t num_bytes)
 
        if (cq->num_pending + num_bytes > cq->max_pending)
                return -E_QUEUE;
-       qc = para_malloc(sizeof(struct queued_chunk));
+       qc = alloc(sizeof(struct queued_chunk));
        cq->num_pending += num_bytes;
        qc->buf = buf;
        qc->num_bytes = num_bytes;
@@ -130,7 +130,7 @@ int cq_get(struct queued_chunk *qc, const char **buf, size_t *num_bytes)
  */
 struct chunk_queue *cq_new(size_t max_pending)
 {
-       struct chunk_queue *cq = para_malloc(sizeof(*cq));
+       struct chunk_queue *cq = alloc(sizeof(*cq));
        init_list_head(&cq->q);
        cq->max_pending = max_pending;
        cq->num_pending = 0;