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 "api/util.hpp"
  24. #include "core/queue.hpp"
  25.  
  26. using namespace clover;
  27.  
  28. CLOVER_API cl_command_queue
  29. clCreateCommandQueue(cl_context d_ctx, cl_device_id d_dev,
  30.                      cl_command_queue_properties props,
  31.                      cl_int *r_errcode) try {
  32.    auto &ctx = obj(d_ctx);
  33.    auto &dev = obj(d_dev);
  34.  
  35.    if (!count(dev, ctx.devices()))
  36.       throw error(CL_INVALID_DEVICE);
  37.  
  38.    if (props & ~(CL_QUEUE_OUT_OF_ORDER_EXEC_MODE_ENABLE |
  39.                  CL_QUEUE_PROFILING_ENABLE))
  40.       throw error(CL_INVALID_VALUE);
  41.  
  42.    ret_error(r_errcode, CL_SUCCESS);
  43.    return new command_queue(ctx, dev, props);
  44.  
  45. } catch (error &e) {
  46.    ret_error(r_errcode, e);
  47.    return NULL;
  48. }
  49.  
  50. CLOVER_API cl_int
  51. clRetainCommandQueue(cl_command_queue d_q) try {
  52.    obj(d_q).retain();
  53.    return CL_SUCCESS;
  54.  
  55. } catch (error &e) {
  56.    return e.get();
  57. }
  58.  
  59. CLOVER_API cl_int
  60. clReleaseCommandQueue(cl_command_queue d_q) try {
  61.    auto &q = obj(d_q);
  62.  
  63.    q.flush();
  64.  
  65.    if (q.release())
  66.       delete pobj(d_q);
  67.  
  68.    return CL_SUCCESS;
  69.  
  70. } catch (error &e) {
  71.    return e.get();
  72. }
  73.  
  74. CLOVER_API cl_int
  75. clGetCommandQueueInfo(cl_command_queue d_q, cl_command_queue_info param,
  76.                       size_t size, void *r_buf, size_t *r_size) try {
  77.    property_buffer buf { r_buf, size, r_size };
  78.    auto &q = obj(d_q);
  79.  
  80.    switch (param) {
  81.    case CL_QUEUE_CONTEXT:
  82.       buf.as_scalar<cl_context>() = desc(q.context());
  83.       break;
  84.  
  85.    case CL_QUEUE_DEVICE:
  86.       buf.as_scalar<cl_device_id>() = desc(q.device());
  87.       break;
  88.  
  89.    case CL_QUEUE_REFERENCE_COUNT:
  90.       buf.as_scalar<cl_uint>() = q.ref_count();
  91.       break;
  92.  
  93.    case CL_QUEUE_PROPERTIES:
  94.       buf.as_scalar<cl_command_queue_properties>() = q.properties();
  95.       break;
  96.  
  97.    default:
  98.       throw error(CL_INVALID_VALUE);
  99.    }
  100.  
  101.    return CL_SUCCESS;
  102.  
  103. } catch (error &e) {
  104.    return e.get();
  105. }
  106.  
  107. CLOVER_API cl_int
  108. clFlush(cl_command_queue d_q) try {
  109.    obj(d_q).flush();
  110.    return CL_SUCCESS;
  111.  
  112. } catch (error &e) {
  113.    return e.get();
  114. }
  115.