gallium: extend pipe_context::flush for it to accept an END_OF_FRAME flag
[mesa.git] / src / gallium / state_trackers / vdpau / presentation.c
index d83dde647ee8b04304e275d349887f3101c33628..3dd7f05375e7368b6d85166890c4fe29a636b00e 100644 (file)
@@ -26,7 +26,6 @@
  **************************************************************************/
 
 #include <stdio.h>
-
 #include <vdpau/vdpau.h>
 
 #include "util/u_debug.h"
@@ -45,8 +44,6 @@ vlVdpPresentationQueueCreate(VdpDevice device,
    vlVdpPresentationQueue *pq = NULL;
    VdpStatus ret;
 
-   VDPAU_MSG(VDPAU_TRACE, "[VDPAU] Creating PresentationQueue\n");
-
    if (!presentation_queue)
       return VDP_STATUS_INVALID_POINTER;
 
@@ -67,11 +64,14 @@ vlVdpPresentationQueueCreate(VdpDevice device,
 
    pq->device = dev;
    pq->drawable = pqt->drawable;
-   
-   if (!vl_compositor_init(&pq->compositor, dev->context->pipe)) {
+
+   pipe_mutex_lock(dev->mutex);
+   if (!vl_compositor_init_state(&pq->cstate, dev->context)) {
+      pipe_mutex_unlock(dev->mutex);
       ret = VDP_STATUS_ERROR;
       goto no_compositor;
    }
+   pipe_mutex_unlock(dev->mutex);
 
    *presentation_queue = vlAddDataHTAB(pq);
    if (*presentation_queue == 0) {
@@ -95,13 +95,13 @@ vlVdpPresentationQueueDestroy(VdpPresentationQueue presentation_queue)
 {
    vlVdpPresentationQueue *pq;
 
-   VDPAU_MSG(VDPAU_TRACE, "[VDPAU] Destroying PresentationQueue\n");
-
    pq = vlGetDataHTAB(presentation_queue);
    if (!pq)
       return VDP_STATUS_INVALID_HANDLE;
 
-   vl_compositor_cleanup(&pq->compositor);
+   pipe_mutex_lock(pq->device->mutex);
+   vl_compositor_cleanup_state(&pq->cstate);
+   pipe_mutex_unlock(pq->device->mutex);
 
    vlRemoveDataHTAB(presentation_queue);
    FREE(pq);
@@ -117,8 +117,7 @@ vlVdpPresentationQueueSetBackgroundColor(VdpPresentationQueue presentation_queue
                                          VdpColor *const background_color)
 {
    vlVdpPresentationQueue *pq;
-
-   VDPAU_MSG(VDPAU_TRACE, "[VDPAU] Setting background color\n");
+   union pipe_color_union color;
 
    if (!background_color)
       return VDP_STATUS_INVALID_POINTER;
@@ -127,7 +126,14 @@ vlVdpPresentationQueueSetBackgroundColor(VdpPresentationQueue presentation_queue
    if (!pq)
       return VDP_STATUS_INVALID_HANDLE;
 
-   vl_compositor_set_clear_color(&pq->compositor, (float*)background_color);
+   color.f[0] = background_color->red;
+   color.f[1] = background_color->green;
+   color.f[2] = background_color->blue;
+   color.f[3] = background_color->alpha;
+
+   pipe_mutex_lock(pq->device->mutex);
+   vl_compositor_set_clear_color(&pq->cstate, &color);
+   pipe_mutex_unlock(pq->device->mutex);
 
    return VDP_STATUS_OK;
 }
@@ -140,8 +146,7 @@ vlVdpPresentationQueueGetBackgroundColor(VdpPresentationQueue presentation_queue
                                          VdpColor *const background_color)
 {
    vlVdpPresentationQueue *pq;
-
-   VDPAU_MSG(VDPAU_TRACE, "[VDPAU] Getting background color\n");
+   union pipe_color_union color;
 
    if (!background_color)
       return VDP_STATUS_INVALID_POINTER;
@@ -150,7 +155,14 @@ vlVdpPresentationQueueGetBackgroundColor(VdpPresentationQueue presentation_queue
    if (!pq)
       return VDP_STATUS_INVALID_HANDLE;
 
-   vl_compositor_get_clear_color(&pq->compositor, (float*)background_color);
+   pipe_mutex_lock(pq->device->mutex);
+   vl_compositor_get_clear_color(&pq->cstate, &color);
+   pipe_mutex_unlock(pq->device->mutex);
+
+   background_color->red = color.f[0];
+   background_color->green = color.f[1];
+   background_color->blue = color.f[2];
+   background_color->alpha = color.f[3];
 
    return VDP_STATUS_OK;
 }
@@ -162,12 +174,20 @@ VdpStatus
 vlVdpPresentationQueueGetTime(VdpPresentationQueue presentation_queue,
                               VdpTime *current_time)
 {
-   VDPAU_MSG(VDPAU_TRACE, "[VDPAU] Getting queue time\n");
+   vlVdpPresentationQueue *pq;
 
    if (!current_time)
       return VDP_STATUS_INVALID_POINTER;
 
-   return VDP_STATUS_NO_IMPLEMENTATION;
+   pq = vlGetDataHTAB(presentation_queue);
+   if (!pq)
+      return VDP_STATUS_INVALID_HANDLE;
+
+   pipe_mutex_lock(pq->device->mutex);
+   *current_time = vl_screen_get_timestamp(pq->device->vscreen, pq->drawable);
+   pipe_mutex_unlock(pq->device->mutex);
+
+   return VDP_STATUS_OK;
 }
 
 /**
@@ -184,38 +204,79 @@ vlVdpPresentationQueueDisplay(VdpPresentationQueue presentation_queue,
 
    vlVdpPresentationQueue *pq;
    vlVdpOutputSurface *surf;
-   struct pipe_surface *drawable_surface;
-   struct pipe_video_rect vo_rect;
+
+   struct pipe_context *pipe;
+   struct pipe_resource *tex;
+   struct pipe_surface surf_templ, *surf_draw;
+   struct u_rect src_rect, dst_clip, *dirty_area;
+
+   struct vl_compositor *compositor;
+   struct vl_compositor_state *cstate;
 
    pq = vlGetDataHTAB(presentation_queue);
    if (!pq)
       return VDP_STATUS_INVALID_HANDLE;
 
-   drawable_surface = vl_drawable_surface_get(pq->device->context, pq->drawable);
-   if (!drawable_surface)
-      return VDP_STATUS_INVALID_HANDLE;
-
    surf = vlGetDataHTAB(surface);
    if (!surf)
       return VDP_STATUS_INVALID_HANDLE;
 
-   vo_rect.x = 0;
-   vo_rect.y = 0;
-   vo_rect.w = clip_width;
-   vo_rect.h = clip_height;
+   pipe = pq->device->context;
+   compositor = &pq->device->compositor;
+   cstate = &pq->cstate;
+
+   pipe_mutex_lock(pq->device->mutex);
+   tex = vl_screen_texture_from_drawable(pq->device->vscreen, pq->drawable);
+   if (!tex) {
+      pipe_mutex_unlock(pq->device->mutex);
+      return VDP_STATUS_INVALID_HANDLE;
+   }
+
+   dirty_area = vl_screen_get_dirty_area(pq->device->vscreen);
+
+   memset(&surf_templ, 0, sizeof(surf_templ));
+   surf_templ.format = tex->format;
+   surf_draw = pipe->create_surface(pipe, tex, &surf_templ);
+
+   surf->timestamp = (vlVdpTime)earliest_presentation_time;
+
+   dst_clip.x0 = 0;
+   dst_clip.y0 = 0;
+   dst_clip.x1 = clip_width ? clip_width : surf_draw->width;
+   dst_clip.y1 = clip_height ? clip_height : surf_draw->height;
+
+   if (pq->device->delayed_rendering.surface == surface &&
+       dst_clip.x1 == surf_draw->width && dst_clip.y1 == surf_draw->height) {
+
+      // TODO: we correctly support the clipping here, but not the pq background color in the clipped area....
+      cstate = pq->device->delayed_rendering.cstate;
+      vl_compositor_set_dst_clip(cstate, &dst_clip);
+      vlVdpResolveDelayedRendering(pq->device, surf_draw, dirty_area);
+
+   } else {
+      vlVdpResolveDelayedRendering(pq->device, NULL, NULL);
+
+      src_rect.x0 = 0;
+      src_rect.y0 = 0;
+      src_rect.x1 = surf_draw->width;
+      src_rect.y1 = surf_draw->height;
 
-   vl_compositor_clear_layers(&pq->compositor);
-   vl_compositor_set_rgba_layer(&pq->compositor, 0, surf->sampler_view, NULL, NULL);
-   vl_compositor_render(&pq->compositor, drawable_surface, NULL, &vo_rect, true);
+      vl_compositor_clear_layers(cstate);
+      vl_compositor_set_rgba_layer(cstate, compositor, 0, surf->sampler_view, &src_rect, NULL, NULL);
+      vl_compositor_set_dst_clip(cstate, &dst_clip);
+      vl_compositor_render(cstate, compositor, surf_draw, dirty_area);
+   }
 
-   pq->device->context->pipe->screen->flush_frontbuffer
+   vl_screen_set_next_timestamp(pq->device->vscreen, earliest_presentation_time);
+   pipe->screen->flush_frontbuffer
    (
-      pq->device->context->pipe->screen,
-      drawable_surface->texture,
-      0, 0,
-      vl_contextprivate_get(pq->device->context, drawable_surface)
+      pipe->screen, tex, 0, 0,
+      vl_screen_get_private(pq->device->vscreen)
    );
 
+   pipe->screen->fence_reference(pipe->screen, &surf->fence, NULL);
+   pipe->flush(pipe, &surf->fence, 0);
+
    if (dump_window == -1) {
       dump_window = debug_get_num_option("VDPAU_DUMP", 0);
    }
@@ -224,12 +285,17 @@ vlVdpPresentationQueueDisplay(VdpPresentationQueue presentation_queue,
       static unsigned int framenum = 0;
       char cmd[256];
 
-      sprintf(cmd, "xwd -id %d -out vdpau_frame_%08d.xwd", (int)pq->drawable, ++framenum);
-      if (system(cmd) != 0)
-         VDPAU_MSG(VDPAU_TRACE, "[VDPAU] Dumping surface %d failed.\n", surface);
+      if (framenum) {
+         sprintf(cmd, "xwd -id %d -silent -out vdpau_frame_%08d.xwd", (int)pq->drawable, framenum);
+         if (system(cmd) != 0)
+            VDPAU_MSG(VDPAU_ERR, "[VDPAU] Dumping surface %d failed.\n", surface);
+      }
+      framenum++;
    }
 
-   pipe_surface_reference(&drawable_surface, NULL);
+   pipe_resource_reference(&tex, NULL);
+   pipe_surface_reference(&surf_draw, NULL);
+   pipe_mutex_unlock(pq->device->mutex);
 
    return VDP_STATUS_OK;
 }
@@ -242,11 +308,29 @@ vlVdpPresentationQueueBlockUntilSurfaceIdle(VdpPresentationQueue presentation_qu
                                             VdpOutputSurface surface,
                                             VdpTime *first_presentation_time)
 {
+   vlVdpPresentationQueue *pq;
+   vlVdpOutputSurface *surf;
+   struct pipe_screen *screen;
+
    if (!first_presentation_time)
       return VDP_STATUS_INVALID_POINTER;
 
-   //return VDP_STATUS_NO_IMPLEMENTATION;
-   return VDP_STATUS_OK;
+   pq = vlGetDataHTAB(presentation_queue);
+   if (!pq)
+      return VDP_STATUS_INVALID_HANDLE;
+
+   surf = vlGetDataHTAB(surface);
+   if (!surf)
+      return VDP_STATUS_INVALID_HANDLE;
+
+   pipe_mutex_lock(pq->device->mutex);
+   if (surf->fence) {
+      screen = pq->device->vscreen->pscreen;
+      screen->fence_finish(screen, surf->fence, 0);
+   }
+   pipe_mutex_unlock(pq->device->mutex);
+
+   return vlVdpPresentationQueueGetTime(presentation_queue, first_presentation_time);
 }
 
 /**
@@ -258,8 +342,41 @@ vlVdpPresentationQueueQuerySurfaceStatus(VdpPresentationQueue presentation_queue
                                          VdpPresentationQueueStatus *status,
                                          VdpTime *first_presentation_time)
 {
+   vlVdpPresentationQueue *pq;
+   vlVdpOutputSurface *surf;
+   struct pipe_screen *screen;
+
    if (!(status && first_presentation_time))
       return VDP_STATUS_INVALID_POINTER;
 
-   return VDP_STATUS_NO_IMPLEMENTATION;
+   pq = vlGetDataHTAB(presentation_queue);
+   if (!pq)
+      return VDP_STATUS_INVALID_HANDLE;
+
+   surf = vlGetDataHTAB(surface);
+   if (!surf)
+      return VDP_STATUS_INVALID_HANDLE;
+
+   *first_presentation_time = 0;
+
+   if (!surf->fence) {
+      *status = VDP_PRESENTATION_QUEUE_STATUS_IDLE;
+   } else {
+      pipe_mutex_lock(pq->device->mutex);
+      screen = pq->device->vscreen->pscreen;
+      if (screen->fence_signalled(screen, surf->fence)) {
+         screen->fence_reference(screen, &surf->fence, NULL);
+         *status = VDP_PRESENTATION_QUEUE_STATUS_VISIBLE;
+         pipe_mutex_unlock(pq->device->mutex);
+
+         // We actually need to query the timestamp of the last VSYNC event from the hardware
+         vlVdpPresentationQueueGetTime(presentation_queue, first_presentation_time);
+         *first_presentation_time += 1;
+      } else {
+         *status = VDP_PRESENTATION_QUEUE_STATUS_QUEUED;
+         pipe_mutex_unlock(pq->device->mutex);
+      }
+   }
+
+   return VDP_STATUS_OK;
 }