X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/bb3a649562245b802c9465eec776f2af752e898f..84079cc1149b1d8c588a029f2bde6c863b5ce740:/src/xbt/xbt_queue.c diff --git a/src/xbt/xbt_queue.c b/src/xbt/xbt_queue.c index 4aed8d953f..8321246017 100644 --- a/src/xbt/xbt_queue.c +++ b/src/xbt/xbt_queue.c @@ -57,7 +57,7 @@ void xbt_queue_free(xbt_queue_t *queue) { } /** @brief Get the queue size */ -unsigned long xbt_queue_length(xbt_queue_t queue) { +unsigned long xbt_queue_length(const xbt_queue_t queue) { unsigned long res; xbt_mutex_lock(queue->mutex); res=xbt_dynar_length(queue->data); @@ -145,20 +145,39 @@ void xbt_queue_shift(xbt_queue_t queue, void* const dst) { * @see #xbt_queue_push */ void xbt_queue_push_timed(xbt_queue_t queue, const void *src,double delay) { - double timeout = xbt_os_time() + delay; - xbt_mutex_lock(queue->mutex); - if (queue->capacity != 0 && queue->capacity == xbt_dynar_length(queue->data)) { - DEBUG2("Capacity of %p exceded (=%d). Waiting",queue,queue->capacity); - xbt_cond_timedwait(queue->not_full,queue->mutex, delay); - /* check if a timeout occurs */ - if (xbt_os_time() >= timeout) { - xbt_mutex_unlock(queue->mutex); - THROW0(timeout_error,0,"Timeout"); - } - } - xbt_dynar_push(queue->data,src); - xbt_cond_signal(queue->not_empty); - xbt_mutex_unlock(queue->mutex); + double timeout = xbt_time() + delay; + xbt_ex_t e; + + xbt_mutex_lock(queue->mutex); + + if (delay == 0) { + if (queue->capacity != 0 && + queue->capacity == xbt_dynar_length(queue->data)) { + + xbt_mutex_unlock(queue->mutex); + THROW2(timeout_error,0,"Capacity of %p exceded (=%d), and delay = 0", + queue,queue->capacity); + } + } else { + while (queue->capacity != 0 && + queue->capacity == xbt_dynar_length(queue->data) && + (delay<0 || xbt_time() < timeout) ) { + + DEBUG2("Capacity of %p exceded (=%d). Waiting", + queue,queue->capacity); + TRY { + xbt_cond_timedwait(queue->not_full,queue->mutex, + delay < 0 ? -1 : timeout - xbt_time()); + } CATCH(e) { + xbt_mutex_unlock(queue->mutex); + RETHROW; + } + } + } + + xbt_dynar_push(queue->data,src); + xbt_cond_signal(queue->not_empty); + xbt_mutex_unlock(queue->mutex); } @@ -168,20 +187,33 @@ void xbt_queue_push_timed(xbt_queue_t queue, const void *src,double delay) { * */ void xbt_queue_pop_timed(xbt_queue_t queue, void* const dst,double delay) { - double timeout = xbt_os_time() + delay; - xbt_mutex_lock(queue->mutex); - if (xbt_dynar_length(queue->data) == 0) { + double timeout = xbt_time() + delay; + xbt_ex_t e; + + xbt_mutex_lock(queue->mutex); + + if (delay == 0) { + if (xbt_dynar_length(queue->data) == 0) { + xbt_mutex_unlock(queue->mutex); + THROW0(timeout_error,0,"Delay = 0, and queue is empty"); + } + } else { + while ( (xbt_dynar_length(queue->data) == 0) && + (delay<0 || xbt_time() < timeout) ) { DEBUG1("Queue %p empty. Waiting",queue); - xbt_cond_timedwait(queue->not_empty,queue->mutex,delay); - /* check if a timeout occurs */ - if (xbt_os_time() >= timeout) { - xbt_mutex_unlock(queue->mutex); - THROW0(timeout_error,0,"Timeout"); - } - } - xbt_dynar_pop(queue->data,dst); - xbt_cond_signal(queue->not_full); - xbt_mutex_unlock(queue->mutex); + TRY { + xbt_cond_timedwait(queue->not_empty,queue->mutex, + delay<0 ? -1 : timeout - xbt_time()); + } CATCH(e) { + xbt_mutex_unlock(queue->mutex); + RETHROW; + } + } + } + + xbt_dynar_pop(queue->data,dst); + xbt_cond_signal(queue->not_full); + xbt_mutex_unlock(queue->mutex); } /** @brief Unshift something to the message exchange queue, with a timeout. @@ -189,20 +221,39 @@ void xbt_queue_pop_timed(xbt_queue_t queue, void* const dst,double delay) { * @see #xbt_queue_unshift */ void xbt_queue_unshift_timed(xbt_queue_t queue, const void *src,double delay) { - double timeout = xbt_os_time() + delay; - xbt_mutex_lock(queue->mutex); - if (queue->capacity != 0 && queue->capacity == xbt_dynar_length(queue->data)) { - DEBUG2("Capacity of %p exceded (=%d). Waiting",queue,queue->capacity); - xbt_cond_timedwait(queue->not_full,queue->mutex,delay); - /* check if a timeout occurs */ - if (xbt_os_time() >= timeout) { - xbt_mutex_unlock(queue->mutex); - THROW0(timeout_error,0,"Timeout"); - } - } - xbt_dynar_unshift(queue->data,src); - xbt_cond_signal(queue->not_empty); - xbt_mutex_unlock(queue->mutex); + double timeout = xbt_time() + delay; + xbt_ex_t e; + + xbt_mutex_lock(queue->mutex); + + if (delay==0) { + if (queue->capacity != 0 && + queue->capacity == xbt_dynar_length(queue->data)) { + + xbt_mutex_unlock(queue->mutex); + THROW2(timeout_error,0,"Capacity of %p exceded (=%d), and delay = 0", + queue,queue->capacity); + } + } else { + while (queue->capacity != 0 && + queue->capacity == xbt_dynar_length(queue->data) && + (delay<0 || xbt_time() < timeout) ) { + + DEBUG2("Capacity of %p exceded (=%d). Waiting", + queue,queue->capacity); + TRY { + xbt_cond_timedwait(queue->not_full,queue->mutex, + delay < 0 ? -1 : timeout - xbt_time()); + } CATCH(e) { + xbt_mutex_unlock(queue->mutex); + RETHROW; + } + } + } + + xbt_dynar_unshift(queue->data,src); + xbt_cond_signal(queue->not_empty); + xbt_mutex_unlock(queue->mutex); } @@ -212,18 +263,31 @@ void xbt_queue_unshift_timed(xbt_queue_t queue, const void *src,double delay) { * */ void xbt_queue_shift_timed(xbt_queue_t queue, void* const dst,double delay) { - double timeout = xbt_os_time() + delay; - xbt_mutex_lock(queue->mutex); - while (xbt_dynar_length(queue->data) == 0) { + double timeout = xbt_time() + delay; + xbt_ex_t e; + + xbt_mutex_lock(queue->mutex); + + if (delay == 0) { + if (xbt_dynar_length(queue->data) == 0) { + xbt_mutex_unlock(queue->mutex); + THROW0(timeout_error,0,"Delay = 0, and queue is empty"); + } + } else { + while ( (xbt_dynar_length(queue->data) == 0) && + (delay<0 || xbt_time() < timeout) ) { DEBUG1("Queue %p empty. Waiting",queue); - xbt_cond_timedwait(queue->not_empty,queue->mutex,delay); - /* check if a timeout occurs */ - if (xbt_os_time() >= timeout) { - xbt_mutex_unlock(queue->mutex); - THROW0(timeout_error,0,"Timeout"); - } - } - xbt_dynar_shift(queue->data,dst); - xbt_cond_signal(queue->not_full); - xbt_mutex_unlock(queue->mutex); + TRY { + xbt_cond_timedwait(queue->not_empty,queue->mutex, + delay<0 ? -1 : timeout - xbt_time()); + } CATCH(e) { + xbt_mutex_unlock(queue->mutex); + RETHROW; + } + } + } + + xbt_dynar_shift(queue->data,dst); + xbt_cond_signal(queue->not_full); + xbt_mutex_unlock(queue->mutex); }