Imported Upstream version 3.3.1

[debian/amanda] / xfer-src / element-glue.c

diff --git a/xfer-src/element-glue.c b/xfer-src/element-glue.c
index ecc543d66d924ed1c407ff58af3a6562305158de..319b576080658f3639913c52adf03c90e9fc6937 100644 (file)
--- a/xfer-src/element-glue.c
+++ b/xfer-src/element-glue.c
@@ -68,7 +68,7 @@ typedef struct XferElementGlue_ {
 
     /* a ring buffer of ptr/size pairs with semaphores */
     struct { gpointer buf; size_t size; } *ring;
-    semaphore_t *ring_used_sem, *ring_free_sem;
+    amsemaphore_t *ring_used_sem, *ring_free_sem;
     gint ring_head, ring_tail;
 
     GThread *thread;
@@ -851,8 +851,8 @@ setup_impl(
     /* set up ring if desired */
     if (need_ring) {
        self->ring = g_malloc(sizeof(*self->ring) * GLUE_RING_BUFFER_SIZE);
-       self->ring_used_sem = semaphore_new_with_value(0);
-       self->ring_free_sem = semaphore_new_with_value(GLUE_RING_BUFFER_SIZE);
+       self->ring_used_sem = amsemaphore_new_with_value(0);
+       self->ring_free_sem = amsemaphore_new_with_value(GLUE_RING_BUFFER_SIZE);
     }
 
     if (need_listen_input) {
@@ -944,7 +944,7 @@ pull_buffer_impl(
            }
 
            /* make sure there's at least one element available */
-           semaphore_down(self->ring_used_sem);
+           amsemaphore_down(self->ring_used_sem);
 
            /* get it */
            buf = self->ring[self->ring_tail].buf;
@@ -952,7 +952,7 @@ pull_buffer_impl(
            self->ring_tail = (self->ring_tail + 1) % GLUE_RING_BUFFER_SIZE;
 
            /* and mark this element as free to be overwritten */
-           semaphore_up(self->ring_free_sem);
+           amsemaphore_up(self->ring_free_sem);
 
            return buf;
        }
@@ -1077,7 +1077,7 @@ push_buffer_impl(
            }
 
            /* make sure there's at least one element free */
-           semaphore_down(self->ring_free_sem);
+           amsemaphore_down(self->ring_free_sem);
 
            /* set it */
            self->ring[self->ring_head].buf = buf;
@@ -1085,7 +1085,7 @@ push_buffer_impl(
            self->ring_head = (self->ring_head + 1) % GLUE_RING_BUFFER_SIZE;
 
            /* and mark this element as available for reading */
-           semaphore_up(self->ring_used_sem);
+           amsemaphore_up(self->ring_used_sem);
 
            return;
 
@@ -1181,8 +1181,8 @@ finalize_impl(
        }
 
        amfree(self->ring);
-       semaphore_free(self->ring_used_sem);
-       semaphore_free(self->ring_free_sem);
+       amsemaphore_free(self->ring_used_sem);
+       amsemaphore_free(self->ring_free_sem);
     }
 
     /* chain up */