Home | History | Annotate | Download | only in api 
      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 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
     20 // SOFTWARE.
     21 //
     22 
     23 #include "api/util.hpp"
     24 #include "core/queue.hpp"
     25 
     26 using namespace clover;
     27 
     28 PUBLIC cl_command_queue
     29 clCreateCommandQueue(cl_context ctx, cl_device_id dev,
     30                      cl_command_queue_properties props,
     31                      cl_int *errcode_ret) try {
     32    if (!ctx)
     33       throw error(CL_INVALID_CONTEXT);
     34 
     35    if (!ctx->has_device(dev))
     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(errcode_ret, CL_SUCCESS);
     43    return new command_queue(*ctx, *dev, props);
     44 
     45 } catch (error &e) {
     46    ret_error(errcode_ret, e);
     47    return NULL;
     48 }
     49 
     50 PUBLIC cl_int
     51 clRetainCommandQueue(cl_command_queue q) {
     52    if (!q)
     53       return CL_INVALID_COMMAND_QUEUE;
     54 
     55    q->retain();
     56    return CL_SUCCESS;
     57 }
     58 
     59 PUBLIC cl_int
     60 clReleaseCommandQueue(cl_command_queue q) {
     61    if (!q)
     62       return CL_INVALID_COMMAND_QUEUE;
     63 
     64    if (q->release())
     65       delete q;
     66 
     67    return CL_SUCCESS;
     68 }
     69 
     70 PUBLIC cl_int
     71 clGetCommandQueueInfo(cl_command_queue q, cl_command_queue_info param,
     72                       size_t size, void *buf, size_t *size_ret) {
     73    if (!q)
     74       return CL_INVALID_COMMAND_QUEUE;
     75 
     76    switch (param) {
     77    case CL_QUEUE_CONTEXT:
     78       return scalar_property<cl_context>(buf, size, size_ret, &q->ctx);
     79 
     80    case CL_QUEUE_DEVICE:
     81       return scalar_property<cl_device_id>(buf, size, size_ret, &q->dev);
     82 
     83    case CL_QUEUE_REFERENCE_COUNT:
     84       return scalar_property<cl_uint>(buf, size, size_ret, q->ref_count());
     85 
     86    case CL_QUEUE_PROPERTIES:
     87       return scalar_property<cl_command_queue_properties>(buf, size, size_ret,
     88                                                           q->props());
     89 
     90    default:
     91       return CL_INVALID_VALUE;
     92    }
     93 }
     94 
     95 PUBLIC cl_int
     96 clFlush(cl_command_queue q) {
     97    if (!q)
     98       return CL_INVALID_COMMAND_QUEUE;
     99 
    100    q->flush();
    101    return CL_SUCCESS;
    102 }
    103