Changeset 1188:f40de74bd1c7 in freeDiameter for libfdproto/fifo.c

Timestamp:

Jun 10, 2013, 3:27:15 PM (11 years ago)

Author:

Sebastien Decugis <sdecugis@freediameter.net>

Branch:

default

Phase:

public

Message:

Don't block PSM during failover

File:

• libfdproto/fifo.c (modified) (4 diffs)

libfdproto/fifo.c

@@ -377 +377 @@
 
 /* Post a new item in the queue */
-int fd_fifo_post_int ( struct fifo * queue, void ** item )
+int fd_fifo_post_internal ( struct fifo * queue, void ** item, int skip_max )
 {
         struct fifo_item * new;
@@ -383 +383 @@
         struct timespec posted_on, queued_on;
         
-        TRACE_ENTRY( "%p %p", queue, item );
-        
-        /* Check the parameters */
-        CHECK_PARAMS( CHECK_FIFO( queue ) && item && *item );
-        
         /* Get the timing of this call */
         CHECK_SYS(  clock_gettime(CLOCK_REALTIME, &posted_on)  );
@@ -394 +389 @@
         CHECK_POSIX(  pthread_mutex_lock( &queue->mtx )  );
         
-        if (queue->max) {
+        if ((!skip_max) && (queue->max)) {
                 while (queue->count >= queue->max) {
                         int ret = 0;
@@ -460 +455 @@
         /* Done */
         return 0;
+}
+
+/* Post a new item in the queue */
+int fd_fifo_post_int ( struct fifo * queue, void ** item )
+{
+        TRACE_ENTRY( "%p %p", queue, item );
+        
+        /* Check the parameters */
+        CHECK_PARAMS( CHECK_FIFO( queue ) && item && *item );
+        
+        return fd_fifo_post_internal ( queue,item, 0 );
+        
+}
+
+/* Post a new item in the queue, not blocking */
+int fd_fifo_post_noblock ( struct fifo * queue, void ** item )
+{
+        TRACE_ENTRY( "%p %p", queue, item );
+        
+        /* Check the parameters */
+        CHECK_PARAMS( CHECK_FIFO( queue ) && item && *item );
+        
+        return fd_fifo_post_internal ( queue,item, 1 );
+        
 }