Mesa (lp-binning): llvmpipe: added new lp_bin_queue.[ch] files
Brian Paul
brianp at kemper.freedesktop.org
Thu Dec 10 21:56:52 UTC 2009
Module: Mesa
Branch: lp-binning
Commit: ea35993e7479793212529b1db081c84aa71ea4cc
URL: http://cgit.freedesktop.org/mesa/mesa/commit/?id=ea35993e7479793212529b1db081c84aa71ea4cc
Author: Brian Paul <brianp at vmware.com>
Date: Wed Dec 9 14:36:52 2009 -0700
llvmpipe: added new lp_bin_queue.[ch] files
The queues will be used for keeping track of full and empty bins so
we can overlap setup with the rasterization threads.
---
src/gallium/drivers/llvmpipe/Makefile | 1 +
src/gallium/drivers/llvmpipe/SConscript | 1 +
src/gallium/drivers/llvmpipe/lp_bin_queue.c | 156 +++++++++++++++++++++++++++
src/gallium/drivers/llvmpipe/lp_bin_queue.h | 55 ++++++++++
4 files changed, 213 insertions(+), 0 deletions(-)
diff --git a/src/gallium/drivers/llvmpipe/Makefile b/src/gallium/drivers/llvmpipe/Makefile
index 6ff45d0..4cc4c88 100644
--- a/src/gallium/drivers/llvmpipe/Makefile
+++ b/src/gallium/drivers/llvmpipe/Makefile
@@ -7,6 +7,7 @@ CFLAGS += -D__STDC_CONSTANT_MACROS -D__STDC_LIMIT_MACROS
C_SOURCES = \
lp_bin.c \
+ lp_bin_queue.c \
lp_bld_alpha.c \
lp_bld_arit.c \
lp_bld_blend_aos.c \
diff --git a/src/gallium/drivers/llvmpipe/SConscript b/src/gallium/drivers/llvmpipe/SConscript
index 4aef338..19ef686 100644
--- a/src/gallium/drivers/llvmpipe/SConscript
+++ b/src/gallium/drivers/llvmpipe/SConscript
@@ -20,6 +20,7 @@ llvmpipe = env.ConvenienceLibrary(
target = 'llvmpipe',
source = [
'lp_bin.c',
+ 'lp_bin_queue.c',
'lp_bld_alpha.c',
'lp_bld_arit.c',
'lp_bld_blend_aos.c',
diff --git a/src/gallium/drivers/llvmpipe/lp_bin_queue.c b/src/gallium/drivers/llvmpipe/lp_bin_queue.c
new file mode 100644
index 0000000..19e1a58
--- /dev/null
+++ b/src/gallium/drivers/llvmpipe/lp_bin_queue.c
@@ -0,0 +1,156 @@
+/**************************************************************************
+ *
+ * Copyright 2009 VMware, Inc.
+ * All Rights Reserved.
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the
+ * "Software"), to deal in the Software without restriction, including
+ * without limitation the rights to use, copy, modify, merge, publish,
+ * distribute, sub license, and/or sell copies of the Software, and to
+ * permit persons to whom the Software is furnished to do so, subject to
+ * the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the
+ * next paragraph) shall be included in all copies or substantial portions
+ * of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
+ * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+ * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT.
+ * IN NO EVENT SHALL VMWARE AND/OR ITS SUPPLIERS BE LIABLE FOR
+ * ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
+ * TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
+ * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ *
+ **************************************************************************/
+
+
+/**
+ * Bin queue. We'll use two queues. One contains "full" bins which
+ * are produced by the "setup" code. The other contains "empty" bins
+ * which are produced by the "rast" code when it finishes rendering a bin.
+ */
+
+
+#include "pipe/p_thread.h"
+#include "lp_bin.h"
+#include "lp_bin_queue.h"
+
+
+
+#define MAX_BINS 4
+
+
+/**
+ * A queue of bins
+ */
+struct lp_bins_queue
+{
+ /** XXX might use a linked list here somedone, but the list will
+ * probably always be pretty short.
+ */
+ struct lp_bins *bins[MAX_BINS];
+ unsigned size;
+
+ pipe_condvar size_change;
+ pipe_mutex mutex;
+};
+
+
+
+/** Allocate a new bins queue */
+struct lp_bins_queue *
+lp_bins_queue_create(void)
+{
+ struct lp_bins_queue *queue = CALLOC_STRUCT(lp_bins_queue);
+ if (queue) {
+ pipe_condvar_init(queue->size_change);
+ pipe_mutex_init(queue->mutex);
+ }
+ return queue;
+}
+
+
+/** Delete a new bins queue */
+void
+lp_bins_queue_destroy(struct lp_bins_queue *queue)
+{
+ pipe_condvar_destroy(queue->size_change);
+ pipe_mutex_destroy(queue->mutex);
+}
+
+
+/** Remove first lp_bins from head of queue */
+struct lp_bins *
+lp_bins_dequeue(struct lp_bins_queue *queue)
+{
+ struct lp_bins *bins;
+ unsigned i;
+
+ pipe_mutex_lock(queue->mutex);
+ while (queue->size == 0) {
+ pipe_condvar_wait(queue->size_change, queue->mutex);
+ }
+
+ assert(queue->size >= 1);
+
+ /* get head */
+ bins = queue->bins[0];
+
+ /* shift entries */
+ for (i = 0; i < queue->size - 1; i++) {
+ queue->bins[i] = queue->bins[i + 1];
+ }
+
+ queue->size--;
+
+ /* signal size change */
+ pipe_condvar_signal(queue->size_change);
+
+ pipe_mutex_unlock(queue->mutex);
+
+ return bins;
+}
+
+
+/** Add an lp_bins to tail of queue */
+void
+lp_bins_enqueue(struct lp_bins_queue *queue, struct lp_bins *bins)
+{
+ pipe_mutex_lock(queue->mutex);
+
+ assert(queue->size < MAX_BINS);
+
+ /* add to end */
+ queue->bins[queue->size++] = bins;
+
+ /* signal size change */
+ pipe_condvar_signal(queue->size_change);
+
+ pipe_mutex_unlock(queue->mutex);
+}
+
+
+/** Return number of entries in the queue */
+unsigned
+lp_bins_queue_size(struct lp_bins_queue *queue)
+{
+ unsigned sz;
+ pipe_mutex_lock(queue->mutex);
+ sz = queue->size;
+ pipe_mutex_unlock(queue->mutex);
+ return sz;
+}
+
+
+/** Wait until the queue as 'size' entries */
+void
+lp_bins_queue_wait_size(struct lp_bins_queue *queue, unsigned size)
+{
+ pipe_mutex_lock(queue->mutex);
+ while (queue->size != size) {
+ pipe_condvar_wait(queue->size_change, queue->mutex);
+ }
+ pipe_mutex_unlock(queue->mutex);
+}
diff --git a/src/gallium/drivers/llvmpipe/lp_bin_queue.h b/src/gallium/drivers/llvmpipe/lp_bin_queue.h
new file mode 100644
index 0000000..8946a54
--- /dev/null
+++ b/src/gallium/drivers/llvmpipe/lp_bin_queue.h
@@ -0,0 +1,55 @@
+/**************************************************************************
+ *
+ * Copyright 2009 VMware, Inc.
+ * All Rights Reserved.
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the
+ * "Software"), to deal in the Software without restriction, including
+ * without limitation the rights to use, copy, modify, merge, publish,
+ * distribute, sub license, and/or sell copies of the Software, and to
+ * permit persons to whom the Software is furnished to do so, subject to
+ * the following conditions:
+ *
+ * The above copyright notice and this permission notice (including the
+ * next paragraph) shall be included in all copies or substantial portions
+ * of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
+ * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+ * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT.
+ * IN NO EVENT SHALL VMWARE AND/OR ITS SUPPLIERS BE LIABLE FOR
+ * ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
+ * TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
+ * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ *
+ **************************************************************************/
+
+
+#ifndef LP_BIN_QUEUE
+#define LP_BIN_QUEUE
+
+struct lp_bin_queue;
+struct lp_bins;
+
+
+struct lp_bins_queue *
+lp_bins_queue_create(void);
+
+void
+lp_bins_queue_destroy(struct lp_bins_queue *queue);
+
+struct lp_bins *
+lp_bins_dequeue(struct lp_bins_queue *queue);
+
+void
+lp_bins_enqueue(struct lp_bins_queue *queue, struct lp_bins *bins);
+
+unsigned
+lp_bins_queue_size(struct lp_bins_queue *queue);
+
+void
+lp_bins_queue_wait_size(struct lp_bins_queue *queue, unsigned size);
+
+
+#endif /* LP_BIN_QUEUE */
More information about the mesa-commit
mailing list