1 /* lists.c -- Buffer list handling routines -*- linux-c -*-
2 * Created: Mon Apr 19 20:54:22 1999 by faith@precisioninsight.com
4 * Copyright 1999 Precision Insight, Inc., Cedar Park, Texas.
5 * Copyright 2000 VA Linux Systems, Inc., Sunnyvale, California.
8 * Permission is hereby granted, free of charge, to any person obtaining a
9 * copy of this software and associated documentation files (the "Software"),
10 * to deal in the Software without restriction, including without limitation
11 * the rights to use, copy, modify, merge, publish, distribute, sublicense,
12 * and/or sell copies of the Software, and to permit persons to whom the
13 * Software is furnished to do so, subject to the following conditions:
15 * The above copyright notice and this permission notice (including the next
16 * paragraph) shall be included in all copies or substantial portions of the
19 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
20 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
21 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
22 * PRECISION INSIGHT AND/OR ITS SUPPLIERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
23 * OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
24 * ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
25 * DEALINGS IN THE SOFTWARE.
28 * Rickard E. (Rik) Faith <faith@valinux.com>
32 #define __NO_VERSION__
35 int drm_waitlist_create(drm_waitlist_t
*bl
, int count
)
37 if (bl
->count
) return -EINVAL
;
40 bl
->bufs
= drm_alloc((bl
->count
+ 2) * sizeof(*bl
->bufs
),
44 bl
->end
= &bl
->bufs
[bl
->count
+1];
45 bl
->write_lock
= SPIN_LOCK_UNLOCKED
;
46 bl
->read_lock
= SPIN_LOCK_UNLOCKED
;
50 int drm_waitlist_destroy(drm_waitlist_t
*bl
)
52 if (bl
->rp
!= bl
->wp
) return -EINVAL
;
53 if (bl
->bufs
) drm_free(bl
->bufs
,
54 (bl
->count
+ 2) * sizeof(*bl
->bufs
),
64 int drm_waitlist_put(drm_waitlist_t
*bl
, drm_buf_t
*buf
)
69 left
= DRM_LEFTCOUNT(bl
);
71 DRM_ERROR("Overflow while adding buffer %d from pid %d\n",
76 buf
->time_queued
= get_cycles();
78 buf
->list
= DRM_LIST_WAIT
;
80 spin_lock_irqsave(&bl
->write_lock
, flags
);
82 if (++bl
->wp
>= bl
->end
) bl
->wp
= bl
->bufs
;
83 spin_unlock_irqrestore(&bl
->write_lock
, flags
);
88 drm_buf_t
*drm_waitlist_get(drm_waitlist_t
*bl
)
93 spin_lock_irqsave(&bl
->read_lock
, flags
);
95 if (bl
->rp
== bl
->wp
) {
96 spin_unlock_irqrestore(&bl
->read_lock
, flags
);
99 if (++bl
->rp
>= bl
->end
) bl
->rp
= bl
->bufs
;
100 spin_unlock_irqrestore(&bl
->read_lock
, flags
);
105 int drm_freelist_create(drm_freelist_t
*bl
, int count
)
107 atomic_set(&bl
->count
, 0);
109 init_waitqueue_head(&bl
->waiting
);
112 atomic_set(&bl
->wfh
, 0);
113 bl
->lock
= SPIN_LOCK_UNLOCKED
;
118 int drm_freelist_destroy(drm_freelist_t
*bl
)
120 atomic_set(&bl
->count
, 0);
125 int drm_freelist_put(drm_device_t
*dev
, drm_freelist_t
*bl
, drm_buf_t
*buf
)
127 drm_device_dma_t
*dma
= dev
->dma
;
130 DRM_ERROR("No DMA support\n");
134 if (buf
->waiting
|| buf
->pending
|| buf
->list
== DRM_LIST_FREE
) {
135 DRM_ERROR("Freed buffer %d: w%d, p%d, l%d\n",
136 buf
->idx
, buf
->waiting
, buf
->pending
, buf
->list
);
139 #if DRM_DMA_HISTOGRAM
140 buf
->time_freed
= get_cycles();
141 drm_histogram_compute(dev
, buf
);
143 buf
->list
= DRM_LIST_FREE
;
145 spin_lock(&bl
->lock
);
146 buf
->next
= bl
->next
;
148 spin_unlock(&bl
->lock
);
150 atomic_inc(&bl
->count
);
151 if (atomic_read(&bl
->count
) > dma
->buf_count
) {
152 DRM_ERROR("%d of %d buffers free after addition of %d\n",
153 atomic_read(&bl
->count
), dma
->buf_count
, buf
->idx
);
156 /* Check for high water mark */
157 if (atomic_read(&bl
->wfh
) && atomic_read(&bl
->count
)>=bl
->high_mark
) {
158 atomic_set(&bl
->wfh
, 0);
159 wake_up_interruptible(&bl
->waiting
);
164 static drm_buf_t
*drm_freelist_try(drm_freelist_t
*bl
)
168 if (!bl
) return NULL
;
171 spin_lock(&bl
->lock
);
173 spin_unlock(&bl
->lock
);
177 bl
->next
= bl
->next
->next
;
178 spin_unlock(&bl
->lock
);
180 atomic_dec(&bl
->count
);
182 buf
->list
= DRM_LIST_NONE
;
183 if (buf
->waiting
|| buf
->pending
) {
184 DRM_ERROR("Free buffer %d: w%d, p%d, l%d\n",
185 buf
->idx
, buf
->waiting
, buf
->pending
, buf
->list
);
191 drm_buf_t
*drm_freelist_get(drm_freelist_t
*bl
, int block
)
193 drm_buf_t
*buf
= NULL
;
194 DECLARE_WAITQUEUE(entry
, current
);
196 if (!bl
|| !bl
->initialized
) return NULL
;
198 /* Check for low water mark */
199 if (atomic_read(&bl
->count
) <= bl
->low_mark
) /* Became low */
200 atomic_set(&bl
->wfh
, 1);
201 if (atomic_read(&bl
->wfh
)) {
203 add_wait_queue(&bl
->waiting
, &entry
);
205 current
->state
= TASK_INTERRUPTIBLE
;
206 if (!atomic_read(&bl
->wfh
)
207 && (buf
= drm_freelist_try(bl
))) break;
209 if (signal_pending(current
)) break;
211 current
->state
= TASK_RUNNING
;
212 remove_wait_queue(&bl
->waiting
, &entry
);
217 return drm_freelist_try(bl
);