Subversion Repositories Kolibri OS

Rev

Blame | Last modification | View Log | RSS feed

  1. //
  2. // Copyright 2012 Francisco Jerez
  3. //
  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:
  10. //
  11. // The above copyright notice and this permission notice shall be included in
  12. // all copies or substantial portions of the Software.
  13. //
  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 OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
  18. // OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
  19. // ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
  20. // OTHER DEALINGS IN THE SOFTWARE.
  21. //
  22.  
  23. #include "core/queue.hpp"
  24. #include "core/event.hpp"
  25. #include "pipe/p_screen.h"
  26. #include "pipe/p_context.h"
  27.  
  28. using namespace clover;
  29.  
  30. command_queue::command_queue(clover::context &ctx, clover::device &dev,
  31.                              cl_command_queue_properties props) :
  32.    context(ctx), device(dev), props(props) {
  33.    pipe = dev.pipe->context_create(dev.pipe, NULL);
  34.    if (!pipe)
  35.       throw error(CL_INVALID_DEVICE);
  36. }
  37.  
  38. command_queue::~command_queue() {
  39.    pipe->destroy(pipe);
  40. }
  41.  
  42. void
  43. command_queue::flush() {
  44.    pipe_screen *screen = device().pipe;
  45.    pipe_fence_handle *fence = NULL;
  46.  
  47.    std::lock_guard<std::mutex> lock(queued_events_mutex);
  48.    if (!queued_events.empty()) {
  49.       pipe->flush(pipe, &fence, 0);
  50.  
  51.       while (!queued_events.empty() &&
  52.              queued_events.front()().signalled()) {
  53.          queued_events.front()().fence(fence);
  54.          queued_events.pop_front();
  55.       }
  56.  
  57.       screen->fence_reference(screen, &fence, NULL);
  58.    }
  59. }
  60.  
  61. cl_command_queue_properties
  62. command_queue::properties() const {
  63.    return props;
  64. }
  65.  
  66. bool
  67. command_queue::profiling_enabled() const {
  68.    return props & CL_QUEUE_PROFILING_ENABLE;
  69. }
  70.  
  71. void
  72. command_queue::sequence(hard_event &ev) {
  73.    std::lock_guard<std::mutex> lock(queued_events_mutex);
  74.    if (!queued_events.empty())
  75.       queued_events.back()().chain(ev);
  76.  
  77.    queued_events.push_back(ev);
  78. }
  79.