From 4b96c9539e7b31bbfd5b349d16b51dd5eb556707 Mon Sep 17 00:00:00 2001
From: Michael Bien <mbien@fh-landshut.de>
Date: Wed, 16 Jun 2010 20:23:33 +0200
Subject: implemented OpenCL 1.1 user events + JUnit test.

---
 test/com/jogamp/opencl/CLCommandQueueTest.java | 59 ++++++++++++++++++++++++++
 1 file changed, 59 insertions(+)

(limited to 'test/com')

diff --git a/test/com/jogamp/opencl/CLCommandQueueTest.java b/test/com/jogamp/opencl/CLCommandQueueTest.java
index 9070b268..3df894e5 100644
--- a/test/com/jogamp/opencl/CLCommandQueueTest.java
+++ b/test/com/jogamp/opencl/CLCommandQueueTest.java
@@ -161,6 +161,65 @@ public class CLCommandQueueTest {
 
     }
 
+    @Test
+    public void customEventsTest() throws IOException, InterruptedException {
+        out.println(" - - - user events test - - - ");
+
+        final int elements = roundUp(groupSize, ONE_MB / SIZEOF_INT * 5); // 5MB per buffer
+
+        final CLContext context = CLContext.create();
+
+        try{
+
+            CLBuffer<ByteBuffer> clBufferA = context.createByteBuffer(elements * SIZEOF_INT, Mem.READ_ONLY);
+            CLBuffer<ByteBuffer> clBufferB = context.createByteBuffer(elements * SIZEOF_INT, Mem.READ_ONLY);
+            CLBuffer<ByteBuffer> clBufferC = context.createByteBuffer(elements * SIZEOF_INT, Mem.READ_ONLY);
+
+            fillBuffer(clBufferA.buffer, 12345);
+            fillBuffer(clBufferB.buffer, 67890);
+
+            CLProgram program = context.createProgram(getClass().getResourceAsStream("testkernels.cl")).build();
+            CLKernel vectorAddKernel = program.createCLKernel("VectorAddGM").setArg(3, elements);
+            CLCommandQueue queue = context.getDevices()[0].createCommandQueue();
+
+            queue.putWriteBuffer(clBufferA, true) // write A
+                 .putWriteBuffer(clBufferB, true);// write B
+
+            vectorAddKernel.setArgs(clBufferA, clBufferB, clBufferC); // C = A+B
+
+            // the interesting part...
+
+            CLUserEvent condition = CLUserEvent.create(context);
+            assertEquals(CommandType.USER, condition.getType());
+            assertEquals(ExecutionStatus.SUBMITTED, condition.getStatus());
+            out.println(condition);
+
+            final CLEventList conditions = new CLEventList(condition);
+            final CLEventList events     = new CLEventList(1);
+            assertEquals(1, conditions.size());
+            assertEquals(1, conditions.capacity());
+            assertEquals(0, events.size());
+            assertEquals(1, events.capacity());
+
+            queue.put1DRangeKernel(vectorAddKernel, 0, elements, groupSize, conditions, events);
+            assertEquals(1, events.size());
+
+            Thread.sleep(1000);
+            final CLEvent status = events.getEvent(0);
+
+            assertEquals(ExecutionStatus.QUEUED, status.getStatus());
+            condition.setComplete();
+            assertTrue(condition.isComplete());
+
+            queue.finish();
+            assertTrue(status.isComplete());
+
+        }finally{
+            context.release();
+        }
+
+    }
+
     @Test
     public void concurrencyTest() throws IOException, InterruptedException {
 
-- 
cgit v1.2.3