diff options
| author | eb <eb@221aa14e-8319-0410-a670-987f0aec2ac5> | 2008-03-24 06:09:29 +0000 |
|---|---|---|
| committer | eb <eb@221aa14e-8319-0410-a670-987f0aec2ac5> | 2008-03-24 06:09:29 +0000 |
| commit | 28361a1bfc8f155a7b1367a234c9256b7b69da38 (patch) | |
| tree | d75e71d0e87a56a542f905256688475662eee075 /gcell/src/lib/runtime/gc_jd_queue.c | |
| parent | a3ee0a2d8557477c873fb0bb43a34455944f7f58 (diff) | |
Merged gcell, the Cell SPE scheduler and RPC mechanism into the trunk.
(eb/trunk-with-gcell r8037:8085). Expect additional tweaks, but
currently works and passes distcheck.
git-svn-id: http://gnuradio.org/svn/gnuradio/trunk@8086 221aa14e-8319-0410-a670-987f0aec2ac5
Diffstat (limited to 'gcell/src/lib/runtime/gc_jd_queue.c')
| -rw-r--r-- | gcell/src/lib/runtime/gc_jd_queue.c | 78 |
1 files changed, 78 insertions, 0 deletions
diff --git a/gcell/src/lib/runtime/gc_jd_queue.c b/gcell/src/lib/runtime/gc_jd_queue.c new file mode 100644 index 0000000000..b5cdcac9bb --- /dev/null +++ b/gcell/src/lib/runtime/gc_jd_queue.c @@ -0,0 +1,78 @@ +/* -*- c -*- */ +/* + * Copyright 2007 Free Software Foundation, Inc. + * + * This file is part of GNU Radio + * + * GNU Radio is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 3, or (at your option) + * any later version. + * + * GNU Radio is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + */ + +#include "gc_jd_queue.h" +#include "memory_barrier.h" +#include <mutex_init.h> +#include <mutex_lock.h> +#include <mutex_unlock.h> + +void +gc_jd_queue_init(gc_jd_queue_t *q) +{ + _mutex_init(ptr_to_ea(&q->mutex)); + q->head = 0; + q->tail = 0; + smp_wmb(); +} + +void +gc_jd_queue_enqueue(gc_jd_queue_t *q, gc_job_desc_t *item) +{ + item->sys.next = 0; + _mutex_lock(ptr_to_ea(&q->mutex)); + smp_rmb(); // import barrier + + if (q->tail == 0){ // currently empty + q->tail = q->head = jdp_to_ea(item); + } + else { // not empty, append + ea_to_jdp(q->tail)->sys.next = jdp_to_ea(item); + q->tail = jdp_to_ea(item); + } + + smp_wmb(); // orders stores above before clearing of mutex + _mutex_unlock(ptr_to_ea(&q->mutex)); +} + +gc_job_desc_t * +gc_jd_queue_dequeue(gc_jd_queue_t *q) +{ + _mutex_lock(ptr_to_ea(&q->mutex)); + smp_rmb(); // import barrier + + gc_eaddr_t item_ea = q->head; + if (item_ea == 0){ // empty + _mutex_unlock(ptr_to_ea(&q->mutex)); + return 0; + } + + q->head = ea_to_jdp(item_ea)->sys.next; + if (q->head == 0) // now emtpy + q->tail = 0; + + gc_job_desc_t *item = ea_to_jdp(item_ea); + item->sys.next = 0; + + smp_wmb(); // orders stores above before clearing of mutex + _mutex_unlock(ptr_to_ea(&q->mutex)); + return item; +} |