2 * Copyright 2010 Christoph Bumiller
4 * Permission is hereby granted, free of charge, to any person obtaining a
5 * copy of this software and associated documentation files (the "Software"),
6 * to deal in the Software without restriction, including without limitation
7 * the rights to use, copy, modify, merge, publish, distribute, sublicense,
8 * and/or sell copies of the Software, and to permit persons to whom the
9 * Software is furnished to do so, subject to the following conditions:
11 * The above copyright notice and this permission notice shall be included in
12 * all copies or substantial portions of the Software.
14 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
15 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
16 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
17 * THE AUTHORS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
18 * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF
19 * OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
23 #include "util/u_double_list.h"
25 #include "nouveau_screen.h"
26 #include "nouveau_fence.h"
28 #include "nouveau/nouveau_pushbuf.h"
35 nouveau_fence_new(struct nouveau_screen
*screen
, struct nouveau_fence
**fence
,
38 *fence
= CALLOC_STRUCT(nouveau_fence
);
42 (*fence
)->screen
= screen
;
44 LIST_INITHEAD(&(*fence
)->work
);
47 nouveau_fence_emit(*fence
);
53 nouveau_fence_trigger_work(struct nouveau_fence
*fence
)
55 struct nouveau_fence_work
*work
, *tmp
;
57 LIST_FOR_EACH_ENTRY_SAFE(work
, tmp
, &fence
->work
, list
) {
58 work
->func(work
->data
);
59 LIST_DEL(&work
->list
);
65 nouveau_fence_work(struct nouveau_fence
*fence
,
66 void (*func
)(void *), void *data
)
68 struct nouveau_fence_work
*work
;
70 if (!fence
|| fence
->state
== NOUVEAU_FENCE_STATE_SIGNALLED
) {
75 work
= CALLOC_STRUCT(nouveau_fence_work
);
80 LIST_ADD(&work
->list
, &fence
->work
);
85 nouveau_fence_emit(struct nouveau_fence
*fence
)
87 struct nouveau_screen
*screen
= fence
->screen
;
89 fence
->sequence
= ++screen
->fence
.sequence
;
91 assert(fence
->state
== NOUVEAU_FENCE_STATE_AVAILABLE
);
93 /* set this now, so that if fence.emit triggers a flush we don't recurse */
94 fence
->state
= NOUVEAU_FENCE_STATE_EMITTED
;
96 screen
->fence
.emit(&screen
->base
, fence
->sequence
);
100 if (screen
->fence
.tail
)
101 screen
->fence
.tail
->next
= fence
;
103 screen
->fence
.head
= fence
;
105 screen
->fence
.tail
= fence
;
109 nouveau_fence_del(struct nouveau_fence
*fence
)
111 struct nouveau_fence
*it
;
112 struct nouveau_screen
*screen
= fence
->screen
;
114 if (fence
->state
== NOUVEAU_FENCE_STATE_EMITTED
||
115 fence
->state
== NOUVEAU_FENCE_STATE_FLUSHED
) {
116 if (fence
== screen
->fence
.head
) {
117 screen
->fence
.head
= fence
->next
;
118 if (!screen
->fence
.head
)
119 screen
->fence
.tail
= NULL
;
121 for (it
= screen
->fence
.head
; it
&& it
->next
!= fence
; it
= it
->next
);
122 it
->next
= fence
->next
;
123 if (screen
->fence
.tail
== fence
)
124 screen
->fence
.tail
= it
;
128 if (!LIST_IS_EMPTY(&fence
->work
)) {
129 debug_printf("WARNING: deleting fence with work still pending !\n");
130 nouveau_fence_trigger_work(fence
);
137 nouveau_fence_update(struct nouveau_screen
*screen
, boolean flushed
)
139 struct nouveau_fence
*fence
;
140 struct nouveau_fence
*next
= NULL
;
141 u32 sequence
= screen
->fence
.update(&screen
->base
);
143 if (screen
->fence
.sequence_ack
== sequence
)
145 screen
->fence
.sequence_ack
= sequence
;
147 for (fence
= screen
->fence
.head
; fence
; fence
= next
) {
149 sequence
= fence
->sequence
;
151 fence
->state
= NOUVEAU_FENCE_STATE_SIGNALLED
;
153 nouveau_fence_trigger_work(fence
);
154 nouveau_fence_ref(NULL
, &fence
);
156 if (sequence
== screen
->fence
.sequence_ack
)
159 screen
->fence
.head
= next
;
161 screen
->fence
.tail
= NULL
;
164 for (fence
= next
; fence
; fence
= fence
->next
)
165 fence
->state
= NOUVEAU_FENCE_STATE_FLUSHED
;
169 #define NOUVEAU_FENCE_MAX_SPINS (1 << 31)
172 nouveau_fence_signalled(struct nouveau_fence
*fence
)
174 struct nouveau_screen
*screen
= fence
->screen
;
176 if (fence
->state
>= NOUVEAU_FENCE_STATE_EMITTED
)
177 nouveau_fence_update(screen
, FALSE
);
179 return fence
->state
== NOUVEAU_FENCE_STATE_SIGNALLED
;
183 nouveau_fence_wait(struct nouveau_fence
*fence
)
185 struct nouveau_screen
*screen
= fence
->screen
;
188 if (fence
->state
< NOUVEAU_FENCE_STATE_EMITTED
) {
189 nouveau_fence_emit(fence
);
191 if (fence
== screen
->fence
.current
)
192 nouveau_fence_new(screen
, &screen
->fence
.current
, FALSE
);
194 if (fence
->state
< NOUVEAU_FENCE_STATE_FLUSHED
)
195 FIRE_RING(screen
->channel
);
198 nouveau_fence_update(screen
, FALSE
);
200 if (fence
->state
== NOUVEAU_FENCE_STATE_SIGNALLED
)
204 if (!(spins
% 8)) /* donate a few cycles */
207 } while (spins
< NOUVEAU_FENCE_MAX_SPINS
);
209 debug_printf("Wait on fence %u (ack = %u, next = %u) timed out !\n",
211 screen
->fence
.sequence_ack
, screen
->fence
.sequence
);
217 nouveau_fence_next(struct nouveau_screen
*screen
)
219 if (screen
->fence
.current
->state
< NOUVEAU_FENCE_STATE_EMITTED
)
220 nouveau_fence_emit(screen
->fence
.current
);
222 nouveau_fence_ref(NULL
, &screen
->fence
.current
);
224 nouveau_fence_new(screen
, &screen
->fence
.current
, FALSE
);